网络—DAY4

思维导图

多进程并发服务器
 

#include<myhead.h>
#define SER_IP "192.168.122.56"
#define SER_PORT 8888
void handler(int signo)
{if(signo==SIGCHLD){while(waitpid(-1,NULL,WNOHANG)>0);}
}
int main(int argc, char *argv[])
{//将SIGCHLD信号与处理函数绑定if(signal(SIGCHLD,handler)==SIG_ERR){perror("signal");return -1;}//创建套接字int sfd=socket(AF_INET,SOCK_STREAM,0);if(sfd==-1){perror("socket");return -1;}printf("socket success sfd=%d\n",sfd);//端口快速重用int reuse=1;if(setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))==-1){perror("setsockopt");return -1;}printf("端口号快速重用成功\n");//绑定ip地址和端口//填充地址信息结构体struct sockaddr_in sin;sin.sin_family=AF_INET;sin.sin_port=htons(SER_PORT);sin.sin_addr.s_addr=inet_addr(SER_IP);//绑定if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))==-1){perror("bind");return -1;}  printf("bind success\n");//将套接字设置成被动监听状态if(listen(sfd,128)==-1){perror("listen");return -1;}printf("listen success\n");//阻塞等待客户端连接//第二个参数->我要记录发送连接方的地址信息结构体struct sockaddr_in cin;socklen_t socklen=sizeof(cin);while(1){int newfd=accept(sfd,(struct sockaddr*)&cin,&socklen);if(newfd==-1){perror("accept");return -1;}printf("[%s:%d]:已连接,newfd=%d\n",\inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),newfd);pid_t pid=fork();if(pid>0){//accept创了一个newfd,父进程中不使用,关闭close(newfd);}else if(pid==0){//数据通信char rbuf[128]="";while(1){bzero(rbuf,sizeof(rbuf));int ret = recv(newfd,rbuf,sizeof(rbuf),0);if(ret==0){printf("客户端已下线\n");break;}printf("[%s:%d]:%s\n",\inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),rbuf);strcat(rbuf,"*_*");send(newfd,rbuf,strlen(rbuf),0);printf("发送成功\n");}close(newfd);exit(EXIT_SUCCESS);}}close(sfd);return 0;
}

多线程并发服务器
 

#include<myhead.h>
#define SER_IP "192.168.122.56"
#define SER_PORT 8888
struct MsgInfo
{int newfd;struct sockaddr_in cin;
};void* deal_cli_msg(void* arg)
{//将传递进来的数据解析出来int newfd=((struct MsgInfo*)arg)->newfd;struct sockaddr_in cin=((struct MsgInfo*)arg)->cin;//数据通信char rbuf[128]="";while(1){bzero(rbuf,sizeof(rbuf));int ret = recv(newfd,rbuf,sizeof(rbuf),0);if(ret==0){printf("客户端已下线\n");break;}printf("[%s:%d]:%s\n",\inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),rbuf);strcat(rbuf,"*_*");send(newfd,rbuf,strlen(rbuf),0);printf("发送成功\n");}close(newfd);pthread_exit(NULL);
}
int main(int argc, char *argv[])
{//创建套接字int sfd=socket(AF_INET,SOCK_STREAM,0);if(sfd==-1){perror("socket");return -1;}printf("socket success sfd=%d\n",sfd);//端口快速重用int reuse=1;if(setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))==-1){perror("setsockopt");return -1;}printf("端口号快速重用成功\n");//绑定ip地址和端口//填充地址信息结构体struct sockaddr_in sin;sin.sin_family=AF_INET;sin.sin_port=htons(SER_PORT);sin.sin_addr.s_addr=inet_addr(SER_IP);//绑定if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))==-1){perror("bind");return -1;}  printf("bind success\n");//将套接字设置成被动监听状态if(listen(sfd,128)==-1){perror("listen");return -1;}printf("listen success\n");//阻塞等待客户端连接//第二个参数->我要记录发送连接方的地址信息结构体struct sockaddr_in cin;socklen_t socklen=sizeof(cin);while(1){int newfd=accept(sfd,(struct sockaddr*)&cin,&socklen);if(newfd==-1){perror("accept");return -1;}printf("[%s:%d]:已连接,newfd=%d\n",\inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),newfd);//定义用于传参的变量struct MsgInfo info={newfd,cin};//创建分支线程用于通信pthread_t tid=-1;if(pthread_create(&tid,NULL,deal_cli_msg,&info)==-1){printf("创建线程失败\n");return -1;}//回收分支线程的资源pthread_detach(tid);}close(sfd);return 0;
}

