C/S架构学习之基于UDP的本地通信(服务器)

news/2024/5/18 14:41:52 标签: c语言, 架构, 学习, udp, 服务器
  • 基于UDP的本地通信(服务器):
  • 创建流程:
  • 一、创建数据报式套接字(socket函数):
		int sock_fd = socket(AF_UNIX,SOCK_DGRAM,0);
	    if(-1 == sock_fd)
	    {
	        perror("socket error");
	        exit(-1);
	    }
  • 二、创建服务器和客户机的本地网络信息结构体并填充服务器本地网络信息结构体 (struct sockaddr_un):
  • 本地网络信息结构体:
	#include <sys/un.h>
	struct sockaddr_un {
	    sa_family_t sun_family;               //AF_UNIX
	    char        sun_path[108];            //pathname
	};
		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;
	    strcpy(serveraddr.sun_path,"./udpserver");
  • 三、绑定数据报式套接字(bind函数):
		if(-1 == bind(sock_fd,(struct sockaddr *)&serveraddr,serveraddr_len))
	    {
	        perror("bind error");
	        exit(-1);
	    }
  • 四、服务器端收发数据(recvfrom函数、sendto函数):
            memset(buf,0,sizeof(buf));
	
	        int ret1 = recvfrom(sock_fd,buf,sizeof(buf),0,(struct sockaddr*)&clientaddr,&clientaddr_len);
	        if(-1 == ret1)
	        {
	            perror("recvfrom error");
	            exit(-1);
	        }
	        printf("客户端[%s]发来消息[%s]\n",clientaddr.sun_path,buf);
	
	        //发送应答消息
	        strcat(buf,"---------k");
	
	        int ret2 = sendto(sock_fd,buf,sizeof(buf),0,(struct sockaddr *)&clientaddr,clientaddr_len);
	        if(-1 == ret2)
	        {
	            perror("sendto error");
	            exit(-1);
	        }
	
  • 五、关闭套接字(close函数):
	close(sock_fd);
  • 示例代码:
	#include <stdio.h>
	#include <string.h>
	#include <stdlib.h>
	
	#include <sys/socket.h>
	#include <sys/types.h>
	
	#include <unistd.h>
	#include <stdbool.h>
	#include <sys/un.h>
	
	#include <arpa/inet.h>
	#include <netinet/ip.h>
	
	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;
	    strcpy(serveraddr.sun_path,"./udpserver");
	
	
	    //绑定套接字
	    if(-1 == bind(sock_fd,(struct sockaddr *)&serveraddr,serveraddr_len))
	    {
	        perror("bind error");
	        exit(-1);
	    }
	
	    printf("基于UDP的本地通信服务器启动!!!\n");
	
	    char buf[128] = {0};
	    //收发数据
	    while(true)
	    {
	        memset(buf,0,sizeof(buf));
	
	        int ret1 = recvfrom(sock_fd,buf,sizeof(buf),0,(struct sockaddr*)&clientaddr,&clientaddr_len);
	        if(-1 == ret1)
	        {
	            perror("recvfrom error");
	            exit(-1);
	        }
	        printf("客户端[%s]发来消息[%s]\n",clientaddr.sun_path,buf);
	
	        //发送应答消息
	        strcat(buf,"---------k");
	
	        int ret2 = sendto(sock_fd,buf,sizeof(buf),0,(struct sockaddr *)&clientaddr,clientaddr_len);
	        if(-1 == ret2)
	        {
	            perror("sendto error");
	            exit(-1);
	        }
	
	
	    }
	    //关闭套接字
	    close(sock_fd);
	
	    return 0;
	}


  • 运行结果:
	基于UDP的本地通信服务器启动!!!
	客户端[./udpclient]发来消息[hello]
	客户端[./udpclient]发来消息[I Love China!!!]
	客户端[./udpclient]发来消息[miss U]
  • 特别注意:
  • strcpy(serveraddr.sun_path,"./udpserver");udpserver文件套接字文件
  • 如下所示:
	srwxrwxr-x 1 linux linux     0 1111 01:18 udpserver

http://www.niftyadmin.cn/n/5172616.html

相关文章

【java进阶】集合的三种遍历(迭代器、增强for、Lambda)

目录 一、先谈集合&#xff1a; 二、单列集合的三种遍历方式 迭代器遍历 增强for遍历 Lambda表达式遍历 一、先谈集合&#xff1a; &#x1f525;那我们平常用for循环依赖下标遍历不行嘛&#xff0c;这就与集合的分类有关了。 集合的体系结构&#xff1a; collection是单…

【六袆 - Framework】Angular-framework;前端框架Angular发展的由来0001;

Angular发展介绍&#xff0c;Angular17新特性 官方文档Angular框架发展的由来何为结构化、模块化 Angular17新特性 English unit Embarking on the journey of deep technical learning requires a well-structured approach, applicable to any programming language. The key…

【深度挖掘Java性能调优】「底层技术原理体系」深入挖掘和分析如何提升服务的性能以及执行效率(引导篇)

深入挖掘和分析如何提升服务的性能以及执行效率 前提介绍知识要点 性能概述教你看懂程序的性能案例介绍性能指标性能的参考指标性能瓶颈&#xff08;木桶原理&#xff09; 性能分析三大定律Amdahl定律计算公式参数解释案例分析定律总结 Gustafson定律与Amdahl定律相对立Gustafs…

在nodejs中验证收到的请求

在nodejs中验证收到的请求 Node.js是构建Web应用程序的一种常用方式。随着应用程序的增长&#xff0c;验证传入的请求变得至关重要&#xff0c;以确保它们格式正确并符合某些标准。在这篇文章中&#xff0c;我们将探索不同的方法来验证接收到的请求&#xff0c;并提供如何在自…

使用 eBPF检测 mmap泄露

目录 背景 官网 malloc泄露检测 mmap泄露检测 调用munmap释放内存 小结 背景 我们知道 mmap系统调用申请的内存空间&#xff0c;属于文件映射区域 和 匿名映射区域。这部分区域并不属于 heap&#xff0c;所以用一般的内存泄露检测工具是检测不出来的。例如&#xff1a;一…

MySQL的索引和复合索引

由于MySQL自动将主键加入到二级索引&#xff08;自行建立的index&#xff09;里&#xff0c;所以当select的是主键或二级索引就会很快&#xff0c;select *就会慢。因为有些列是没在索引里的 假设CA有1kw人咋整&#xff0c;那我这个索引只起了前一半作用。 所以用复合索引&am…

CSDN写博文的128天

起因 为什么要写博文&#xff1f; 写博文是因为当我还是编程小白时&#xff0c;我那会啥也不懂&#xff0c;不懂函数调用&#xff0c;不懂指针&#xff0c;更不懂结构体&#xff0c;别更说Linux&#xff0c;平时不会也没有可以问的人&#xff0c;也幸好有CSDN&#xff0c;遇到…

代码随想录 Day43 动态规划11 LeetCode T309 买卖股票的最佳时期含冷冻期 T714买卖股票的最佳时机含手续费

LeetCode T309 买卖股票的最佳时机含冷冻期 题目链接:309. 买卖股票的最佳时机含冷冻期 - 力扣&#xff08;LeetCode&#xff09; 题目思路: 这题其实就是将卖出的状态拆分成三个状态 1.前两天就卖出并一直保持卖出的状态 2.今天卖出的状态 3.今天是冷冻期的状态 当然还有一个…