linux——两个客户端之间实现聊天（TCP、单线程）

两个客户端实现聊天功能，那么服务器作转发信息的作用，客户端A先将信息发送到服务器，在由服务器将信息发送到客户端B，客户端B也是一样。客户端与服务器都应该有两个执行流，服务器的一个执行流不断的接收客户端A的信息并将其发送给客户端B，另一个执行流不断地接收客户端B的信息并将其发送给客户端A，而客户端的两个执行流分别做读信息操作和写信息操作。这是我们的常规思维，如果用单线程的方法有该如何做呢？
socket称之为网络套接字，但其实也是一个文件描述符，这个文件描述符被默认为阻塞状态，accept函数如果没有客户端与之相连就一直阻塞在这里，程序不会在执行下去，read函数也是一样，如果从缓冲区中没有读到数据就会被阻塞，直到读到数据时才能退出这个函数。如下图，clientA向server发送一个data1,server读到了这个data1后在发送给clientB，如果clientA并没有发送信息，此时read函数就会阻塞，函数卡在read函数这，那么此时如果clientB发来一个data2，server根本读不到，但是这个data2已经放在了缓冲区里，当clientA发来消息后，read函数便不再阻塞，并将这条消息发送给clientB，此时server才能从缓冲区里读到data2。
在这里插入图片描述
既然是默认为阻塞，那么也可以设置为非阻塞，在非阻塞状态下，read函数读到数据就返回所读取数据的个数，没有读到数据就立即返回0，此时便不会出现无法发送数据或者发完数据后才接收到上一条信息。
我们可用如下方法设置阻塞

 #include <unistd.h>
#include <fcntl.h>
int flags=fcntl(sockid,F_GETFL,0);
fcntl(sockid,F_SETFL,flags|O_NONBLOCK);

sockid表示套接字，也是文件描述符，想要设置谁非阻塞就填谁的套接字

设置非阻塞方法：

 #include <unistd.h>
#include <fcntl.h>
int flags=fcntl(sockid,F_GETFL,0);
fcntl(sockid,F_SETFL,flags&~O_NONBLOCK);

服务器

#include <stdio.h>
#include <time.h>
#include <fcntl.h>
#include <sys/select.h>
#include <string.h>
#include <unistd.h>
#include <malloc.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>#define clientA 0
#define clientB 1
#define max_client 2  //最大连接客户端数量typedef struct clientNew
{char     *addr;int      sockid;uint16_t port;
}client_new;//存放所连客户端的地址和socket等信息void client_new_init(client_new c_new[])
{int i=0;for(;i<max_client;i++){c_new[i].addr=NULL;c_new[i].sockid=0;c_new[i].port=0;}
}void setsocket_noblock(client_new c_new[])
{//设置所连的两个客户端socket非阻塞int flags=fcntl(c_new[clientA].sockid,F_GETFL,0);fcntl(c_new[clientA].sockid,F_SETFL,flags|O_NONBLOCK);flags=fcntl(c_new[clientB].sockid,F_GETFL,0);fcntl(c_new[clientB].sockid,F_SETFL,flags|O_NONBLOCK);
}void  read_clientA(client_new c_new[],int *flag)
{char receive[100]={0};if(read(c_new[clientA].sockid,receive,sizeof(receive))>0)//读取A客户端信息，如果没读到数据就返回0{time_t timep;//获取A客户端发来信息的时间time(&timep);if(strcmp(receive,"quit\n")==0)//如果A客户端发来quit，先把quit发给B客户端，在结束聊天{printf("ip=%s %s 用户发起退出\n",c_new[clientA].addr,ctime(&timep));write(c_new[clientB].sockid,receive,strlen(receive));usleep(1000);*flag=0;return ;}printf("ip=%s %s: ",c_new[clientA].addr,ctime(&timep));printf("%s\n",receive);write(c_new[clientB].sockid,receive,strlen(receive));//将A客户端发来的信息转发给B客户端}
}void  read_clientB(client_new c_new[],int *flag)
{char receive[100]={0};if(read(c_new[clientB].sockid,receive,sizeof(receive))>0)//读取B客户端信息，如果没读到数据就返回0{time_t timep;time(&timep);if(strcmp(receive,"quit\n")==0){printf("ip=%s %s 用户发起退出\n",c_new[clientA].addr,ctime(&timep));write(c_new[clientA].sockid,receive,strlen(receive));usleep(1000);*flag=0;return ;}printf("ip=%s: %s:",c_new[clientB].addr,ctime(&timep));printf("%s\n",receive);write(c_new[clientA].sockid,receive,strlen(receive));//将B客户端发来的信息转发给A客户端}
}void  communication(client_new c_new[],int server_sockid)
{	int flag=1;while(flag){read_clientA(c_new,&flag);read_clientB(c_new,&flag);}close(server_sockid);
}int internet(client_new c_new[])
{struct sockaddr_in sockaddr;sockaddr.sin_family=AF_INET;sockaddr.sin_port=htons(5188);sockaddr.sin_addr.s_addr=htonl(INADDR_ANY);int server_sockid=socket(AF_INET,SOCK_STREAM,0);const int on=1;if(setsockopt(server_sockid,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on))<0)//设置端口可重复利用{printf("setsockopt\n");return 0;}if(bind(server_sockid,(struct sockaddr *)&sockaddr,sizeof(sockaddr))<0){printf("bind\n");return 0;}if(listen(server_sockid,SOMAXCONN)<0){printf("listen\n");return 0;}struct sockaddr_in other_sock_addr;socklen_t other_sock_addr_len=sizeof(other_sock_addr);int j=0;while(j!=max_client)//连接两个客户端{int sockid_client=accept(server_sockid,(struct sockaddr *)&other_sock_addr,&other_sock_addr_len);c_new[j].sockid =sockid_client;c_new[j].addr=inet_ntoa(other_sock_addr.sin_addr);c_new[j].port=ntohs(other_sock_addr.sin_port);printf("ip=%s,port=%d  已连接\n",c_new[j].addr,c_new[j].port);j++;}return server_sockid;
}int main()
{client_new c_new[max_client];		//定义结构体数组client_new_init(c_new);				//初始化结构体数组int server_sockid=internet(c_new);	//网络连接并返回服务器socketsetsocket_noblock(c_new);			//设置所连的两个客户端socket非阻塞communication(c_new,server_sockid);	//通信return 0;
}

