利用Redis发布订阅完成tomcat集群下的消息通知

博主是刚入职半年的新手，如果有说的不对的地方请各位大佬见谅！

---

　　

　　这是博主的第一篇博客，可能排版以及一些描述有不合理的地方还请勿喷，希望大家尽可能的多给我这样的新手一些鼓励让我能在写博客的道路上走下去。

 

---

 

 

进入正题，首先开发背景

---

 

　　　

　　近期公司的一些项目上出现了内存溢出的问题，究其原因是缓存的数据量太大导致jvm内存溢出，产品的架构上比较老所以针对缓存这块，领导叫我去重构移植到redis中，博主之前并没有学习过redis以及关于分布式系统的并发问题，所以也是对我的一次挑战，还好没有辜负领导的期望在期望时间之前完成了任务，废话不多说，下面讲讲我对redis发布订阅以及实现应用集群的分布式锁。

 

---

 

利用redis的发布订阅实现各个tomcat的消息通知

---

 

 　　首先了解一下redis的发布与订阅，redis的发布订阅是基于redis的组成架构 ：redis client和redis server，具体关于redis发布订阅的信息请查阅这里，利用redis的该特性，只要将redis单点同时设置为订阅者与发布者，那么当有一个tomcat发送消息给redis，redis去发布该消息时就会通知到所有的节点，这样就实现了各个节点间的消息通知

　　下图大概描述一下整个消息的传递。

　　至于实现，博主使用的是java，继承jedispubsub类重写它的onsubscribe、onunsubscribe、onmessage三个方法实现订阅者类，再利用jedis.publish()去发布信息。

　　整个过程中需要注意的是，再发布消息后执行的动作必须放在onmessage中，不能放在发布消息的过程中，因为一个节点去发布消息后，redis还会反向通知到这个节点，如果在发布消息的过程中执行动作会导致该节点的动作重复执行，所以整个过程可以分为两个部分第一是去发布消息不做任何其他多余动作，二是接收消息立即去执行对应动作。

　　需要注意的是redis的发布订阅不会做持久化所以如果在发布信息时redis宕机会导致消息丢失并且无法恢复，如果业务场景中丢失消息会导致严重结果请慎用！

　　

---

 

 

感谢

 　　其实在本次的项目中还有许多关于redis以及分布式锁的体会，在后面也会写出来供大家参考一下，感谢各位看到这里的读者！