RT-Thread-【网络编程学习】+ A Byte of China + qemu环境下简单TCP聊天ClientRT-Thread问答社区

【网络编程学习】+ A Byte of China + qemu环境下简单TCP聊天Client

发布于 2018-08-02 00:49:05 浏览：1985 订阅该版

* 本帖最后由 ianhom 于 2018-8-2 14:20 编辑 *

很高兴有机会可以参加此次学习活动，学习交流收获不少，希望能顺利完成学习任务。
第一周的学习是基于Qemu环境，在此环境下无需特定硬件支持，即可以愉快的玩转RT-Thread，这一点非常的赞，关于Qemu的使用和网络编程的入门相关知识，在文档中心中有非常详细的说明和指导[http://ci.rt-thread.com/3067/site/topics/qemu/setup/](http://ci.rt-thread.com/3067/site/topics/qemu/setup/)

下面要交作业了。
![FastAdmin]()

**_作业题目_**
![TIM截图20180802000515.png](/uploads/201808/02/000648hkju0w72f2uhuszj.png)
![TIM截图20180802000538.png](/uploads/201808/02/000649r595h9o2zha5y9u9.png)
对于作业的要求，很多小伙伴都理解成了通过msh命令来实现，其实本次作业的要求是_一条msh命令自动实现整个connect，login，say，look，who，logout_的操作。其中对who的操作还有一个要求，就是要获取在聊天室的人员名单，并通过say操作打印出来“I see XXX,XXX,XXXXX,XXX in the room”。

**_开发过程_**
开发环境还是采用Qemu环境，此前的学习过程中有一个TCP Client例程[http://ci.rt-thread.com/3067/sit ... pclient/tcp-client/](http://ci.rt-thread.com/3067/site/tutorial/network/tcpclient/tcp-client/)，我们就基于此例程来完成我们聊天室客户端的功能。
1、我们在rt-thread-master\bsp\qemu-vexpress-a9路劲下打开env工具，输入menuconfig进行配置（此时注意把env窗口调大，否则无法config），在如图所示的菜单中找到tcp client的sample，选中保存并退出。
**注意**，如果此时menuconfig菜单选项与图示不一致，请在menuconfig之前使用“**pkgs --upgrade**”命令。
![TIM截图20180802002447.png](/uploads/201808/02/002723ept7pxskx3f5tv8h.png)

2、完成配置后，使用“**pkgs --update**”命令更新例程代码，然后在该路径rt-thread-master\bsp\qemu-vexpress-a9\packages\samples-latest etwork\tcpclient下找到tcpclient.c文件，我们将在此文件上修改实现作业。tcpclient源码实现的功能是先初始化，然后循环堵塞式接收报文，收到报文后进行处理，如果不是q或Q，则回发固定的报文给服务器。这里我采用了一种简单的方式，不启用更多线程，将接收和发送剥离出来，实现命令发送和报文接收，然后在根据自动操作的流程进一步安排发送和接收的顺序，比如logic成功后是没有报文回复的，这里只就不进行报文接收操作；而在who和look命令后，服务器会发送两条报文（这可以通过之前的网络编程学习资料的wireshark工具可以抓到两条TCP报文），这里因为没有线程支持，所以需要调用两次接收函数才行。在收到第二条报文后，因为第二条报文全部都是在聊天室的人员名单，就可以使用strtok这个函数进行切片，就可以轻松实现 I can see的任务了，最后在使用logout命令退出聊天室，不然下次登录会提示“重名”而拒绝登录。
```void I_see_you(void)
{
 char *token;
 rt_kprintf("I can see ");
 token = strtok(recv_data, " ");
 while(token != NULL)
 {
 rt_kprintf("%s, ",token);
 token = strtok(NULL, " ");
 }
 rt_kprintf("in the room ");
 return;
}```

根据作业要求修改代码保存后（源码详见末尾），使用“**scons**”命令进行编译，如果编译无问题后，即可使用“**qemu.ba**t”命令启动RT-Thread。
![TIM截图20180802003527.png](/uploads/201808/02/003552rlnu0r0vlv1u6nxl.png)

3、在msh环境中，输入“**Chat_tcpclient_hy**”命令，即可启动聊天客户端，看到预期的效果。
![TIM截图20180802004001.png](/uploads/201808/02/004109k880093ry3k03g5n.png)

**_总结_**
1、recv是堵塞操作，所以在开线程的情况下，如果没有收到报文，将会一直卡死。
2、look和who命令后，服务器返回时的是两条tcp报文，所以如果没有线程支持的条件下，需要recv两次才能正常运行。
3、获取聊天室人员名单，使用strtok函数，通过“ ”实现切片，依次打印出人员名单。

**_代码_**```#include <rtthread.h>
#include <sys/socket.h> /* 使用BSD socket，需要包含socket.h头文件 */
#include "netdb.h"

#define BUFSZ   1024

static const char login[] = "login A Byte of China "; 
static const char say[] = "say May name is A Byte of China, I am doing this job at 20180801 "; 
static const char look[] = "look "; 
static const char who[] = "who "; 
static const char see[] = "say I can see "; 
static const char quit[] = "say I am quiting "; 
static const char logout[] = "logout ";

static int sock;
static char *recv_data;

void I_see_you(void)
{
 char *token;
 rt_kprintf("I can see ");
 token = strtok(recv_data, " ");
 while(token != NULL)
 {
 rt_kprintf("%s, ",token);
 token = strtok(NULL, " ");
 }
 rt_kprintf("in the room ");
 return;
}

static void sent_cmd(const char *str, int len)
{
 int ret;
 rt_kprintf("Command:");
 rt_kprintf(str);
 /* 发送数据到sock连接 */
 ret = send(sock, str, len, 0);
 if (ret < 0)
 {
 /* 接收失败，关闭这个连接 */
 closesocket(sock);
 rt_kprintf(" send error,close the socket. ");
 rt_free(recv_data);
 return;
 }
 else if (ret == 0)
 {
 /* 打印send函数返回值为0的警告信息 */
 rt_kprintf(" Send warning,send function return 0. ");
 }
 
 return;
}

static void recv_fun(void)
{
    int bytes_received;

/* 从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);
        return;
    }

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

/* 在控制终端显示收到的数据 */
 rt_kprintf(" %s ", recv_data);
 
 return;
}

void Chat_tcpclient_hy(int argc, char **argv)
{
    struct hostent *host;
    struct sockaddr_in server_addr;
    const char *url;
    int port;

if (argc < 3)
 {
 url = "183.193.243.90";
 port = 11222;
 }
 else
 {
 url = argv[1];
 port = strtoul(argv[2], 0, 10);
 }

/* 通过函数入口参数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;
    }
    recv_fun();

while (1)
    {
        sent_cmd(login,strlen(login));
        sent_cmd(say,strlen(say));
        recv_fun();
        sent_cmd(look,strlen(look));
        recv_fun();
        recv_fun();  /* Server will send 2 telegrams back */
        sent_cmd(who,strlen(who));
        recv_fun();
        recv_fun();  /* Server will send 2 telegrams back */
        I_see_you();
        sent_cmd(quit,strlen(quit));
        sent_cmd(logout,strlen(logout));

rt_kprintf("The end ");
 }
 
 return;
}

MSH_CMD_EXPORT(Chat_tcpclient_hy, a tcp client sample);
```