流式域套接字服务器

#include<myhead.h>
int main(int argc, char *argv[])
{//创建套接字int sfd=socket(AF_UNIX,SOCK_STREAM,0);if(sfd==-1){perror("socket");return -1;}printf("socket success sfd=%d\n",sfd);//判断要绑定的套接字文件是否存在if(access("./unix",F_OK)==0){//说明文件存在,将其删除if(unlink("./unix")!=0){perror("unlink");return -1;}}//绑定ip地址和端口//填充地址信息结构体struct sockaddr_un sun;sun.sun_family=AF_UNIX;strcpy(sun.sun_path,"./unix");//绑定if(bind(sfd,(struct sockaddr*)&sun,sizeof(sun))==-1){perror("bind");return -1;}  printf("bind success\n");//将套接字设置成被动监听状态if(listen(sfd,128)==-1){perror("listen");return -1;}printf("listen success\n");//阻塞等待客户端连接//第二个参数->我要记录发送连接方的地址信息结构体struct sockaddr_un cun;socklen_t socklen=sizeof(cun);int newfd=accept(sfd,(struct sockaddr*)&cun,&socklen);if(newfd==-1){perror("accept");return -1;}printf("[%s]:已连接,newfd=%d\n",cun.sun_path,newfd);//数据通信char rbuf[128]="";while(1){bzero(rbuf,sizeof(rbuf));int ret = recv(newfd,rbuf,sizeof(rbuf),0);if(ret==0){printf("客户端已下线\n");break;}printf("[%s]:%s\n",cun.sun_path,rbuf);strcat(rbuf,"*_*");send(newfd,rbuf,strlen(rbuf),0);printf("发送成功\n");}close(sfd);close(newfd);return 0;
}

流式域套接字客户端
 

#include<myhead.h>
int main(int argc, char *argv[])
{int cfd=socket(AF_UNIX,SOCK_STREAM,0);if(cfd==-1){perror("socket");return -1;}printf("socket success\n");if(access("./linux",F_OK)==0){if(unlink("./linux")!=0){perror("unlink");return -1;}}//绑定ip地址和端口	//填充地址信息结构体struct sockaddr_un cun;cun.sun_family=AF_UNIX;strcpy(cun.sun_path,"./linux");//绑定if(bind(cfd,(struct sockaddr*)&cun,sizeof(cun))==-1){perror("bind");return -1;}struct sockaddr_un sun;sun.sun_family=AF_UNIX;strcpy(sun.sun_path,"./unix");if(connect(cfd,(struct sockaddr*)&sun,sizeof(sun))==-1){perror("connect");return -1;}printf("connect success\n");char wbuf[128]="";while(1){printf("请输入>>>>");fgets(wbuf,sizeof(wbuf),stdin);wbuf[strlen(wbuf)-1]='\0';if(strcmp(wbuf,"quit")==0){break;}send(cfd,wbuf,strlen(wbuf),0);bzero(wbuf,sizeof(wbuf));recv(cfd,wbuf,sizeof(wbuf),0);printf("收到消息为:%s\n",wbuf);}close(cfd);return 0;
}

报式域套接字服务器
 

