2021.12.28基于UDP同信的相关流程

作业

1、将TCP的CS模型再敲一遍

服务器

#include <myhead.h>
#define PORT 8888
#define IP "192.168.124.123"
int main(int argc, const char *argv[])
{
	//创建套接字
	//绑定本机IP和端口号
	//监听客户端请求
	//接收客户端连接请求
	//收发消息
	
	//创建套接字
	int oldfd ;
	if((oldfd = socket(AF_INET,SOCK_STREAM,0))==-1) 	//创建套接字
	{
		perror("socket");
		return -1;
	}

	//端口号快速复用
	int n = 2;
	if(setsockopt(oldfd,SOL_SOCKET,SO_REUSEADDR,&n,sizeof(n))==-1)
	{
		perror("setsockopt");
		return -1;
	}

	//绑定本机IP和端口号
	struct sockaddr_in server = {
		.sin_family = AF_INET,
		.sin_port = htons(PORT),
		.sin_addr.s_addr = inet_addr(IP)
	};
	if(bind(oldfd,(struct sockaddr *)&server,sizeof(server))==-1)
	{
		perror("bind");
		return -1;
	}

	//监听客户端连接请求，client变量接收客户端信息
	struct sockaddr_in client;
	int client_len = sizeof(client);
	int newfd;
	if(newfd = accept(oldfd,(struct sockaddr *)&client,&client_len)==-1)
	{
		perror("accept");
		return -1;
	}
	printf("%s:%d连接\n",inet_ntoa(client.sin_addr),ntohs(client.sin_port));

	//收发消息
	char buff[1024];
	while(1)
	{
		int res = recv(newfd,buff,sizeof(buff),0);
		if(res == 0)
		{
			printf("客户端退出\n");
			break;
		}
		printf("收到消息：%s,收到消息的长度：%d\n",buff,res);
		strcat(buff,"霜雪");
		send(newfd,buff,sizeof(buff),0);
		bzero(buff,sizeof(buff));
	}
	close(newfd);
	close(oldfd);
	return 0;
}

客户端

#include <myhead.h>
#define IP "192.168.124.123"
#define SERPORT 9999
int main(int argc, const char *argv[])
{
    //1、创建套接字
    //2、绑定（不是必须绑定）
    //3、连接
    //4、收发消息
    
    int oldfd = socket(AF_INET,SOCK_STREAM,0);
    if(oldfd==-1)
    {
        perror("socket");
        return -1;
    }
#if 0
    //绑定固定的IP和端口号(不是必须的)
    struct sockaddr_in client = {
        .sin_family  =AF_INET,
        .sin_port = htons(7899),//自定义端口号
        .sin_addr.s_addr = inet_addr("192.168.124.34")
    };
    if(bind(oldfd,(struct sockaddr *)&client,sizeof(client))==-1)
    {
        perror("bind");
        return -1;
    }
#endif
    //连接服务器
    struct sockaddr_in server = {
        .sin_family  =AF_INET,
        .sin_port = htons(SERPORT),//注意端口号需要服务器端口
        .sin_addr.s_addr = inet_addr(IP)
    };
    
    if(connect(oldfd,(struct sockaddr *)&server,sizeof(server))==-1)
    {
        perror("connect");
        return -1;
    }
    //收发消息
    char buff[1024];
    while(1)
    {
        fgets(buff,sizeof(buff),stdin);
        buff[strlen(buff)-1] = '\0';
        send(oldfd,buff,sizeof(buff),0);
        if(strcmp(buff,"quit")==0)//退出客户端
        {
            break;
        }
        bzero(buff,sizeof(buff));
        recv(oldfd,buff,sizeof(buff),0);//阻塞接收服务器消息
        printf("服务器发来消息：%s\n",buff);
    }
 close(oldfd);
    return 0;
}

2、UDP服务器中，使用connect函数，实现唯一的客户端与服务器通话。

服务器

#include <myhead.h>
#define PORT 8888

#define IP "192.168.124.123"

