你好,游客 登录 注册 搜索
背景:
阅读新闻

Linux多进程CS服务器简单实现

[日期:2018-01-02] 来源:cnblogs.com/yanlei2018  作者:yanlei2018 [字体: ]

Linux多进程CS服务器简单实现

server端

  • 多进程实现多用户连接,即每个用户一个连接,这里仍然用server将收到的字符串转大写后返回给客户端。
    • 代码实现
    #include <stdio.h>
    #include <string.h>
    #include <netinet/in.h>
    #include <arpa/inet.h>
    #include <unistd.h>
    #include <ctype.h>
    #include <stdlib.h>
    #include <sys/wait.h>
    
    #define SERV_IP "127.0.0.1"
    #define SERV_PORT 8000
    
    void wait_child(int signo)//回收子进程函数
    {
        while(waitpid(0, NULL, WNOHANG)>0);
        return;
    }
    int main(int argc,char *argv[])
    {
        pid_t pid;//进程ID
        int sfd, cfd;//接收连接的sfd,和client通讯的cfd
        struct sockaddr_in serv_addr, clie_addr;//创建服务器和客户端结构体
        socklen_t clie_addr_len;//客户端结构体长度
        char buf[BUFSIZ], clie_IP[BUFSIZ];//buf存放接收到的数据
        int n , i;//读取的数据数n, 循环因子i
    
        sfd = socket(AF_INET, SOCK_STREAM, 0);//创建套接字
    
        bzero(&serv_addr, sizeof(serv_addr));//清零
        serv_addr.sin_family = AF_INET;//设置协议族为IPv4
        serv_addr.sin_addr.s_addr = htonl(INADDR_ANY); //设置网卡为本地任何有效网卡
        //inet_pton(AF_INET, SERV_IP, &serv_addr.sin_addr.s_addr);
        serv_addr.sin_port = htons(SERV_PORT);//设置端口
    
        bind(sfd, (struct sockaddr * )&serv_addr, sizeof(serv_addr));//设置套接字与sfd关联
        listen(sfd, 128);//设置未完成accept的最大数量.开始监听.
        while(1)//循环接收客户端连接
        {
            clie_addr_len = sizeof(clie_addr);//初始化客户端结构体长度
            cfd = accept(sfd, (struct sockaddr *)&clie_addr, &clie_addr_len);//接收客户端连接
            printf("client IP:%s, port:%d\n", inet_ntop(AF_INET, &clie_addr.sin_addr.s_addr, clie_IP, sizeof(clie_IP)), ntohs(clie_addr.sin_port));
            pid = fork();//创建新进程
            if(pid< 0)//出错
            {
                perror("fork error");
                exit(1);
            }
            else if(pid == 0)//子进程
            {
                close(sfd);//子进程中先关闭父进程文件描述符
                break;
            }
            else if(pid>0)//父进程
            {
                close(cfd);//父进程中先关闭子进程文件描述符
                signal(SIGCHLD, wait_child);//注册信号用于回收已结束的子进程
            }
        }
        if(pid == 0)//以下是子进程真正的业务处理部分
        {
            while(1)//循环处理客户端业务
            {
                n = read(cfd, buf, sizeof(buf));
                if(n == 0)//如果read返回0, 说明客户端已断开连接
                {  
                    close(cfd);//关闭客户端文件描述符
                    return 0;
                }
                else if(n == -1)//出错
                {
                    perror("read error");
                    exit(1);
                }
                else
                {
                    write(STDOUT_FILENO, buf, n);
                    for(i= 0; i< n;++i)
                    {
                        buf[i] = toupper(buf[i]);
                    }
                    write(cfd, buf, n);
                }
            }
        }
        return 0;
    }
    

client端

  • 连接server端,发送字符串,将收到的字符串打印出来(即:与nc命令功能相同)。
    • 代码实现
    #include <stdio.h>
    #include <string.h>
    #include <unistd.h>
    #include <netinet/in.h>
    #include <arpa/inet.h>
    #define MAXLINE 8192
    #define SERV_PORT 8000
    
    int main(int argc,char *argv[])
    {
        struct sockaddr_in servaddr;
        char buf[MAXLINE];
        int sockfd, n;
    
        sockfd = socket(AF_INET, SOCK_STREAM, 0);
    
        bzero(&servaddr, sizeof(servaddr));
    
        servaddr.sin_family = AF_INET;
        inet_pton(AF_INET, "127.0.0.1", &servaddr.sin_addr);
        servaddr.sin_port = htons(SERV_PORT);
    
        connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr));
        while(fgets(buf, MAXLINE, stdin)!=NULL)
        {
            write(sockfd, buf, strlen(buf));
            n =Read(sockfd, buf, MAXLINE);
            if(n ==0)
            {
                printf("the other side has been closed.\n");
                break;
            }
            else 
                write(STDOUT_FILENO, buf, n);
        }
        close(sockfd);
        return 0;
    }
    

测试结果

  • 可以实现多个客户端同时连接服务器,服务器每接受一个客户就创建一个子进程,用户端断开后,进程由父进程自动回收子进程。

存在问题

  • 仅供学习参考,未进行错误处理。多用户连接时,可能产生读写中断干扰。

本文永久更新链接地址http://www.linuxidc.com/Linux/2018-01/150035.htm

linux
相关资讯       CS服务器  Linux多进程CS服务器 
本文评论   查看全部评论 (0)
表情: 表情 姓名: 字数

       

评论声明
  • 尊重网上道德,遵守中华人民共和国的各项有关法律法规
  • 承担一切因您的行为而直接或间接导致的民事或刑事法律责任
  • 本站管理人员有权保留或删除其管辖留言中的任意内容
  • 本站有权在网站内转载或引用您的评论
  • 参与本评论即表明您已经阅读并接受上述条款