客户端

#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <fcntl.h>
#include <sys/stat.h>void do_read(int sockid,int *flag)
{char receive[100]={0};int r_size=read(sockid,receive,sizeof(receive));if(strcmp(receive,"quit\n")==0){printf("对方已结束聊天\n");*flag=0;return;}if(r_size>0){printf("\t\t\t");fputs(receive,stdout);}
}void do_write(int sockid,int *flag)
{char send[100]={0};int w_size=read(0,send,sizeof(send));if(strcmp(send,"quit\n")==0){printf("您已下线\n");write(sockid,send,sizeof(send));*flag=0;return;}if(w_size>0){write(sockid,send,sizeof(send));memset(send,0,strlen(send));}
}int internet()
{int  flag=1;struct sockaddr_in addr;addr.sin_family=AF_INET;addr.sin_port=htons(5188);addr.sin_addr.s_addr=inet_addr("127.0.0.1");int sockid=socket(AF_INET,SOCK_STREAM,0);socklen_t addrlen=sizeof(addr);if(connect(sockid,(struct sockaddr *)&addr,addrlen)<0){printf("connect\n");return 0;}int flags=fcntl(sockid,F_GETFL,0);fcntl(sockid,F_SETFL,flags|O_NONBLOCK);flags=fcntl(0,F_GETFL,0);fcntl(0,F_SETFL,flags|O_NONBLOCK);while(flag){do_read(sockid,&flag);do_write(sockid,&flag);}close(sockid);return 0;
}int main()
{internet();return 0;
}

以上程序只能实现局域网内通信。实现跨局域网聊天请点击

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

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

相关文章

zabbix邮件通知，短信通知配置详解

zabbix邮件通知，短信通知配置详解

一、使用邮件发送报警1、前提条件是zabbix我们已经安装完成2、在官网我们下载msmtp的文件http://sourceforge.net/projects/msmtp/files/msmtp/1.4.32/msmtp-1.4.32.tar.bz2/download tar xf msmtp-1.4.32.tar.bz2 cd msmtp-1.4.32 ./configure--prefix/usr/local/msmtp make m…
阅读更多...
linux——客户端服务器文件传输

linux——客户端服务器文件传输

