1. Toy模板网首页
  2. > Toy博客

C/S客户端核服务端-并发服务器

7月前 作者：li星野 分类：Toy博客 阅读(26) 违法举报

这篇具有很好参考价值的文章主要介绍了C/S客户端核服务端-并发服务器。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

使用方法

1、新建两个程序，分别引用两个函数，先执行server端的程序，再执行client端的程序
2、实现功能：当client和sever连接成功后，从client输入什么都会传输给server端，当输入第一个字母为q时 两端程序都会退出
3、特别注意：需要修改SERVER_HOST 为自己主机地址
4、本程序编写的环境，如果时windows下执行可能需要修改头文件什么的，耐心一点看就好

gcc -v
gcc version 11.3.0 (Ubuntu 11.3.0-1ubuntu1~22.04.1)

cmake -version
cmake version 3.22.1

make -v
GNU Make 4.3

一、使用线程实现并发服务器

1、服务器端代码

优化功能：

1、再任意主机上可以运行代码
2、添加读取客户信息
3、允许地址快速重用，当服务器断开后可以快速重用

#include <arpa/inet.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <strings.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <unistd.h>
#define SERVER_PORT 5001 // 本地字节序
#define SERVER_HOST "192.168.0.43"
#define SERVER_BACKLOG 5
#define SERVER_QUIT "q"
#define SERVER_SIZE 32

void *cli_data_handle(void *arg)
{
    int newfd = *(int *)arg;
    char buf[SERVER_SIZE];
    printf("%s %d newfd = %d\n", __func__, __LINE__, newfd);
    while (1)
    {
        memset(buf, 0, SERVER_SIZE);
        int recread = read(newfd, buf, SERVER_SIZE - 1);
        if (recread > 0)
        {
            printf("%s %d buf = %s\n", __func__, __LINE__, buf);
            if (!strncasecmp(buf, SERVER_QUIT, strlen(SERVER_QUIT)))
            {
                printf("%s %d q======\n", __func__, __LINE__);
                break;
            }
        }

        usleep(100);
    }
    close(newfd);

    return NULL;
}
int test_server()
{
    printf("%s %d \n", __func__, __LINE__);

    int fd = -1;
    struct sockaddr_in addr_in;
    char buf[SERVER_SIZE];
    /*
    AF_INET:IPV4
    SOCK_STREAM:TCP
    */
    // 1、创建socket 得到fd
    fd = socket(AF_INET, SOCK_STREAM, 0);
    if (fd < 0)
    {
        printf("%s %d fd<0\n", __func__, __LINE__);
        return 0;
    }

    // 优化3 允许地址快速重用，当服务器断开后可以快速重用
    int b_reuse = 1;
    setsockopt(fd,SOL_SOCKET,SO_REUSEADDR,&b_reuse,sizeof(int));

    //  2、绑定
    memset(&addr_in, 0, sizeof(addr_in));  // 将变量addr_in置0
    addr_in.sin_port = htons(SERVER_PORT); // 将端口号从本地字节序转换为网络字节序
    addr_in.sin_family = AF_INET;
    // int rec = inet_pton(AF_INET,SERVER_HOST,(void*)&addr_in.sin_addr.s_addr);
    //    if(rec!= 1){
    //     printf("%s %d rec!= 1\n", __func__, __LINE__);
    //         return 0;
    //    }

    // addr_in.sin_addr.s_addr = inet_addr(SERVER_HOST); // 将主机从点分形式转换为32字节
    // 优化1：
    addr_in.sin_addr.s_addr = htonl(INADDR_ANY); // 任意IP可以运行
    int rec = bind(fd, (struct sockaddr *)&addr_in, sizeof(addr_in));
    if (rec < 0)
    {
        printf("%s %d rec<0\n", __func__, __LINE__);
        return 0;
    }

    // 3、listen() 将主动套接字转换为被动套接字
    int reclisten = listen(fd, SERVER_BACKLOG); // 允许正在进行连接的客户端数目
    if (reclisten < 0)
    {
        printf("%s %d reclisten<0\n", __func__, __LINE__);
        return 0;
    }
    // 4、阻塞等待客户端连接请求

#if 0
#if 0
    int newfd = accept(fd, NULL, NULL);
    if (newfd < 0)
    {
        printf("%s %d newfd<0\n", __func__, __LINE__);
        return 0;
    }
#else
    // 优化2：
    struct sockaddr_in addr_c;
    socklen_t addr_len = sizeof(addr_c);
    int newfd = accept(fd, (struct sockaddr *)&addr_c, &addr_len);
    if (newfd < 0)
    {
        printf("%s %d newfd<0\n", __func__, __LINE__);
        return 0;
    }

    char ipV4_addr[16];
    if (!inet_ntop(AF_INET, (void *)&addr_c.sin_addr.s_addr, ipV4_addr, sizeof(addr_c)))
    {
        // 为空取反 不为空 就执行这里
        printf("%s %d newfd<0\n", __func__, __LINE__);
        return 0;
    }

    printf("%s %d addr_c.sin_port = %d\n", __func__, __LINE__, ntohs(addr_c.sin_port));
    printf("%s %d addr_c.sin_addr = %s\n", __func__, __LINE__, ipV4_addr);
#endif
#else
    pthread_t tid;
    struct sockaddr_in addr_c;
    socklen_t addr_len = sizeof(addr_c);
    int newfd;
    while (1)
    {

        newfd = accept(fd, (struct sockaddr *)&addr_c, &addr_len);
        if (newfd < 0)
        {
            printf("%s %d newfd<0\n", __func__, __LINE__);
            return 0;
        }

        char ipV4_addr[16];
        if (!inet_ntop(AF_INET, (void *)&addr_c.sin_addr.s_addr, ipV4_addr, sizeof(addr_c)))
        {
            // 为空取反 不为空 就执行这里
            printf("%s %d newfd<0\n", __func__, __LINE__);
            return 0;
        }
        printf("%s %d addr_c.sin_port = %d\n", __func__, __LINE__, ntohs(addr_c.sin_port));
        printf("%s %d addr_c.sin_addr = %s\n", __func__, __LINE__, ipV4_addr);
        pthread_create(&tid, NULL, cli_data_handle, (void *)&newfd);
    }

    close(fd);
    printf("%s %d xxxxxxxxxxxxxx newfd = %d\n", __func__, __LINE__, fd);

#endif

    // 5、读写
    // 和最新的newfd进行通信

    return 0;
}

