赞
踩
官方文档:https://github.com/apache/rocketmq/tree/master/docs/cn
官方下载:https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.7.0/rocketmq-all-4.7.0-bin-release.zip
需要java环境为前提:
1、下载后解压;2、增加环境变量
ROCKETMQ_HOME=E:\Develop\rocketmq47
NAMESRV_ADDR=localhost:9876
3、启动程序,注意在rocketmq47目录操作,否则可能提示成功但是不可用
启动nameServer
start .bin\mqnamesrv.cmd
启动broker
start .bin\mqbroker.cmd -n localhoost:9876 autoCreateTopicEnable=true
4、下载编译mq-console
源码路径:
https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console
编译后拷贝到rocketmq47便于后期使用
启动访问:java -jar rocketmq-console-ng-1.0.1.jar
注意端口及路径,本机做了修改:http://localhost:8080/rocketmq/#/
接下来就可以在界面上做各种操作了;
5、代码demo验证
生产者:
public class SyncProducer {
public static void main(String[] args) throws Exception {
// 实例化消息生产者Producer
DefaultMQProducer producer = new DefaultMQProducer(<
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。