RT-Thread-【网络编程学习】+ lihanchao + qemu网络编程入门聊天室RT-Thread问答社区

【网络编程学习】+ lihanchao + qemu网络编程入门聊天室

发布于 2018-08-01 12:57:22 浏览：1619 订阅该版

[tocm]

#  【网络编程学习】+ lihanchao + qemu网络编程入门 聊天室

tags： rtt qemu 网络编程

---

## 1.在 Windows QEMU 上运行 RT-Thread
按照[网络编程教程][1]在qemu上搭建RT-Thread环境

![qemu上搭建RT-Thread环境][2]
## 2.实现聊天室
思路：客户端与服务器建立tcp连接，线程1用于recv服务器的下发的数据，并显示在msh上；
线程2接受msh输入字符串把数据send到服务器或者通过msh export把数据send到服务器。

### 实现tcpclinet
参考sample中tcpclient例子，修改tcpclient函数参数为 url和port，
```
int sock, bytes_received;
char *recv_data;
void tcpclient(const char *url,int port)
{
    int ret;
    
    struct hostent *host;
    struct sockaddr_in server_addr;
    /* 通过函数入口参数url获得host地址（如果是域名，会做域名解析） */
    host = gethostbyname(url);

/* 分配用于存放接收数据的缓冲 */
 recv_data = rt_malloc(BUFSZ);
 if (recv_data == RT_NULL)
 {
 rt_kprintf("No memory ");
 return;
 }

/* 创建一个socket，类型是SOCKET_STREAM，TCP类型 */
 if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1)
 {
 /* 创建socket失败 */
 rt_kprintf("Socket error ");

/* 释放接收缓冲 */
        rt_free(recv_data);
        return;
    }

/* 初始化预连接的服务端地址 */
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(port);
    server_addr.sin_addr = *((struct in_addr *)host->h_addr);
    rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));

/* 连接到服务端 */
 if (connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1)
 {
 /* 连接失败 */
 rt_kprintf("Connect fail! ");
 closesocket(sock);

/*释放接收缓冲 */
        rt_free(recv_data);
        return;
    }

while (1)
 {
 /* 从sock连接中接收最大BUFSZ - 1字节数据 */
 bytes_received = recv(sock, recv_data, BUFSZ - 1, 0);
 if (bytes_received < 0)
 {
 /* 接收失败，关闭这个连接 */
 closesocket(sock);
 rt_kprintf(" received error,close the socket. ");

/* 释放接收缓冲 */
 rt_free(recv_data);
 break;
 }
 else if (bytes_received == 0)
 {
 /* 默认 recv 为阻塞模式，此时收到0认为连接出错，关闭这个连接 */
 closesocket(sock);
 rt_kprintf(" received error,close the socket. ");

/* 释放接收缓冲 */
            rt_free(recv_data);
            break;
        }

/* 有接收到数据，把末端清零 */
        recv_data[bytes_received] = '\0';

if (strncmp(recv_data, "q", 1) == 0 || strncmp(recv_data, "Q", 1) == 0)
 {
 /* 如果是首字母是q或Q，关闭这个连接 */
 closesocket(sock);
 rt_kprintf(" got a 'q' or 'Q',close the socket. ");

/* 释放接收缓冲 */
 rt_free(recv_data);
 break;
 }
 else
 {
 /* 在控制终端显示收到的数据 */
 rt_kprintf(" server: %s ", recv_data);
 }
 }
 return;
}
```
### 线程chatroom_thread 用于接收服务器数据
chatroom_thread 实现建立tcp连接，并接收数据
```
void chatroom_thread(void *parameter)
{
	rt_kprintf("connect server:183.193.243.90 port:11222 ! ");
	tcpclient("183.193.243.90",11222);		
}
int chatroom_init(void)
{
	rt_thread_t tid;
	tid = rt_thread_create("chatroom",
							chatroom_thread,
							RT_NULL,
							1024,
							10,20);
	if(tid!=RT_NULL)
	{
		rt_thread_startup(tid);
	}
	return 0;
}
```
### 通过msh export实现聊天命令
注意服务器对应的格式login+ 空格 + 
```
void login(int argc , char** argv)
{
	if(sock !=-1)
	{
		send(sock,"login ",strlen("login "),0);
		send(sock,argv[1],strlen(argv[1]),0);
		send(sock," ",strlen(" "),0);
		
	}
	else
	{
		rt_kprintf("warning: Please use connect socket! ");
	}
	
}
void say(int argc , char** argv)
{
	if(sock !=-1)
	{
		send(sock,"say ",strlen("say "),0);
		for(int i=1;i<argc;i++)
		{
			send(sock,argv[1],strlen(argv[1]),0);
		}
		
		send(sock," ",strlen(" "),0);
		
	}
	else
	{
		rt_kprintf("warning: Please use connect socket! ");
	}
	
}
void look(int argc ,char** argv)
{
	if(sock !=-1)
	{
		send(sock,"look ",strlen("look "),0);
		send(sock," ",strlen(" "),0);
	}
	else
	{
		rt_kprintf("warning: Please use connect socket! ");
	}	
}
void who(int argc,char** argv)
{
	if(sock !=-1)
	{
		send(sock,"who ",strlen("who "),0);
		send(sock," ",strlen(" "),0);
	}
	else
	{
		rt_kprintf("warning: Please use connect socket! ");
	}	
}
void logout(int argc,char** argv)
{
	if(sock !=-1)
	{
		send(sock,"logout ",strlen("logout "),0);
		send(sock," ",strlen(" "),0);
	}
	else
	{
		rt_kprintf("warning: Please use connect socket! ");
	}	
}
MSH_CMD_EXPORT(login,login xxx);
MSH_CMD_EXPORT(say,say xxx);
MSH_CMD_EXPORT(look,look xxx);
MSH_CMD_EXPORT(who,who xxx);
MSH_CMD_EXPORT(logout,logout xxx);
```
![聊天室截图][3]

[1]: http://ci.rt-thread.com/3067/site/topics/qemu/setup/
  [2]: https://ws1.sinaimg.cn/large/d40bc2e4gy1fttg8cutwyj20qa0h6gmo.jpg
  [3]: https://ws1.sinaimg.cn/large/d40bc2e4gy1ftu3neg5r2j20q80f4wek.jpg