Canal解析binlog日志信息按顺序发到MQ的队列中。
现在是要保证消费端如何按顺序消费队列中的消息。
解决方法：
多个jvm进程监听同一个队列保证只有消费者活跃，即只有一个消费者接收消息。
队列需要增加x-single-active-consumer参数，值为true，表示否启用单一活动消费者模式。
消费队列中的数据使用单线程。
在监听队列的java代码中指定消费线程为1，如下图：
Canal解析binlog日志信息按顺序发到MQ的队列中。
现在是要保证消费端如何按顺序消费队列中的消息。
解决方法：
多个jvm进程监听同一个队列保证只有消费者活跃，即只有一个消费者接收消息。
队列需要增加x-single-active-consumer参数，值为true，表示否启用单一活动消费者模式。
消费队列中的数据使用单线程。
在监听队列的java代码中指定消费线程为1，如下图：
