redis消息队列的实现方法
发表于：2025-12-02 作者：千家信息网编辑
千家信息网最后更新 2025年12月02日，这篇文章主要讲解了"redis消息队列的实现方法"，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习"redis消息队列的实现方法"吧！方式一：通过list的
千家信息网最后更新 2025年12月02日redis消息队列的实现方法
这篇文章主要讲解了"redis消息队列的实现方法"，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习"redis消息队列的实现方法"吧！
方式一：通过list的阻塞读取命令，blpop或者brpop
消费者
public class Consumer extends DemoApplicationTests{ @Test public void consume(){ int timeout = 0;//永不超时 String key = "test_que"; //list集合 第一个元素为key值，第二个元素为弹出的元素值;当超时返回[null] while(true){ List生产者
public class Productor extends DemoApplicationTests { @Test public void generateMsg() { String key = "test_que"; redisTemplate.opsForList().leftPush(key,"hht2"); }}方式二：Pub/Sub（发布/订阅）使用的 spring boot
依赖包
org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-data-redis org.springframework.boot spring-boot-starter-test test org.apache.commons commons-pool2
配置类
@Configuration@AutoConfigureAfter(RedisAutoConfiguration.class)@EnableCachingpublic class RedisConfig extends CachingConfigurerSupport { /** * 配置自定义redisTemplate * @return */ @Bean RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) { RedisTemplate template = new RedisTemplate<>(); template.setConnectionFactory(redisConnectionFactory); //使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值 Jackson2JsonRedisSerializer serializer = new Jackson2JsonRedisSerializer(Object.class); ObjectMapper mapper = new ObjectMapper(); mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); mapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); serializer.setObjectMapper(mapper); template.setValueSerializer(serializer); //使用StringRedisSerializer来序列化和反序列化redis的key值 template.setKeySerializer(new StringRedisSerializer()); template.setHashKeySerializer(new StringRedisSerializer()); template.setHashValueSerializer(serializer); template.afterPropertiesSet(); return template; } /** * 序列化定制 * * @return */ @Bean public Jackson2JsonRedisSerializer 模拟消息发布类
@Servicepublic class RedisPubSub { private static final Logger logger = LoggerFactory.getLogger(RedisPubSub.class); @Autowired private RedisTemplate redisTemplate; private ChannelTopic topic = new ChannelTopic("/redis/pubsub"); @Scheduled(initialDelay = 5000, fixedDelay = 10000) private void schedule() { logger.info("publish message"); publish("admin", "hey you must go now!"); } /** * 推送消息 * * @param publisher * @param message */ public void publish(String publisher, String content) { logger.info("message send {} by {}", content, publisher); redisTemplate.convertAndSend(topic.getTopic(), content); }} 模拟消息接收类
@Componentpublic class MessageSubscriber { Logger logger = LoggerFactory.getLogger(MessageSubscriber.class); public void onMessage(String message, String pattern) { logger.info("topic {} received {} ", pattern, message); }}启动类
@SpringBootApplication@EnableSchedulingpublic class DemoApplication { public static void main(String[] args) { SpringApplication.run(DemoApplication.class, args); }}感谢各位的阅读，以上就是"redis消息队列的实现方法"的内容了，经过本文的学习后，相信大家对redis消息队列的实现方法这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是，小编将为大家推送更多相关知识点的文章，欢迎关注！
消息
队列
方法
元素
序列
学习
内容
方式
推送
订阅
配置
阻塞
命令
容器
就是
思路
情况
文章
更多
永不
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
网络安全思维导图怎么画
唱一个网络安全的手抄报
农行网络安全知识
网络安全问题与对策的探讨
大服务器组
数据库怎么关联两个表详细
网络安全健康文明手抄报
专科学软件开发知乎
浅谈网络安全800字
软件开发弘毅
戴尔虚拟服务器怎么进去
台州机场网络安全
2019搭建补丁服务器
临沂app软件开发公司排名
深信服软件开发面试牛客网
XREADER下载软件开发
做网络安全需要加班吗
怎么保持wifi网络安全
公司服务器管理
网络安全宣传工作机制
宝山区销售软件开发
安徽华亿乐购网络技术
国家水稻数据库龙洋16
军人网络安全责任书
数据库数据推送技术
网络安全教育资料名称有哪些
sql数据库死锁解决
武汉达梦数据库市场占比
安卓软件开发有什么语言
查询数据库中哪个表数据量大
