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

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方法