如何实现RocketMQ消息的生产与消费Demo示例？

本文共计1998个文字，预计阅读时间需要8分钟。

我们展示了针对消息排序、定时消息、批量消息和过滤消息的处理demo，便于后续CV。消息排序的生产与消费：消息排序是指消息消费时按照特定的顺序进行处理。排序消息是指出发时按顺序发送，消费时也会按照这个顺序进行消费。RocketMQ可以确保先发送先消费的原则。

我们对顺序消息，延时消息，批量消息，过滤消息进行一个demo,方便以后cv。

顺序消息的生产与消费

顺序消息是指当消息消费的时候，会按照消息发送的顺序进行消费。RocketMQ可以保证消息严格的有序，这里分为全局有序和分区有序。 全局有序是针对所有消息的，每一个消息都按照绝对的先入先出原则。 分区有序，是指将需要有序的消息控制发送到同一个Queue上，消费的时候从这个Queue上拉取。即相对每个Queue是有序的。

全局有序

控制Topic指定只有一个队列，并且保证生产者与消费者只有一个就可以了

分区有序

要完成分区有序性，在生产者环节使用自定义的消息队列选择策略，我们以下单为例，我们需要确保订单号尾数相同的消息会被先后发送到同一个队列中，然后再消费端开启负载均衡模式，每个消费者只消费一个队列。最终确保一个消费者拿到的消息对于一个订单来说是有序的。

也就是说，需要自定义规则使得同一个订单的或者同一个业务逻辑的消息发送到同一个消息队列，再让一个消费者去消费的时候，就是顺序消费了。