本文主要是介绍手拉手RocketMQ消息跟踪与acl权限控制，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
| 环境介绍 | |
| 技术栈 | springboot+mybatis-plus+mysql+rocketmq |
| 软件 | 版本 |
| mysql | 8 |
| IDEA | IntelliJ IDEA 2022.2.1 |
| JDK | 17 |
| Spring Boot | 3.1.7 |
| dynamic-datasource | 3.6.1 |
| mybatis-plus | 3.5.3.2 |
| rocketmq | 4.9.4 |
RocketMQ开启消息跟踪
消息轨迹简单来说就是日志，其把消息的生产、存储、消费等所有的访问和操作日志。
RocketMQ消息轨迹的优劣：
优势：
实时监控：消息轨迹可以实时记录消息的发送、消费等关键事件，提供实时监控和追踪能力，方便运维人员进行故障排查和性能优化。
故障定位：通过消息轨迹，可以准确地定位消息在整个消息队列系统中的位置，帮助快速定位故障点，提高故障排查效率。
业务分析：消息轨迹可以提供详细的消息流转信息，帮助业务人员进行数据分析和业务监控，了解消息的处理情况和延迟情况。
劣势：
存储开销：消息轨迹需要记录大量的消息流转信息，会增加存储开销。对于大规模的消息系统，可能需要额外的存储资源来支持消息轨迹功能。
网络开销：消息轨迹需要将消息流转信息发送到监控系统或存储系统，会增加网络开销。对于高并发的消息系统，可能会对网络带宽和性能造成一定影响
1.修改配置文件broker.conf ，添加traceTopicEnable=true
2.重启broker
3.生产者开启消息轨迹
enable-msg-trace: true
@Test
void sendTraceMsg() {
/**
* 发送同步消息
* destination 目的地-主题
* payload 消息
*/
rocketMQTemplate.syncSend("traceTopicTest", "轨迹消息");
}
MQ面板消息查询
24098A55348F66E0F191D52199A60918544063947C6B8FF3FF1D0000
4.消费者开启消息轨迹
开启消息轨迹，增加开销，性能下降
@Component
@RocketMQMessageListener(topic = "traceTopicTest",
consumerGroup = "traceConsumerGroup-springboot",
enableMsgTrace = true //开启消息轨迹，增加开销，性能下降
)
public class traceMQListener implements RocketMQListener<MessageExt> {
/**
* onMessage 消费者方法
* @param messages 消息内容
*/
@Override
public void onMessage(MessageExt messages) {
//不报错就是签收信息，
//报错就是重试，重试三次后还是报错，就代表消费失败，会重新入队 （根据yml配置）
System.out.println("接收到消息："+new String(messages.getBody()));
}
}
RocketMQ开启用户acl权限控制
RocketMQ支持通过ACL（Access Control List）权限控制来保护消息队列的安全性
vim broker.conf
aclEnable=true
配置账号密码
vim plain_acl.yml
开启管理员账号
开启用户acl权限控制需要重启mqnamesrv
生产者
yml配置用户名密码连接RocketMQ
producer:
#用户名+密码
access-key: rocketmq2
secret-key: 12345678
消费者
yml配置用户名密码连接RocketMQ
consumer:
#用户名+密码
access-key: rocketmq2
secret-key: 12345678
rocketmq-dashboard-1.0.0 配置key
rocketmq-dashboard-1.0.0开启用户登入
这篇关于手拉手RocketMQ消息跟踪与acl权限控制的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