2、客户端代码

注意：

使用该函数时需要注意输入参数：
./project_cmake serv_ip ser_port
./project_cmake 192.168.0.43 5001 //服务器主机的IP和是设置的端口号文章来源地址https://www.toymoban.com/news/detail-485943.html

#include <arpa/inet.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <stdio.h>
#include <stdlib.h>
#include <strings.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <unistd.h>
#define SERVER_PORT 5001 // 本地字节序
#define SERVER_HOST "192.168.0.43"
#define SERVER_BACKLOG 5
#define SERVER_QUIT "q"
#define SERVER_SIZE 32

void usage(char *s)
{
    printf("%s %d %s serv_ip ser_port\n", __func__, __LINE__, s);
    printf("%s %d  serv_ip : server ip address\n", __func__, __LINE__);
    printf("%s %d  ser_port: server port (>5000)\n", __func__, __LINE__);
}
/*
./client serv_ip ser_port

*/
int test_client(int argc, char **argv)
{
    printf("%s %d \n", __func__, __LINE__);
    int port;
    if (argc != 3)
    {
        usage(argv[0]);
        return 0;
    }

    int fd = -1;
    struct sockaddr_in addr_in;
    char buf[SERVER_SIZE];
    /*
    AF_INET:IPV4
    SOCK_STREAM:TCP
    */
    // 1、创建socket 得到fd
    fd = socket(AF_INET, SOCK_STREAM, 0);
    if (fd < 0)
    {
        printf("%s %d fd<0\n", __func__, __LINE__);
        return 0;
    }

    port = atoi(argv[2]);
    if (port < 5000)
    {
        usage(argv[0]);
        return 0;
    }
    /*
    2、连接
    */
    memset(&addr_in, 0, sizeof(addr_in)); // 将变量addr_in置0
    addr_in.sin_port = htons(port);       // 将端口号从本地字节序转换为网络字节序
    addr_in.sin_family = AF_INET;
    int rec = inet_pton(AF_INET, argv[1], (void *)&addr_in.sin_addr.s_addr);
    if (rec != 1)
    {
        printf("%s %d rec!= 1\n", __func__, __LINE__);
        return 0;
    }

    int reccon = connect(fd, (struct sockaddr *)&addr_in, sizeof(addr_in));
    if (reccon < 0)
    {
        printf("%s %d reccon<0\n", __func__, __LINE__);
        return 0;
    }

    // 读写

    while (1)
    {
        memset(buf, 0, SERVER_SIZE);
        char *rec_p = fgets(buf, SERVER_SIZE - 1, stdin);

        int recwrite = write(fd, buf, strlen(buf));
        if (recwrite > 0)
        {
            printf("%s %d buf = %s\n", __func__, __LINE__, buf);
            // int recstr = strcmp(buf, SERVER_QUIT);
            int recstr = strncasecmp(buf, SERVER_QUIT, strlen(SERVER_QUIT));
            printf("%s %d recstr = %d\n", __func__, __LINE__, recstr);
            if (0 == recstr)
            {
                printf("%s %d q======\n", __func__, __LINE__);
                break;
            }
        }

        usleep(100);
    }
    close(fd);
    printf("%s %d xxxxxxxxxxxxxx\n", __func__, __LINE__);
    return 0;
}