int main(int argc, const char *argv[])
{
	//创建套接字
	int oldfd = socket(AF_INET,SOCK_DGRAM,0);
	if(oldfd == -1)
	{
		perror("socket");
		return -1;
	}
	//绑定
	struct sockaddr_in server = {
		.sin_family = AF_INET,
		.sin_port = htons(PORT),
		.sin_addr.s_addr = inet_addr(IP)
	};
	if(bind (oldfd,(struct sockaddr *)&server,sizeof(server))==-1)
	{
		perror("bind");
		return -1;
	}
	struct sockaddr_in client;
	int client_len = sizeof(client);
	char buff[1024];
	int flag = 0;
	while(1)
	{
		recvfrom(oldfd,buff,sizeof(buff),0,(struct sockaddr *)&client,&client_len);
		printf("%s:%d信息：%s\n",inet_ntoa(client.sin_addr),ntohs(client.sin_port),buff);
		if(connect(oldfd,(struct sockaddr *)&client,sizeof(client))==-1)
		{
			perror("connect");
			return -1;
		}
		while(1)
		{
			int res = recvfrom(oldfd,buff,sizeof(buff),0,NULL,NULL);
			printf("%s\n",buff);
			strcat(buff,"周日还要上课，吴！！！！");
			sendto(oldfd,buff,sizeof(buff),0,NULL,0);
			bzero(buff,sizeof(buff));

			if(res == 0)
			{
				printf("退出客户端\n");
				break;
			}

		}
	}
	return 0;
}

客户端

#include <myhead.h>
#define IP "192.168.124.123"
#define PORT 8888
int main(int argc, const char *argv[])
{
    //1、创建套接字
    int oldfd = socket(AF_INET,SOCK_DGRAM,0);
    if(oldfd==-1)
    {
        perror("socket");
        return -1;
    }
    //2、收发消息
    struct sockaddr_in server = {
        .sin_family = AF_INET,
        .sin_port = htons(PORT),
        .sin_addr.s_addr = inet_addr(IP)
    };
	if(connect(oldfd,(struct sockaddr *)&server,sizeof(server))==-1)
    {
        perror("connect");
        return -1;
    }	

    char buff[1024];
    while(1)
    {
        fgets(buff,sizeof(buff),stdin);
        buff[strlen(buff)-1] = '\0';
        sendto(oldfd,buff,sizeof(buff),0,(struct sockaddr *)&server,sizeof(server));

        bzero(buff,sizeof(buff));
        recvfrom(oldfd,buff,sizeof(buff),0,NULL,NULL);
        printf("接收服务器信息：%s\n",buff);
    }
    
    return 0;
}

笔记整理

流程图

UDP服务器

1、创建套接字。

2、绑定本机IP和端口号。

3、收发消息，由于不知道对方是谁，对方也不知道您是谁，所以在发送时附带自己的信息，接收时接收对方信息。

UDP相关API

        #include <sys/types.h>

        #include <sys/socket.h>

                ssize_t sendto(int sockfd, const void *buf, size_t len, int flags, const struct sockaddr *dest_addr, socklen_t addrlen);

        功能：发送信息函数

        参数1：套接字

        参数2：发送的信息

        参数3：信息大小

        参数4： 0：阻塞接收

                        MSG_DONTWAIT:费阻塞接收

        参数5：填写发送目标的IP和端口号 参数6：参数5的大小。

        返回值：成功返回发送的字节个数，失败返回-1，并置位错误码。

        #include <sys/types.h>

        #include <sys/socket.h>

                ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags, struct sockaddr *src_addr, socklen_t *addrlen);

        功能：接收信息函数

        参数1：套接字

        参数2：发送的信息

        参数3：信息大小

        参数4： 0：阻塞接收

                        MSG_DONTWAIT:费阻塞接收

        参数5：自动填充发信息的主机信息。

        返回值：成功返回发送的字节个数，失败返回-1，并置位错误码。

、UDP服务器

