402-如何解决集群聊天服务器跨服务器通信

╰半夏微凉° 2022-09-03 14:21 146阅读 0赞

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70]  
我们在集群聊天服务器中涉及的通信是：一对一的聊天，群聊。  
我们看上图，client1登录在chatserver1上，client2登录在chatserver2上，client3登录在chatserver3上，按我们现有的单台服务器业务来说，当client1给client2发送聊天消息的话，我们在每一台服务器上都有\_userConMap，在chatserver1上的\_userConMap肯定是找不到client2的connection，所以，在集群环境中，我们服务器的代码在业务逻辑上应该做修改，客户端完全不用改动，因为客户端不用去了解服务器有几台。我们要继续判断，如果当前client1所要聊的client2并不在这台chatserver1的机器上，就要去数据库找client2用户的一个在线状态，如果是offline，说明client2确实不在线，直接按照原来的逻辑发送离线消息就可以了，如果是在数据库查到client2的状态是online，是在线的，不在这台主机上的\_userConMap而已，只是登录在集群的其他的服务器上，如果是这种情况，如何聊天呢？client1根本不知道client2的connection是什么，  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 1]  
**如果说是让这几台服务器之间建立连接，那这几台服务器就承担着客户端和服务端的两层角色了，这样设计非常不好。**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 2]  
上面的设计，让各个ChatServer服务器互相之间直接建立TCP连接进行通信，相当于在服务器网络之间进行广播。这样的设计使得各个服务器之间耦合度太高，不利于系统扩展，并且会占用系统大量的socket资源，各服务器之间的带宽压力很大，不能够节省资源给更多的客户端提供服务，因此绝对不是一个好的设计。

## 服务器中间件-基于发布-订阅的Redis ##

**集群部署的服务器之间进行通信，最好的方式就是引入中间件消息队列，解耦各个服务器，使整个系统松耦合，提高服务器的响应能力，节省服务器的带宽资源，如下图所示：**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 3]  
在集群分布式环境中，经常使用的中间件消息队列有ActiveMQ、RabbitMQ、Kafka等，都是应用场景广泛并且性能很好的消息队列，供集群服务器之间，分布式服务之间进行消息通信。限于我们的项目业务类型并不是非常复杂，对并发请求量也没有太高的要求，因此我们的中间件消息队列选型的是-基于发布-订阅模式的redis。

## Redis详解见我博客的Redis专栏 ##

## 跨服务器通信 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 4]  
client客户端在某台服务器上登录成功后，每一台服务器和消息队列建立连接  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 5]  
往消息队列写数据和读数据，client1在chatserver1登录成功，chatserver1每一次有用户登录后，chatserver1都要向消息队列订阅一下，才能给你发送，  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 6]  
如果有人向client1发送消息，那你这个消息队列就给我上报一下，你就拿到了。  
client2在chatserver2登录的话，chatserver2向消息队列订阅，我对client2的消息感兴趣。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 7]

这时候如果client1向client2发消息，一看client2没有在这台聊天服务器上，但是client2是在线的状态，说明确实在线，在其他服务器上登录，client2所在的机器肯定向消息队列订阅了client2的消息事件，client publish一下消息（聊天的json消息），放到消息队列里面，在消息队列上的client2就可以感受到，因为它事先已经在消息队列里面订阅了，然后消息队列给chatserver2 notify一下，你之前订阅了client2报纸，现在发生了印出来了给你递过来，chatserver2知道有人给client2发送消息了，就找client2通信用的connection，把这个聊天消息转发到client2上。  
也就是说，引入了消息队列，除了消息队列是单独开发的代码模块，我们的服务器只需要向消息队列订阅发布消息。![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 8]

（观察者模式的应用场景）

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70]: /images/20220829/a3cb7d03a2a145dba0aef094b8ed1f10.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 1]: /images/20220829/f57b506e4f5145dfae80549fad8a1c7c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 2]: /images/20220829/3beaced387a94288a2b9eb01d6d121ff.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 3]: /images/20220829/b3348444ef8f441d97fee6a48a14297f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 4]: /images/20220829/7aa749f4b710452ca21c956e9c1bd13e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 5]: /images/20220829/2e44671053d44ecca393c1d90f20c7c9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 6]: /images/20220829/b28e7e6a70dc440cbc3fa8137cf6982d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 7]: /images/20220829/f74c544d10274511a9f6c36714f535d3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 8]: /images/20220829/6aff66498b8a4b1d9973732c700f0758.png