RT-Thread-【网络编程学习】LeeJianhua＋网络编程＋聊天室（线程版）RT-Thread问答社区

【网络编程学习】LeeJianhua＋网络编程＋聊天室（线程版）

发布于 2018-08-02 22:02:32 浏览：2320 订阅该版

* 本帖最后由 LeeJianhua 于 2018-8-2 23:58 编辑 *

一、开发环境搭建
操作系统：WIN10

1. 下载一站式 编程开发环境env，
下载地址：[https://www.rt-thread.org/page/download.html](https://www.rt-thread.org/page/download.html)

![110,0](https://www.rt-thread.org/qa/forum.php?mod=image&aid=4816&size=300x300&key=21f4fda07dbe3abc&nocache=yes&type=fixnone)

![110,0](https://www.rt-thread.org/qa/forum.php?mod=image&aid=4831&size=300x300&key=df2117892291ff76&nocache=yes&type=fixnone)

![110,0](https://www.rt-thread.org/qa/forum.php?mod=image&aid=4830&size=300x300&key=485f670ee9f90520&nocache=yes&type=fixnone)

![110,0](https://www.rt-thread.org/qa/forum.php?mod=image&aid=4829&size=300x300&key=6012650dfb615e27&nocache=yes&type=fixnone)

![110,0](https://www.rt-thread.org/qa/forum.php?mod=image&aid=4828&size=300x300&key=da0b8403f7f99d7a&nocache=yes&type=fixnone)

![110,0](https://www.rt-thread.org/qa/forum.php?mod=image&aid=4816&size=300x300&key=21f4fda07dbe3abc&nocache=yes&type=fixnone)

env使用教程地址：
[https://www.rt-thread.org/docume ... nv/env-user-manual/](https://www.rt-thread.org/document/site/rtthread-development-guide/rtthread-tool-manual/env/env-user-manual/)

2. 拉取RT-Thread 最新代码

github 地址：[https://github.com/RT-Thread/rt-thread](https://github.com/RT-Thread/rt-thread)

3. tap 网络配置
安装 tap 
下载地址：（一定要下载原版）很多群里的同学下载了错误的版本，被绑定了opera。
[https://openvpn.net/index.php/open-source/downloads.html](https://openvpn.net/index.php/open-source/downloads.html)

安装并配置：安装tap，配置可上网的网卡为共享模式。这样qemu就可以通过tap链接互联网。同时在RTT目录中找到： bsp\qemu-vexpress-a9路径下的 qemu.bat 文件，使用文本编辑器打开该文件，在下图所示位置添加 -net nic -net tap,ifname=TAP （虽然在win下，但是网卡名字严格区分大小写） 配置，并保存退出。给QEMU增加网卡。
4. 安装 Wireshark 抓包软件下载地址：[https://www.wireshark.org/#download](https://www.wireshark.org/#download)
5. 安装git 下载地址：https://git-scm.com/downloads

二、env使用  package scons menuconfig
1. env 包含了编译系统和包管理系统env集成了gcc，scons，menuconfig，qemu2.package 用来管理RTT的packagepackage --upgrade 升级在线包目录3.scons 用来编译项目，生成项目4.menuconfig 用来配置RTT

三、TCP连接
四、UDP连接五、ICMP六、NTP七、Telnet八、TFTP九、聊天室在login 的地方卡了很久，最终原因是：客户端发送login 命令服务器端不回应。所以不必等待recv；

```/*
 * 程序清单：tcp 客户端
 *
 * 这是一个 tcp 客户端的例程
 * 导出 tcpclient 命令到控制终端
 * 命令调用格式：tcpclient URL PORT
 * URL：服务器地址 PORT:：端口号
 * 程序功能：接收并显示从服务端发送过来的信息，接收到开头是 'q' 或 'Q' 的信息退出程序
*/
#include <rtthread.h>
#include <stdio.h>
#include <unistd.h>
#include <sys/socket.h> /* 使用BSD socket，需要包含socket.h头文件 */
#include <netdb.h>
#include <string.h>

#define THREAD_PRIORITY     25
#define THREAD_STACK_SIZE   4096
#define THREAD_TIMESLICE    5

#define BUFSZ   1024
int sock, i;
int ret;
int cmd_num = 0;
char cmd_buf[BUFSZ];
char *recv_data;
struct hostent *host;
int bytes_received;
struct sockaddr_in server_addr;
const char *url;
int port;

/*
 * 线程删除(rt_thread_delete)函数仅适合于动态线程，为了在一个线程
 * 中访问另一个线程的控制块，所以把线程块指针声明成全局类型以供全
 * 局访问
 */
static rt_thread_t tid1 = RT_NULL, tid2 = RT_NULL;
/* 线程1的入口函数 */
static void thread1_entry(void *parameter)
{
    rt_uint32_t count = 0;

while (1)
 {
 /* 线程1采用低优先级运行，一直打印计数值 */
 //rt_kprintf("thread count: %d ", count ++);
 
 //rt_kprintf("recv!!! ");
 /* 从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';

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

static void thread1_cleanup(struct rt_thread *tid)
{
 if (tid != tid1)
 {
 return ;
 }
 rt_kprintf("thread1 end ");
 tid1 = RT_NULL;
}

void tcpclient(int argc, char **argv)
{

if (argc < 3)
 {
 rt_kprintf("Usage: tcpclient URL PORT ");
 rt_kprintf("Like: tcpclient 183.193.243.90 11222 ");
 return ;
 }

url = argv[1];
        //url = "183.193.243.90";
    port = strtoul(argv[2], 0, 10);
        //port = strtoul("11222", 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;
    }
        
            /* 创建线程1 */
    tid1 = rt_thread_create("t1", /* 线程1的名称是t1 */
                            thread1_entry, RT_NULL,   /* 入口是thread1_entry，参数是RT_NULL */
                            THREAD_STACK_SIZE, THREAD_PRIORITY-1, THREAD_TIMESLICE);
    if (tid1 != RT_NULL) /* 如果获得线程控制块，启动这个线程 */
    {
        tid1->cleanup = thread1_cleanup;
        rt_thread_startup(tid1);
    }

while(1)
 {
 //rt_kprintf("send!!! ");
 //rt_kprintf("recv from shell ");
 memset(cmd_buf, 0 , BUFSZ);
 i = 0;
 while(1)
 {
 cmd_buf* = getchar();
 rt_kprintf("%c",cmd_buf*);
 if(cmd_buf* == ' ')
 {
 cmd_buf[++i] = ' ';
 rt_kprintf(" ");
 break;
 }
 i++;
 if(i == BUFSZ-1)
 {
 cmd_buf* = ' ';
 cmd_buf[i+1] = ' ';
 rt_kprintf(" ");
 break;
 }
 }
 cmd_buf* = ' ';
 //rt_kprintf("shell = %s ", cmd_buf);
 /* 发送数据到sock连接 */
 ret = send(sock, cmd_buf, strlen(cmd_buf), 0);
 
 //ret = send(sock, cmd[cmd_num], strlen(cmd[cmd_num]), 0);
 if (ret < 0)
 {
 /* 接收失败，关闭这个连接 */
 closesocket(sock);
 rt_kprintf(" send error,close the socket. ");

break;
 }
 else if (ret == 0)
 {
 /* 打印send函数返回值为0的警告信息 */
 rt_kprintf(" Send warning,send function return 0. ");
 }
 else
 {
 //rt_kprintf("send = %s ",cmd_buf);
 }
 }

return;
}
#ifdef FINSH_USING_MSH
#include <finsh.h>

MSH_CMD_EXPORT(tcpclient, a tcp client sample);
#endif
```

![110,0](https://www.rt-thread.org/qa/forum.php?mod=image&aid=4834&size=300x300&key=b8cd3e18ca38eded&nocache=yes&type=fixnone)

最后版本：多线程版 网络聊天室：开启线程接受网络服务器发来的最新消息。例如谁登陆了。同时读取stdio输入信息，当输入为完整的一行，发送给服务器。

![Screen Shot 2018-08-02 at 11.56.23 PM.png](https://oss-club.rt-thread.org/uploads/201808/02/235754kmk3f5qakhzddd80.png)

![Screen Shot 2018-08-02 at 10.01.51 PM.png](https://oss-club.rt-thread.org/uploads/201808/02/220220d9iv4sco4vf672mj.png)

![Screen Shot 2018-07-31 at 11.29.28 PM.png](https://oss-club.rt-thread.org/uploads/201808/02/144053n82jbrgb7amuwwtr.png)

![Screen Shot 2018-07-31 at 11.29.30 PM.png](https://oss-club.rt-thread.org/uploads/201808/02/200153lh3va35avt5zmkfn.png)

![Screen Shot 2018-07-31 at 11.29.32 PM.png](https://oss-club.rt-thread.org/uploads/201808/02/200154xpreafrpx1pv5f7x.png)

![Screen Shot 2018-07-31 at 11.29.34 PM.png](https://oss-club.rt-thread.org/uploads/201808/02/200155eabi25yjjb232ys2.png)

![Screen Shot 2018-07-31 at 11.29.37 PM.png](https://oss-club.rt-thread.org/uploads/201808/02/200156i0k5z1swz9fsawef.png)

![Screen Shot 2018-07-31 at 11.29.39 PM.png](https://oss-club.rt-thread.org/uploads/201808/02/200156kwswzfa3pxvo6zoh.png)

回到
底部

【网络编程学习】LeeJianhua＋网络编程＋聊天室（线程版）

撰写答案

关于作者

LeeJianhua

相关问题

热门标签

本月文章贡献

【网络编程学习】LeeJianhua＋网络编程＋聊天室（线程版）

撰写答案

关于作者

LeeJianhua

相关问题

推荐文章

最新文章

热门标签

本月问答贡献

本月文章贡献