下面的代码是上面的基础将进行进行修改的，可以参考着看！

二、使用进程实现并发服务器

1、服务器端代码

#include <arpa/inet.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <pthread.h>
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <strings.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <unistd.h>
#define SERVER_PORT 5001 // 本地字节序
#define SERVER_HOST "192.168.0.43"
#define SERVER_BACKLOG 5
#define SERVER_QUIT "q"
#define SERVER_SIZE 32

void *cli_data_handle(void *arg)
{
    int newfd = *(int *)arg;
    char buf[SERVER_SIZE];
    printf("%s %d newfd = %d\n", __func__, __LINE__, newfd);
    while (1)
    {
        memset(buf, 0, SERVER_SIZE);
        int recread = read(newfd, buf, SERVER_SIZE - 1);
        if (recread > 0)
        {
            printf("%s %d buf = %s\n", __func__, __LINE__, buf);
            if (!strncasecmp(buf, SERVER_QUIT, strlen(SERVER_QUIT)))
            {
                printf("%s %d q======\n", __func__, __LINE__);
                break;
            }
        }

        usleep(100);
    }
    close(newfd);

    return NULL;
}

void sig_child_handle(int signo)
{
    if (signo == SIGCHLD)
    {
        waitpid(-1, NULL, WNOHANG);
    }
}
int test_server()
{
    printf("%s %d \n", __func__, __LINE__);

    int fd = -1;
    struct sockaddr_in addr_in;
    char buf[SERVER_SIZE];
    signal(SIGCHLD, sig_child_handle);
    /*
    AF_INET:IPV4
    SOCK_STREAM:TCP
    */
    // 1、创建socket 得到fd
    fd = socket(AF_INET, SOCK_STREAM, 0);
    if (fd < 0)
    {
        printf("%s %d fd<0\n", __func__, __LINE__);
        return 0;
    }

    // 优化4 允许地址快速重用，当服务器断开后可以快速重用
    int b_reuse = 1;
    setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &b_reuse, sizeof(int));

    //  2、绑定
    memset(&addr_in, 0, sizeof(addr_in));  // 将变量addr_in置0
    addr_in.sin_port = htons(SERVER_PORT); // 将端口号从本地字节序转换为网络字节序
    addr_in.sin_family = AF_INET;
    // int rec = inet_pton(AF_INET,SERVER_HOST,(void*)&addr_in.sin_addr.s_addr);
    //    if(rec!= 1){
    //     printf("%s %d rec!= 1\n", __func__, __LINE__);
    //         return 0;
    //    }

    // addr_in.sin_addr.s_addr = inet_addr(SERVER_HOST); // 将主机从点分形式转换为32字节
    // 优化1：
    addr_in.sin_addr.s_addr = htonl(INADDR_ANY); // 任意IP可以运行
    int rec = bind(fd, (struct sockaddr *)&addr_in, sizeof(addr_in));
    if (rec < 0)
    {
        printf("%s %d rec<0\n", __func__, __LINE__);
        return 0;
    }

    // 3、listen() 将主动套接字转换为被动套接字
    int reclisten = listen(fd, SERVER_BACKLOG); // 允许正在进行连接的客户端数目
    if (reclisten < 0)
    {
        printf("%s %d reclisten<0\n", __func__, __LINE__);
        return 0;
    }
    // 4、阻塞等待客户端连接请求

    struct sockaddr_in addr_c;
    socklen_t addr_len = sizeof(addr_c);
    int newfd;

    while (1)
    {
        pid_t pid = -1;
        newfd = accept(fd, (struct sockaddr *)&addr_c, &addr_len);
        if (newfd < 0)
        {
            printf("%s %d newfd<0\n", __func__, __LINE__);
            break;
        }
        // 创建一个子进程用于处理已建立连接的客户的交互数据
        if ((pid = fork()) < 0)
        {
            printf("%s %d pid = fork() < 0 \n", __func__, __LINE__);
            break;
        }
        if (0 == pid)
        { // 子进程
            close(fd);
            char ipV4_addr[16];
            if (!inet_ntop(AF_INET, (void *)&addr_c.sin_addr.s_addr, ipV4_addr, sizeof(addr_c)))
            {
                // 为空取反 不为空 就执行这里
                printf("%s %d newfd<0\n", __func__, __LINE__);
                return 0;
            }
            printf("%s %d addr_c.sin_port = %d\n", __func__, __LINE__, ntohs(addr_c.sin_port));
            printf("%s %d addr_c.sin_addr = %s\n", __func__, __LINE__, ipV4_addr);
            cli_data_handle(&newfd);
            return 0;
        }
        else
        { // 父线程pid > 0
            close(newfd);
        }
    }

    close(fd);
    printf("%s %d xxxxxxxxxxxxxx newfd = %d\n", __func__, __LINE__, fd);

    // 5、读写
    // 和最新的newfd进行通信

    return 0;
}

