目录
一、rocketmq服务器搭建启动：
二、springboot 集成rocketmq落地：
三、可视化页面集成：
rocketmq是最近很流行的消息中间件，有很多的优点，比如多个topic也不会引起性能问题；今天我们开始搭建启动集成springboot落地：
一、rocketmq服务器搭建启动：
1、解压到一个无中文无空格的目录下，解压后目录如下：
注意：解压到一个无中文无空格的目录下，否则会有各种意想不到的错误。
2、调整堆内存大小：把Xms、Xmx、-Xmn都设置成512m
打开runserver.cmd：
这里%CLASSPATH%要加个双引号，不然启动时会找不到jdk
打开runbroker.cmd:
此处添加 ‐Drocketmq.broker.diskSpaceWarningLevelRatio=0.99的意思是：把Broker磁盘空间利用率设置为99%，默认是85%。
3、启动NameServer ：进入bin目录，执行 start mqnamesrv.cmd
以上说明启动成功
4、启动broker：进入bin目录，执行 mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true，此处的autoCreateTopicEnable=true 也可以添加到配置文件broker.conf中，意思是自动生成topic，测试环境可以开启！线上环境尽量关闭！
启动成功显示：
5、测试生产信息：进入cmd命令窗口，执行
set NAMESRV_ADDR=127.0.0.1:9876
tools.cmd org.apache.rocketmq.example.quickstart.Producer此处会产生1000条消息
6、测试消费信息 ：进入cmd命令窗口，执行
set NAMESRV_ADDR=127.0.0.1:9876
tools.cmd org.apache.rocketmq.example.quickstart.Consumer此处会消费1000条信息
7、关闭命令：
# 1.关闭NameServer
sh bin/mqshutdown namesrv
# 2.关闭Broker
sh bin/mqshutdown broker二、springboot 集成rocketmq落地：
1、相关jar包引入
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.2.1</version>
<exclusions>
<exclusion>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</exclusion>
<exclusion>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
</exclusion>
<exclusion>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
</exclusion>
</exclusions>
</dependency>对应的mq版本如下：
2、核心配置文件：最基础的配置
rocketmq.name-server=127.0.0.1:9876
rocketmq.producer.group=springBootGroup
server.port=80813、生产者生产消息
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.apache.rocketmq.spring.support.RocketMQHeaders;
import org.springframework.messaging.Message;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
/**
* @author ：nandao
**/
@Component
public class SpringProducer {
@Resource
private RocketMQTemplate rocketMQTemplate;
public void sendMessage(String topic,String msg){
this.rocketMQTemplate.convertAndSend(topic,msg);
}
}
调用入口：
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
/**
* @author ：nandao
* @description:
**/
@RestController
@RequestMapping("/MQTest")
public class MQTestController {
private final String topic = "TestTopic";
@Resource
private SpringProducer producer;
@RequestMapping("/sendMessage")
public String sendMessage(String message){
producer.sendMessage(topic,message);
return "消息发送完成";
}
}4、消费者监听
import org.apache.rocketmq.spring.annotation.ConsumeMode;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
/**
* @RocketMQMessageListener 注解可以详细了解
* @author ：nandao
**/
@Component
@RocketMQMessageListener(consumerGroup = "MyConsumerGroup", topic = "TestTopic",consumeMode= ConsumeMode.CONCURRENTLY)
public class SpringConsumer implements RocketMQListener<String> {
@Override
public void onMessage(String message) {
System.out.println("consumer message : "+ message);
}
}5、启动boot服务：生产消息
生产调用：
消费显示：
三、可视化页面集成：
RocketMQ源代码中并没有提供控制台，但是有一个Rocket的社区扩展项目中提供
了一个控制台，地址： https://github.com/apache/rocketmq-dashboard
下载下来后，解压并进入对应的目录
1、使用maven进行编译
mvn clean package -Dmaven.test.skip=true2、执行jar:
编译完成后，获取target下的jar包，就可以直接执行。但是这个时候要注意，在这
个项目的application.yml中需要指定nameserver的地址。默认这个属性是指向本
地。如果配置为空，会读取环境变量NAMESRV_ADDR。
那我们可以在jar包的当前目录下增加一个application.yml文件，覆盖jar包中默认的
一个属性：
java -jar rocketmq-dashboard-1.0.1-SNAPSHOT.jar3、启动完成后，可以访问 http://127.0.0.1:8080/ 看到管理页面
上面有多个菜单，可以点击一一查看，均为监控指标！
到此，rocketmq整个使用流程分享完毕，下篇我们更深入分析其原理和高级功能，敬请期待！
