redis java 消息队列 订阅

要在Java应用中使用Redis作为消息队列，可以使用Redis Pub/Sub模型。Pub/Sub模型中，消息发布者(Publisher)将消息发布到指定的频道(Channel)，而消息订阅者(Subscriber)则可以订阅感兴趣的频道，并接收到频道中的消息。

以下是在Java中使用Redis Pub/Sub模型实现消息订阅的基本步骤：

1. 导入Jedis客户端依赖。

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>3.6.1</version>
</dependency>

2. 创建Jedis客户端连接。

String host = "localhost";
int port = 6379;
Jedis jedis = new Jedis(host, port);

3. 实现消息订阅逻辑。

String channel = "testChannel";
JedisPubSub jedisPubSub = new JedisPubSub() {
    @Override
    public void onMessage(String channel, String message) {
        System.out.println("Received message: " + message + " from channel: " + channel);
    }

    @Override
    public void onSubscribe(String channel, int subscribedChannels) {
        System.out.println("Subscribed to channel: " + channel);
    }

    @Override
    public void onUnsubscribe(String channel, int subscribedChannels) {
        System.out.println("Unsubscribed from channel: " + channel);
    }
};
jedis.subscribe(jedisPubSub, channel);

在上述代码中，我们首先指定要订阅的频道名称，然后创建一个JedisPubSub对象，并重写其onMessage()、onSubscribe()和onUnsubscribe()方法，分别用于处理订阅到消息、订阅成功和取消订阅时的回调逻辑。最后，我们通过调用Jedis的subscribe()方法来订阅指定频道，从而开始接收频道中的消息。

需要注意的是，上述代码中的JedisPubSub对象是一个匿名内部类，可以根据实际需求来创建自定义的JedisPubSub子类。此外，消息发布者可以使用Jedis的publish()方法将消息发布到指定频道中，从而实现消息的发送。