3.19网络编程

2024-03-20 13:36
文章标签 编程 网络 3.19

本文主要是介绍3.19网络编程，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

select实现的TCP并发服务器

#include <myhead.h>
#define SER_IP "192.168.141.134" 
#define SER_PORT 8888           
int main(int argc, const char *argv[])
{// 1、创建一个套接字int sfd = -1;sfd = socket(AF_INET, SOCK_STREAM, 0);if (sfd == -1){perror("socket error");return -1;}printf("%d success sfd = %d\n", __LINE__, sfd); // 3// 端口号快速重用int reuse = 1;if (setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) == -1){perror("setsockopt error");return -1;}// 2、绑定IP地址和端口号// 2.1填充地址信息结构体struct sockaddr_in sin;sin.sin_family = AF_INET;                sin.sin_port = htons(SER_PORT);          sin.sin_addr.s_addr = inet_addr(SER_IP); // 2.2 绑定if (bind(sfd, (struct sockaddr *)&sin, sizeof(sin)) == -1){perror("bind error");return -1;}printf("%d  bind success\n", __LINE__);// 3、将套接字设置成被动监听状态if (listen(sfd, 128) == -1){perror("listen error");return -1;}printf("%d  listen success\n", __LINE__);// 4、阻塞等待客户端的链接请求int newfd = -1;// 定义结构体变量接收对方地址信息结构体struct sockaddr_in cin;          // 用于接收客户端地址信息结构体socklen_t addrlen = sizeof(cin); // 用于接收客户端结构体的大小char sbuf[128] = "";             // 服务器输入数据内容// 11、定义一个文件描述符集合fd_set readfds, tempfds;// 22、将集合清空FD_ZERO(&readfds);// 33、将要被检测的文件描述符放入集合FD_SET(0, &readfds);FD_SET(sfd, &readfds);int maxfd = sfd;                  // 最大文件描述符struct sockaddr_in cin_arr[1024]; // 结构体数组while (1){tempfds = readfds;int res = select(maxfd + 1, &tempfds, NULL, NULL, NULL); if (res == -1){perror("select error");return -1;}else if (res == 0){printf("time out\n");return -1;}// 当程序执行到此，说明集合中有事件产生，此时集合中只剩下本次触发事件的文件描述符for (int i = 0; i <= maxfd; i++){// 如果不是触发事件的文件描述符，直接跳过if (!FD_ISSET(i, &tempfds)){continue;}// 程序执行至此，表示当前i这个文件描述符触发了事件// 判断sfd是否触发事件if (i == sfd){if ((newfd = accept(sfd, (struct sockaddr *)&cin, &addrlen)) == -1){perror("accept error");return -1;}printf("[%s  %d]:发来连接请求\n", inet_ntoa(cin.sin_addr), ntohs(cin.sin_port));// 将客户端地址信息结构体放入数组容器中cin_arr[newfd] = cin;// 将newfd放入readfds容器中页参与检测FD_SET(newfd, &readfds);// 可能要更新maxfdif (newfd > maxfd){maxfd = newfd;}}else// 判断0号文件描述符是否触发事件if (0 == i){fgets(sbuf, sizeof(sbuf), stdin); // 从终端输入数据sbuf[strlen(sbuf) - 1] = 0;printf("触发了键盘输入事件:%s\n", sbuf);// 将该消息发送给所有客户端for (int i = 4; i <= maxfd; i++){send(i, sbuf, sizeof(sbuf), 0);}printf("发送成功\n");}else{// 说明某个客户端发来消息了,遍历所有的客户端，判断是哪个发来的消息// 5、收发数据char rbuf[128] = ""; // 用于接收客户发发来的数据// 将容器清空bzero(rbuf, sizeof(rbuf)); // memset(rbuf, 0, sizeof(rbuf));// 从套接字中读取数据‘int res = recv(i, rbuf, sizeof(rbuf) - 1, 0);if (res == 0){printf("客户端已经下线\n");// 关闭跟客户端通信的套接字close(i);// 将当前文件描述符移除容器FD_CLR(i, &readfds);// 可能要更新maxfdfor (int k = maxfd; k >= sfd; k--){if (FD_ISSET(k, &readfds)){maxfd = k;break;}}continue;}printf("[%s  %d]: %s\n", inet_ntoa(cin_arr[i].sin_addr), ntohs(cin_arr[i].sin_port), rbuf);// 加个笑脸再回回去strcat(rbuf, "*_*");send(i, rbuf, strlen(rbuf), 0);printf("发送成功\n");}}}// 6、关闭服务器close(sfd);return 0;
}

