新开发一个即时通讯IM服务端源代码（基于Netty，有完整源码）

来源：即时通讯网 2020-06-29 10:50:41

0、引言

站长提拔：白文合乎IM生手阅读，但最最有毫无疑问的台网编程经历，必竟实践性的代码左方即使如此台网编程。只要你对大网编程，以及IM的一部分理论知识一知半解，请必须先是披阅：《新手入门一篇就够：从零开发移位端IM》，该文为IM小白分类整理了详尽的说理资料，请按需补给血脉相通学识。

配套源码：正文写的可比浅显但不太易懂，建言献计咬合代码一起来读，成文配套的完整源码请从正文文末 “11、完整源码下载” 处下载！

本站的另几篇同类代码你或许也欢喜：

《自已开发IM有那么难吗？手把手教你自撸一个Andriod版简易IM (有源码)》

《拿起键盘即或干：跟我一并徒手开发一套分布式IM体系》

《适合新手：手把手教你用Go飞跃搭建高性能、可扩展的IM系统(有源码)》

1、始末简述

首先张嘴IM（即时通讯）技巧方可用来做好家伙：

1）谈天：qq、微信；

2）直播：斗鱼直播、抖音；

3）实时职务共享、嬉戏多人相互之类。

足以说差一点享有高实时性的行使现象都需要用到IM招术。

本篇将带大家从零开始搭建一个轻量级的IM服务端。

麻雀虽小，五脏俱全，俺们搭建的IM服务端心想事成之下成效：

1）相当的文牍信息、文牍信息通信；

2）每个信息有“已发送”/“已送达”/“已读”回条；

3）贮存离线音信；

4）引而不发用户登录，知音兼及等基本功能；

5）能够方便地水平扩张。

经过这个部类能学到过剩后端必不可少学问：

1）rpc通信；

2）数据库；

3）缓存；

4）信息行列；

5）分布式、高并发的架构设计；

6）docker配置。

2、痛痒相关笔札

更多实践性代码参照：

《开源运动端IM招术框架MobileIMSDK》（* 引荐）

《自已开支IM有那么难吗？手把手教你自撸一个Andriod版简易IM (有源码)》

《相符新手：手把手教你用Go神速搭建高性能、可扩展的IM系统(有源码)》

《一种Android端IM智能怔忡算法的规划与奋斗以成探赜索隐（含样例代码）》

《手把手教你用Netty奋斗以成网络通信程序的怔忡机制、断线重连单式编制》

《NIO框架入门(一)：服务端基于Netty4的UDP双向通信Demo言传身教 [附件下载]》

《NIO框架入门(二)：服务端依据MINA2的UDP双向通信Demo以身作则 [附件下载]》

《NIO框架入门(三)：iOS与MINA2、Netty4的跨平台UDP双向通信实战 [附件下载]》

《NIO框架入门(四)：Android与MINA2、Netty4的跨平台UDP双向通信实战 [附件下载]》

《一个WebSocket实时聊天室Demo：基于node.js+socket.io [附件下载]》

休戚相关IM架构方面的笔札：

《浅谈IM系统的架构设计》

《简述举手投足端IM支出的那些坑：架构设计、通信协议和客户端》

《一套洪量在线用户的位移端IM架构设计执行分享(含详细图文)》

《一套原创分布式即时通讯(IM)体系理论架设方案》

《从零到卓越：京东客服即时通讯系统的招术架构形成进程》

《迁延街即时通讯/IM服务器开发之架构挑拣》

《一套高可用、易伸缩、高面世的IM群聊、单聊架构方案设计实行》

3、信息通信

3.1文本音问

咱俩先从最简单的特点上马贯彻：一个普通消息的发送。

音问格式一般来说：

01020304050607080910message ChatMsg{ id = 1; //音信id fromId = Alice //发送者userId destId = Bob //接收者userId msgBody = hello //音尘体}

顺应新手：从零支出一个IM服务端（依据Netty，有完整源码）_1.png

如上图，咱俩现在有两个用户：Alice和Bob连珠到了服务器，当Alice殡葬音问message(hello)给Bob，服务端接纳到音讯，依据消息的destId拓展转正，转发给Bob。

3.2殡葬回单

那我辈要怎么来奋斗以成回单的出殡呢？

我们定义一种回帖数据格式ACK，MsgType有三种，个别是sent（已发送）,delivered（已送达）, read（已读）。

音问格式如下：

0102030405060708091011121314151617message AckMsg { id; //音信id fromId; //发送者id destId; //收信人id msgType; //消息花色 ackMsgId; //认账的信息id} enum MsgType { DELIVERED; READ;}

当服务端收受到Alice发来的信息时：

1）向Alice发送一个sent(hello)意味着音问久已被发送到服务器：

1234567message AckMsg { id = 2; fromId = Alice; destId = Bob; msgType = SENT; ackMsgId = 1;}

顺应新手：从零开发一个IM服务端（依据Netty，有完整源码）_2.png

2）服务器把hello转发给Bob后，顿然向Alice殡葬delivered(hello)意味着信息久已发送给Bob：

1234567message AckMsg { id = 3; fromId = Bob; destId = Alice; msgType = DELIVERED; ackMsgId = 1;}

切合新手：从零支出一个IM服务端（据悉Netty，有完整源码）_3.png

3）Bob涉猎音问后，客户端向服务器发送read(hello)意味消息已读：

1234567message AckMsg { id = 4; fromId = Bob; destId = Alice; msgType = READ; ackMsgId = 1;}

核符新手：从零支出一个IM服务端（依据Netty，有完整源码）_4.png

这个音讯会像一个普通闲话音信扳平被服务器甩卖，末了发送给Alice。

在服务器这里不区分ChatMsg和AckMsg，处理过程都是雷同的：浅析音讯的destId并进展换车。

4、档次恢弘

当用户量一发大，势将急需充实服务器的数目，用户的连连被分散在不同的机具上。此刻，就内需存储用户连天在哪台机具上。

咱们引入一个新的模块来管住用户的连珠音息。

4.1管制用户状态

严丝合缝新手：从零支出一个IM服务端（根据Netty，有完整源码）_5.png

模块称之为user status，共有三个接口：

0102030405060708091011121314151617181920212223242526public interface UserStatusService { /** * 用户上线，储存userId与机具id的论及 * * @param userId * @param connectorId * @return 假若时下用户在线，则回去他连日的机器id，要不然赶回null */ String online(String userId, String connectorId); /** * 用户下线 * * @param userId */ void offline(String userId); /** * 由此用户id寻找他目下连续不断的机器id * * @param userId * @return */ String getConnectorId(String userId);}

如斯咱们就力所能及对用户连珠状态拓展管理了，具体的落实应设想服务的用户量、企望性能等开展贯彻。

此间俺们动用redis来贯彻，将userId和connectorId的旁及以key-value的款型仓储。

4.2音讯转发

除外，还急需一个模块在不同的机器上转折音问，一般来说结构：

顺应生手：从零支付一个IM服务端（基于Netty，有完整源码）_6.png

这时候咱们的劳务被拆分成了connector和transfer两个模块，connector模块用以维持用户的长链接，而transfer的用意是将音尘在多个connector之间中转。

现在时Alice和Bob连天到了两台connector上，那么音讯要哪样传递呢？

1）Alice上线，一个劲到机具[1]上时：

1.1）将Alice和它的接二连三存入内存中。

1.2）调用user status的online艺术笔录Alice上线。

2）Alice殡葬了一条消息给Bob：

2.1）机器[1]收取音息后，条分缕析destId，在内存中寻觅是不是有Bob。