关闭套接字程序挂掉

发布于 2018-09-03 17:12:38 浏览：1664 订阅该版

2 个回答

yqiu 2018-09-03

这家伙很懒，什么也没写！

先驱者 2018-09-04

这家伙很懒，什么也没写！

>贴代码，让大家帮找找碴

---

#include <rtthread.h>
#include <sys/socket.h>
#include "netdb.h"

#define BUFSZ   1024
int sock, bytes_received;

void tcpclose(void)
{
        rt_kprintf("ww0\n");
        closesocket(sock);
        rt_kprintf("ww1\n");
}
#ifdef RT_USING_FINSH
#include <finsh.h>
MSH_CMD_EXPORT(tcpclose, startup tcpclose);
#endif

void tcpclient(void)
{
    int ret;
    char *recv_data;
    struct hostent *host;
    struct sockaddr_in server_addr;
        char* url = "192.168.1.166";

/* 域名解析 */
    host = gethostbyname(url);

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

/* 创建一个socket，类型是SOCKET_STREAM，TCP类型 */
    if((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    {
        rt_kprintf("Socket error\n");
        rt_free(recv_data);
        return;
    }
    
        /* 初始化预连接的服务端地址 */
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(9000);
    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!\n");
        closesocket(sock);
        rt_free(recv_data);
        return;
    }
        rt_kprintf("Connect Ok!\n");
        
        
    while(1)
    {
                /* 阻塞式接收 */
        bytes_received = recv(sock, recv_data, BUFSZ - 1, 0);
        if(bytes_received < 0)
        {
                        rt_kprintf("received<0\r\n");
                        rt_thread_delay(2000);
            break;
        }
        
                /* 打印接收到的数据 */
        recv_data[bytes_received] = '\0';
                rt_kprintf("received=%s\r\n", recv_data);
                rt_thread_delay(600);
    }

return;
}