poll实现的TCP客户端

#include <myhead.h>
#define SER_PORT 8888			 // 服务器端口号
#define SER_IP "192.168.141.134" // 服务器IP
#define CLI_PORT 9999			 // 客户端口号
#define CLI_IP "192.168.141.134" // 客户端IP
int main(int argc, const char *argv[])
{//1、创建用于连接的客户端套接字int cfd = socket(AF_INET, SOCK_STREAM, 0);if(cfd == -1){perror("socket error");return -1;}printf("socket success cfd = %d\n", cfd);        //3//设置端口号快速重用int reuse = 1;if(setsockopt(cfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) ==-1){perror("setsockopt error");return -1;}printf("端口号快速重用成功\n");//2、绑定端口号和ip地址(非必须)//2.1 填充客户端地址信息结构体struct sockaddr_in cin;cin.sin_family = AF_INET;cin.sin_port = htons(CLI_PORT);cin.sin_addr.s_addr = inet_addr(CLI_IP);//2.2 绑定端口号和IPif(bind(cfd, (struct sockaddr*)&cin, sizeof(cin)) == -1){perror("bind error");return -1;}printf("bind success\n");//3、连接服务器//3.1 填充要连接服务器的地址信息结构体struct sockaddr_in sin;sin.sin_family = AF_INET;      //地址族sin.sin_port = htons(SER_PORT);   //服务器端口号sin.sin_addr.s_addr = inet_addr(SER_IP);    //服务器的IP地址//3.2 连接服务器if(connect(cfd, (struct sockaddr*)&sin, sizeof(sin)) == -1){perror("connect error");return -1;}printf("连接成功!\n");//使用poll完成0号文件描述符和cfd文件描述符的多路复用//11、准备文件描述符容器struct pollfd pfds[2];pfds[0].fd = 0; //文件描述符pfds[0].events = POLLIN;    //检测读事件pfds[1].fd = cfd;       //文件描述符pfds[1].events = POLLIN;    //检测读事件//4、收发数据char wbuf[128] = "";while(1){int res = poll(pfds, 2, -1);        //阻塞检测集合中是否有事件产生if(res == -1){perror("poll error");return -1;}else if(res == 0){printf("time out\n");return -1;}//程序执行至此，说明检测的文件描述符集合中有事件产生//判断是否为0号文件描述符产生事件if(pfds[0].revents == POLLIN){fgets(wbuf, sizeof(wbuf), stdin);    //从终端上获取一个字符串wbuf[strlen(wbuf)-1] = 0;   //判断输入的字符串值if(strcmp(wbuf, "quit") ==0){break;}//将数据发送给服务器send(cfd, wbuf, strlen(wbuf), 0);}//判断释放为cfd文件描述符中产生事件if(pfds[1].revents == POLLIN){//将字符数组清空bzero(wbuf, sizeof(wbuf));recv(cfd, wbuf, sizeof(wbuf)-1, 0);printf("收到服务器消息为：%s\n", wbuf);}}//5、关闭套接字close(cfd);return 0;
}

select实现的TCP客户端

#include <myhead.h>
#define SER_IP "192.168.141.134" // 服务器IP
#define SER_PORT 8888            // 服务器端口号
#define CLI_IP "192.168.141.134"
#define CLI_PORT 9999
int main(int argc, const char *argv[])
{// 1.创建套接字int cfd = socket(AF_INET, SOCK_STREAM, 0);if (cfd == -1){perror("socket error");return -1;}printf("cfd=%d\n", cfd);/*//2.绑定（随意）struct sockaddr_in cin;cin.sin_family=AF_INET;cin.sin_port=htons(CLI_PORT);cin.sin_addr.s_addr=inet_addr(CLI_IP);if(bind(cfd,(struct sockaddr*)&cin,sizeof(cin))==-1){perror("bind error");return -1;}printf("bind success %d\n",__LINE__);*/// 3.连接服务器// 3.1填充地址信息结构体struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(SER_PORT);sin.sin_addr.s_addr = inet_addr(SER_IP);// 3.2链接if (connect(cfd, (struct sockaddr *)&sin, sizeof(sin)) == -1){perror("connect error");return -1;}printf("链接成功\n");// 准备文件描述符容器fd_set readfds, tempfds;// 清空容器FD_ZERO(&readfds);// 将要监测的文件描述符放入集合FD_SET(0, &readfds);FD_SET(cfd, &readfds);// 4.收发数据char buf[128] = "";while (1){tempfds = readfds;// 使用select函数对容器中的文件描述符进行赋值int res = select(cfd + 1, &tempfds, 0, 0, 0);if (res == -1){perror("select error");return -1;}else if (res == 0){printf("time out\n");return -1;}// 判断是否是文件描述符触发事件if (FD_ISSET(0, &tempfds)){bzero(buf, sizeof(buf));fgets(buf, sizeof(buf), stdin);buf[strlen(buf) - 1] = 0;// 发送给服务器send(cfd, buf, sizeof(buf), 0);printf("发送成功\n");if (strcmp(buf, "quit") == 0){break;}}else if (FD_ISSET(cfd, &tempfds)){// 接收服务器发来的消息recv(cfd, buf, sizeof(buf), 0);printf("[%s  %d]:%s\n", SER_IP, SER_PORT, buf);}}// 5.关闭套接字close(cfd);return 0;
}

