源码网商城,靠谱的源码在线交易网站 我的订单 购物车 帮助

源码网商城

Android 基于Socket的聊天应用实例(二)

  • 时间:2020-08-31 17:47 编辑: 来源: 阅读:
  • 扫一扫,手机访问
摘要:Android 基于Socket的聊天应用实例(二)
前言 很久没写BLOG了,之前在写Android聊天室的时候答应过要写一个客户(好友)之间的聊天demo,Android 基于Socket的聊天室已经实现了通过Socket广播形式的通信功能。 以下是我写的一个类似现在多数聊天软件的冒泡聊天APP。全部功能都是自己的想法,对于现在市面上成功的例子是怎么实现的,我还不了解。所以读者可只做参考学习,也可以分享您的案例给我。 [b]功能[/b] [list] [*]一对一聊天,非聊天室[/*] [*]好友列表[/*] [*]好友在线,离线状态(实时更新)[/*] [*]冒泡实时聊天窗口[/*] [*]发送离线信息[/*] [/list] [b]基本原理[/b] 之前的聊天室原理:每当客户端Socket连接到该ServerSocket之后,程序将对应Socket加入clients集合中保存,并为该Socket启动一条线程,该线程负责处理该Socket所有的通信任务,当服务器线程读到客户端数据之后,程序遍历clients集合,并将该数据向clients集合中的每个Socket发送一次 [img]http://files.jb51.net/file_images/article/201612/201612895120510.jpg?201611895132[/img] 一对一的聊天:Server通过Map把Clients的Socket都储存起来,把Client用户ID作为Map的key,当A发送信息给B时,服务器搜索出B的Socket,建立他们的通信通道。 [img]http://files.jb51.net/file_images/article/201612/201612895144597.jpg?201611895154[/img] [b]服务器Server[/b] [img]http://files.jb51.net/file_images/article/201612/201612895217447.jpg?201611895227[/img] 这次我在服务器加入了2个Socket集合,一个用来处理用户Online/Offline,另一个则专门用于处理用户之间的通信信息传递
 static Map<String, Socket> socketMap = new HashMap<String, Socket>();
 static Map<String, Socket> onlineMap = new HashMap<String, Socket>();
Clients 上线,下线动作,Server都会经过筛选然后通知其在线的好友,Clients收到好友的在线状态然后修改Friends List。
//save client's name ,online
//...
getnameString = str.substring(config.PROTOCOL_KEY.length()+config.PROTOCOL_ONLINE.length());
Server.onlineMap.put(getnameString, s);
//...
//update online friends
DataOutputStream onlineDOS = new DataOutputStream (Server.onlineMap.get(clientKey).getOutputStream());
onlineDOS.writeUTF(config.PROTOCOL_FRIENDS_START+onlineString+config.PROTOCOL_FRIENDS_END);
onlineDOS.flush();
关于聊天,我是通过一个自定义加密符来给每个Client做标志的,例如:Client A发出的信息,该条信息的头部带有一条服务器和客户端都会识别的特殊符号,通过字符处理,找出该条信息的用户信息;以此类推,Client A的通信对象也是用这个方法 我们找到ClientA的目标对象后,找出这个Socket通道,他们就可以一对一的对话了
//send msg to friend
DataOutputStream ndos = new DataOutputStream (Server.socketMap.get(forname).getOutputStream());
ndos.writeUTF(fromname+date+"\n"+forchat);
ndos.flush();

关于离线信息,这个主要是服务器承担的功能,我是使用mySql保存数据的。Client A 向离线状态的Client B发送一条信息,Server会判断Client B是否在线,如果是离线状态,服务器则把该信息先保存在mySql里;当Client B上线时,服务器会查找它的离线信息,如果有未读信息,则会及时发送。Client B就能收到离线信息了  ( ̄ˇ ̄)    [b]客户端 Clients[/b] [img]http://files.jb51.net/file_images/article/201612/201612895502231.png?201611895516[/img] 关于聊天,为了能够实现同时与多个好友聊天(不同窗口线程),这里用了ContentProvider监视聊天数据的变化,使不在当前聊天窗口的Activity也能收到好友的信息拼打印。
 //监视聊天数据的变化
 getContentResolver().registerContentObserver(DataChangeProvider.CONTENT_URI,true, cob);
那后台是怎么样接收好友发来的信息的呢?上面Server里说过,有一个SocketMap的集合,而这个集合就是记录用户的通信Socket,当有信息的时候,客户端后台的WaitMsg()会接到发来的信息并做处理。
 private Runnable waitThread = new Runnable() {
 public void run() {
 System.out.println("wait running!");
 WaitMsg();
 }
 };
关于Online/Offline状态,好友列表Activity ReceiveMsg()会监视Server发送的好友状态信息,及时更新好友列表ListActivity。
 //更新好友数据库
 fanDS.updateData(reMsg,name);
 //获取好友列表
 fansArray = fanDS.getFans();
 
 friends = new Friends(fansArray,reMsg,name);
 friendList = friends.getFriends();
[b]总结[/b] 相对聊天室而言,一对一的聊天主要是对每个Client的Socket都标志记录起来,让每个通讯动作有了目标对象;Server作为信使把两者的Socket对接,使两者可以通信聊天。 这是在 TCP/IP协议下的 C/S 模式通信方式,还有UDP协议,P2P模式下的通信方式的值得再去学习。 现在把代码直接放上博客园,Download:[url=http://xiazai.jb51.net/201612/yuanma/chat1.1_jb51.rar]demo [/url] 以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持编程素材网。
  • 全部评论(0)
联系客服
客服电话:
400-000-3129
微信版

扫一扫进微信版
返回顶部