UDP实现服务器和客户端的通信

Love The Way You Lie 2021-09-19 01:04 522阅读 0赞

**一 服务端**

#include <sys/types.h>  
    #include <sys/stat.h>  
    #include <fcntl.h>  
    #include <stdio.h>  
    #include <stdlib.h>  
    #include <string.h>  
    #include <strings.h>  
    #include <unistd.h>  
    #include <errno.h>  
    #include <sys/stat.h>  
    #include <dirent.h>  
    #include <sys/mman.h>  
    #include <sys/wait.h>  
    #include <signal.h>  
    #include <sys/ipc.h>  
    #include <sys/shm.h>  
    #include <sys/msg.h>  
    #include <sys/sem.h>  
    #include <pthread.h>  
    #include <semaphore.h>  
    #include <poll.h>  
    #include <sys/epoll.h>  
    #include <sys/socket.h>  
    #include <netinet/in.h>  
    #include <arpa/inet.h>  
    #include <netinet/in.h>  
    
    
    char rbuf[50];  
      
    int main()  
    {  
        int sockfd;  
        int size;  
        int ret;  
        int on =1;  
        struct sockaddr_in saddr;  
        struct sockaddr_in raddr;  
      
        //设置地址信息，ip信息  
        size = sizeof(struct sockaddr_in);  
        bzero(&saddr,size);  
        saddr.sin_family = AF_INET;  
        saddr.sin_port = htons(8888);  
        saddr.sin_addr.s_addr = htonl(INADDR_ANY);  
      
        //创建udp 的套接字  
        sockfd = socket(AF_INET,SOCK_DGRAM,0);  
        if(sockfd<0)  
        {  
            perror("socket failed");  
            return -1;  
        }  
      
        //设置端口复用  
        setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on));   
      
        //绑定地址信息，ip信息  
        ret = bind(sockfd,(struct sockaddr*)&saddr,sizeof(struct sockaddr));  
        if(ret<0)  
        {  
            perror("sbind failed");  
            return -1;  
        }  
      
        socklen_t  val = sizeof(struct sockaddr);  
        //循环接收客户端发来的消息  
        while(1)  
        {  
            puts("waiting data");  
            // 没有数据过来时，就在recvfrom函数上阻塞着
            ret=recvfrom(sockfd,rbuf,50,0,(struct sockaddr*)&raddr,&val);  
            if(ret <0)  
            {  
                perror("recvfrom failed");  
            }  
      
            printf("the data :%s\n",rbuf);  
            bzero(rbuf,50);  
        }  
        //关闭udp套接字，这里不可达的。  
        close(sockfd);  
        return 0;  
    }

**二 客户端**

#include <sys/types.h>  
    #include <sys/stat.h>  
    #include <fcntl.h>  
    #include <stdio.h>  
    #include <stdlib.h>  
    #include <string.h>  
    #include <strings.h>  
    #include <unistd.h>  
    #include <errno.h>  
    #include <sys/stat.h>  
    #include <dirent.h>  
    #include <sys/mman.h>  
    #include <sys/wait.h>  
    #include <signal.h>  
    #include <sys/ipc.h>  
    #include <sys/shm.h>  
    #include <sys/msg.h>  
    #include <sys/sem.h>  
    #include <pthread.h>  
    #include <semaphore.h>  
    #include <poll.h>  
    #include <sys/epoll.h>  
    #include <sys/socket.h>  
    #include <netinet/in.h>  
    #include <arpa/inet.h>  
    #include <netinet/in.h>  
    
    char wbuf[50];  
      
    int main()  
    {  
        int sockfd;  
        int size,on = 1;  
        struct sockaddr_in saddr;  
        int ret;  
      
        size = sizeof(struct sockaddr_in);  
        bzero(&saddr,size);  
      
        //设置地址信息，ip信息  
        saddr.sin_family = AF_INET;  
        saddr.sin_port = htons(8888);  
        saddr.sin_addr.s_addr = inet_addr("192.168.0.110");//192.168.0.110为服务端所在的ip  
        
        sockfd= socket(AF_INET,SOCK_DGRAM,0);  //创建udp 的套接字  
        if(sockfd<0)  
        {  
            perror("failed socket");  
            return -1;  
        }  
        //设置端口复用  
        setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on));  
      
        //循环发送信息给服务端  
        while(1)  
        {  
            puts("please enter data:");  
            scanf("%s",wbuf);  
            ret=sendto(sockfd,wbuf,50,0,(struct sockaddr*)&saddr,  
                sizeof(struct sockaddr));  
            if(ret<0)  
            {  
                perror("sendto failed");  
            }  
      
            bzero(wbuf,50);  
        }  
        close(sockfd);  
        return 0;  
    }

**三 运行**

1 先启动服务端

[root@localhost test]# g++ test.cpp -o test
    [root@localhost test]# ./test
    waiting data

2 在启动客户端，并输入数据

[root@localhost test]# g++ client.cpp -o client
    [root@localhost test]# ./client
    please enter data:
    明天你来吗？

3 服务端结果

[root@localhost test]# ./test
    waiting data
    the data :明天你来吗？
    waiting data