42、网络编程/多点通信和域套接字通信模型20240304

2024-03-05 07:44
文章标签 编程 网络 42 和域 接字 多点通信 通信模型 20240304

本文主要是介绍42、网络编程/多点通信和域套接字通信模型20240304，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一、多点通信之广播的收发端实现

1.广播发送端代码：

#include<myhead.h>int main(int argc, const char *argv[])
{int sfd=socket(AF_INET,SOCK_DGRAM,0);//创建套接字if(sfd==-1){perror("socket,error");return -1;}int broadcast=1;//设置套接字广播属性if(setsockopt(sfd,SOL_SOCKET,SO_BROADCAST,&broadcast,sizeof(broadcast))==-1){perror("setsockopt error");return -1;}struct sockaddr_in sin;//广播地址结构体sin.sin_family=AF_INET;sin.sin_port=htons(8888);sin.sin_addr.s_addr=inet_addr("192.168.32.255");char sbuf[128]="";while(1){printf("请输入>>>");fgets(sbuf,sizeof(sbuf),stdin);sbuf[strlen(sbuf)-1]=0;//向广播地址发送数据sendto(sfd,sbuf,strlen(sbuf),0,(struct sockaddr*)&sin,sizeof(sin));printf("发送成功\n");}close(sfd);return 0;
}

2.广播接收端代码：

int main(int argc, const char *argv[])
{int rfd=socket(AF_INET,SOCK_DGRAM,0);//基于ipv4的udp模型实现广播if(rfd==-1){perror("socket error");return -1;}printf("rfd=%d\n",rfd);struct sockaddr_in rin;rin.sin_family=AF_INET;rin.sin_port=htons(8888);//端口号设置rin.sin_addr.s_addr=inet_addr("192.168.32.255");//ip地址主机号全为1的地址为广播地址if(bind(rfd,(struct sockaddr*)&rin,sizeof(rin))==-1)//绑定到广播地址{perror("bind error");return -1;}char rbuf[128]="";while(1){bzero(rbuf,sizeof(rbuf));recv(rfd,rbuf,sizeof(rbuf),0);//接收广播消息printf("收到消息：%s\n",rbuf);}close(rfd);return 0;
}

运行：

二、多点通信之组播的收发实现

1.组播发送端代码

#include<myhead.h>int main(int argc, const char *argv[])
{//创建套接字int rfd=socket(AF_INET,SOCK_DGRAM,0);//基于ipv4的udp模型if(rfd==-1){perror("socket error");return -1;}//绑定端口和ip地址struct sockaddr_in rin;rin.sin_family=AF_INET;rin.sin_port=htons(9999);//自身端口号rin.sin_addr.s_addr=inet_addr("192.168.32.130");//ip地址if(bind(rfd,(struct sockaddr*)&rin,sizeof(rin))==-1){perror("bind error");return -1;}//发送消息struct sockaddr_in sin;sin.sin_family=AF_INET;sin.sin_port=htons(8888);//设置组播的端口号sin.sin_addr.s_addr=inet_addr("224.1.2.3");//组播的ipchar sbuf[128]="";while(1){printf("请输入>>>");fgets(sbuf,sizeof(sbuf),stdin);sbuf[strlen(sbuf)-1]=0;//向组播内发送信息sendto(rfd,sbuf,strlen(sbuf),0,(struct sockaddr*)&sin,sizeof(sin));printf("发送成功\n");}//关闭close(rfd);return 0;
}

2.组播接收端代码

