本文由作者“大白菜”分享,有较多订正和改变。留神:本系列是给 IM 初学者的文章,IM 老油条们还望海涵,勿喷!
1、引言
接上两篇《IM 零碎设计篇》、《编码实际篇(单聊性能)》,本篇次要解说的是通过实战编码实现 IM 的群聊性能,内容波及群聊技术实现原理、编码实际等常识。
学习交换:- 挪动端 IM 开发入门文章:《新手入门一篇就够:从零开发挪动端 IM》- 开源 IM 框架源码:https://github.com/JackJiang2…(备用地址点此)
(本文已同步公布于:http://www.52im.net/thread-39…)
2、写在后面
倡议你在浏览本文之前,务必先读本系列的前两篇《IM 零碎设计篇》、《编码实际篇(单聊性能)》,在着重了解 IM 零碎的实践设计思路之后,再来浏览实战代码则成果更好。最初,在开始本文之前,请您务必提前理解 Netty 的相干基础知识,可从本系列首篇《IM 零碎设计篇》中的“常识筹备”一章开始。
3、系列文章
本文是系列文章的第 3 篇,以下是系列目录:《基于 Netty,从零开发 IM(一):IM 零碎设计篇》《基于 Netty,从零开发 IM(二):编码实际篇(单聊性能)》《基于 Netty,从零开发 IM(三):编码实际篇(群聊性能)》(* 本文)《基于 Netty,从零开发 IM(四):编码实际篇(系统优化)》(稍后公布..)
4、本篇概述
在上篇《编码实际篇(单聊性能)》中,咱们次要实现了 IM 的单聊性能,本节次要是实现 IM 群聊性能。本篇波及的群聊外围性能,大抵如下所示:1)登录:每个客户端连贯服务端的时候,都须要输出本人的账号信息,以便和连贯通道进行绑定;2)创立群组:输出群组 ID 和群组名称进行创立群组。须要先依据群组 ID 进行校验,判断是否曾经存在了;3)查看群组:查看目前曾经创立的群组列表;4)退出群组:主要参数是群组 ID 和用户 ID,用户 ID 只需从 Channel 的绑定属性外面获取即。次要是判断群组 ID 是否存在,如果存在还须要判断该用户 ID 是否曾经在群组外面了;5)退出群组:次要是判断群组 ID 是否存在,如果存在则删除相应的关系;6)查看组成员:依据群组 ID 去查问对应的成员列表;7)群发音讯:抉择某个群进行音讯发送,该群下的成员都能收到信息。次要判断群组 ID 是否存在,如果存在再去获取其对应的成员列表。
5、群聊原理
其实群聊和单聊,整体上原理是一样的,只是做了一下细节上的降级。在首篇《IM 零碎设计篇》的“6、IM 群聊思路设计”设计局部也做了具体的阐明了。群聊的大略流程就是:依据群组 ID 查找到所有的成员汇合,而后再遍历找到每个成员对应的连贯通道。具体的群聊架构思路如下图:
如上图所示,群聊通信流程技术原理如下:1)群聊和单聊整体上的思路统一:须要保留每个用户和通道的对应关系,不便前期通过用户 ID 去查找到对应的通道,再跟进通道推送音讯;2)群聊把音讯发送给群员的原理:其实很简略,服务端再保留另外一份映射关系,那就是聊天室和成员的映射关系。发送音讯时,首先依据聊天室 ID 找到对应的所有成员,而后再跟进各个成员的 ID 去查找到对应的通道,最初由每个通道进行音讯的发送;3)群成员退出某个群聊聊的时候:往映射表新增一条记录,如果成员退群的时候则删除对应的映射记录。
6、运行成果
补充阐明:因为本系列文章次要目标是疏导 IM 初学者在基于 Netty 的状况下,如何一步一步从零写出 IM 的逻辑和思维能力,因此为了简化编码实现,本篇中编码实现的客户端都是基于控制台实现的(心愿不要被厌弃),因为了解技术的实质显然比炫酷的外在表现形式更为重要。用户登录效果图:
群组操作效果图:
7、实体定义实战
7.1 服务端实体服务端映射关系的治理,别离是:1)登录信息(用户 ID 和通道);2)群组信息(群组 ID 和群组成员关系)。次要通过两个 Map 去保护,具体如下:public class ServerChatGroupHandler extends ChannelInboundHandlerAdapter {private static Map<Integer, Channel> map=new HashMap<Integer, Channel>(); private static Map<Integer, Group> groups=new HashMap<Integer, Group>();}// 组和成员列表关系实体 @Datapublic class Group implements Serializable {private String groupName; private List<GroupMember> members=new ArrayList<GroupMember>();}// 成员和连贯通道的关系实体 public class GroupMember implements Serializable {private Integer userid; private Channel channel;}7.2 实体和指令关系咱们筹备好相应的实体,以及实体和指令的映射关系,具体如下所示:private static Map<Byte, Class<? extends BaseBean>> map=new HashMap<Byte,Class<? extends BaseBean>>(); static{ // 登录的申请和响应实体 map.put(1, LoginReqBean.class); map.put(2, LoginResBean.class); // 创立群组的申请和响应实体 map.put(3, GroupCreateReqBean.class); map.put(4, GroupCreateResBean.class); // 查看群组的申请和响应实体 map.put(5, GroupListReqBean.class); map.put(6, GroupListResBean.class); // 退出群组的申请和响应实体 map.put(7,GroupAddReqBean.class); map.put(8,GroupAddResBean.class); // 退出群组的申请和响应实体 map.put(9,GroupQuitReqBean.class); map.put(10,GroupQuitResBean.class); // 查看成员列表的申请和响应实体 map.put(11,GroupMemberReqBean.class); map.put(12,GroupMemberResBean.class); // 发送响应的实体(发送音讯、发送响应、承受音讯)map.put(13,GroupSendMsgReqBean.class); map.put(14,GroupSendMsgResBean.class); map.put(15,GroupRecMsgBean.class); }通过上面这张图,能看的更清晰一些:
8、Handler 定义实战
IM 群聊性能的实现,咱们须要两个两个业务 Handler:1)别离是客户端(ClientChatGroupHandler);2)服务端(ServerChatGroupHandler)。8.1 客户端 Handler 客户端 Handler,次要是通过判断实体类型来做不同的业务操作,当然也能够应用 SimpleChannelInboundHandler 去进行 Handler 拆分。public class ClientChatGroupHandler extends ChannelInboundHandlerAdapter {@Override public void channelActive(ChannelHandlerContext ctx) throws Exception {// 在链接就绪时登录 login(ctx.channel()); } // 次要是“承受服务端”的响应信息 @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {if(msg instanceof LoginResBean){LoginResBean res=(LoginResBean) msg; System.out.println(“ 登录响应:”+res.getMsg()); if(res.getStatus()==0){// 登录胜利 //1. 给通道绑定身份 ctx.channel().attr(AttributeKey.valueOf(“userid”)).set(res.getUserid()); //2. 显示操作类型【请看上面】deal(ctx.channel()); }else{// 登录失败,持续登录 login(ctx.channel()); } }else if(msg instanceof GroupCreateResBean){GroupCreateResBean res=(GroupCreateResBean)msg; System.out.println(“ 创立响应群组:”+res.getMsg()); }else if(msg instanceofGroupListResBean){GroupListResBean res=(GroupListResBean)msg; System.out.println(“ 查看群组列表:”+res.getLists()); }elseif(msg instanceofGroupAddResBean){GroupAddResBean res=(GroupAddResBean)msg; System.out.println(“ 退出群组响应:”+res.getMsg()); }elseif(msg instanceof GroupQuitResBean){GroupQuitResBean res=(GroupQuitResBean)msg; System.out.println(“ 退群群组响应:”+res.getMsg()); }else if(msg instanceof GroupMemberResBean){GroupMemberResBean res=(GroupMemberResBean)msg; if(res.getCode()==1){System.out.println(“ 查看成员列表:”+res.getMsg()); }else{System.out.println(“ 查看成员列表:”+res.getLists()); } }else if(msg instanceof GroupSendMsgResBean){GroupSendMsgResBean res=(GroupSendMsgResBean)msg; System.out.println(“ 群发音讯响应:”+res.getMsg()); }else if(msg instanceof GroupRecMsgBean){GroupRecMsgBean res=(GroupRecMsgBean)msg; System.out.println(“ 收到音讯 fromuserid=”+ res.getFromuserid()+ “,msg=”+res.getMsg()); } }}通过子线程循环向输入控制台输入操作类型的办法,以下办法目前都是空办法,上面将具体解说。private void deal(final Channel channel){final Scanner scanner=new Scanner(System.in); new Thread(new Runnable() {public void run() {while(true){System.out.println(“ 请抉择类型:0 创立群组,1 查看群组,2 退出群组,3 退出群组,4 查看群成员,5 群发音讯 ”); int type=scanner.nextInt(); switch(type){case 0: createGroup(scanner,channel); break; case 1: listGroup(scanner,channel); break; case 2: addGroup(scanner,channel); break; case 3: quitGroup(scanner,channel); break; case 4: listMembers(scanner,channel); break; case 5: sendMsgToGroup(scanner,channel); break; default: System.out.println(“ 输出的类型不存在!”); } } } }).start();}8.2 服务端 Handler 服务端 Handler,次要是通过判断实体类型来做不同的业务操作,当然也能够应用 SimpleChannelInboundHandler 去进行 Handler 拆分。以下办法目前都是空办法,上面将具体解说。public class ServerChatGroupHandler extends ChannelInboundHandlerAdapter {private static Map<Integer, Channel> map=new HashMap<Integer, Channel>(); private static Map<Integer, Group> groups=new HashMap<Integer, Group>(); @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {if(msg instanceof LoginReqBean) {// 登录 login((LoginReqBean) msg, ctx.channel()); }else if(msg instanceof GroupCreateReqBean){// 创立群组 createGroup((GroupCreateReqBean)msg,ctx.channel()); }else if(msg instanceof GroupListReqBean){// 查看群组列表 listGroup((GroupListReqBean)msg,ctx.channel()); }else if(msg instanceof GroupAddReqBean){// 退出群组 addGroup((GroupAddReqBean)msg,ctx.channel()); }else if(msg instanceof GroupQuitReqBean){// 退出群组 quitGroup((GroupQuitReqBean)msg,ctx.channel()); }else if(msg instanceof GroupMemberReqBean){// 查看成员列表 listMember((GroupMemberReqBean)msg,ctx.channel()); }else if(msg instanceof GroupSendMsgReqBean){// 音讯发送 sendMsg((GroupSendMsgReqBean) msg,ctx.channel()); } }}
9、具体性能编码实战
9.1 创立群组客户端申请:private void createGroup(Scanner scanner,Channel channel){System.out.println(“ 请输出群组 ID”); Integer groupId=scanner.nextInt(); System.out.println(“ 请输出群组名称 ”); String groupName=scanner.next(); GroupCreateReqBean bean=new GroupCreateReqBean(); bean.setGroupId(groupId); bean.setGroupName(groupName); channel.writeAndFlush(bean); }服务端解决:public class ServerChatGroupHandler extends ChannelInboundHandlerAdapter {private static Map<Integer, Channel> map=new HashMap<Integer, Channel>(); private static Map<Integer, Group> groups=new HashMap<Integer, Group>(); private void createGroup(GroupCreateReqBean bean,Channel channel){// 定义一个响应实体 GroupCreateResBean res=new GroupCreateResBean(); // 查问 groups 是否曾经存在 Group group=groups.get(bean.getGroupId()); // 判断是否曾经存在 if(group==null){// 定义群组实体 Group g=new Group(); // 定义一个汇合,专门存储成员 List<GroupMember> members=new ArrayList<GroupMember>(); // 属性赋值 g.setGroupName(bean.getGroupName()); g.setMembers(members); // 增加到 Map 外面 groups.put(bean.getGroupId(),g); // 响应信息 res.setCode(0); res.setMsg(“ 创立群组胜利 ”); }else{res.setCode(1); res.setMsg(“ 该群组曾经存在!”); } channel.writeAndFlush(res); }}9.2 查看群组客户端申请:private void listGroup(Scanner scanner,Channel channel){GroupListReqBean bean=new GroupListReqBean(); bean.setType(“list”); channel.writeAndFlush(bean);}服务端解决:public class ServerChatGroupHandler extends ChannelInboundHandlerAdapter {private static Map<Integer, Channel> map=new HashMap<Integer, Channel>(); private static Map<Integer, Group> groups=new HashMap<Integer, Group>(); private void listGroup(GroupListReqBean bean,Channel channel){if(“list”.equals(bean.getType())){// 定义一个响应实体 GroupListResBean res=new GroupListResBean(); // 定义一个汇合 List<GroupInfo> lists=new ArrayList<GroupInfo>(); // 变量 groups Map 汇合 for(Map.Entry<Integer, Group> entry : groups.entrySet()){Integer mapKey = entry.getKey(); Group mapValue = entry.getValue(); GroupInfo gi=new GroupInfo(); gi.setGroupId(mapKey); gi.setGroupName(mapValue.getGroupName()); lists.add(gi); } // 把汇合增加到响应实体外面 res.setLists(lists); // 开始写到客户端 channel.writeAndFlush(res); } }}9.3 退出群组客户端申请:private void addGroup(Scanner scanner,Channel channel){System.out.println(“ 请输出退出的群组 ID”); int groupId=scanner.nextInt(); Integer userId=(Integer) channel.attr(AttributeKey.valueOf(“userid”)).get(); GroupAddReqBean bean=new GroupAddReqBean(); bean.setUserId(userId); bean.setGroupId(groupId); channel.writeAndFlush(bean);}服务端解决:public class ServerChatGroupHandler extends ChannelInboundHandlerAdapter {private static Map<Integer, Channel> map=new HashMap<Integer, Channel>(); private static Map<Integer, Group> groups=new HashMap<Integer, Group>(); private void addGroup(GroupAddReqBean bean,Channel channel){GroupAddResBean res=new GroupAddResBean(); //1. 依据“群组 ID”获取对应的“组信息”Group group=groups.get(bean.getGroupId()); //2.“群组”不存在 if(group==null){res.setCode(1); res.setMsg(“groupId=”+bean.getGroupId()+”, 不存在!”); channel.writeAndFlush(res); return; } //3.“群组”存在,则获取其底下的“成员汇合”List<GroupMember> members=group.getMembers(); boolean flag=false; //4. 遍历汇合,判断“用户”是否曾经存在了 for(GroupMember gm:members){if(gm.getUserid()==bean.getUserId()){flag=true; break;} } if(flag){res.setCode(1); res.setMsg(“ 曾经在群组外面, 无奈再次退出!”); }else{//1. 用户信息 GroupMember gm=new GroupMember(); gm.setUserid(bean.getUserId()); gm.setChannel(channel); //2. 增加到汇合外面 members.add(gm); //3. 给“群组”从新赋值 group.setMembers(members); res.setCode(0); res.setMsg(“ 退出群组胜利 ”); } channel.writeAndFlush(res); }}9.4 退出群组客户端申请:private void quitGroup(Scanner scanner,Channel channel){System.out.println(“ 请输出退出的群组 ID”); int groupId=scanner.nextInt(); Integer userId=(Integer) channel.attr(AttributeKey.valueOf(“userid”)).get(); GroupQuitReqBean bean=new GroupQuitReqBean(); bean.setUserId(userId); bean.setGroupId(groupId); channel.writeAndFlush(bean);}服务端解决:public class ServerChatGroupHandler extends ChannelInboundHandlerAdapter {private static Map<Integer, Channel> map=new HashMap<Integer, Channel>(); private static Map<Integer, Group> groups=new HashMap<Integer, Group>(); private void quitGroup(GroupQuitReqBean bean,Channel channel){GroupQuitResBean res=new GroupQuitResBean(); //1. 依据“群组 ID”获取对应的“组信息”Group group=groups.get(bean.getGroupId()); if(group==null){//2. 群组不存在 res.setCode(1); res.setMsg(“groupId=”+bean.getGroupId()+”, 不存在!”); channel.writeAndFlush(res); return; } //3. 群组存在,则获取其底下“成员汇合”List<GroupMember> members=group.getMembers(); //4. 遍历汇合,找到“以后用户”在汇合的序号 int index=-1; for(inti=0;i<members.size();i++){if(members.get(i).getUserid()==bean.getUserId()){index=i; break;} } //5. 如果序号等于 -1,则示意“以后用户”不存在汇合外面 if(index==-1){res.setCode(1); res.setMsg(“userid=”+bean.getUserId()+”, 不存在该群组外面!”); channel.writeAndFlush(res); return; } //6. 从汇合外面删除“以后用户”members.remove(index); //7. 给“群组”的“成员列表”从新赋值 group.setMembers(members); res.setCode(0); res.setMsg(“ 退出群组胜利 ”); channel.writeAndFlush(res); }}9.5 查看群组成员客户端申请:private void listMembers(Scanner scanner,Channel channel){System.out.println(“ 请输出群组 ID:”); int groupId=scanner.nextInt(); GroupMemberReqBean bean=new GroupMemberReqBean(); bean.setGroupId(groupId); channel.writeAndFlush(bean);}服务端解决:public class ServerChatGroupHandler extends ChannelInboundHandlerAdapter {private static Map<Integer, Channel> map=new HashMap<Integer, Channel>(); private static Map<Integer, Group> groups=new HashMap<Integer, Group>(); private void listMember(GroupMemberReqBean bean,Channel channel){GroupMemberResBean res=new GroupMemberResBean(); List<Integer> lists=new ArrayList<Integer>(); //1. 依据“群组 ID”获取对应的“组信息”Group group=groups.get(bean.getGroupId()); if(group==null){//2. 查问的群组不存在 res.setCode(1); res.setMsg(“groupId=”+bean.getGroupId()+”, 不存在!”); channel.writeAndFlush(res); }else{//3. 群组存在,则变量其底层的成员 for(Map.Entry<Integer, Group> entry : groups.entrySet()){Group g = entry.getValue(); List<GroupMember> members=g.getMembers(); for(GroupMember gm:members){lists.add(gm.getUserid()); } } res.setCode(0); res.setMsg(“ 查问胜利 ”); res.setLists(lists); channel.writeAndFlush(res); } }}9.6 群发音讯客户端申请:private void sendMsgToGroup(Scanner scanner,Channel channel){System.out.println(“ 请输出群组 ID:”); int groupId=scanner.nextInt(); System.out.println(“ 请输出发送音讯内容:”); String msg=scanner.next(); Integer userId=(Integer) channel.attr(AttributeKey.valueOf(“userid”)).get(); GroupSendMsgReqBean bean=new GroupSendMsgReqBean(); bean.setFromuserid(userId); bean.setTogroupid(groupId); bean.setMsg(msg); channel.writeAndFlush(bean);}服务端解决:public class ServerChatGroupHandler extends ChannelInboundHandlerAdapter {private static Map<Integer, Channel> map=new HashMap<Integer, Channel>(); private static Map<Integer, Group> groups=new HashMap<Integer, Group>(); privatevoidsendMsg(GroupSendMsgReqBean bean,Channel channel){GroupSendMsgResBean res=new GroupSendMsgResBean(); //1. 依据“群组 ID”获取对应的“组信息”Group group=groups.get(bean.getTogroupid()); //2. 给“发送人”响应,告诉其发送的音讯是否胜利 if(group==null){res.setCode(1); res.setMsg(“groupId=”+bean.getTogroupid()+”, 不存在!”); channel.writeAndFlush(res); return; }else{res.setCode(0); res.setMsg(“ 群发音讯胜利 ”); channel.writeAndFlush(res); } //3. 依据“组”上面的“成员”,变量并且一一推送音讯 List<GroupMember> members=group.getMembers(); for(GroupMember gm:members){GroupRecMsgBean rec=new GroupRecMsgBean(); rec.setFromuserid(bean.getFromuserid()); rec.setMsg(bean.getMsg()); gm.getChannel().writeAndFlush(rec); } }}
10、本篇小结
本篇中波及的性能点略微有点多,次要是实现了群聊的几个外围性能,别离是:创立群组、查看群组列表、退出群组、退出群组、查看成员列表、群发音讯。这些性能通过拆解,看起来就不是那么简单了,心愿大家都能够亲自动手实现一遍,加深了解,进步学习效果。实际上,真正的产品级 IM 中,群聊波及的技术细节是十分多的,有趣味能够详读上面这几篇:IM 群聊音讯如此简单,如何保障不丢不重?挪动端 IM 中大规模群音讯的推送如何保障效率、实时性?对于 IM 即时通讯群聊音讯的乱序问题探讨 IM 群聊音讯到底是存 1 份 (即扩散读) 还是存多份(即扩散写)?一套高可用、易伸缩、高并发的 IM 群聊、单聊架构方案设计实际网易云信技术分享:IM 中的万人群聊技术计划实际总结阿里电商 IM 音讯平台,在群聊、直播场景下的技术实际企业微信的 IM 架构设计揭秘:音讯模型、万人群、已读回执、音讯撤回等融云 IM 技术分享:万人群聊音讯投递计划的思考和实际
11、参考资料
[1] 手把手教你用 Netty 实现心跳机制、断线重连机制
[2] 自已开发 IM 很难?手把手教你撸一个 Andriod 版 IM
[3] 基于 Netty,从零开发一个 IM 服务端
[4] 拿起键盘就是干,教你徒手开发一套分布式 IM 零碎
[5] 正确理解 IM 长连贯、心跳及重连机制,并入手实现
[6] 手把手教你用 Go 疾速搭建高性能、可扩大的 IM 零碎
[7] 手把手教你用 WebSocket 打造 Web 端 IM 聊天
[8] 万字长文,手把手教你用 Netty 打造 IM 聊天
[9] 基于 Netty 实现一套分布式 IM 零碎
[10] 基于 Netty,搭建高性能 IM 集群(含技术思路 + 源码)
[11] SpringBoot 集成开源 IM 框架 MobileIMSDK,实现即时通讯 IM 聊天性能
(本文已同步公布于:http://www.52im.net/thread-39…)