EC20

10 EC20发送数据问题

发布于 2022-08-12 11:28:08 浏览：596 订阅该版

2 个回答

crystal266 2022-08-12

嵌入式

FrankLing 2022-08-12

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

crystal266 2022-08-12

嵌入式

crystal266 2022-08-12

嵌入式

FrankLing 2022-08-12

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

FrankLing 2022-08-12

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

crystal266 2022-08-12

嵌入式

crystal266 2022-08-12

嵌入式

[@FrankLing](https://club.rt-thread.org/u/6b61b5f38dc315fd 'FrankLing')

类似下面的示例，也可以找一些 socket 编程的资料，类似于 [Socket网络编程之TCP编程](https://blog.csdn.net/Justina0806/article/details/122061680) 这种的

```c
#include <rtthread.h>
#include "rtdevice.h"
#include "board.h"

#include <string.h>
#include <sys/socket.h>

void ec20_tcp_test_thread_entry(void *parameter)
{
    struct sockaddr_in server_addr;
    int sockfd = -1, ret;
    char send_data[] = "hello rtthread\r\n";
    char recv_data[1024];

#define SERVER_HOST   "127.0.0.1"
#define SERVER_PORT   8080

if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    {
        LOG_E("Socket create failed.\n");
        return;
    }

/* 初始化预连接的服务端地址 */
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(SERVER_PORT);
    server_addr.sin_addr.s_addr = inet_addr(SERVER_HOST);
    rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));

/* 连接到服务端 */
    if (connect(sockfd, (struct sockaddr *) &server_addr, sizeof(struct sockaddr)) < 0)
    {
        LOG_E("socket connect failed!\n");
        closesocket(sockfd);
        return;
    }
    else
    {
        LOG_I("socket connect success!\n");
    }

/* 发送数据到 socket 连接 */
    ret = send(sockfd, send_data, strlen(send_data), 0);
    if (ret <= 0)
    {
        LOG_E("send error,close the socket.\n");
        return;
    }

while (1)
    {
        ret = recv(sockfd, recv_data, sizeof(recv_data), 0);
        if (ret <= 0)
        {
            LOG_E("recv error.\n");
        }
        else
        {
            rt_kprintf("recv data: %s", recv_data);
        }

rt_thread_mdelay(100);
    }

/* 关闭连接 */
    closesocket(sockfd);

return;
}

/**
 * @brief  启动 EC20 TCP 测试线程
 * @param  无
 * @return 无
 */
int ec20_tcp_test(void)
{
    /* 创建EC200X模组数据接收处理线程 */
    rt_thread_t thread = rt_thread_create("ec20_tcp_test_thread", ec20_tcp_test_thread_entry, RT_NULL, 4096, 10, 20);
    if (thread != RT_NULL)
    {
        rt_thread_startup(thread);  // 创建成功则启动线程
    }
    else
    {
        LOG_E("create ex20 tcp test thread failed");
        return (-RT_ERROR);
    }

return RT_EOK;
}
MSH_CMD_EXPORT(ec20_tcp_test, ec20 tcp test);
```

FrankLing 2022-08-12

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

crystal266 2022-08-12

嵌入式

[@FrankLing](https://club.rt-thread.org/u/6b61b5f38dc315fd 'FrankLing')
找个公网服务器试试看，测试一下 socket 编程。

在文件 rt-thread\components\net\sal_socket\src\sal_socket.c 中 rtt 实现了一个网络检查的测试代码，如下所示，你也可以参考一下。
```c
static void check_netdev_internet_up_work(struct rt_work *work, void *work_data)
{
#define SAL_INTERNET_VERSION   0x00
#define SAL_INTERNET_BUFF_LEN  12
#define SAL_INTERNET_TIMEOUT   (2)

#define SAL_INTERNET_HOST      "link.rt-thread.org"
#define SAL_INTERNET_PORT      8101

#define SAL_INTERNET_MONTH_LEN 4
#define SAL_INTERNET_DATE_LEN  16

int index, sockfd = -1, result = 0;
    struct sockaddr_in server_addr;
    struct hostent *host;
    struct timeval timeout;
    struct netdev *netdev = (struct netdev *)work_data;
    socklen_t addr_len = sizeof(struct sockaddr_in);
    char send_data[SAL_INTERNET_BUFF_LEN], recv_data = 0;

const char month[][SAL_INTERNET_MONTH_LEN] = {"Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sep", "Oct", "Nov", "Dec"};
    char date[SAL_INTERNET_DATE_LEN];
    int moth_num = 0;

struct sal_proto_family *pf = (struct sal_proto_family *) netdev->sal_user_data;
    const struct sal_socket_ops *skt_ops;

if (work)
    {
        rt_free(work);
    }

/* get network interface socket operations */
    if (pf == RT_NULL || pf->skt_ops == RT_NULL)
    {
        result = -RT_ERROR;
        goto __exit;
    }

host = (struct hostent *) pf->netdb_ops->gethostbyname(SAL_INTERNET_HOST);
    if (host == RT_NULL)
    {
        result = -RT_ERROR;
        goto __exit;
    }

skt_ops = pf->skt_ops;
    if ((sockfd = skt_ops->socket(AF_INET, SOCK_DGRAM, 0)) < 0)
    {
        result = -RT_ERROR;
        goto __exit;
    }

server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(SAL_INTERNET_PORT);
    server_addr.sin_addr = *((struct in_addr *)host->h_addr);
    rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));

timeout.tv_sec = SAL_INTERNET_TIMEOUT;
    timeout.tv_usec = 0;

/* set receive and send timeout */
    skt_ops->setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, (void *) &timeout, sizeof(timeout));
    skt_ops->setsockopt(sockfd, SOL_SOCKET, SO_SNDTIMEO, (void *) &timeout, sizeof(timeout));

/* get build moth value*/
    rt_memset(date, 0x00, SAL_INTERNET_DATE_LEN);
    rt_snprintf(date, SAL_INTERNET_DATE_LEN, "%s", __DATE__);

for (index = 0; index < sizeof(month) / SAL_INTERNET_MONTH_LEN; index++)
    {
        if (rt_memcmp(date, month[index], SAL_INTERNET_MONTH_LEN - 1) == 0)
        {
            moth_num = index + 1;
            break;
        }
    }

/* not find build month */
    if (moth_num == 0 || moth_num > sizeof(month) / SAL_INTERNET_MONTH_LEN)
    {
        result = -RT_ERROR;
        goto __exit;
    }

rt_memset(send_data, 0x00, SAL_INTERNET_BUFF_LEN);
    send_data[0] = SAL_INTERNET_VERSION;
    for (index = 0; index < netdev->hwaddr_len; index++)
    {
        send_data[index + 1] = netdev->hwaddr[index] + moth_num;
    }
    send_data[9] = RT_VERSION;
    send_data[10] = RT_SUBVERSION;
    send_data[11] = RT_REVISION;

skt_ops->sendto(sockfd, send_data, SAL_INTERNET_BUFF_LEN, 0,
                    (struct sockaddr *)&server_addr, sizeof(struct sockaddr));

result = skt_ops->recvfrom(sockfd, &recv_data, sizeof(recv_data), 0, (struct sockaddr *)&server_addr, &addr_len);
    if (result < 0)
    {
        goto __exit;
    }

if (recv_data == RT_FALSE)
    {
        result = -RT_ERROR;
        goto __exit;
    }

__exit:
    if (result > 0)
    {
        LOG_I("Set network interface device(%s) internet status up.", netdev->name);
        netdev_low_level_set_internet_status(netdev, RT_TRUE);
    }
    else
    {
        LOG_I("Set network interface device(%s) internet status down.", netdev->name);
        netdev_low_level_set_internet_status(netdev, RT_FALSE);
    }

if (sockfd >= 0)
    {
        skt_ops->closesocket(sockfd);
    }
}
```