#include<myhead.h>int main(int argc, const char *argv[])
{int rfd=socket(AF_INET,SOCK_DGRAM,0);//创建套接字if(rfd==-1){perror("socket error");return -1;}printf("rfd=%d\n",rfd);//设置加入多播组struct ip_mreqn imr;imr.imr_multiaddr.s_addr=inet_addr("224.1.2.3");//组播ipimr.imr_address.s_addr=inet_addr("192.168.32.130");//本机ipimr.imr_ifindex=2;//网卡编号//设置加入组播if(setsockopt(rfd,IPPROTO_IP,IP_ADD_MEMBERSHIP,&imr,sizeof(imr))==-1){perror("setsockopt error");return -1;}struct sockaddr_in rin;//组播地址信息rin.sin_family=AF_INET;rin.sin_port=htons(8888);rin.sin_addr.s_addr=inet_addr("224.1.2.3");//绑定到组播地址if(bind(rfd,(struct sockaddr*)&rin,sizeof(rin))==-1){perror("bind error");return -1;}char rbuf[128]="";while(1){bzero(rbuf,sizeof(rbuf));recv(rfd,rbuf,sizeof(rbuf),0);//接收组播消息printf("收到消息：%s\n",rbuf);}close(rfd);return 0;
}

运行结果：

三、 流式域套接字（基于tcp）的服务器、客户端实现。

1.服务器代码：

#include<myhead.h>int main(int argc, const char *argv[])
{int sfd=socket(AF_UNIX,SOCK_STREAM,0);//通过设置参数不同创建域套接字 传输方式tcpif(sfd==-1){perror("socket error");return -1;}if(access("./mysocket",F_OK)==0)//判断文件是否存在，如果存在则删除{if(unlink("./mysocket")==-1){perror("unlink error");return -1;}}struct sockaddr_un sun;//地址信息结构体sun.sun_family=AF_UNIX;strcpy(sun.sun_path,"./mysocket");//绑定地址信息if(bind(sfd,(struct sockaddr*)&sun,sizeof(sun))==-1){perror("bind error");return -1;}printf("bind success\n");//监听if(listen(sfd,128)==-1){perror("listen error");return -1;}printf("listen error");//接收客户端发来的链接请求，并保存客户端地址信息，返回新的文件描述符用于通信struct sockaddr_un cun;socklen_t socklen=sizeof(cun);int newfd=-1;if((newfd=accept(sfd,(struct sockaddr*)&cun,&socklen))==-1){perror("accept error");return -1;}puts("已接受新客户端连接");char rbuf[128]="";while(1){bzero(rbuf,sizeof(rbuf));//接收客户端信息recv(newfd,rbuf,sizeof(rbuf),0);printf("[%s]:%s\n",cun.sun_path,rbuf);strcat(rbuf,"*_*");//回复消息send(newfd,rbuf,strlen(rbuf),0);printf("发送成功\n");}close(sfd);close(newfd);return 0;
}

 2.客户端代码

#include<myhead.h>int main(int argc, const char *argv[])
{int cfd=socket(AF_UNIX,SOCK_STREAM,0);if(cfd==-1){perror("socket error");return -1;}if(access("./mysocket1",F_OK)==0){if(unlink("./mysocket1")==-1){perror("unlink error");return -1;}}struct sockaddr_un cun;//客户端地址信息cun.sun_family=AF_UNIX;strcpy(cun.sun_path,"./mysocket1");if(bind(cfd,(struct sockaddr*)&cun,sizeof(cun))==-1)//绑定客户端{perror("bind error");return -1;}printf("bind success\n");struct sockaddr_un sun;//服务器地址信息sun.sun_family=AF_UNIX;strcpy(sun.sun_path,"./mysocket");if(connect(cfd,(struct sockaddr*)&sun,sizeof(sun))==-1)//连接服务器{perror("connet error");return -1;}printf("connet success\n");char wbuf[128]="";while(1){bzero(wbuf,sizeof(wbuf));printf("请输入>>>");fgets(wbuf,sizeof(wbuf),stdin);wbuf[strlen(wbuf)-1]=0;send(cfd,wbuf,strlen(wbuf),0);printf("发送成功\n");if(strcmp(wbuf,"quit")==0){break;}bzero(wbuf,sizeof(wbuf));recv(cfd,wbuf,sizeof(wbuf),0);printf("收到消息为：%s\n",wbuf);}close(cfd);return 0;
}

运行：

四、报式域套接字 （基于udp）的服务器、客户端实现。

1.服务器代码

