消息队列RocketMQ实践

RocketMQ服务启动

1. NameServer 启动在/bin 目录下，双击mqnamesrv.cmd 启动

   

2. broker 启动

        默认双击mqbroker.cmd 启动会在其他端口上，这里使用 命令方式，将broker启动在9876端口：

mqbroker -n localhost:9876

普通收发消息实战

第一套input，output

定制第二套input,output

需要自定义source和sink。

Dashboard 控制台

控制台这里为了跟踪源码，暂时使用源码启动的方式运行：

官方下载源码：GitHub - apache/rocketmq-dashboard: The state-of-the-art Dashboard of Apache RoccketMQ provides excellent monitoring capability. Various graphs and statistics of events, performance and system information of clients and application is evidently made available to the user.

然后导入本地IDEA中。

修改配置文件

然后在启动类中启动：

跟踪消息收发轨迹

引入轨迹的目的

• 轨迹是实实在在存在的话，那么就可以避免一些相互“扯皮”的情况
• 证实生产者是否发送了消息，也可以证实消费者是否消费了消息
• 通过轨迹，轨迹就需要有轨迹应该体现的信息：
  • 从哪里来
  • 什么时间来
  • 停留在哪里
  • 停留的时间
  • 去向哪里
  • 去向的时间是多少
  • 整条消息消耗的时间是多少

如何使用轨迹

1. 先启动MQ