我们在平时的开发中，经常需要使用发布订阅(Pub/Sub)模式来进行消息处理。Java提供了很多中间件来供开发者来根据自己的需求来使用。常见的有基于jms的消息中间件：kafka,rocketmq,rabbitmq.但是很多开发的同学可能不知道，Redis也提供了Pub/Sub模式，Guava中的 EventBus也可以认为是Pub/Sub模式，还有Hazelcast也提供了Pub/Sub功能.
消息中间件kafka,rocketmq,rabbitmq,ons都是实现了jms协议的，他们一般都是有一个中间件服务器，就相当于一个代理，来隔离Pub端和Sub端。Pub端和Sub端都是通过中间服务器来进行交互。消息中间件可以支持消息的发布订阅，消息甚至可以是有序的，或者广播模式。
Redis也提供了Pub/Sub功能，java客户端封装了其内部的pub/sub命令，使用起来也很简单，本人做过测试，如果对消息可靠性要求不是很高，可以使用redis提供对pub/sub功能
Hazelcast提供对pub/sub主要是集群内有效的。Hazelcast是个很神奇的框架，它提供了分布式的Map,Queue,Set,List,Job,CountdownLatch等功能，topic发布订阅只是其功能之一。接入也很简单。
Guava的EventBus也可以当作一个Pub/Sub模式，用户只需要使用@Subscriber注册的方法进行消息处理即可。
@程序员
网友评论