Network

lwip总算ping通了

发布于 2019-01-20 21:28:59 浏览：2849 订阅该版

![ping 通.png](/uploads/201901/20/212011z63up1cmkkhx17g7.png)感谢@aozima  @whj467467222 @summer_gift  几位大佬的热心帮助，总算成功Ping通！但是还有一个问题，我要怎么将我的tcpserv函数导入到shell中?输入help之后我的tcpserv还是没有shell命令，是我的操作方式不对吗？
![7.png](/uploads/201901/20/212714ynx90ni3onn4paii.png)

应该怎么样将它导入？下面是我的tcpserv函数
```static const char send_data[] = "This is TCP Server from RT-Thread! "; /*发送用到的数据*/
void tcpserv(void){
	char *recv_data; /*用于接受用的指针， 后面会做一次动态分配以请求内存 */
	rt_uint32_t sin_size;
	int sock, connected, bytes_received;
	struct sockaddr_in server_addr, client_addr;
	rt_bool_t stop = RT_FALSE; /*停止标志*/
	
	recv_data = rt_malloc(1024); /*分配接收用的数据缓冲*/
	if(recv_data == RT_NULL){
		
		rt_kprintf("No Memory! ");
		return;
	}
	
	/*一个socket在使用之前，需要先预先创建出来，指定SOCK_STREAM为TCP的socket */
	if((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1){
		
		/*创建失败的错误处理*/
		rt_kprintf("socket error! ");
		
		/*释放已经分配的接收缓存*/
		rt_free(recv_data);
		return;
	}
	
	/*初始化服务器地址*/
	
	server_addr.sin_family = AF_INET;
	server_addr.sin_port = htons(5000); /*服务器工作的端口*/
	server_addr.sin_addr.s_addr = INADDR_ANY;
	rt_memset(&(server_addr.sin_zero), 8, sizeof(server_addr.sin_zero));
	
	/*绑定socket到服务端地址*/
	if(bind(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1){
		
		/*绑定失败*/
		rt_kprintf("Unable to bind! ");
		
		/*释放已经分配的缓存*/
		rt_free(recv_data);
		return;
	}
	
	/*在socket上进行监听*/
	if(listen(sock, 5) == -1){
		
		rt_kprintf("listen error! ");
		
		/* release recv buffer*/
		rt_free(recv_data);
		return;
	}
	rt_kprintf(" TCPSever waiting for client on port 5000.. !");
	while(stop != RT_TRUE){
		sin_size = sizeof(struct sockaddr_in);
		
		/*接受一个客户端连接socket的请求，这个函数调用时阻塞式的*/
		connected = accept(sock, (struct sockaddr *)&client_addr, &sin_size);
		/*返回链接成功的socket*/
		
		/*接收返回的client_addr指向客户端的地址信息*/
		rt_kprintf("I got a connection from (%s, %d) ", 
								inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));
		
		/*客户端连接的处理*/
		while(1){
			
			/*发送数据到connected socket*/
			send(connected, send_data, strlen(send_data), 0);
			/*从connect socket中接收数据，接收buffer是1024大小，但并不一定能够收到1024大小*/
			
			bytes_received = recv(connected, recv_data, 1024, 0);
			if(bytes_received <= 0){
				/*接收失败，关闭这个connected socket*/
				lwip_close(connected);
				break;
			}
			/*接收到数据，把末端清0*/
			recv_data[bytes_received] = '\0';
			if(strcmp(recv_data, "q") == 0 || strcmp(recv_data, "Q") == 0){
				
				/*如果首字母是q或者Q，关闭这个连接*/
				lwip_close(connected);
				break;
			}
			else if(strcmp(recv_data, "exit") == 0){
			
				/*如果接收的是eixt,则关闭整个服务器*/
				lwip_close(connected);
				stop = RT_TRUE;
				break;
			}
			else{
				/*在控制终端显示收到的数据*/
				rt_kprintf("Received Data = %s ", recv_data);
			}
		}
	}
	
	/*退出服务*/
	lwip_close(sock);
	
	/*释放接收缓存*/
	rt_free(recv_data);
	return;
}

#ifdef RT_USING_FINSH
#include <finsh.h>

/*输出tcpserv函数到finsh shell中*/
FINSH_FUNCTION_EXPORT(tcpserv, startup tcp server);
#endif```