博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Socket网络编程--聊天程序(8)
阅读量:6986 次
发布时间:2019-06-27

本文共 4700 字,大约阅读时间需要 15 分钟。

  上一节已经完成了对用户的身份验证了,既然有了验证,那么接下来就能对不同的客户端进行区分了,所以这一节讲实现私聊功能。就是通过服务器对客户端的数据进行转发到特定的用户上,

  实现私聊功能的聊天程序

  实现的技术细节是:对客户端发送的数据增加一个标识头,由于我们处理的是纯文本,所以为了讲解的方便就把标识头加到聊天信息的前面,然后在服务器中判断。如果是要在做成产品的话,因为要考虑传送纯文本,图片,文件,特定的结构体等等其他非纯文本信息,那么我们可以对一次聊天信息,发送两次数据,第一次用TCP发送一个结构体,该结构体包含接下来要接收的信息的格式,大小等信息,然后第二次就发送真正的数据块。

  关于第二次发送为什么要用UDP呢?这个是学腾讯qq的,因为标识结构体比较小,而且是必须要有的(为什么?)所以使用TCP,而信息那一部分,往往是数据比较大的,都用tcp传的话,会占用更多的资源。所以我们聊天的时候,有时候会出现这样一条信息,“由于网络问题,该信息可能发送失败”。想想,如果是tcp传输,那么就只有成功和失败,没有什么可能的问题,注意传文件是两个客户端进行tcp连接的,不然怎么确保正确性呢,哎,其实还是很复杂的。(真的吗?求辟谣!)

  回到我们的程序中来吧,我的处理办法是在服务器里判断第一个单词是不是simple,如果是就读取第二个单词,为用户名,然后根据用户名从fd_C中查找,看fd_C对应fd_A的socket号码,然后根据这个fd号码进行转发,而不是进行群发。(如果要增加什么功能,如传文件的话那么,道理一样,判断第一个单词是不是file,如果是第二个单词是文件名什么的,具体就是这样做的。如果是做有界面的客户端,就可以进行选择要聊天的用户,然后在后台生成simple这个标识号了。就对用户友好一点。)

  好了,到了激动人心的时刻了,下面是代码讲解。

  client.c 基本不变

  server.c 

  ... 17 #include 
//用于mysql连接  ... 24 25 struct user 26 {    ... 29 }; 30 31 int MAX(int a,int b)    ... 37 38 void print_time(char * ch,time_t *now) 39 {    ... 43 } 44 45 46 int mysql_check_login(struct user su) 47 {    ... 91 return 0; 92 } 93 94 //根据用户名返回该用户名在fd_A中的位置 95 //fd=-1,表示没有该用户 //fd>0 正常返回 96 int fd_ctoa(char fd_C[][32],char *ch) 97 { 98 int i,j; 99 int fd=-1;100 for(i=0;i
=0)//表示找到对应的用户名296 {297 strcpy(sendBuf,fd_C[i]);298 strcat(sendBuf," 对您私聊 ");299 print_time(ch,&now);300 strcat(sendBuf,ch);//加个时间戳301 strcat(sendBuf,"\t\t");302 strcat(sendBuf,&recvBuf[j]);303 //sendSize=send(fd_A[fd],&recvBuf[j],strlen(recvBuf)-j,0);304 sendSize=send(fd_A[fd],sendBuf,strlen(sendBuf),0);//发往指定的客户端305 }306 else307 {308 strcpy(ch,"私聊信息发送失败,可能是没有该用户");309 sendSize=send(fd_A[i],ch,strlen(ch),0);310 311 }312 }313 else314 {315 strcpy(ch,"私聊信息发送失败,可能是没有 # 符号");316 sendSize=send(fd_A[i],ch,strlen(ch),0);317 318 }319 break;320 }321 else322 {323 }324 //其他else就是其他命令了,为了方便就不支持其他命令了325 ... 352 }353 }354 }355 break;356 }//end-switch357 }//end-while(1)358 return 0;359 }

   照例给个运行时的截图,提提神。

  好了,我们已经完成群聊和私聊的功能了,作为一个聊天程序实现这两个基本功能也就差不多啦。

  一点小小的补充:

