/rabbitmq-consumer-demo

rabbitmq consumer demo

Primary LanguageJava

需求

上游系统同步用户信息过来,消息是用户的增删改,也就是有序的。

消息的可靠性

设置手动签收模式,默认是自动签收的。业务处理成功手动签收,异常直接重试、丢弃、异常记录等。

消息的有序性

无论是生产者通过id hash分到不同队列,还是消费者内部通过id hash分到同一个线程。想要保证一组消息的消费的有序性,那么一个队列只能由一个消费者消费。应用多实例的情况下,可设置队列是独占的,当前消费者下线后才会选取下一个消费者。