• C/S架构学习之基于UDP的本地通信(客户机)


    • 基于UDP的本地通信(客户机):
    • 创建流程:
    • 一、创建数据报式套接字(socket函数):
    		int sock_fd = socket(AF_UNIX,SOCK_DGRAM,0);
    	    if(-1 == sock_fd)
    	    {
    	        perror("socket error");
    	        exit(-1);
    	    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 二、创建客户机和服务器的本地网络信息结构体并填充客户机和服务器本地网络信息结构体 (struct sockaddr_un):
    • 本地网络信息结构体:
    	#include 
    	struct sockaddr_un {
    	    sa_family_t sun_family;               //AF_UNIX
    	    char        sun_path[108];            //pathname
    	};
    
    • 1
    • 2
    • 3
    • 4
    • 5
    		struct sockaddr_un serveraddr,clientaddr;
    	    socklen_t serveraddr_len = sizeof(serveraddr);
    	    socklen_t clientaddr_len = sizeof(clientaddr);
    	
    	    memset(&serveraddr,0,serveraddr_len);
    	    memset(&clientaddr,0,clientaddr_len);
    	
    	    serveraddr.sun_family = AF_UNIX;
    	    clientaddr.sun_family = AF_UNIX;
    	
    	    strcpy(serveraddr.sun_path,"./udpserver");
    	    strcpy(clientaddr.sun_path,"./udpclient");
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 三、客户机绑定数据报式套接字(bind函数):
    		if(-1 == bind(sock_fd,(struct sockaddr *)&clientaddr,clientaddr_len))
    	    {
    	        perror("bind error");
    	        exit(-1);
    	    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 四、客户机端发收数据(sendto函数、recvfrom函数):
    			memset(buf,0,sizeof(buf));
    	
    	        fgets(buf,sizeof(buf),stdin);
    	        buf[strlen(buf) - 1] = '\0';
    	        int ret1 = sendto(sock_fd,buf,sizeof(buf),0,(struct sockaddr *)&serveraddr,serveraddr_len);
    	        if(-1 == ret1)
    	        {
    	            perror("sendto error");
    	            exit(-1);
    	        }
    	
    	        int ret2 = recvfrom(sock_fd,buf,sizeof(buf),0,(struct sockaddr*)&serveraddr,&serveraddr_len);
    	        if(-1 == ret2)
    	        {
    	            perror("recvfrom error");
    	            exit(-1);
    	        }
    	
    	        printf("服务器[%s]发来应答消息[%s]\n",serveraddr.sun_path,buf);
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 五、关闭套接字(close函数):
    	close(sock_fd);
    
    • 1
    • 示例代码:
    	#include 
    	#include 
    	#include 
    	
    	#include 
    	#include 
    	
    	#include 
    	#include 
    	#include 
    	
    	#include 
    	#include 
    	
    	int main(int argc, char const *argv[])
    	{
    	    //创建套接字
    	    int sock_fd = socket(AF_UNIX,SOCK_DGRAM,0);
    	    if(-1 == sock_fd)
    	    {
    	        perror("socket error");
    	        exit(-1);
    	    }
    	    //填充网络信息结构体
    	
    	    struct sockaddr_un serveraddr,clientaddr;
    	    socklen_t serveraddr_len = sizeof(serveraddr);
    	    socklen_t clientaddr_len = sizeof(clientaddr);
    	
    	    memset(&serveraddr,0,serveraddr_len);
    	    memset(&clientaddr,0,clientaddr_len);
    	
    	    serveraddr.sun_family = AF_UNIX;
    	    clientaddr.sun_family = AF_UNIX;
    	
    	    strcpy(serveraddr.sun_path,"./udpserver");
    	    strcpy(clientaddr.sun_path,"./udpclient");
    	
    	
    	    //绑定套接字
    	    if(-1 == bind(sock_fd,(struct sockaddr *)&clientaddr,clientaddr_len))
    	    {
    	        perror("bind error");
    	        exit(-1);
    	    }
    	
    	    printf("基于UDP的本地通信客户机启动!!!\n");
    	
    	    char buf[128] = {0};
    	    //收发数据
    	    while(true)
    	    {
    	        memset(buf,0,sizeof(buf));
    	
    	        fgets(buf,sizeof(buf),stdin);
    	        buf[strlen(buf) - 1] = '\0';
    	        int ret1 = sendto(sock_fd,buf,sizeof(buf),0,(struct sockaddr *)&serveraddr,serveraddr_len);
    	        if(-1 == ret1)
    	        {
    	            perror("sendto error");
    	            exit(-1);
    	        }
    	
    	        int ret2 = recvfrom(sock_fd,buf,sizeof(buf),0,(struct sockaddr*)&serveraddr,&serveraddr_len);
    	        if(-1 == ret2)
    	        {
    	            perror("recvfrom error");
    	            exit(-1);
    	        }
    	
    	        printf("服务器[%s]发来应答消息[%s]\n",serveraddr.sun_path,buf);
    	
    	
    	
    	    }
    	    //关闭套接字
    	    close(sock_fd);
    	
    	    return 0;
    	}
    
    
    
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49
    • 50
    • 51
    • 52
    • 53
    • 54
    • 55
    • 56
    • 57
    • 58
    • 59
    • 60
    • 61
    • 62
    • 63
    • 64
    • 65
    • 66
    • 67
    • 68
    • 69
    • 70
    • 71
    • 72
    • 73
    • 74
    • 75
    • 76
    • 77
    • 78
    • 79
    • 80
    • 81
    • 82
    • 83
    • 运行结果:
    	基于UDP的本地通信客户机启动!!!
    	hello
    	服务器[./udpserver]发来应答消息[hello---------k]
    	I Love China!!!
    	服务器[./udpserver]发来应答消息[I Love China!!!---------k]
    	miss U
    	服务器[./udpserver]发来应答消息[miss U---------k]
    
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 特别注意:
    • strcpy(serveraddr.sun_path,"./udpserver");strcpy(clientaddr.sun_path,"./udpclient");代码段中的udpserver文件udpclient文件套接字文件
    • 如下所示:
    	srwxrwxr-x 1 linux linux     0 1111 01:18 udpclient
    	srwxrwxr-x 1 linux linux     0 1111 01:18 udpserver
    
    • 1
    • 2
  • 相关阅读:
    数据结构----线性表之双向链表
    BeanPostProcessor(Spring后置处理器)如何使用呢?
    Centos, RockyLinux 常用软件安装汇总
    Java实现拼图小游戏(3)—— 添加图片(含JFrame源码阅读)
    js第十一章
    LabVIEW 使用VISA Close真的关闭COM口了吗
    springboot整合quartz实现任务持久化(下)
    几个西门子PLC常见通讯问题的解决方法
    前端开发规范
    大学英语试卷
  • 原文地址:https://blog.csdn.net/qq_41878292/article/details/134351399