java redis 发布订阅

Redis提供了发布订阅（Pub/Sub）功能，允许多个客户端通过订阅特定的频道来接收消息，同时允许多个客户端向特定的频道发布消息。

Java Redis客户端提供了JedisPubSub类来实现发布订阅功能。以下是一个简单的示例：

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;

public class RedisPubSubExample {

    public static void main(String[] args) throws Exception {
        Jedis jedis = new Jedis("localhost");
        String channel = "news";
        jedis.subscribe(new JedisPubSub() {
            @Override
            public void onMessage(String channel, String message) {
                System.out.println("Received message: " + message + " from channel: " + channel);
            }
        }, channel);
        
        // 发布消息
        jedis.publish(channel, "Hello, World!");
        
        // 等待消息接收
        Thread.sleep(1000);
        
        jedis.close();
    }
}

在以上示例中，我们首先创建了一个Jedis实例并指定了Redis服务器的地址。然后我们订阅了一个名为“news”的频道，并在回调函数中打印出接收到的消息。接着我们发布了一条消息，最后等待一秒钟以确保消息已经被接收到，然后关闭Jedis实例。

注意，以上示例仅为演示如何使用Java Redis客户端实现发布订阅功能。在实际生产环境中，我们需要考虑更多的细节，例如如何处理异常、如何处理大量的订阅和发布等。