RocketMq的用法示例

这篇文章主要为大家展示了"RocketMq的用法示例"，内容简而易懂，条理清晰，希望能够帮助大家解决疑惑，下面让小编带领大家一起研究并学习一下"RocketMq的用法示例"这篇文章吧。

1.搭建rocketmq服务

下载: https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.5.1/rocketmq-all-4.5.1-bin-release.zip

# 解压至: /usr/local/rocketmq-all-4.5.1-bin-release# 启动/关闭服务:     rocketmq        # 启动:            /usr/local/rocketmq-all-4.5.1-bin-release/bin/mqnamesrv -c /usr/local/rocketmq-all-4.5.1-bin-release/conf/namesrv.properties -n "192.168.1.180:6500" &            # 设置自定义端口: 6500            -n /usr/local/rocketmq-all-4.5.1-bin-release/conf/namesrv.properties            # 文件内容是:                 listenPort=6600        # 关闭:             /usr/local/rocketmq-all-4.5.1-bin-release/bin/mqshutdown namesrv    mqbroker:        # 启动:  autoCreateTopicEnable=true(允许微服务创建topic)            /usr/local/rocketmq-all-4.5.1-bin-release/bin/mqbroker -n "192.168.1.180:6500" autoCreateTopicEnable=true &        # 关闭:         /usr/local/rocketmq-all-4.5.1-bin-release/bin/mqshutdown broker

2.生产者-微服务(发送-队列消息)

# 消息体-对象:@Data@Builder@ToStringpublic class MemberMoneyMessage {    int memberId;    String event;    double money;}# 发送消息:@AutowiredRocketMQTemplate rocketMQTemplate;....rocketMQTemplate.convertAndSend(            "member-money-act",            MemberMoneyMessage.builder()                    .event("pay-order")                    .memberId(50)                    .money(100)                    .build()    );....配置rocket服务端:rocketmq:name-server: tsca.cc:6600producer:    group: tsca-group

3.消费者-微服务(处理-队列消息)

# 监听处理(发送方的member-money-act和接收方的member-money-act一样便能接收):@Service@RocketMQMessageListener(consumerGroup = "tsca-group",topic = "member-money-act")@Slf4jpublic class MemberMoneyMqListener implements RocketMQListener {    @Override    public void onMessage(MemberMoneyMessage memberMoneyMessage) {        log.info("收到-用户余额变动");        log.info(JSON.toJSONString(memberMoneyMessage));    }}# 配置:rocketmq:    name-server: tsca.cc:6600    producer:        group: tsca-group

4.搭建: rocketmq-控制台

# 1.下载源码git clone https://github.com/apache/rocketmq-externals.git# 2.用IDEA打开【rocketmq-console】项目，修改pom文件 rocketmq版本 (2-1).更改pom文件的rocketmq版本:4.4.0# 改为:4.5.1 (2-2).更改代码:org/apache/rocketmq/console/service/impl/MessageServiceImpl.java# 92,93 rowsDefaultMQPullConsumer consumer = new DefaultMQPullConsumer(MixAll.TOOLS_CONSUMER_GROUP, null);改为:RPCHook rpcHook = null;DefaultMQPullConsumer consumer = new DefaultMQPullConsumer(MixAll.TOOLS_CONSUMER_GROUP, rpcHook);# 3.更改配置# 当前网页控制台端口server.port=6650# rocketmq服务端口rocketmq.config.namesrvAddr=192.168.1.180:6600# 4.编译打包mvn clean package -DskipTests# 5.运行java -jar -Dserver.port=6650 -Drocketmq.config.namesrvAddr=192.168.1.180:6600 rocketmq-console-ng-1.0.1.jar

以上是"RocketMq的用法示例"这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注行业资讯频道！