#include<myhead.h>int main(int argc, const char *argv[])
{int sfd=socket(AF_UNIX,SOCK_DGRAM,0);//创建基于udp创建域套接字if(sfd==-1){perror("socket error");return -1;}if(access("./linux1",F_OK)==0)//检查文件是否存在如果存在则删除{if(unlink("./linux1")==-1){perror("unlink error");return -1;}}struct sockaddr_un sun;//设置服务器地址sun.sun_family=AF_UNIX;strcpy(sun.sun_path,"./linux1");//绑定服务器自身地址信息if(bind(sfd,(struct sockaddr*)&sun,sizeof(sun))==-1){perror("bind error");return -1;}printf("bind success\n");char rbuf[128]="";struct sockaddr_un cun;//客户端地址信息容器socklen_t socklen=sizeof(cun);while(1){bzero(rbuf,sizeof(rbuf));//接收客户端消息并且保存客户端地址recvfrom(sfd,rbuf,sizeof(rbuf),0,(struct sockaddr*)&cun,&socklen);printf("收到消息为：%s\n",rbuf);strcat(rbuf,"*_*");//给发来消息的客户端回复if(sendto(sfd,rbuf,strlen(rbuf),0,(struct sockaddr*)&cun,sizeof(cun))==-1){perror("sendto error");return -1;}}close(sfd);return 0;
}

2.客户端代码

#include<myhead.h>int main(int argc, const char *argv[])
{int cfd=socket(AF_UNIX,SOCK_DGRAM,0);//创建域套接字 传输方式udpif(cfd==-1){perror("socket error");return -1;}printf("cfd=%d\n",cfd);if(access("./linux2",F_OK)==0){if(unlink("./linux2")==-1){perror("unlink error");return -1;}}	struct sockaddr_un cun;//客户端自身地址信息cun.sun_family=AF_UNIX;strcpy(cun.sun_path,"./linux2");//绑定地址信息 如果要从服务器接收消息则必须绑定 否则系统不会自动绑定 服务器接收的地址为空 无法发来消息if(bind(cfd,(struct sockaddr*)&cun,sizeof(cun))==-1){perror("bind error");return -1;}printf("bind success\n");char wbuf[128]="";struct sockaddr_un sun;//保存服务器地址sun.sun_family=AF_UNIX;strcpy(sun.sun_path,"./linux1");while(1){bzero(wbuf,sizeof(wbuf));printf("请输入>>>");fgets(wbuf,sizeof(wbuf),stdin);wbuf[strlen(wbuf)-1]=0;//发送消息sendto(cfd,wbuf,sizeof(wbuf),0,(struct sockaddr*)&sun,sizeof(sun));printf("发送成功\n");bzero(wbuf,sizeof(wbuf));recvfrom(cfd,wbuf,sizeof(wbuf),0,NULL,NULL);//接收消息，因为前面已经有了服务器地址信息 所以此处可以不接收printf("收到消息：%s\n",wbuf);}close(cfd);return 0;
}

运行：

思维导图：

这篇关于42、网络编程/多点通信和域套接字通信模型20240304的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/775781。

相关文章

Linux 网络编程 --- 应用层

Linux 网络编程 --- 应用层

一、自定义协议和序列化反序列化 代码： 序列化反序列化实现网络版本计算器 二、HTTP协议 1、谈两个简单的预备知识 https://www.baidu.com/ --- 域名 --- 域名解析 --- IP地址 http的端口号为80端口，https的端口号为443 url为统一资源定位符。CSDNhttps://mp.csdn.net/mp_blog/creation/editor
阅读更多...
【Python编程】Linux创建虚拟环境并配置与notebook相连接

【Python编程】Linux创建虚拟环境并配置与notebook相连接

1.创建 使用 venv 创建虚拟环境。例如，在当前目录下创建一个名为 myenv 的虚拟环境： python3 -m venv myenv 2.激活 激活虚拟环境使其成为当前终端会话的活动环境。运行： source myenv/bin/activate 3.与notebook连接 在虚拟环境中，使用 pip 安装 Jupyter 和 ipykernel： pip instal
阅读更多...
ASIO网络调试助手之一：简介

ASIO网络调试助手之一：简介

