使用RedisMessageListenerContainer扩展消费者

问题描述

我想增加RedisMessageListenerContainer上的消息侦听器的数量。 我的RedisConfig代码如下：

@Configuration
public class RedisConfig {

    @Bean
    MessageListener messageListener() {
        return new MessageListenerAdapter(new RedisMessageListener());
    }

    @Bean
    RedisMessageListenerContainer redisContainer() {
        final RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(jedisConnectionFactory());
        container.addMessageListener(messageListener(),topic());
        // here I want multiple copies of same messageListener bean registered
        return container;
    }

}

我可以使用RabbitMQ轻松扩展消费者，例如：

@Bean
    MessageListenerContainer messageListenerContainer() {
        SimpleMessageListenerContainer simpleMessageListenerContainer = new SimpleMessageListenerContainer(connectionFactory());
        simpleMessageListenerContainer.setQueues(myQueue());
        simpleMessageListenerContainer.setMessageListener(new RabbitMQListener());
        // here        
        simpleMessageListenerContainer.setConcurrentConsumers(CONSUMER_SIZE);
        return simpleMessageListenerContainer;
    }

我想要与RedisMessageListenerContainer相同的东西。我们如何订阅同一个bean的多个并发侦听器（MessageListener）？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）