本文主要是介绍Redis学习笔记-发布订阅PubSub,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
Redis发布/订阅(Pub/Sub)是一种通信机制,将数据推到某个消息管道中,其他客户端可以通过订阅这些管道来获取推送的信息,以此用于消息的传输。
Redis发布/订阅(Pub/Sub)主要由三部分组成:发布者(Publisher)、频道(Channel)、订阅者(Subscriber)。
Redis发布/订阅(Pub/Sub)的消息分到不同的频道,不需要知道什么样的订阅者订阅。订阅者对一个或多个频道感兴趣,只需要接收自身感兴趣的消息,不需要知道什么样的发布者发布。主要的目的就是解除消息的发布者与订阅者之间的耦合关系。
Redis发布订阅基于RedissonClient简单实现:
@Slf4j
@AllArgsConstructor
public class RedisCachePubSub {private final RedissonClient redissonClient;/*** publish* @param topic* @param message* @return*/public long publish(String topic, Object message) {return redissonClient.getTopic(topic).publish(message);}/*** publish* @param topic* @param codec* @param message* @return*/public long publish(String topic, Codec codec, Object message) {return redissonClient.getTopic(topic, codec).publish(message);}/*** publish async* @param topic* @param message*/public void publishAsync(String topic, Object message) {redissonClient.getTopic(topic).publishAsync(message);}/*** publish async* @param topic* @param codec* @param message*/public void publishAsync(String topic, Codec codec, Object message) {redissonClient.getTopic(topic, codec).publishAsync(message);}/**
这篇关于Redis学习笔记-发布订阅PubSub的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!