#include <myhead.h>
#define PORT 8888
#define IP "192.168.124.34"

int main(int argc, const char *argv[])
{
    //1、创建UDP套接字
    int oldfd = socket(AF_INET,SOCK_DGRAM,0);
    if(oldfd==-1)
    {
        perror("socket");
        return -1;
    }
    
    //2、绑定
    struct sockaddr_in server = {
        .sin_family = AF_INET,
        .sin_port = htons(PORT),
        .sin_addr .s_addr = inet_addr(IP)
    };
    
    if(bind(oldfd,(struct sockaddr *)&server,sizeof(server))==-1)
    {
        perror("bind");
        return -1;
    }

    //收发消息
    struct sockaddr_in client;
    int client_len = sizeof(client);

    char buff[1024];
    while(1)
    {
        //接收客户端消息时会将客户端信息写入client
        recvfrom(oldfd,buff,sizeof(buff),0,(struct sockaddr *)&client,&client_len);
        printf("收到%s：%d的消息：%s\n",inet_ntoa(client.sin_addr),ntohs(client.sin_port),buff);

        strcat(buff,"元旦不放假难受");
        sendto(oldfd,buff,sizeof(buff),0,(struct sockaddr *)&client,sizeof(client));//收到谁的信息就发给谁

    }
    return 0;
}

4、UDP客户端

1、创建套接字

2、收发消息

#include <myhead.h>
#define IP "192.168.124.34"
#define PORT 8888
int main(int argc, const char *argv[])
{
    //1、创建套接字
    int oldfd = socket(AF_INET,SOCK_DGRAM,0);
    if(oldfd==-1)
    {
        perror("socket");
        return -1;
    }

    //2、收发消息
    struct sockaddr_in server = {
        .sin_family = AF_INET,
        .sin_port = htons(PORT),
        .sin_addr.s_addr = inet_addr(IP)
    };
    char buff[1024];
    while(1)
    {
        fgets(buff,sizeof(buff),stdin);
        buff[strlen(buff)-1] = '\0';
        sendto(oldfd,buff,sizeof(buff),0,(struct sockaddr *)&server,sizeof(server));

        bzero(buff,sizeof(buff));
        recvfrom(oldfd,buff,sizeof(buff),0,NULL,NULL);
        printf("接收服务器信息：%s\n",buff);
    }
    
    return 0;
}

思维导图

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/944253.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

OpenCV和PyQt的应用

OpenCV和PyQt的应用

1.创建一个 PyQt 应用程序&#xff0c;该应用程序能够&#xff1a; 使用 OpenCV 加载一张图像。在 PyQt 的窗口中显示这张图像。提供四个按钮&#xff08;QPushButton&#xff09;&#xff1a; 一个用于将图像转换为灰度图一个用于将图像恢复为原始彩色图一个用于将图像进行翻…
阅读更多...
kibana启动报错：Invalid character in header content [“kbn-name“]

kibana启动报错：Invalid character in header content [“kbn-name“]

启动时候kibana报错&#xff1a; 打开 kibana配置文件&#xff0c;config/kibana.yml&#xff0c;配置上server.name即可&#xff0c;如下&#xff1a;
阅读更多...
Pandas08

Pandas08

Pandas01 Pandas02 Pandas03 Pandas04 Pandas05 Pandas06 Pandas07 文章目录 内容回顾同期群分析1.1 同期群分析概念1.2 案例代码 数据分析报告数据分析工作内容数据分析简历说明用户生命周期标签1 什么是生命周期标签2 如何计算生命周期标签 内容回顾 TGI 偏好分析 TGI 目标…
阅读更多...
网页数据的解析提取之Beautiful Soup

网页数据的解析提取之Beautiful Soup

前面博客介绍了正则表达式的相关用法&#xff0c;只是一旦正则表达式写得有问题&#xff0c;得到的结果就可能不是我们想要的了。而且每一个网页都有一定的特殊结构和层级关系&#xff0c;很多节点都用id或 class 作区分所以借助它们的结构和属性来提取不也可以吗? 本篇博客我…
阅读更多...
电脑缺失sxs.dll文件要怎么解决？