#include<myhead.h>
int main(int argc, char *argv[])
{//创建套接字int sfd=socket(AF_UNIX,SOCK_DGRAM,0);if(sfd==-1){perror("socket");return -1;}printf("socket success sfd=%d\n",sfd);//判断要绑定的套接字文件是否存在if(access("./unix",F_OK)==0){//说明文件存在,将其删除if(unlink("./unix")!=0){perror("unlink");return -1;}}//绑定ip地址和端口//填充地址信息结构体struct sockaddr_un sun;sun.sun_family=AF_UNIX;strcpy(sun.sun_path,"./unix");//绑定if(bind(sfd,(struct sockaddr*)&sun,sizeof(sun))==-1){perror("bind");return -1;}  printf("bind success\n");//第二个参数->我要记录发送连接方的地址信息结构体struct sockaddr_un cun;socklen_t socklen=sizeof(cun);//数据通信char rbuf[128]="";while(1){bzero(rbuf,sizeof(rbuf));recvfrom(sfd,rbuf,sizeof(rbuf),0,(struct sockaddr*)&cun,&socklen);printf("[%s]:%s\n",cun.sun_path,rbuf);strcat(rbuf,"*_*");if(sendto(sfd,rbuf,sizeof(rbuf),0,(struct sockaddr*)&cun,sizeof(cun))==-1){perror("sendto");return -1;}printf("发送成功\n");}close(sfd);return 0;
}

报式域套接字客户端
 

#include<myhead.h>
int main(int argc, char *argv[])
{int cfd=socket(AF_UNIX,SOCK_DGRAM,0);if(cfd==-1){perror("socket");return -1;}printf("socket success\n");//判断要绑定的套接字文件是否存在if(access("./linux",F_OK)==0){//说明文件存在,将其删除if(unlink("./linux")!=0){perror("unlink");return -1;}}struct sockaddr_un cun;cun.sun_family=AF_UNIX;strcpy(cun.sun_path,"./linux");if(bind(cfd,(struct sockaddr*)&cun,sizeof(cun))==-1){perror("bind");return -1;}struct sockaddr_un sun;sun.sun_family=AF_UNIX;strcpy(sun.sun_path,"./unix");char wbuf[128]="";while(1){printf("请输入>>>>");fgets(wbuf,sizeof(wbuf),stdin);wbuf[strlen(wbuf)-1]=0;sendto(cfd,wbuf,strlen(wbuf),0,(struct sockaddr*)&sun,sizeof(sun));printf("发送成功\n");recvfrom(cfd,wbuf,sizeof(wbuf),0,NULL,NULL);printf("收到服务器消息:%s\n",wbuf);}close(cfd);return 0;
}

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

项目中，如何写 readme.md 文件 | 写项目总结

项目中，如何写 readme.md 文件 | 写项目总结

tips&#xff1a;注意写 1. readme文件&#xff1a;①项目文档&#xff08;项目需求和设计文档、项目系统架构和技术文档、接口文档&#xff09;、②项目结构、③启动项目。具体结构见下文。 2. 项目总结&#xff1a;技术栈、描述、主要工作&#xff01;&#xff01;需求及功…
阅读更多...
MySQL常见故障现象分析及解决办法

MySQL常见故障现象分析及解决办法

一、背景 MySQL作为广泛使用的关系型数据库管理系统&#xff0c;在日常使用中难免会遇到各种故障。本文将通过一个具体的案例&#xff0c;分析MySQL常见的故障现象&#xff0c;并提供相应的解决办法和代码示例。 二、故障现象 某企业使用的MySQL数据库服务器近期出现以下问题…
阅读更多...
FastAPI 是干啥的

FastAPI 是干啥的

FastAPI 是一个现代、快速&#xff08;高性能&#xff09;的 Web 框架&#xff0c;用于构建 API&#xff0c;与 Python 3.6 类型提示一起使用。它基于标准 Python 类型提示&#xff0c;使用 Python 3.6 的类型注解来声明请求参数和返回值的类型&#xff0c;这使得代码既简洁又易…
阅读更多...
递归、搜索与回溯算法——递归

