rocketmq demo

首先下载rocketmq，启动需要指定rocketmq home目录

cd github

代码结构代码 收藏代码

依赖：

xml代码 收藏代码

conf.properties

类似于zookeeper的服务：

java代码 收藏代码

broker:

consumer:

producer:

修改namesrvstartup,brokerstartup中的配置文件路径，依次启动namesrvstartup,brokerstartup,consumer,producer.