2022
我们一起努力

如何监听redis消息队列

监听redis消息队列的示例:

springBoot实现redis发布式监听消息队列,定时器监听不同功能的消息,代码:

import org.springframework.context.annotation.Bean;

import org.springframework.data.redis.connection.RedisConnectionFactory;

import org.springframework.data.redis.listener.PatternTopic;

import org.springframework.data.redis.listener.RedisMessageListenerContainer;

import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;

import org.springframework.stereotype.Component;

@Component

public class RedisMessageListener {

private static final String RECEIVE_NAME = "test";

/**

* 监听quest1信息

*/

@Bean

public MessageListenerAdapter quest1() {

return new MessageListenerAdapter(new quest1(), RECEIVE_NAME);

}

/**

* 定义消息监听者容器

* @param connectionFactory 连接工厂

* @param quest1 监听quest1

* @return RedisMessageListenerContainer

*/

@Bean

public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,

MessageListenerAdapter quest1) {

RedisMessageListenerContainer listenerContainer = new RedisMessageListenerContainer();

listenerContainer.setConnectionFactory(connectionFactory);

listenerContainer.addMessageListener(接收消息--quest1, new PatternTopic("消息key"));

return listenerContainer;

}

}

赞(0)
文章名称:《如何监听redis消息队列》
文章链接:https://www.fzvps.com/28722.html
本站文章来源于互联网,如有侵权,请联系管理删除,本站资源仅供个人学习交流,请于下载后24小时内删除,不允许用于商业用途,否则法律问题自行承担。
图片版权归属各自创作者所有,图片水印出于防止被无耻之徒盗取劳动成果的目的。

评论 抢沙发

评论前必须登录!