递归、搜索与回溯算法——递归

T04BF &#x1f44b;专栏: 算法|JAVA|MySQL|C语言 &#x1faf5; 小比特 大梦想 此篇文章与大家分享递归,搜索与回溯算法关于递归的专题 如果有不足的或者错误的请您指出! 目录 1.什么时候使用递归2.汉诺塔2.1解析2.2题解 3.合并两个有序链表3.1解析3.2题解 4.翻转链表4.1解析4…
阅读更多...
mysql SQL必知语法

mysql SQL必知语法

文章目录 概要技术细节小结 概要 mysql SQL必知语法 SQL必知语法包括SELECT、FROM、WHERE、GROUP BY、HAVING、ORDER BY等关键字&#xff0c;用于查询和操作数据库中的数据。SELECT用于选择需要查询的列&#xff0c;FROM用于指定数据表&#xff0c;WHERE用于设置查询条件&…
阅读更多...
下载软件时的Ubuntu x86_64-v2、skylake、aarch64版本分别代表什么？

下载软件时的Ubuntu x86_64-v2、skylake、aarch64版本分别代表什么？

Ubuntu-x86_64-v2、Ubuntu-x86_64-skylake和Ubuntu-aarch64都是Ubuntu的不同版本或变种&#xff0c;它们之间的主要区别在于所支持的硬件架构和针对特定硬件的优化。 Ubuntu-x86_64-v2&#xff1a; 这是基于x86_64&#xff08;也称为AMD64或Intel 64&#xff09;架构的Ubuntu版…
阅读更多...
Ubuntu上根据关键字模糊查找指定文件夹或文件

Ubuntu上根据关键字模糊查找指定文件夹或文件

在Ubuntu上根据关键字模糊查找指定文件夹或文件&#xff0c;可以使用以下方法&#xff1a; GNOME 桌面搜索&#xff1a; 使用GNOME桌面的Spotlight式搜索功能&#xff0c;通过按下Super键&#xff08;通常是Windows键&#xff09;并输入关键字&#xff0c;可以搜索文件和文件夹…
阅读更多...
人类连接的桥梁：探索Facebook如何连接世界

人类连接的桥梁：探索Facebook如何连接世界

随着技术的发展和全球化的进程&#xff0c;我们的世界正在变得越来越紧密相连。在这个过程中&#xff0c;社交媒体平台扮演了一个至关重要的角色&#xff0c;为人们提供了一个跨越国界、文化和语言的交流平台。其中&#xff0c;Facebook作为全球最大的社交媒体平台&#xff0c;…
阅读更多...
rancher踩坑日志：prometheus访问kubelet 10250端口提示鉴权失败

rancher踩坑日志：prometheus访问kubelet 10250端口提示鉴权失败

该原因是因为kubectl禁止了非授权用户访问10250端口来获取node的数据。 解决思路&#xff1a; 添加prometheus访问kubelet时带上证书进行验证匹配 --> 由于我的prometheus是rancher安装的&#xff0c;不知道要怎么修改所以研究了一会没研究明白就放弃了。设置prometheus访问…
阅读更多...
Rockchip Android13 Vold（二）：Framework层

Rockchip Android13 Vold（二）：Framework层

目录 前言 1、接收VolumeInfo状态 2、通知VolumeInfo状态变化 3、创建StorageVolume
阅读更多...
Create2024百度AI开发者大会记录

Create2024百度AI开发者大会记录

去年2023.3.16日百度文心大模型发布&#xff0c;今天2024.4.16日 代码智能体&#xff1a;思考模型代码解释器 思考模型整合提示&#xff0c;输入给代码解释器 代码解释器出结果&#xff0c;返回给思考模型&#xff0c;然后迭代 智能代码助手 baidu Comate 多模型推理 种子模型…
阅读更多...
JavaScript入门--循环

JavaScript入门--循环

