打开APP
userphoto
未登录

开通VIP,畅享免费电子书等14项超值服

开通VIP
嵌入式中,TCP server如何与多个client通信?(附代码)

大家好,我是LinuxZn。

上一篇文章我们分享了嵌入式中,TCP通信常用接口的使用封装,其demo中我们只是简单地实现一对一的收发。

但是实际开发中,tcp server是要支持与多个client同时进行通信的,本篇分享一对多的收发,也即tcp server并发处理。

tcp server实现并发的方式有:多进程、多线程。

多进程开销比较大,不常用。本篇笔记我们分享多线程的方法。

简单的demo

tcp_server.c:

左右滑动查看全部代码>>>

#include <pthread.h>
#include 'tcp_socket.h'

static pthread_t cli_data_proce_thread_tid;

static void *process_client_data(void *arg)
{
    int client_fd = *(int*)arg;

    while (1)
    {
        char buf[128] = {0};
        
        int recv_len = tcp_blocking_recv(client_fd, buf, sizeof(buf));
        if (recv_len <= 0)
        {
            printf('recv error!\n');
            tcp_close(client_fd);
            return NULL;
        }
        printf('client_fd = %d, recv : %s\n', client_fd, buf);

        int send_len = tcp_send(client_fd, buf, strlen(buf));
        if (send_len <= 0)
        {
            printf('send error!\n');
            tcp_close(client_fd);
            return NULL;
        }
        else
        {
            printf('send success! send: %s, send_len: %d\n', buf, send_len);
        }
        usleep(10 * 1000);
    }
}

int main(int argc, char **argv)
{
    printf('==================tcp server==================\n');
    int server_fd = tcp_init(NULL4321);

    while (1)
    {
        int new_fd = tcp_accept(server_fd);

        // 创建客户端数据处理线程
        int ret = pthread_create(&cli_data_proce_thread_tid, NULL, process_client_data, (void*)&new_fd);
        if(ret != 0)
        {
            perror('pthread_create');
            exit(EXIT_FAILURE);
        }
    }

    tcp_close(server_fd);

    return 0;
}

主线程,监听客户端连接;cli_data_proce_thread_tid线程处理客户端数据。下面我们创建4个client与该server进行连接。

首先,需要注意的是,我们创建tcp_server的方式为:

左右滑动查看全部代码>>>

int server_fd = tcp_init(NULL4321);
int tcp_init(const char* ip, int port)
{
    int optval = 1
    int server_fd = socket(AF_INET, SOCK_STREAM, 0);
    if (server_fd < 0)
    {
        perror('socket');
        return -1;
    }

    /* 解除端口占用 */
    if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval)) < 0)
 {
  perror('setsockopt\n');
  return -1;
 }

    struct sockaddr_in server_addr;
    bzero(&server_addr, sizeof(struct sockaddr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(port);
    if (NULL == ip)
    {
        server_addr.sin_addr.s_addr = htonl(INADDR_ANY); 
    }
    else
    {
        server_addr.sin_addr.s_addr = inet_addr(ip); 
    }

    if (bind(server_fd, (struct sockaddr*)&server_addr,sizeof(struct sockaddr)) < 0)
    {
        perror('bind');
        close(server_fd);
        return -1;
    }

    if(listen(server_fd, MAX_CONNECT_NUM) < 0)
    {
        perror('listen');
        close(server_fd);
        return -1;
    }

    return server_fd;
}

我们使用INADDR_ANY来创建server。

INADDR_ANY:表示不确定地址,或所有地址、任意地址。也就是表示本机的所有IP,因为有些机子不止一块网卡,多网卡的情况下,这个就表示所有网卡ip地址的意思。

我们本机所有网卡的IP:

192.168.1.107
127.0.0.1

我们的本机上的client(client的代码见上一节)连接这两个IP都可以连上server。

下面使用我们本机上两个client连接server并进行数据交互:

Windows的网络助手链接server:

我们再开一个Ubuntu虚拟机,上面的client连接该server:

以上就是本次demo演示的server同时与4个client通信的小实验。

本站仅提供存储服务,所有内容均由用户发布,如发现有害或侵权内容,请点击举报
打开APP,阅读全文并永久保存 查看更多类似文章
猜你喜欢
类似文章
【热】打开小程序,算一算2024你的财运
Linux IO多路转接——UDP通信
3个学习Socket编程的简单例子:TCP Server/Client, Select
简说TCP通信非阻塞接收(附代码例子)
socket本地进程通信
libevent小示例
linux 编程
更多类似文章 >>
生活服务
热点新闻
分享 收藏 导长图 关注 下载文章
绑定账号成功
后续可登录账号畅享VIP特权!
如果VIP功能使用有故障,
可点击这里联系客服!

联系客服