监听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;
}
}
了解更多如何监听redis消息队列相关的解答,就上多想派(www.duoxiangpai.com)。
本文章由用户本地宝分享,版权归原作者,如侵犯,请联系(点这里联系),经核实,我们将第一时间删除。如若转载,请注明出处:https://www.duoxiangpai.com/64335.html