基于java实现redis实现发布与订阅

在Java中，可以使用Jedis库来实现Redis的发布订阅功能。以下是一个简单的例子：

首先，确保你的项目中包含了Jedis依赖。如果你使用Maven，可以在pom.xml中添加以下依赖：

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>最新版本</version>
</dependency>

然后，你可以使用以下代码来实现发布者和订阅者：

发布者:

import redis.clients.jedis.Jedis;
 
public class RedisPublisher {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("localhost");
        String channel = "myChannel";
        String message = "Hello, Redis!";
        jedis.publish(channel, message);
        jedis.close();
    }
}

订阅者:

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;
 
public class RedisSubscriber extends JedisPubSub {
 
    @Override
    public void onMessage(String channel, String message) {
        System.out.println("Received Message: " + message + " on channel: " + channel);
    }
 
    @Override
    public void onSubscribe(String channel, int subscribedChannels) {
        System.out.println("Subscribed to channel: " + channel + ", currently subscribed channels: " + subscribedChannels);
    }
 
    @Override
    public void onUnsubscribe(String channel, int subscribedChannels) {
        System.out.println("Unsubscribed from channel: " + channel + ", currently subscribed channels: " + subscribedChannels);
    }
 
    public static void main(String[] args) {
        Jedis jedis = new Jedis("localhost");
        RedisSubscriber subscriber = new RedisSubscriber();
        jedis.subscribe(subscriber, "myChannel");
    }
}

在上面的例子中，RedisPublisher类用于发布消息到指定的频道，而RedisSubscriber类扩展了JedisPubSub类，并重写了onMessage、onSubscribe和onUnsubscribe方法来处理不同的订阅事件。

运行RedisSubscriber类将会订阅指定的频道，运行RedisPublisher类将会向该频道发送消息，订阅者会收到发布的消息。