RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。本文介绍如何在业务系统中使用RocketMQ消费消息。
工具/原料
java
maven
编写消息消费模板代码
1、添加maven依赖，我们使用4.5.1版本
2、新建MessageConsumer接口，用来管理消费者生命周期：创建--消费--销毁，消息使用泛型，不同的业务通过泛型接入。
3、新建消息消费者配置类
4、新建基于rocketmq的消息消费懋鲕壶迎基类RocketMQMessageConsumer，定义必要的属性：consumer是rocketmq的消费者对象，entityClass是泛型类型，topic是订阅的主题，tag是消息过滤的标签
5、编写RocketMQMessageConsumer的构造方法，首先做一些必要的参数校验，然后找到泛型的类型，最后初始化rocketmq的对象consumer
6、编写start方法，使用consumer订阅对应的topic和tag，然后注册一个回调接口，根据回调接口回传的消息，通过泛型类型解析，然后回调onMessage方法
7、编写shutdown方法
编写业务消息消费代码
1、编写一个OrderMessage对象，表示订单消息
2、新建一个OrderMessageConsumer对象，继承RocketMQMessageConsumer，泛型为OrderMessage，实现onMessage，业务逻辑就在这个方法内实现
3、配置spring文件，首先配置一个RocketMQMessageConfig对象，里面存放通用的配置，然后配置一个OrderMessageConsumer对象，传入group、topic、tag等参数，init-method配置start方法，destroy-method配置shutdown方法
