使用Spring Data Redis的Redis Pub / Sub：消息以错误的顺序到达

我正在尝试使用Redis发布/订阅Spring Data Redis来实现聊天.

我使用RedisTemplate发布消息,如下所示：

public class RedisPublisher {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    public void publish(ChannelTopic channelTopic, Object channelMessage) {
        redisTemplate.convertAndSend(channelTopic.getTopic(), channelMessage);
    }
}

为了接收消息,我有一个MessageListener,如下所示：

public class RedisConsumer implements MessageListener {

MessageSerializer serializer = new MessageSerializer();
AtomicInteger atomicInteger = new AtomicInteger(0);

@Override
public void onMessage(Message message, byte[] pattern) {

    Object obj = serializer.deserialize(message.getBody());
    if(obj != null && obj instanceof RedisMessage) {
        System.err.println("Received message(" + atomicInteger.incrementAndGet() + ") " + obj.toString());
    }

}

消息的发布方式如下：

final ChannelTopic channelTopic=connectionManager.subscribe("topic");
    new Thread(new Runnable() {
        public void run() {                
            Thread.sleep(5000);                
            for (int i = 0; i < 10; i++) {
                redisPublisher.publish(channelTopic, new RedisMessage(i + 1));
            }
        }
    }).run();

但是,收到的消息似乎以错误的顺序传递：

Received message(1) message id: 3
Received message(2) message id: 2
Received message(3) message id: 1
Received message(4) message id: 4
Received message(5) message id: 5
Received message(6) message id: 6
Received message(7) message id: 7
Received message(8) message id: 8
Received message(9) message id: 9
Received message(10) message id: 10

是否可以使用Spring提供的RedisTemplate / MessageListener同步发送/接收消息？

目前的代码库很小,可以在GitHub查看.

解决方法:

众所周知,Redis PubSub按顺序传递消息(至少在使用一个连接并触发PUBLISH时保证.PUBLISH命令返回已通知的客户端数).无序的原因是Spring Data Redis默认调度消息的方式.通知是在不同的线程上处理的,这就是原因.感谢您的代码,它帮助我快速重现行为.

我可以想到两种可能的策略来解决这个问题：

>但是,您可以提供在RedisMessageListenerContainer中遵守订单的执行程序.现在,我正在考虑的任何形式的同步都会损害性能.
>在BinaryJedisPubSub之上实现自己的消息监听器.您可以控制消息,并且可以省略执行程序问题.

HTH,马克

标签：java,spring,redis,spring-data-redis
来源： https://codeday.me/bug/20190519/1136815.html