//上一节忘了说mysql怎么设置开机启动了,指令如下,root用户执行chkconfig mysqld onservice mysqld start

  另一个知识点的补充,也是今天才注意到的。以前我们每登陆一个客户端都会分配一个文件描述符fd,而服务器中对每个连接产生的fd号是从3开始,连一个就加一个。而现在分配的ID(fd)号是从4开始的不说,还每次增加2。这就奇怪了。

1 [myuser@localhost client-server]$ ./server ser 2 username:ser 3 Success to establish a socket... 4 Success to bind the socket... 5 Success to accpet a connection request... 6 >>>>>> 127.0.0.1:54880 join in! ID(fd):4 7 加入的时间是:06:39:04 8  9 客户端发来的用户名是:user3,密码:12345610 查询的sql:select * from clients where username="user3" and password="123456";11 验证成功!12 Success to accpet a connection request...13 >>>>>> 127.0.0.1:54881 join in! ID(fd):614 加入的时间是:06:39:0415 16 客户端发来的用户名是:user1,密码:12345617 查询的sql:select * from clients where username="user1" and password="123456";18 验证成功!19 Success to accpet a connection request...20 >>>>>> 127.0.0.1:54882 join in! ID(fd):821 加入的时间是:06:39:0422 23 客户端发来的用户名是:user2,密码:12345624 查询的sql:select * from clients where username="user2" and password="123456";25 验证成功!26 数据是:user2 06:39:04

  就是那几个大红色标出来的fd号,连接3个客户端居然是分配到4,6,8。而不是3,4,5

  还好我们的代码每次都增加不多,可以很快就知道为什么?因为有了数据库的连接。

  解释:文件描述符0,1,2这三个默认分配给stdin,stdout,stderr,然后接下来就按需分配了。3号是服务器用于接收客户端请求而创建的sockfd,在一开始就创建了。4号就是client1了,5号就是client1下连接数据库而创建的。由于我们的服务器对每个连接都要有一次访问数据库,所以对应单数的那些fd都是用在数据库连接上了。(什么是文件描述符?自己上网查咯)

 

  一些小总结,其实网络编程还是很有趣的,了解后就会发现很多看起来很叼的技术,其内部底层还是很简单的实现的。就我们常常听到的下面这些技术 防火墙,远程控制,远程SHELL,VPN,内网穿透等等看起来很厉害的技术,都基本上都是使用服务器,实现一对一的转发而已。只不过特定的功能还要靠特定的优化办法(如一些特定的IO操作,算法,安全性等)处理而已,也就是优化处理速度与安全性。如果是一般的使用,那我们其实都是可以实现的。所以别看一个小小的聊天程序的一个私聊功能,其实还是很多高级应用的基础(麻雀虽小,五脏俱全)。(由于本人技术问题,本博只提供思路,想法和一个小小的入门级程序。)

 

  参考资料

  关于标识符包头的详解:  

 

  本文地址: 

转载地址:http://rimpl.baihongyu.com/

你可能感兴趣的文章
查找字符是否存在列表中
查看>>
网络信息安全中最热门的果然是它
查看>>
C# -- 等待异步操作执行完成的方式 C# -- 使用委托 delegate 执行异步操作 JavaScript -- 原型:prototype的使用 DBHelper类连接数据库 MVC ...
查看>>
Git rebase使用
查看>>
Tetris in javascript[俄罗斯方块]
查看>>
Just Be
查看>>
一个感人的爱情故事(中英对照)
查看>>
【转载】大整数相乘
查看>>
Android 小项目之--Mini音乐播放器【简单版】(附源码)
查看>>
Delphi判断文件是否正在被使用
查看>>
TaskAsyncHelper
查看>>
知之为知之,不知为不知。
查看>>
设计模式6大原则
查看>>
C# WinForm 文件上传下载
查看>>
[转载]日历设计之重复事件规则设计
查看>>
HTTP协议详解(真的很经典)
查看>>
(转)什么是云计算
查看>>
Linux性能监控命令——sar
查看>>
使用Asp.net mvc + Linq + mvc_scaffold_gen_setup.exe 生成一个完整的家庭帐册大管家程序 之二...
查看>>
视差滚动(Parallax Scrolling)效果的原理和实现
查看>>