作者:施自扬 微信号:shiziyangwx
rocketMQ 使用idea源码解析启动
1. git clone 代码
链接: githup地址
2. 使用idea打开
![在这里插入图片描述](https://img-blog.csdnimg.cn/be66dd88d7a64e909de36483b16d9cf9.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YW46I-c6bG877yIc3p577yJ,size_20,color_FFFFFF,t_70,g_se,x_16) 各个代码包的功能
- acl:权限控制模块
- broker: broker 模块(broke 启动进程)
- client :消息客户端,包含消息生产者、消息消费者相关类
- common :公共包
- dev :开发者信息(非源代码)
- distribution :部署实例文件夹(非源代码)
- docs:很多官方文档。虽然不是源码,但很重要。强烈建议通读一遍。
- example: RocketMQ 例代码
- filter :消息过滤相关基础类
- logappender:日志实现相关类
- namesrv:NameServer实现相关类(NameServer启动进程)
- openmessageing:消息开放标准
- remoting:远程通信模块,基于Netty。
- srcutil:服务工具类
- store:消息存储实现相关类
- style:checkstyle相关实现
- test:测试相关类
- tools:工具类,监控命令相关实现类
3.启动NameSrv
- 先建一个conf目录,存放需要的配置文件。
- 将rocketmq-distribution->conf中的broker.conf,logback_broker.xml,logback_namesrv.xml复制到创建的conf下
![在这里插入图片描述](https://img-blog.csdnimg.cn/26dcc924f446449e830b21ceacdb1386.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YW46I-c6bG877yIc3p577yJ,size_20,color_FFFFFF,t_70,g_se,x_16) - 启动配置 将新创建的conf配置到变量上
![在这里插入图片描述](https://img-blog.csdnimg.cn/9d8096ff1f3a4d37ae3db2e1a55853e6.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YW46I-c6bG877yIc3p577yJ,size_20,color_FFFFFF,t_70,g_se,x_16) - 启动完成
![在这里插入图片描述](https://img-blog.csdnimg.cn/234cad30f1b84fa59899b8411b068856.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YW46I-c6bG877yIc3p577yJ,size_20,color_FFFFFF,t_70,g_se,x_16)
启动Broker
- 修改conf文件
任意目录创建一个data文件,我直接在broker项目下创建了 ![在这里插入图片描述](https://img-blog.csdnimg.cn/7e9612d684a546b3a5516504612b17f0.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YW46I-c6bG877yIc3p577yJ,size_20,color_FFFFFF,t_70,g_se,x_16) 更改broker.conf配置文件
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
# namesrvAddr地址
namesrvAddr=127.0.0.1:9876
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
autoCreateTopicEnable=true
#### 配置为上面设置的文件夹路径
# 存储路径
storePathRootDir=/Users/shiziyang/IdeaProjects/rocketmq-all-4.9.2/broker/data/dataDir
# commitLog路径
storePathCommitLog=/Users/shiziyang/IdeaProjects/rocketmq-all-4.9.2/broker/data/dataDir/commitlog
# 消息队列存储路径
storePathConsumeQueue=/Users/shiziyang/IdeaProjects/rocketmq-all-4.9.2/broker/data/dataDir/consumequeue
# 消息索引存储路径
storePathIndex=/Users/shiziyang/IdeaProjects/rocketmq-all-4.9.2/broker/data/dataDir/index
# checkpoint文件路径
storeCheckpoint=/Users/shiziyang/IdeaProjects/rocketmq-all-4.9.2/broker/data/dataDir/checkpoint
# abort文件存储路径
abortFile=/Users/shiziyang/IdeaProjects/rocketmq-all-4.9.2/broker/data/dataDir/abort
- 启动配置
第一个框为上边修改的broker.conf配置文件路径 ![在这里插入图片描述](https://img-blog.csdnimg.cn/4002eaa52da849f4a3c181e216925b63.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YW46I-c6bG877yIc3p577yJ,size_20,color_FFFFFF,t_70,g_se,x_16) - 启动完成
![在这里插入图片描述](https://img-blog.csdnimg.cn/5bf78c4f18ca45d48239ca7188efcc3a.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YW46I-c6bG877yIc3p577yJ,size_20,color_FFFFFF,t_70,g_se,x_16) - 验证
发送消息 -配置namesrvAddr -启动main方法是否能发送成功 ![在这里插入图片描述](https://img-blog.csdnimg.cn/dc609445d08e4c65ac84b07c3f501c8e.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YW46I-c6bG877yIc3p577yJ,size_20,color_FFFFFF,t_70,g_se,x_16) 消费消息 -配置namesrvAddr -启动main方法是否能消费到 ![在这里插入图片描述](https://img-blog.csdnimg.cn/20e7ddbfdc4c451bb8eeb92881a6c81e.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YW46I-c6bG877yIc3p577yJ,size_20,color_FFFFFF,t_70,g_se,x_16)
springboot引入rocketMQ
1.创建一个springboot项目
2.pom引入
<!--rocketmq-->
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.1.1</version>
</dependency>
3.发送消息
package com.mq.controller;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class MqMessageController {
@Autowired
private RocketMQTemplate rocketMQTemplate;
@RequestMapping(value = "/pushMessage",method = RequestMethod.GET)
public String get(@RequestParam("id") int id) {
rocketMQTemplate.convertAndSend("test-topic", "你好,rocketmq:" + id);
return "success";
}
}
4.消费消息
package com.mq.consumer;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
@Component
@RocketMQMessageListener(topic = "test-topic",consumerGroup = "my-consumer-group")
@Slf4j
public class MqConsumer implements RocketMQListener<String> {
@Override
public void onMessage(String message) {
System.out.println(message);
}
}
5.验证
![在这里插入图片描述](https://img-blog.csdnimg.cn/f26b1238764a41f8ab5b870292069952.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YW46I-c6bG877yIc3p577yJ,size_20,color_FFFFFF,t_70,g_se,x_16) ![在这里插入图片描述](https://img-blog.csdnimg.cn/fe76870fe93548a396824c5b2e3e2da8.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YW46I-c6bG877yIc3p577yJ,size_20,color_FFFFFF,t_70,g_se,x_16)
监控界面RocketMQ-Console使用idea源码解析启动
1.下载代码
链接: RocketMQ-Console的githup地址
2.使用idea打开
![在这里插入图片描述](https://img-blog.csdnimg.cn/d99e29e9badf455bb9f01587aa1c8385.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YW46I-c6bG877yIc3p577yJ,size_20,color_FFFFFF,t_70,g_se,x_16)
3.更改配置文件
![在这里插入图片描述](https://img-blog.csdnimg.cn/536809a64630469babe0d2b66107c08f.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YW46I-c6bG877yIc3p577yJ,size_20,color_FFFFFF,t_70,g_se,x_16)
4.启动
![在这里插入图片描述](https://img-blog.csdnimg.cn/5f8aa3f64ef9497dae2d809d71a74605.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YW46I-c6bG877yIc3p577yJ,size_20,color_FFFFFF,t_70,g_se,x_16)
5.验证
浏览器访问:http://localhost:8080 ![在这里插入图片描述](https://img-blog.csdnimg.cn/c80bcdcdb8c74f779bde25b662008920.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YW46I-c6bG877yIc3p577yJ,size_20,color_FFFFFF,t_70,g_se,x_16)
|