电脑缺失sxs.dll文件要怎么解决？

一、文件丢失问题&#xff1a;以sxs.dll文件缺失为例 当你在运行某个程序时&#xff0c;如果系统提示“找不到sxs.dll文件”&#xff0c;这意味着你的系统中缺少了一个名为sxs.dll的动态链接库文件。sxs.dll文件通常与Microsoft的.NET Framework相关&#xff0c;是许多应用程序…
阅读更多...
进军AI大模型-环境配置

进军AI大模型-环境配置

语言环境配置 合法上网工具&#xff1a; 这个T子试试&#xff0c;一直稳定。走我链接免费用5天: https://wibnm.com/s/ywtc01/pvijpzy python版本&#xff1a; python3.12 Langchain: Introduction | &#x1f99c;️&#x1f517; LangChain v0.3 9月16日升级的版本 pip3…
阅读更多...
WebStorm的下载安装指南

WebStorm的下载安装指南

下载 打开网站https://www.jetbrains.com/webstorm/download/#sectionwindows 或者直接网盘下载 通过网盘分享的文件&#xff1a;WebStorm-2024.3.1.1.exe 链接: https://pan.baidu.com/s/16JRZjleFYshLbVvZB49-FA?pwdn5hc 提取码: n5hc –来自百度网盘超级会员v6的分享 安…
阅读更多...
Vue使用pages构建多页应用

Vue使用pages构建多页应用

经过上一篇文章&#xff0c;大家对单页应用配置的都有了一定的了解。相信大家应该对如何构建一个 Vue 单页应用项目已经有所收获和体会&#xff0c;在大部分实际场景中&#xff0c;我们都可以构建单页应用来进行项目的开发和迭代&#xff0c;然而对于项目复杂度过高或者页面模块…
阅读更多...
springboot506基于Springboot的小区疫情购物系统录(论文+源码)_kaic

springboot506基于Springboot的小区疫情购物系统录(论文+源码)_kaic

摘 要 信息数据从传统到当代&#xff0c;是一直在变革当中&#xff0c;突如其来的互联网让传统的信息管理看到了革命性的曙光&#xff0c;因为传统信息管理从时效性&#xff0c;还是安全性&#xff0c;还是可操作性等各个方面来讲&#xff0c;遇到了互联网时代才发现能补上自古…
阅读更多...
复习打卡大数据篇——Hadoop MapReduce

复习打卡大数据篇——Hadoop MapReduce

目录 1. MapReduce基本介绍 2. MapReduce原理 1. MapReduce基本介绍 什么是MapReduce MapReduce是一个分布式运算程序的编程框架&#xff0c;核心功能是将用户编写的业务逻辑代码和自带默认组件整合成一个完整的分布式运算程序&#xff0c;并发运行在Hadoop集群上。 MapRed…
阅读更多...
RK3506开发板：智能硬件领域的新选择，带来卓越性能与低功耗

RK3506开发板：智能硬件领域的新选择，带来卓越性能与低功耗

在现代智能硬件开发中&#xff0c;选择一款性能稳定、功耗低的开发板是确保产品成功的关键。Rockchip最新推出的RK3506芯片&#xff0c;凭借其卓越的能效比、多功能扩展性和优秀的实时性能&#xff0c;已经成为智能家电、工业控制、手持终端等领域的热门选择。而基于RK3506的Ar…
阅读更多...
Python学习（2）：注释、数字、文本、列表

Python学习（2）：注释、数字、文本、列表

1 关于注释 Python 使用井号#作为单行注释的符号&#xff0c; 使用三个连续的单引号’’或者三个连续的双引号"""注释多行内容。 2 数字 2.1 基本运算 解释器像一个简单的计算器&#xff1a;你可以输入一个表达式&#xff0c;它将给出结果值。 表达式语法很直观…
阅读更多...
加载Tokenizer和基础模型的解析及文件介绍：from_pretrained到底加载了什么？

