java中如何使用rocketmq进行消息消费

RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。本文介绍如何在业务系统中使用RocketMQ消费消息。

工具/原料

java

maven

编写消息消费模板代码

1、添加maven依赖，我们使用4.5.1版本

3、新建消息消费者配置类

5、编写RocketMQMessageConsumer的构造方法，首先做一些必要的参数校验，然后找到泛型的类型，最后初始化rocketmq的对象consumer

7、编写shutdown方法

2、新建一个OrderMessageConsumer对象，继承RocketMQMessageConsumer，泛型为OrderMessage，实现onMessage，业务逻辑就在这个方法内实现