基于redisson实现发布订阅（多服务间用避坑）

在多服务环境下，使用Redisson实现发布订阅模式时，需要确保所有服务实例都使用相同的Redis节点或集群。这样，即使消息发布者和订阅者分布在不同的服务中，它们也能够接收到同样的消息。

以下是使用Redisson进行发布订阅的基本步骤和示例代码：

1. 添加Redisson依赖到项目中。
2. 配置Redisson客户端。
3. 创建发布者和订阅者。

以下是一个简单的例子：

import org.redisson.Redisson;
import org.redisson.api.RTopic;
import org.redisson.config.Config;
import org.redisson.config.SingleServerConfig;
 
public class RedissonPubSubExample {
 
    public static void main(String[] args) {
        // 配置Redisson客户端连接到Redis服务器
        SingleServerConfig config = new SingleServerConfig();
        config.setAddress("redis://127.0.0.1:6379");
 
        // 创建Redisson实例
        Redisson redisson = Redisson.create(config);
 
        // 获取一个Topic对象
        RTopic<String> topic = redisson.getTopic("myTopic");
 
        // 创建订阅者
        topic.addListener(String.class, (channel, message) -> {
            System.out.println("Received message: " + message);
        });
 
        // 发布消息
        topic.publish("Hello, Redisson!");
 
        // 关闭Redisson客户端
        redisson.shutdown();
    }
}

在这个例子中，我们配置了Redisson客户端连接到本地运行的Redis服务器。然后，我们创建了一个RTopic对象，该对象代表了一个发布订阅频道。我们向该频道添加了一个监听器，该监听器会在有消息发布到该频道时接收消息。最后，我们通过publish方法发布了一条消息，并在订阅者接收到消息后关闭了Redisson客户端。

确保所有服务实例使用相同的Redis节点或集群，并且订阅的频道名称相同。这样，即使发布者和订阅者分布在不同的服务中，它们也能够通过Redis进行正确的消息传递。