美文网首页
一、rocketmq idea环境搭建

一、rocketmq idea环境搭建

作者: 捞月亮的阿汤哥 | 来源:发表于2019-06-15 12:04 被阅读0次

1. 下载源码

找一个目录,git https://github.com/apache/rocketmq.git将源码导入到本地。

2. 用idea打开

用idea打开rocketmq所在目录,idea会自动解决项目依赖。

3. 启动NamesrvStartup

双击shift键,在tab框里输入NamesrvStartup,打开,然后点击右上角的debug按钮启动。

4. 启动BrokerStartup

点击右上角的edit configuration按钮,然后在BrokerStartup启动配置项中配置namesrv地址,如下图所示:


捕获.PNG

5. 运行官方样例

在rocketmq-example的模块中,
1) 打开quickstart的Producer

  • 修改producer group的名字
DefaultMQProducer producer = new DefaultMQProducer("p1");
  • 修改namesrv的地址
producer.setNamesrvAddr("127.0.0.1:9876");
  • 然后运行这个样例

2) 打开quickstart的Consumer

  • 修改consumer group的name
//理解下rocketmq中的broadcasting和clustering的两种模式
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("c1");
  • 修改namesrv的地址
consumer.setNamesrvAddr("localhost:9876");
  • 订阅producer中发送的topic和tag
    *表示所有tag
consumer.subscribe("TopicTest", "*");
  • 运行这个样例
  1. 其他
    可以下载https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console,这是一个可视化的图形界面,可以查看topic,发送的消息等内容非常的方便。

7. 快速执行本地rocketmq脚本
如果你不想源码启动nameserver和broker,只是想学习client的用法的话,具体如下。

alias mqstart="/Users/zihao/Documents/servers/rocketmq-all-4.3.1-bin-release/bin/mqnamesrv &;/Users/zihao/Documents/servers/rocketmq-all-4.3.1-bin-release/bin/mqbroker -c /Users/zihao/Documents/servers/rocketmq-all-4.3.1-bin-release/conf/broker.conf &;nohup java -jar /Users/zihao/Documents/servers/rocketmq-externals-master/rocketmq-console/target/rocketmq-console-ng-1.0.1.jar &"
  • 关闭脚本命令 mqstop
    效果就是关掉namesrv,broker和控制台
alias mqstop="/Users/zihao/Documents/servers/rocketmq-all-4.3.1-bin-release/bin/mqshutdown broker;/Users/zihao/Documents/servers/rocketmq-all-4.3.1-bin-release/bin/mqshutdown namesrv;sh /Users/zihao/Documents/servers/rocketmq-all-4.3.1-bin-release/bin/mqconsoleshutdown.sh"

mqconsoleshutdown脚本

#!/usr/bin/env bash 
pid=`jps -m|grep 'rocketmq-console'|awk '{print $1}'`
if [ -n "$pid" ]
then
   echo "kill rocketmq-console-jar,pid:" $pid
   kill -9 $pid
fi
  • 刷新配置文件
source .zprofile

相关文章

网友评论

      本文标题:一、rocketmq idea环境搭建

      本文链接:https://www.haomeiwen.com/subject/fvxbfctx.html