【LWIP】qemu环境下tcp客户端通信学习

发布于 2018-05-20 21:16:34 浏览：3020 订阅该版

第一步，下载rtt官方最新版源码，存放到英文路径下；
第二步，配置好env环境，官方以后文档怎么配置，此处略去；
第三步，在** tthread-rt-thread-master t-thread\bsp\qemu-vexpress-a9目录下，右键选择ConEmu Here选项，打开env工具
第四步，编写程序，存为tcpclient.c，放入** tthread-rt-thread-master t-thread\bsp\qemu-vexpress-a9\applications目录下，
#include <rtthread.h>
#include <lwip/netdb.h> /* 为了解析主机名，需要包含netdb.h头文件 */
#include <lwip/sockets.h> /* 使用BSD socket，需要包含sockets.h头文件 */

#define BUF_SIZE   1024

static const char send_data[] = "login 100 "; /* 发送用到的数据 */
int ext_sockfd; /* socket描述符*/

void rt_tcp_client_entry(void)
{
    char *recv_data; /*接收缓冲区指针*/
    struct hostent *host; /*用于通过DNS解析服务器端信息*/
    int sockfd;        /* socket描述符*/
    int bytes_received;
    struct sockaddr_in server_addr; /* 存储服务端IP和端口号*/

/* 通过函数入口参数url获得host地址（如果是域名，会做域名解析） */
    host = gethostbyname("112.124.34.90");

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

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

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

/* 初始化预连接的服务端地址 htons*/
    server_addr.sin_family = AF_INET;  		/* IPv4因特网域*/
    server_addr.sin_port = htons(5005);    /* 服务器端的端口 这里进行字节序转换*/
    server_addr.sin_addr = *((struct in_addr *)host->h_addr); /* 主机IP信息*/

rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));

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

/*释放接收缓冲 */
 rt_free(recv_data);
 return;
 }
	
	ext_sockfd = sockfd;
	
 while (1)
 {
 /* 从sock连接中接收最大BUF_SIZE - 1字节数据 */
 bytes_received = recv(sockfd, recv_data, BUF_SIZE - 1, 0);
 if (bytes_received <= 0)
 {
 /* 接收失败，关闭这个连接 */
 closesocket(sockfd);

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

/* 有接收到数据，把末端清零 即加入字符串结束符*/
        recv_data[bytes_received] = '\0';

if (strcmp(recv_data , "q") == 0 || strcmp(recv_data , "Q") == 0)
        {
            /* 如果首字母是q或Q，关闭这个连接 */
            closesocket(sockfd);

/* 释放接收缓冲 */
 rt_free(recv_data);
 break;
 }
 else
 {
 /* 在控制终端显示收到的数据 */
 rt_kprintf(" Recieved data = %s " , recv_data);
 }
	
 /* 发送数据到sock连接 */
 //send(sockfd, send_data, strlen(send_data), 0);
		//send(sockfd, content, strlen(content), 0);
 }

return;
}

/***初始化tcp客户端接收线程***/
int tcp_client_init(void)
{
    rt_thread_t tid;
    
    tid = rt_thread_create("tcpclient",
        rt_tcp_client_entry, RT_NULL,
        2048, 25, 10);

if (tid != RT_NULL)
        rt_thread_startup(tid);

return 0;
}
/***tcp客户端发送命令***/
int tcp_client_send(const char *send_content)
{
	send(ext_sockfd, send_content, strlen(send_content), 0);

return 0;
}

#ifdef RT_USING_FINSH
 #include <finsh.h>

//FINSH_FUNCTION_EXPORT(tcpclient, startup tcp client);
 FINSH_FUNCTION_EXPORT(tcp_client_init, startup tcp client);
  FINSH_FUNCTION_EXPORT(tcp_client_send, send tcp client); /* 在控制台发送命令字符串 */
 #endif

第五步，在env命令行，输入scons进行编译；
第六步，在env命令行，输入qemu.bat运行仿真系统；
![1.png](/uploads/201805/20/210638oh84hhlh8haykk4x.png)
第七步，在msh/>后输入exit，进入finsh模式下，输入tcp按tab键，可打印出相关命令
![2.png](/uploads/201805/20/211013gk5jb8lzbl5bzwfa.png)
第八步，首先，初始化tcp_client_init()，然后输入tcp_client_send("login 100 ")登录服务器，最后，tcp_client_send("say My name is MaruisHou ")
![3.png](/uploads/201805/20/211608erwiiltat260t10w.png)![4.png](/uploads/201805/20/211608dmoxtmrtr3tl6bhl.png)![5.png](/uploads/201805/20/211609nlh04xsh8qhtbq00.png)