poll实现的TCP并发服务器

#include <myhead.h>
#define SER_PORT 8888
#define SER_IP "192.168.141.134"
int main(int argc, const char *argv[])
{//1.创建套接字int sfd  = socket(AF_INET,SOCK_STREAM,0);if(sfd==-1){perror("socket error");return -1;}printf("sfd=%d\n",sfd);//将端口号快速重用函数int reuse =1;if(setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))==-1){perror("setsockopt error");return -1;}printf("端口号快速重用成功\n");//2.给套接字绑定IP和端口号//2.1填充地址信息结构体struct sockaddr_in sin;sin.sin_family=AF_INET;sin.sin_port=htons(SER_PORT);sin.sin_addr.s_addr=inet_addr(SER_IP);//2.2绑定if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))==-1){perror("bind error");return -1;}printf("bind success %d\n",__LINE__);//3.将套接字设置成监听状态if(listen(sfd,128)==-1){perror("listen error");return -1;}printf("listen success %d\n",__LINE__);//4.阻塞等待客户端的链接请求//4.1定义容器接收客户端的地址信息struct sockaddr_in cin;   //用于接收地址信息socklen_t socklen = sizeof(cin);  //用于接收地址信息的大小int newfd=-1;//定义一个等待文件描述符结构体数组struct pollfd pfd[10];//填充要等待的文件描述符及事件pfd[0].fd=0;pfd[0].events=POLLIN;pfd[1].fd=sfd;pfd[1].events=POLLIN;int client_num=0;//定义一个地址信息结构体数组，每一个元素对应一个客户端文件描述符struct sockaddr_in cin_arr[1024];while(1){//阻塞监测集合中是否有事件产生int res=poll(pfd,client_num+2,-1);if(res==-1){perror("poll error");return -1;}else if(res==0){printf("time out\n");return -1;}if(pfd[0].revents==POLLIN){char wbuf[128]="";scanf("%s",wbuf);printf("触发了终端输入事件---\n");if(strcmp(wbuf,"quit")==0){break;}//将消息发送给所有客户端for (int i = 4; i <= client_num+3; i++){send(i,wbuf,sizeof(wbuf),0);}}if(pfd[1].revents==POLLIN){//接受客户端的链接if((newfd =accept(sfd,(struct sockaddr*)&cin,&socklen))==-1){perror("accept error");return -1;}printf("您有一个新的客户端[%s:%d]发来连接请求 success %s %s %d\n",\inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),__FILE__,__func__,__LINE__);client_num++;pfd[1+client_num].fd=newfd;pfd[1+client_num].events=POLLIN;printf("客户端连接成功\n");}for(int cli=0;cli<client_num;cli++){if(pfd[cli+2].revents==POLLIN){//跟客户端进行消息通信char buf[128]="";bzero(buf,sizeof(buf));int res=recv(pfd[cli+2].fd,buf,sizeof(buf),0);if(res==0){puts("客户端已经下线");close(pfd[cli+2].fd);client_num--;continue;}printf("收到消息：%s\n",buf);//给客户端发送消息strcat(buf,"=-=");send(pfd[cli+2].fd,buf,sizeof(buf),0);printf("发送成功\n");}}}//6.关闭套接字close(sfd);return 0;
}

 

这篇关于3.19网络编程的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


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

相关文章

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