【C语言】【unix c】服务端与客户端建立通信的实例

迷南。 2022-06-06 22:28 74阅读 0赞

代码：
        头文件：
            p_net
            #ifndef __P_NET_H__
            #define __P_NET_H__
            #include <sys/types.h>
            #include <sys/socket.h>
            #include <ctype.h>
            #include <netinet/in.h>
            #include <arpa/inet.h>
            #include <stdlib.h>
            #include <sys/wait.h>
            #include <unistd.h>
            typedef struct sockaddr SA;
            typedef struct sockaddr_in SA4;
            #endif //__P_NET_H__
    
        服务器端：
        servers.c:
            #include <stdio.h>
            #include <p_net.h>
            void do_work(int fd) {
                int r,i;
                char buf[128];
                //读取数据
                r = read(fd,buf,128);
                //处理数据
                for(i = 0; i < r; i++) {
                buf[i] = toupper(buf[i]);
                }
                //响应客户端
                write(fd, buf, r);
                return;
            }
            int main() {
                int s_fd;
                int c_fd;
                SA4 addr, cli;
                char ip[128];
                pid_t pid;
                //创建socket
                s_fd = socket(AF_INET,SOCK_STREAM,0);
                if(s_fd == -1) {
                perror("socket");
                return -1;
                }
                //初始化ipv4地址
                addr.sin_family = AF_INET;
                //初始化需要将端口号将主机字节序转换为网络字节序
                addr.sin_port = htons(6666);
                addr.sin_addr.s_addr = htonl(INADDR_ANY);
                //将s_fd和addr地址空间绑定
                int b = bind(s_fd, (SA*)&addr, sizeof(addr));
                if(b == -1) {
                perror("bind");
                return -1;
                }
                //将s_fd设置为被动监听
                listen(s_fd, 5);//5是最多可以存放5个链接
                //从未决链接队列里取出一个链接
                while(1) {
                int cli_len = sizeof(cli);
                c_fd = accept(s_fd, (SA*)&cli, &cli_len);
                if(c_fd == -1) {
                    perror("accept");
                    return -1;
                }
                printf("%s\n",inet_ntop(AF_INET,&cli.sin_addr,ip,128));
                //创建子进程
                pid = fork();
                if(pid == -1) {
                    perror("fork");
                    return -1;
                }
                if(pid == 0) {
                    close(s_fd);
                //业务处理
                do_work(c_fd);
                //关闭本次链接，结束本次通讯
                close(c_fd);
                exit(0);
                }else {
                    close(c_fd);
                    waitpid(-1, NULL,WNOWAIT);
                }
                }
                close(s_fd);
                return 0;
            }
    
        客户端：
        client.c:
            #include <stdio.h>
            #include <string.h>
            #include <p_net.h>
            int main(int argc, char *argv[]) {
    
                SA4 serv;
                char *msg = "lao wang\n";
                char buf[128];
                int r;
                //创建一个用于通信的设备
                int s_fd = socket(AF_INET, SOCK_STREAM, 0);
                if(s_fd == -1) {
                perror("socket");
                return -1;
                }
                //初始化服务器的ip地址和端口号
                serv.sin_family = AF_INET;
                serv.sin_port = htons(6666);
                //ip地址127.0.0.1
                inet_pton(AF_INET,argv[1],&serv.sin_addr);
                //将s_fd链接到服务器的地址
                int c = connect(s_fd, (SA*) &serv, sizeof(serv));
                if(c == -1) {
                perror("connect");
                return -1;
                }
                //向服务器发送消息
                write(s_fd,msg,strlen(msg));
                //阻塞等待服务器的响应消息
                r = read(s_fd, buf, 128);
                //处理响应消息
                write(1, buf, r);
                //告知服务器结束本次通话
                close(s_fd);
                return 0;
            }