加载Tokenizer和基础模型的解析及文件介绍：from_pretrained到底加载了什么？

加载Tokenizer和基础模型的解析及文件介绍 在使用Hugging Face的transformers库加载Tokenizer和基础模型时&#xff0c;涉及到许多文件的调用和解析。这篇博客将详细介绍这些文件的功能和它们在加载过程中的作用&#xff0c;同时结合代码片段进行解析。 下图是我本地下载好模…
阅读更多...
Excel批量设置行高，Excel表格设置自动换行后打印显示不全，Excel表格设置最合适的行高后打印显示不全，完美解决方案！！！

Excel批量设置行高，Excel表格设置自动换行后打印显示不全，Excel表格设置最合适的行高后打印显示不全，完美解决方案！！！

文章目录 说个问题&#xff08;很严重&#xff01;&#xff01;&#xff01;&#xff09;写个方案会Python看这里Python环境搭建不存在多行合并存在多行合并 不会Python看这里 说个问题&#xff08;很严重&#xff01;&#xff01;&#xff01;&#xff09; 平时处理Excel表格…
阅读更多...
goview——vue3+vite——数据大屏配置系统

goview——vue3+vite——数据大屏配置系统

低代码数据大屏配置系统&#xff1a; 数据来源是可以动态api配置的&#xff1a; 配置上面的api接口后&#xff0c;在数据过滤中进行数据格式的转化。 以上内容&#xff0c;来源于https://gitee.com/dromara/go-view/tree/master-fetch/ 后端代码如下&#xff0c;需要更改…
阅读更多...
ADC相关算法以及热敏电阻测温

ADC相关算法以及热敏电阻测温

目录 前言 一、平均值滤波算法 二、快速排序算法的使用 三、中位值滤波算法 四、二分查找法 4.1 二分查找法查找某个元素是否存在 4.2 二分查找法查找接近目标数值的元素的下标 五、NTC热敏电阻实现测温 5.1 分层设计 5.2 软件流程图 ​编辑 5.3 API接口及数据结构 5…
阅读更多...
计算机的错误计算（一百九十四）

计算机的错误计算（一百九十四）

摘要 用两个大模型计算 其中&#xff0c;一个大模型通过化简&#xff0c;得出正确结果 0&#xff1b;而另外一个在化简过程中出现错误&#xff0c;得出了错误结果。 例1. 计算 下面是一个大模型的推导化简过程。 以上为一个大模型的回答。 下面是另外一个大模型的回复。 点评…
阅读更多...
任意文件包含漏洞原理解析及演示

任意文件包含漏洞原理解析及演示

原理 文件包含漏洞&#xff1a;即file inclusion&#xff0c;意思是文件包含&#xff0c;是指当服务器开启allow_url_include选项时&#xff0c;就可以通过PHP的某些特性函数&#xff08;include()&#xff0c;require()和include_once()&#xff0c;requir_once()&#xff09;…
阅读更多...
Linux系统之tree命令的基本使用

Linux系统之tree命令的基本使用

Linux系统之tree命令的基本使用 一、tree命令介绍二、tree工具安装三、tree命令帮助3.1 查询帮助信息3.2 tree命令帮助解释 四、tree命令的基本使用4.1 直接使用4.2 *限制显示的层级4.3 仅显示目录4.4 不显示隐藏文件4.5 显示文件大小4.6 彩色输出4.7 输出到文件4.8 输出不同格…
阅读更多...
微信小程序性能优化、分包

微信小程序性能优化、分包

性能优化是任何应用开发中的重要组成部分&#xff0c;尤其是在移动环境中。对于微信小程序而言&#xff0c;随着用户量的增加和应用功能的丰富&#xff0c;性能优化显得尤为关键。良好的性能不仅提升用户体验&#xff0c;还能增加用户留存率和应用的使用频率。我们将探讨如何在…
阅读更多...
最新文章

Copyright @ 2022~2023