个人域名用来做淘宝客网站,长沙网,地图网站 源码,网上买保险哪个平台好文章目录 一、安装1.1、下载RocketMQ1.2、将下载包上传到linux中#xff0c;然后解压1.3、修改runserver.sh的jvm参数大小#xff08;根据自己服务器配置来修改#xff09;1.4、启动mqnamesrv #xff08;类似于注册中心#xff09;1.5、修改runbroker.sh的jvm参数大小然后解压1.3、修改runserver.sh的jvm参数大小根据自己服务器配置来修改1.4、启动mqnamesrv 类似于注册中心1.5、修改runbroker.sh的jvm参数大小根据自己服务器配置来修改1.6、修改broker.conf1.7、启动broker节点 二、springboot中的使用2.1、pom.xml中添加依赖2.2、application.yml配置2.3、生产者模板类2.4、消费者模板类2.5、消息调用测试2.6、成功案例 前言rocketmq-all-5.3.0-bin-release.zip版本为例
一、安装
1.1、下载RocketMQ
下载地址https://rocketmq.apache.org/
1.2、将下载包上传到linux中然后解压
解压命令
unzip rocketmq-all-5.3.0-bin-release.zip1.3、修改runserver.sh的jvm参数大小根据自己服务器配置来修改
# 在rocketmq-all-5.3.0-bin-release/bin下修改
vim runserver.sh# 修改jvm大小如果服务器支持这么大的可以不用修改
# 将以下
JAVA_OPT${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize128m -XX:MaxMetaspaceSize320m
# 修改为
JAVA_OPT${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize128m -XX:MaxMetaspaceSize320m1.4、启动mqnamesrv 类似于注册中心
# 在rocketmq-all-5.3.0-bin-release/bin中启动
nohup ./mqnamesrv 1.5、修改runbroker.sh的jvm参数大小根据自己服务器配置来修改
# 在rocketmq-all-5.3.0-bin-release/bin下修改
vim runbroker.sh# 修改jvm大小如果服务器支持这么大的可以不用修改
# 将以下
JAVA_OPT${JAVA_OPT} -server -Xms4g -Xmx4g
# 修改为
JAVA_OPT${JAVA_OPT} -server -Xms512m -Xmx512m1.6、修改broker.conf
# 在rocketmq-all-5.3.0-bin-release/conf下修改
vim broker.conf# 将以下参数加在文件最下方
# 自动创建topic
autoCreateTopicEnable true
# namesrv注册地址
namesrvAddrlocalhost:98761.7、启动broker节点
# 在rocketmq-all-5.3.0-bin-release/bin中启动
nohup ./mqbroker -c ../conf/broker.conf 二、springboot中的使用
2.1、pom.xml中添加依赖
dependencygroupIdorg.apache.rocketmq/groupIdartifactIdrocketmq-spring-boot-starter/artifactIdversion2.1.1/version
/dependency2.2、application.yml配置
rocketmq:name-server: 192.168.103.81:9876producer:group: my-consumer_testconsumer:group: my-consumer_test2.3、生产者模板类
package com.yhgc.rocket;
import org.apache.rocketmq.spring.annotation.ExtRocketMQTemplateConfiguration;
import org.apache.rocketmq.spring.core.RocketMQTemplate;/*** author 王青松*/
ExtRocketMQTemplateConfiguration(nameServer ${rocketmq.name-server})
public class ExtRocketMQTemplate extends RocketMQTemplate {
}2.4、消费者模板类
package com.yhgc.rocket;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service;
Service
RocketMQMessageListener(topic testTopic, consumerGroup my-consumer_test)
public class TestConsumer implements RocketMQListenerString {Overridepublic void onMessage(String s) {System.out.println(Received message: s);}
}2.5、消息调用测试
package com.yhgc.controller;
import com.alibaba.fastjson.JSONObject;
import com.yhgc.rocket.ExtRocketMQTemplate;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpServletRequest;RestController
RequestMapping(/test1)
public class TestController {Autowiredprivate ExtRocketMQTemplate rocketMQTemplate;RequestMapping(/t2)ResponseBodypublic JSONObject t2(){rocketMQTemplate.convertAndSend(testTopic, Hello, RocketMQ!);JSONObject res new JSONObject();res.put(code,200);res.put(msg,调用成功);return res;}
}2.6、成功案例