多年前，写过几篇《Boost.Asio C++网络编程》的学习文章，一直没机会实践。最近项目中用到了Asio，于是抽空写了个网络调试助手。 开发环境： Win10 Qt5.12.6 + Asio(standalone) + spdlog 支持协议： UDP + TCP Client + TCP Server 独立的Asio（http://www.think-async.com）只包含了头文件，不依
阅读更多...
poj 3181 网络流，建图。

poj 3181 网络流，建图。

题意： 农夫约翰为他的牛准备了F种食物和D种饮料。 每头牛都有各自喜欢的食物和饮料，而每种食物和饮料都只能分配给一头牛。 问最多能有多少头牛可以同时得到喜欢的食物和饮料。 解析： 由于要同时得到喜欢的食物和饮料，所以网络流建图的时候要把牛拆点了。 如下建图： s -> 食物 -> 牛1 -> 牛2 -> 饮料 -> t 所以分配一下点： s  =  0， 牛1= 1~
阅读更多...
poj 3068 有流量限制的最小费用网络流

poj 3068 有流量限制的最小费用网络流

题意： m条有向边连接了n个仓库，每条边都有一定费用。 将两种危险品从0运到n-1，除了起点和终点外，危险品不能放在一起，也不能走相同的路径。 求最小的费用是多少。 解析： 抽象出一个源点s一个汇点t，源点与0相连，费用为0，容量为2。 汇点与n - 1相连，费用为0，容量为2。 每条边之间也相连，费用为每条边的费用，容量为1。 建图完毕之后，求一条流量为2的最小费用流就行了
阅读更多...
poj 2112 网络流+二分

poj 2112 网络流+二分

题意： k台挤奶机，c头牛，每台挤奶机可以挤m头牛。 现在给出每只牛到挤奶机的距离矩阵，求最小化牛的最大路程。 解析： 最大值最小化，最小值最大化，用二分来做。 先求出两点之间的最短距离。 然后二分匹配牛到挤奶机的最大路程，匹配中的判断是在这个最大路程下，是否牛的数量达到c只。 如何求牛的数量呢，用网络流来做。 从源点到牛引一条容量为1的边，然后挤奶机到汇点引一条容量为m的边
阅读更多...
【编程底层思考】垃圾收集机制，GC算法，垃圾收集器类型概述

【编程底层思考】垃圾收集机制，GC算法，垃圾收集器类型概述

Java的垃圾收集（Garbage Collection，GC）机制是Java语言的一大特色，它负责自动管理内存的回收，释放不再使用的对象所占用的内存。以下是对Java垃圾收集机制的详细介绍： 一、垃圾收集机制概述： 对象存活判断：垃圾收集器定期检查堆内存中的对象，判断哪些对象是“垃圾”，即不再被任何引用链直接或间接引用的对象。内存回收：将判断为垃圾的对象占用的内存进行回收，以便重新使用。
阅读更多...
Go Playground 在线编程环境

Go Playground 在线编程环境

For all examples in this and the next chapter, we will use Go Playground. Go Playground represents a web service that can run programs written in Go. It can be opened in a web browser using the follow
阅读更多...
深入理解RxJava：响应式编程的现代方式

深入理解RxJava：响应式编程的现代方式

在当今的软件开发世界中，异步编程和事件驱动的架构变得越来越重要。RxJava，作为响应式编程（Reactive Programming）的一个流行库，为Java和Android开发者提供了一种强大的方式来处理异步任务和事件流。本文将深入探讨RxJava的核心概念、优势以及如何在实际项目中应用它。 文章目录 💯 什么是RxJava？💯 响应式编程的优势💯 RxJava的核心概念
阅读更多...
函数式编程思想

函数式编程思想

我们经常会用到各种各样的编程思想，例如面向过程、面向对象。不过笔者在该博客简单介绍一下函数式编程思想. 如果对函数式编程思想进行概括，就是f(x) = na(x) , y=uf(x)…至于其他的编程思想，可能是y=a(x)+b(x)+c(x)…，也有可能是y=f(x)=f(x)/a + f(x)/b+f(x)/c… 面向过程的指令式编程 面向过程，简单理解就是y=a(x)+b(x)+c(x)
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2