JavaScript入门--循环 一、for循环二、for in语句三、break语句四、continue语句五、while循环六、do-while语句一、for循环 先来看一个循环案例： for (i = 0; i < 5; i++) {
阅读更多...
如何批量删除不包含指定关键字的数据行？

如何批量删除不包含指定关键字的数据行？

一、需求 有一个报名表&#xff0c;包括年龄&#xff0c;地址&#xff0c;特长等数据&#xff0c;现在想删除特长一列中不含“篮球”这个关键字行&#xff0c;可以使用这些办法。 二、删除数据 方法1.自动筛选&#xff0c; 1.1 选中数据后&#xff0c;点击数据选项卡&#…
阅读更多...
java 中公有类的产量如何定义

java 中公有类的产量如何定义

在Java编程语言中，“公有类”和“产量”的概念并不直接相关联。 “公有类”（public class）是指在Java中，可以被任何其他类访问的类。如果你想要定义一个公有类，你将在类声明处使用 public 关键字： // 这是一个公有类的例子 public class MyClass {// 类体部分，包含字段…
阅读更多...
微信人脉扩张！多号批量自动加好友，你get到了吗？

微信人脉扩张！多号批量自动加好友，你get到了吗？

微信是我们在拓展社交圈和寻找商业机会时&#xff0c;与更多的人建立联系的重要渠道。但是&#xff0c;手动一个个添加好友显然费时费力&#xff0c;这时候&#xff0c;微信管理系统的批量自动加好友功能就成为了微信人脉扩张的神器。 通过微信管理系统&#xff0c;我们可以轻…
阅读更多...
Java中如何提取视频文件的缩略图

Java中如何提取视频文件的缩略图

在Java中&#xff0c;可以使用FFmpeg库来提取视频文件的缩略图。以下是一种使用FFmpeg的方法来提取视频缩略图的示例代码&#xff1a; import java.io.File; import java.io.IOException;public class VideoThumbnailExtractor {public static void main(String[] args) {Stri…
阅读更多...
IO流-打印流

IO流-打印流

简介 为打印而生的IO流 打印流的继承体系 优点 高效方便打印的是啥就是啥&#xff0c;不会瞎转&#xff08;不会把97转成a&#xff09; PrintStream try(PrintStream ps new PrintStream("test7.txt", "UTF-8"); ){ps.println(97); // 打印流的优点就是原…
阅读更多...
三个晚上！给干废了！MINI2440 挂载 NFS

三个晚上！给干废了！MINI2440 挂载 NFS

虚拟机执行&#xff1a;sudo ifconfig tap0 10.10.10.1 up qemu 开发板&#xff1a; set bootargs noinitrd root/dev/nfs rw nfsroot10.10.10.1:/nfsroot ip10.10.10.10:10.10.10.1 ::255.255.255.0 consolettySAC0,115200 Hit any key to stop autoboot: 0 MINI2440 # set…
阅读更多...
mybatisplus 使用group by 和 count 报 java.lang.NumberFormatException

mybatisplus 使用group by 和 count 报 java.lang.NumberFormatException

报错信息&#xff1a; java.lang.NumberFormatException: For input string: "Critical" at java.base/java.lang.NumberFormatException.forInputString(NumberFormatException.java:67) ~[na:na] resultMap如下&#xff1a; <resultMap id"severityNumRes…
阅读更多...
前后端分离vue.js+nodejs新闻文章发布论坛网站系统44x94

前后端分离vue.js+nodejs新闻文章发布论坛网站系统44x94

Vue&#xff1a; Vue是一套用于构建用户界面的渐进式框架。与其它大型框架不同的是&#xff0c;Vue 被设计为可以自底向上逐层应用。Vue 的核心库只关注视图层&#xff0c;不仅易于上手&#xff0c;还便于与第三方库或既有项目整合。另一方面&#xff0c;当与现代化的工具链以及…
阅读更多...
最新文章

Copyright @ 2022~2023