实现文件传输并不难&#xff0c;只需用fopen、fread、fwrite、fclose这几个函数对文件操作即可。文本文件就不说了&#xff0c;我们就已下图为例。 我们先来看看这个图片文件里装的是什么&#xff0c;我们以notpad打开这个图片&#xff0c;结果如下&#xff0c;是一堆乱码。 …
阅读更多...
第 1-2 课：你不知道的基础数据类型和包装类 + 面试题

第 1-2 课：你不知道的基础数据类型和包装类 + 面试题

基本数据类型 Java 基础数据按类型可以分为四大类&#xff1a;布尔型、整数型、浮点型、字符型&#xff0c;这四大类包含 8 种基础数据类型。 布尔型&#xff1a;boolean整数型&#xff1a;byte、short、int、long浮点型&#xff1a;float、double字符型&#xff1a;char 八种…
阅读更多...
php中socket的使用

php中socket的使用

一、开启socket phpinfo();查看是否开启了socket扩展&#xff0c;否则在php.ini中开启。 二、服务器端代码的写法 <?php error_reporting(E_ALL); set_time_limit(0); //ob_implicit_flush();$address 127.0.0.1; $port 10005; //创建端口 if( ($sock socket_create(AF_…
阅读更多...
通过xss所引起的信息泄露，防不胜防！

通过xss所引起的信息泄露，防不胜防！

话不多说直接上&#xff1a; 信息搜集,通过google语法 site:"*.redacted.com"优化一下: site:"*.redacted.com" -www -blog -mail之后&#xff0c;利用subfinder、assetfinder和masass等被动枚举工具收集与目标相关的子域列表&#xff0c;并将它们保存在…
阅读更多...
二叉树的前序、中序、后续、层序遍历（包含递归与非递归）

二叉树的前序、中序、后续、层序遍历（包含递归与非递归）

递归形式 递归形式遍历比较简单&#xff0c;不做详细论述。 前序遍历 void Preorder(treenode* root) //前序 {if (root ! NULL){printf("%c", root->data);Preorder(root->left);Preorder(root->right);}中序遍历 } void Inorder(treenode* root) …
阅读更多...
单调递增子序列

单调递增子序列

单调子序列包含有单调递增子序列和递减子序列&#xff0c;不失一般性&#xff0c;这里只讨论单调递增子序列。首先&#xff0c;从定义上明确我们的问题。给定序列a1, a2, …, an&#xff0c;如果存在满足下列条件的子序列 ai1<ai2<…<aim, (其中i1<i2<…<im)…
阅读更多...
51单片机常用功能及相关内容

51单片机常用功能及相关内容

一、基本概念&#xff1a; 1、引脚 图1.1 这里只介绍常用及主要的引脚。 I/O口引脚&#xff1a;P0、P1、P2、P3 P0口&#xff1a;39脚~32脚&#xff0c;双向8位三态I/O口&#xff0c;每个口可独立控制&#xff0c;但内部无上拉电阻&#xff0c;为高阻态&#xff0c;故不能正常…
阅读更多...
No monitoring data is available

No monitoring data is available

No monitoring data is available because monitoring is not enabled for this deployment share...注解&#xff1a;没有监测数据是可用的。报错具体信息如下&#xff1a;Assembly: mscorlib Assembly Version: 2.0.0.0 File Version: 2.0.50727.5420 (Win7SP1.050727-5400…
阅读更多...
Unity查安卓Native Crash的方法，定位SO报错函数

Unity查安卓Native Crash的方法，定位SO报错函数

需要用到两个工具Il2CppDumper和IDA_Pro&#xff0c;网上可以下到对应的软件 可以看到报错的位置是libil2cpp.so 0000000000AFF820 接下来要做的事情就是找到0000000000AFF820对应的函数是哪个 解包 Il2CppDumper解析so文件和符号表&#xff0c;查看对应的函数表 把apk后缀…
阅读更多...
WebApi系列~自主宿主HttpSelfHost的实现

WebApi系列~自主宿主HttpSelfHost的实现

回到目录 宿主一词我们不会陌生&#xff0c;它可以看作是一个基础设施&#xff0c;它为一些服务和功能提供最底层的支持&#xff0c;如你的web应用程序可以运行在iis或者apache上&#xff0c;而这两个东西就是web应用程序的宿主&#xff0c;而今天说的自主宿主SelfHost就是说&a…
阅读更多...
linux——进程（创建、终止、等待、替换）

