网站建设小结,施工企业财务经理年终总结,0基础学习网站开发,wordpress无觅关联插件原文链接#xff1a;ttps://mp.weixin.qq.com/s/IYdo_suKvvReqCiEKjCeHw 第一步下载若依项目 第二步安装rocketMq#xff08;推荐在linux使用docker部署比较快#xff09; 第二步新建一个生产者模块儿#xff0c;再建一个消费者模块
第四步在getway模块中配置接口映射规…原文链接ttps://mp.weixin.qq.com/s/IYdo_suKvvReqCiEKjCeHw 第一步下载若依项目 第二步安装rocketMq推荐在linux使用docker部署比较快 第二步新建一个生产者模块儿再建一个消费者模块
第四步在getway模块中配置接口映射规则 第五步添加依赖生产者和消费者他们的rocketmq依赖一样 dependencygroupIdorg.apache.rocketmq/groupIdartifactIdrocketmq-spring-boot-starter/artifactId# 选择适宜你的版本就好了我的若依项目版本是3.6.3version2.0.2/version/dependency第六步添加配置 生产者的
# Tomcat
server:port: 10301# Spring
spring: application:# 应用名称name: mq-producerprofiles:# 环境配置active: devcloud:nacos:discovery:# 服务注册地址server-addr: 127.0.0.1:9849config:# 配置中心地址server-addr: 127.0.0.1:9849# 配置文件格式file-extension: yml# 共享配置shared-configs:- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
rocketmq:name-server: 192.168.94.130:9876producer:# 发送同一类消息的设置为同一个group保证唯一group: springboot_producer_group# 发送消息超时时间默认3000sendMessageTimeout: 10000# 发送消息失败重试次数默认2retryTimesWhenSendFailed: 2# 异步消息重试此处默认2retryTimesWhenSendAsyncFailed: 2# 消息最大长度默认1024 * 1024 * 4(默认4M)maxMessageSize: 4096# 压缩消息阈值默认4k(1024 * 4)compressMessageBodyThreshold: 4096# 是否在内部发送失败时重试另一个broker默认falseretryNextServer: false
# stream:
# bindings:
# ## 新版本固定格式 函数名-{out/in}-{index}
# demoChannel-out-0:
# destination: stream-test-topic
# rocketmq:
# binder:
# name-server: 192.168.94.130:9876
消费者的
# Tomcat
server:port: 10302# Spring
spring: application:# 应用名称name: mq-consumerprofiles:# 环境配置active: devcloud:nacos:discovery:# 服务注册地址server-addr: 127.0.0.1:9849config:# 配置中心地址server-addr: 127.0.0.1:9849# 配置文件格式file-extension: yml# 共享配置shared-configs:- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
rocketmq:consumer:group: springboot_consumer_group# 一次拉取消息最大值注意是拉取消息的最大值而非消费最大值pull-batch-size: 10name-server: 192.168.94.130:9876逻辑代码 生产消息的代码
package com.zhj.mqproducer.controller;import lombok.Setter;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;import org.springframework.messaging.Message;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import javax.annotation.Resource;RestController
RequestMapping(/mqpro)
public class SendMessageController {Setter(onMethod_ Autowired)private RocketMQTemplate rocketmqTemplate;GetMapping(/test)public String test() {MessageString msg MessageBuilder.withPayload(Hello,RocketMQ).build();rocketmqTemplate.send(eatfan, msg);return haha;}}
消费消息的代码
package com.zhj.mqconsumer.domain;import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;Component
RocketMQMessageListener(topic eatfan, consumerGroup consumer-zhj2)
public class MyConsumer implements RocketMQListenerString {Overridepublic void onMessage(String message) {// 处理消息的逻辑System.out.println(Received message: message);}
}
在浏览器地址中输入如图信息发送消息 控制台查看输出
