rocketmq搭建启动集成springboot落地并监控

拼搏现实的明天。 2023-10-03 22:37 9阅读 0赞

**目录**

一、rocketmq服务器搭建启动：

二、springboot 集成rocketmq落地：

三、可视化页面集成：

--------------------

rocketmq是最近很流行的消息中间件，有很多的优点，比如多个topic也不会引起性能问题；今天我们开始搭建启动集成springboot落地：

## 一、rocketmq服务器搭建启动： ##

官网上进行下载 ：https://github.com/apache/rocketmq/releases 我们选择4.9.1版本，或者点击

[Index of /dist/rocketmq/4.9.1][Index of _dist_rocketmq_4.9.1]

1、解压到一个无中文无空格的目录下，解压后目录如下：

![8a5894b76ae84affba16f0207cca2cd7.png][]

**注意：解压到一个无中文无空格的目录下，否则会有各种意想不到的错误**。

2、调整堆内存大小：把Xms、Xmx、-Xmn都设置成512m

打开runserver.cmd：

![0281f2b6a70d4c78b1fc14a40d2f5281.png][]

这里%CLASSPATH%要加个双引号，不然启动时会找不到jdk

打开runbroker.cmd:

![608b537874cf461aab1ba6a0fae165d2.png][]  
此处添加 ‐Drocketmq.broker.diskSpaceWarningLevelRatio=0.99的意思是：把Broker磁盘空间利用率设置为99%，默认是85%。

3、启动NameServer ：进入bin目录，执行 start mqnamesrv.cmd

![b0fd56efd3774a19b43add9403953926.png][]

以上说明启动成功

4、启动broker：进入bin目录，执行 mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true，此处的autoCreateTopicEnable=true 也可以添加到配置文件broker.conf中，意思是自动生成topic，测试环境可以开启！线上环境尽量关闭！

![421735aa02364e3281e798e9611d3ea1.png][]

启动成功显示：

![5fba9b653a9547128868fa9a0705122f.png][]

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、消息轨迹配置：  
打开消息轨迹功能，需要在broker.conf中打开一个关键配置：

traceTopicEnable=true

8、关闭命令：

# 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版本如下：

![32d63625ccf4472f8afb0bfd1d5535a8.png][]

2、核心配置文件：最基础的配置

rocketmq.name-server=127.0.0.1:9876
    rocketmq.producer.group=springBootGroup
    server.port=8081

3、生产者生产消息

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服务：生产消息

生产调用：

![3185974abb824c42bec077b1bb069761.png][]

消费显示：

![82fee0260780408196f5926413007ddb.png][]

## 三、可视化页面集成： ##

RocketMQ源代码中并没有提供控制台，但是有一个Rocket的社区扩展项目中提供  
了一个控制台，地址： https://github.com/apache/rocketmq-dashboard  
下载下来后，解压并进入对应的目录

1、使用maven进行编译

mvn clean package -Dmaven.test.skip=true

2、执行jar:

编译完成后，获取target下的jar包，就可以直接执行。但是这个时候要注意，在这  
个项目的application.yml中需要指定nameserver的地址。默认这个属性是指向本  
地。如果配置为空，会读取环境变量NAMESRV\_ADDR。  
那我们可以在jar包的当前目录下增加一个application.yml文件，覆盖jar包中默认的  
一个属性：

java -jar rocketmq-dashboard-1.0.1-SNAPSHOT.jar

3、启动完成后，可以访问 [http://127.0.0.1:8080/][http_127.0.0.1_8080] 看到管理页面

![b1ab2eed5471425d9acf6d0da2971053.png][]

上面有多个菜单，可以点击一一查看，均为监控指标！

到此，rocketmq整个使用流程分享完毕，下篇我们更深入分析其原理和高级功能，敬请期待！

[Index of _dist_rocketmq_4.9.1]: https://archive.apache.org/dist/rocketmq/4.9.1/
[8a5894b76ae84affba16f0207cca2cd7.png]: https://img-blog.csdnimg.cn/8a5894b76ae84affba16f0207cca2cd7.png
[0281f2b6a70d4c78b1fc14a40d2f5281.png]: https://img-blog.csdnimg.cn/0281f2b6a70d4c78b1fc14a40d2f5281.png
[608b537874cf461aab1ba6a0fae165d2.png]: https://img-blog.csdnimg.cn/608b537874cf461aab1ba6a0fae165d2.png
[b0fd56efd3774a19b43add9403953926.png]: https://img-blog.csdnimg.cn/b0fd56efd3774a19b43add9403953926.png
[421735aa02364e3281e798e9611d3ea1.png]: https://img-blog.csdnimg.cn/421735aa02364e3281e798e9611d3ea1.png
[5fba9b653a9547128868fa9a0705122f.png]: https://img-blog.csdnimg.cn/5fba9b653a9547128868fa9a0705122f.png
[32d63625ccf4472f8afb0bfd1d5535a8.png]: https://img-blog.csdnimg.cn/32d63625ccf4472f8afb0bfd1d5535a8.png
[3185974abb824c42bec077b1bb069761.png]: https://img-blog.csdnimg.cn/3185974abb824c42bec077b1bb069761.png
[82fee0260780408196f5926413007ddb.png]: https://img-blog.csdnimg.cn/82fee0260780408196f5926413007ddb.png
[http_127.0.0.1_8080]: http://127.0.0.1:8080/
[b1ab2eed5471425d9acf6d0da2971053.png]: https://img-blog.csdnimg.cn/b1ab2eed5471425d9acf6d0da2971053.png