RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件,支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。本文介绍如何在业务系统中使用RocketMQ消费消息。
工具/原料
java
maven
编写消息消费模板代码
1、添加maven依赖,我们使用4.5.1版本

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

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

7、编写shutdown方法

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