2、客户端代码

和上面一致，这里不赘述。

注意：

使用该函数时需要注意输入参数：
./project_cmake serv_ip ser_port
./project_cmake 192.168.0.43 5001 //服务器主机的IP和是设置的端口号

到了这里，关于C/S客户端核服务端-并发服务器的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处： 如若内容造成侵权/违法违规/事实不符，请点击违法举报进行投诉反馈，一经查实，立即删除！

分享到：
领支付宝红包 赞助服务器费用

相关文章

  • 服务器异步客户端

    internal class MessageManagerT:SingletonMessageManagerT {     Dictionaryint, ActionT MsgDic = new Dictionaryint, ActionT();     public void OnAddListen(int id,ActionT action)     {         if(MsgDic.ContainsKey(id))         {             MsgDic[id] += action;         }         else         {             MsgDic.Add(id, ac

    2024年04月09日
    浏览(41)
  • UDP客户端和服务器

    UDP客户端和服务器

    UDP客户端，也就是首先主动发送数据的一方，也就是发起服务请求的一方。 UDP服务器，也就是首先等待接收数据，并对接收的数据进行处理，返回计算结果的一方，也就是提供服务的一方。 在下面实验中使用到的函数 测试代码  UDP接收端(服务器) 执行代码：    实验解析 

    2024年02月13日
    浏览(74)
  • UDP通讯（服务器/客户端）

    UDP通讯（服务器/客户端）

    前言：UDP通讯实现比较简单，单某些情况下也会使用，建议先看一下说明，然后运行代码感受一下。         传输层主要应用的协议模型有两种，一种是TCP协议，另外一种则是UDP协议。TCP协议在网络通信中占主导地位，绝大多数的网络通信借助TCP协议完成数据传输。但U

    2024年02月03日
    浏览(48)

  • ZeroTier客户端连接服务器

    ZeroTier客户端连接服务器 下载客户端 https://www.zerotier.com/download/ 加入新的网络（例如d5e04297a16fa690，由管理员提供） 管理员授权并告知服务器IP 测试连接：ping 服务器IP 使用putty, pycharm, vscode等工具连接即可 官方文档 https://docs.zerotier.com/getting-started/getting-started 注: 若路由器无法

    2024年02月09日
    浏览(34)

  • Java 构建websocket客户端，构建wss客户端，使用wss连接，并发送数据到服务器端，接收服务器端消息

    Java 构建websocket客户端，构建wss客户端，使用wss连接，并发送数据到服务器端，接收服务器端消息 回调函数处理

    2024年02月13日
    浏览(45)
  • netty构建udp服务器以及发送报文到客户端客户端详细案例

    netty构建udp服务器以及发送报文到客户端客户端详细案例

    目录 一、基于netty创建udp服务端以及对应通道设置关键 二、发送数据 三、netty中的ChannelOption常用参数说明 1、ChannelOption.SO_BACKLOG 2、ChannelOption.SO_REUSEADDR 3、ChannelOption.SO_KEEPALIVE 4、ChannelOption.SO_SNDBUF和ChannelOption.SO_RCVBUF 5、ChannelOption.SO_LINGER 6、ChannelOption.TCP_NODELAY 以上代码中

    2024年04月09日
    浏览(50)
  • TDengine服务器与客户端安装

    TDengine服务器与客户端安装

    TDengine官网: https://docs.taosdata.com/get-started/package/ https://www.taosdata.com/assets-download/3.0/TDengine-server-3.0.4.1-Linux-x64.tar.gz tar -zxvf TDengine-server- version -Linux-x64.tar.gz tar -zxvf TDengine-server-3.0.4.1-Linux-x64.tar.gz 安装脚本在执行过程中，会通过命令行交互界面询问一些配置信息。如果希望采取无

    2024年02月05日
    浏览(45)

  • SSH客户端连接远程服务器

    目录 一、什么是客户端连接远程服务器 二、什么是服务端连接远程服务器 三、查看网络信息 1、图形程序查看网络信息 2、命令查看网络信息 四、SSH客户端（Linux） 五、SSH客户端（windows） 六、SSH远程服务器 发起连接的一方，计算机或设备（称为客户端）与另一个计算机或

    2024年02月16日
    浏览(40)
  • 爬虫——服务器渲染和客户端渲染

    爬虫——服务器渲染和客户端渲染

    目录 爬虫——服务器渲染和客户端渲染 服务器渲染 客户端渲染 专业解释 服务器渲染（Server-Side Rendering，SSR）是一种在服务器端完成页面渲染的网页处理技术。具体来说，就是服务器在响应客户端请求时，会生成页面的HTML代码，并将其返回给客户端。这种方式的优点包括更

    2024年02月06日
    浏览(45)
  • 1.6 服务器处理客户端请求

    1.6 服务器处理客户端请求

    客户端进程向服务器进程发送一段文本（MySQL语句），服务器进程处理后再向客户端进程发送一段文本（处理结果）。 从图中我们可以看出，服务器程序处理来自客户端的查询请求大致需要经过三个部分，分别是 连接管理 、 解析与优化 、 存储引擎 。 客户端进程可以采用我

    2024年02月11日
    浏览(27)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包，优惠每天领

二维码1

领取红包

二维码2

领红包