linux——进程（创建、终止、等待、替换）

进程的基本操作 概念 程序运行的一个实例&#xff0c;其占有一定的空间。 查询某一进程当前情况 ps aux | grep 进程名终止进程 kill -9 pid&#xff1b; //pid指需要终止的进程pid创建 pid_t fork();该函数有两个返回值&#xff0c;对于子进程其返回的是0&#xf…
阅读更多...
第 3-1 课：集合详解（上） + 面试题

第 3-1 课：集合详解（上） + 面试题

先来看看集合的继承关系图，如下图所示： 其中： 外框为虚线的表示接口，边框为实线的表示类；箭头为虚线的表示实现了接口，箭头为实线的表示继承了类。为了方便理解，我隐藏了一些与本文内容无关的信息，隐藏的这些内容会在后面的章节中进行详细地介绍。 从图中可以看出，集…
阅读更多...
CCNA 学习笔记(四)--路由协议（RIP）

CCNA 学习笔记(四)--路由协议（RIP）

现在我们先复习下&#xff0c;什么是路由&#xff1f;答&#xff1a;当路由器&#xff08;或者其它三层设备&#xff09;收到一个IP数据包时&#xff0c;会查看数据包的IP头部中的目的IP地址&#xff0c;并在路由表中进行查找&#xff0c;在匹配到最优路由后&#xff0c;将数据…
阅读更多...
linux——进程间通信(管道)

linux——进程间通信(管道)

概念 进程间通信是指子进程与父进程间的通信&#xff0c;一般用作父进程对子进程的控制或者子进程将其动向告诉父进程&#xff0c;由于进程是一个程序执行的实例&#xff0c;进程之间本身是无法进行通信的&#xff0c;故而运用一种管道将二者联系起来。当然管道并不只限于在父子…
阅读更多...
第 3-2 课：集合详解（下） + 面试题

第 3-2 课：集合详解（下） + 面试题

集合有两个大接口：Collection 和 Map，本文重点来讲解集合中另一个常用的集合类型 Map。 以下是 Map 的继承关系图： Map 简介 Map 常用的实现类如下： Hashtable：Java 早期提供的一个哈希表实现，它是线程安全的，不支持 null 键和值，因为它的性能不如 ConcurrentHashMap…
阅读更多...
第 4-1 课：BIO、NIO、AIO 详解 + 面试题

第 4-1 课：BIO、NIO、AIO 详解 + 面试题

IO 介绍 IO 是 Input/Output 的缩写，它是基于流模型实现的，比如操作文件时使用输入流和输出流来写入和读取文件等。 IO 分类 传统的 IO，按照流类型我们可以分为： 字符流字节流其中，字符流包括 Reader、Writer；字节流包括 InputStream、OutputStream。传统 IO 的类关系…
阅读更多...
带头节点循环链表实现队列

带头节点循环链表实现队列

队列的特征就是“先入先出”&#xff0c;入队时在链表的尾部插入数据&#xff0c;出队时删除掉头节点后面的节点&#xff0c;需要一个尾指针&#xff0c;始终指向链表的尾部&#xff08;新加进来的节点&#xff09;。具体请看原理图&#xff1a; 代码实现 #include <stdio…
阅读更多...
第 3-4 课：数据结构——队列详解 + 面试题

第 3-4 课：数据结构——队列详解 + 面试题

队列（Queue）：与栈相对的一种数据结构， 集合（Collection）的一个子类。队列允许在一端进行插入操作，而在另一端进行删除操作的线性表，栈的特点是后进先出，而队列的特点是先进先出。队列的用处很大，比如实现消息队列。 Queue 类关系图，如下图所示： 注：为了让读者更直…
阅读更多...
GB/T 17710-1999 PHP生成校验码

GB/T 17710-1999 PHP生成校验码

校验码算法描述如下&#xff1a;详细&#xff1a;http://wenku.baidu.com/link?urlCDvNJ1sLYOPzbbxjEy5R-oME95RlfTCUU5-I5M0bqUt0I32b0Xd0EKmI-HiFQHhY8OcB6ERTml7pUwXFseLl8GGvkuc7w0V2sFDxi2H0XGC本例子以16位编号为例子&#xff0c;用PHP予以实现&#xff0c;代码如下&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023