建设局网站新闻,购物网站建设规划书,网站建设应走什么会计科目,制作网页时常用的网页有哪些架构说明#xff1a; 1#xff09;CIM 中的各个组件均采用 SpringBoot 构建#xff1b;2#xff09;采用 Netty Google Protocol Buffer 构建底层通信#xff1b;3#xff09;Redis 存放各个客户端的路由信息、账号信息、在线状态等#xff1b;4#xff09;Zookeeper …架构说明 1CIM 中的各个组件均采用 SpringBoot 构建2采用 Netty Google Protocol Buffer 构建底层通信3Redis 存放各个客户端的路由信息、账号信息、在线状态等4Zookeeper 用于 IM-server 服务的注册与发现。 整体主要由以下模块组成 1cim-server——IM 服务端用于接收 client 连接、消息透传、消息推送等功能。支持集群部署2cim-forward-route——消息路由服务器用于处理消息路由、消息转发、用户登录、用户下线以及一些运营工具获取在线用户数等3cim-client——IM 客户端给用户使用的消息终端一个命令即可启动并向其他人发起通讯群聊、私聊同时内置了一些常用命令方便使用。
流程解释如下 1客户端向 route 发起登录2登录成功从 Zookeeper 中选择可用 IM-server 返回给客户端并保存登录、路由信息到 Redis3客户端向 IM-server 发起长连接成功后保持心跳4客户端下线时通过 route 清除状态信息。
所以当我们自己部署时需要以下步骤 1搭建基础中间件 Redis、Zookeeper2部署 cim-server这是真正的 IM 服务器为了满足性能需求所以支持水平扩展只需要注册到同一个 Zookeeper 即可3部署 cim-forward-route这是路由服务器所有的消息都需要经过它。由于它是无状态的所以也可以利用 Nginx 代理提高可用性4cim-client 真正面向用户的客户端启动之后会自动连接 IM 服务器便可以在控制台收发消息了。
这里就设计的比较简单直接利用 Redis 来存储用户信息用户信息也只有 ID 和 userName 而已。只是为了方便查询在 Redis 中的 KV 又反过来存储了一份 VK这样 ID 和 userName 都必须唯一。 具体的流程 1登录成功之后需要判断是否是重复登录一个用户只能运行一个客户端2登录成功后需要从 Zookeeper 中获取服务列表cim-server并根据某种算法选择一台服务返回给客户端3登录成功之后还需要保存路由信息也就是当前用户分配的服务实例保存到 Redis 中。
为了实现只能一个用户登录使用了 Redis 中的 set 来保存登录信息利用 userID 作为 key 重复的登录就会写入失败。 1先从 Zookeeper 获取所有的服务实例做一个内部缓存2轮询选择一台服务器目前只有这一种算法后续会新增。即时通讯聊天软件app开发可以加小蓝豆的vweikeyun24咨询即可
当然要获取 Zookeeper 中的服务实例前自然是需要监听 cim-server 之前注册上去的那个节点。
这是一个真正发消息的接口实现的效果就是其中一个客户端发消息其余所有客户端都能收到流程肯定是客户端发送一条消息到服务端服务端收到后在上文介绍的 SessionSocketHolder 中遍历所有 Channel通道然后下发消息即可。服务端是单机倒也可以但现在是集群设计。所以所有的客户端会根据之前的轮询算法分配到不同的 cim-server 实例中。
由于 Redis 单线程的特质当数据量大时一旦使用 keys 匹配所有 cim-route:* 数据会导致 Redis 不能处理其他请求。所以这里改为使用 scan 命令来遍历所有的 cim-route:*。
接着会挨个调用每个客户端所在的服务端的 HTTP 接口用于推送消息。
之所以说获取在线用户是一个辅助接口其实就是用于辅助私聊使用的。一般我们使用私聊的前提肯定得知道当前哪些用户在线接着你才会知道你要和谁进行私聊。
所以私聊接口在收到消息后需要查询到接收者所在的 cim-server 实例信息后续的步骤就和群聊一致了。调用接收者所在实例的 HTTP 接口下发信息。只是群聊是遍历所有的在线用户私聊只发送一个的区别。
