参考官网教程 https://rocketmq.apache.org/docs/quick-start/
记录问题在此,除此之外和教程流程一样
linux下搭建
遇到的问题
broker启动不起来
nohup日志是
xxxx/distribution/target/apache-rocketmq/bin/runbroker.sh: line 62: 126674 Killed $JAVA ${JAVA_OPT} $@
这种
应该是服务器有什么监控线程,看对应的runbroker.sh 怀疑是里面jvm空间分配需求较大导致
全部改小即可解决
RemotingConnectException: connect to <> failed
之前broker没有关闭干净
需要确保进程kill干净(实测broker应该是启动了两个进程)
windows下搭建
有几点要注意
Start Name Server步骤前,配置环境变量

我的机器是
E:\work\openSource\RocketMQ\incubator-rocketmq\distribution\target\apache-rocketmq
启动mq Name Server 和broker

遇到的问题
No name server address, please set it.
自己导入工程,找到 org.apache.rocketmq.example.quickstart.Producer 这个类,运行出现上述错误
看代码,以及参照http://blog.csdn.net/xiaoshunzi111/article/details/50219009
发现有

自己加一行 producer.setNamesrvAddr("127.0.0.1:9876");
运行成功.
同样的 在org.apache.rocketmq.example.quickstart.Consumer也加上consumer.setNamesrvAddr("127.0.0.1:9876");
执行效果

备注:日志在
C:\Users\xxx\logs\rocketmqlogs
refer
http://www.jianshu.com/p/3afd610a8f7d
https://rocketmq.apache.org/docs/quick-start/
http://blog.csdn.net/xiaoshunzi111/article/details/50219009
网友评论