• ADADADADAD

    如何监听redis消息队列[ 建站问答 ]

    建站问答 时间:2024-12-01 19:16:22

    作者:文/会员上传

    简介:

    监听redis消息队列的示例:springBoot实现redis发布式监听消息队列,定时器监听不同功能的消息,代码:import org.springframework.context.annotation.Bean;import org.springfram

    以下为本文的正文内容,内容仅供参考!本站为公益性网站,复制本文以及下载DOC文档全部免费。

    监听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消息队列.docx

    将本文的Word文档下载到电脑

    推荐度:

    下载