Java使用Redis实现消息订阅/发布的几种方式
更新时间：2025年08月12日 10:41:48 作者：二九筒
Redis 提供了 Pub/Sub (发布/订阅) 模式,允许客户端订阅频道并接收发布到这些频道的消息,以下是 Java 中使用 Redis 实现消息订阅的几种方式,需要的朋友可以参考下
Redis 提供了 Pub/Sub (发布/订阅) 模式，允许客户端订阅频道并接收发布到这些频道的消息。以下是 Java 中使用 Redis 实现消息订阅的几种方式。
1. 使用 Jedis 客户端
添加依赖
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>4.3.1</version>
</dependency>基本订阅示例
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;
public class RedisSubscriber {
public static void main(String[] args) {
// 创建 Jedis 连接
Jedis jedis = new Jedis("localhost", 6379);
// 创建订阅者
JedisPubSub subscriber = new JedisPubSub() {
@Override
public void onMessage(String channel, String message) {
System.out.println("收到消息 - 频道: " + channel + ", 内容: " + message);
}
@Override
public void onSubscribe(String channel, int subscribedChannels) {
System.out.println("订阅成功 - 频道: " + channel);
}
};
// 订阅频道
jedis.subscribe(subscriber, "myChannel");
}
}发布消息
import redis.clients.jedis.Jedis;
public class RedisPublisher {
public static void main(String[] args) {
Jedis jedis = new Jedis("localhost", 6379);
jedis.publish("myChannel", "Hello, Redis Pub/Sub!");
jedis.close();
}
}2. 使用 Lettuce 客户端 (推荐)
Lettuce 是另一个流行的 Redis Java 客户端，支持响应式编程。
添加依赖
<dependency>
<groupId>io.lettuce</groupId>
<artifactId>lettuce-core</artifactId>
<version>6.2.3.RELEASE</version>
</dependency>订阅示例
import io.lettuce.core.RedisClient;
import io.lettuce.core.pubsub.RedisPubSubListener;
import io.lettuce.core.pubsub.StatefulRedisPubSubConnection;
import io.lettuce.core.pubsub.api.sync.RedisPubSubCommands;
public class LettuceSubscriber {
public static void main(String[] args) {
RedisClient client = RedisClient.create("redis://localhost");
StatefulRedisPubSubConnection<String, String> connection = client.connectPubSub();
connection.addListener(new RedisPubSubListener<String, String>() {
@Override
public void message(String channel, String message) {
System.out.println("收到消息 - 频道: " + channel + ", 内容: " + message);
}
@Override
public void message(String pattern, String channel, String message) {
// 模式匹配的消息
}
@Override
public void subscribed(String channel, long count) {
System.out.println("订阅成功 - 频道: " + channel);
}
// 其他需要实现的方法...
});
RedisPubSubCommands<String, String> sync = connection.sync();
sync.subscribe("myChannel");
// 保持程序运行以持续接收消息
try {
Thread.sleep(Long.MAX_VALUE);
} catch (InterruptedException e) {
e.printStackTrace();
}
connection.close();
client.shutdown();
}
}3. Spring Data Redis 集成
如果你使用 Spring Boot，可以更方便地集成 Redis Pub/Sub，这也是比较常用的方式
添加依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>配置 Redis 容器
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.ChannelTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
@Configuration
public class RedisConfig {
@Bean
public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
RedisMessageSubscriber subscriber) {
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.addMessageListener(subscriber, new ChannelTopic("myChannel"));
return container;
}
}配置订阅
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.stereotype.Component;
@Component
public class RedisMessageSubscriber implements MessageListener {
@Override
public void onMessage(Message message, byte[] pattern) {
System.out.println("收到消息: " + new String(message.getBody()));
}
}发布消息
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
@Service
public class RedisMessagePublisher {
private final RedisTemplate<String, Object> redisTemplate;
public RedisMessagePublisher(RedisTemplate<String, Object> redisTemplate) {
this.redisTemplate = redisTemplate;
}
public void publish(String message) {
redisTemplate.convertAndSend("myChannel", message);
}
}高级功能
模式匹配订阅：可以使用 psubscribe 订阅匹配模式的频道
取消订阅
处理连接断开：实现 onPMessage, onPUnsubscribe 等方法处理各种事件
//模式匹配订阅
// Jedis
jedis.psubscribe(subscriber, "news.*");
// Lettuce
sync.psubscribe("news.*");
//取消订阅
subscriber.unsubscribe("myChannel");
subscriber.punsubscribe("news.*");以上就是Java使用Redis实现消息订阅/发布的几种方式的详细内容，更多关于Java Redis消息订阅/发布的资料请关注脚本之家其它相关文章！
相关文章
在现代软件开发中,多线程编程已成为提高程序性能和响应速度的重要手段,Java提供了丰富的多线程支持,使得在Java中实现并发操作变得相对简单,本文将深入探讨Java多线程编程的基本概念、常见问题和最佳实践,需要的朋友可以参考下2024-06-06
下面小编就为大家带来一篇Java-JFrame-swing嵌套浏览器的具体步骤。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-10-10
本文主要详细介绍了mybatis二级缓存执行流程,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考价值,感兴趣的朋友们下面随着小编来一起学习吧2024-02-02
这篇文章主要介绍了Java通俗易懂系列设计模式之建造者模式，对设计模式感兴趣的读者，一定要看一下2021-04-04
这篇文章主要介绍了Java中Semaphore信号量的方法解析, Semaphore信号量是用来控制同 时访问 特定 资 源的 线 程数量,它通 过协调 各个 线 程,以保证合理的使用公共 资源,需要的朋友可以参考下2023-12-12
这篇文章主要为大家详细介绍了java秒杀之redis限流操作，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-11-11
这篇文章主要介绍了springboot中的controller注意事项说明，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-03-03
这篇文章主要介绍了MyBatis自定义Plugin插件的相关知识，实现方法也很简单，只需实现 Interceptor 接口，并指定想要拦截的方法签名即可,需要的朋友可以参考下2018-06-06
Java concurrency之LockSupport_动力节点Java学院整理
这篇文章主要为大家详细介绍了Java concurrency之LockSupport的相关资料，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-06-06
IntelliJ IDEA 2020.2正式发布,两点多多总能助你提效
这篇文章主要介绍了IntelliJ IDEA 2020.2正式发布，诸多亮点总有几款能助你提效,本文通过图文实例代码相结合给大家介绍的非常详细，需要的朋友可以参考下2020-07-07
最新评论