windows搭建RocketMQ服务

一、下载二进制程序包
在官网选择编译后的压缩包下载
http://rocketmq.apache.org/release_notes/release-notes-4.2.3/
或者去apache存档库中下载
http://archive.apache.org/dist/rocketmq/4.2.3/

下载好的文件： rocketmq-all-4.2.3-bin-release.zip

将下载好的zip包解压，注意路径也不要包含空格。
二、修改rocketmq配置
这一步也可以跳过，但有可能会因为内存设置过大导致一系列的问题

需要执行的命令都在程序目录下的bin文件夹下，主要是mqnamesrv.cmd和mqbroker.cmd这两个命令，但他们又都各自调用了runserver.cmd和runbroker.cmd命令，分别修改这两个文件里的JAVA_OPT设置，如下

set “JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m”
1
将 Xms Xmx 这两个值改小一些，改为1g，如:

set "JAVA_OPT=%JAVA_OPT% -server -Xms1g -Xmx1g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=32

三、启动 NameServer
在rocketmq安装目录下的bin目录下，执行命令：

mqnamesrv.cmd -n localhost:9876
1
出现The Name Server boot success.字样表示成功

四、启动 Broker
在rocketmq安装目录下的bin目录下，执行命令：

mqbroker.cmd -n localhost:9876

五、java示例代码
添加maven依赖

	<dependency>
			<groupId>org.apache.rocketmq</groupId>
			<artifactId>rocketmq-client</artifactId>
			<version>4.3.2</version>
		</dependency>

org.apache.rocketmq rocketmq-client 4.3.2

package cn.itcast.rocketmq;

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.remoting.common.RemotingHelper;

public class SyncProducer {
	public static void main(String[] args) throws Exception {
//Instantiate with a producer group name.
		DefaultMQProducer producer = new DefaultMQProducer("test-group");
// Specify name server addresses.
		producer.setNamesrvAddr("127.0.0.1:9876");
//Launch the instance.
		producer.start();
		for (int i = 0; i < 100; i++) {
//Create a message instance, specifying topic, tag and message body.
			Message msg = new Message("TopicTest11" /* Topic */, "TagA" /* Tag */,
					("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET) /* Message body */
			);
//Call send message to deliver message to one of brokers.
			SendResult sendResult = producer.send(msg);
			System.out.printf("%s%n", sendResult);
		}
//Shut down once the producer instance is not longer in use.
		producer.shutdown();
	}
}

六、搭建RocketMQ web控制台
1、访问 https://github.com/apache/rocketmq-externals/ ，
使用git将代码clone下来

2、修改项目配置信息
这是一个用springboot编写的工程，进入到 rocketmq-externals\rocketmq-console\src\main\resources 目录下，编辑 application.properties 文件， 修改mq的连接地址信息：

rocketmq.config.namesrvAddr=localhost:9876
1
3、启动项目
在rocketmq-externals\rocketmq-console目录下，执行：

mvn spring-boot:run
1
等待启动成功。