RocketMq的控制台安装以及RocketMqTemplate的使用

跟别的mq一样，RocketMq也有自己的控制台，本章讲解控制台的安装以及在实际开发中RocketMq的使用。

1、RocketMq控制台安装

首先进入github中RocketMq控制台的源码中：添加链接描述

将其下载下来，如图：可以直接通过down的方式也可以通过git去拉，这里简单为主就直接下载了，如图：

下载好了之后解压到我们本地，目录是这样的：

然后进入rockemq-console，这个就是我们控制台的源码了，在使用之前需要修改一下console中的配置，配置成我们自己的rocketmq-server的地址。找到如下图所示的配置文件：

然后进入修改成我们自己的rocketmq地址：

修改好了之后，接下来就是给console打个包，然后运行起来就可以使用了。
打包命令：
mvn clean package -Dmaven.test.skip=true

在rocketmq-console目录中就可以看到新生成的target文件夹：进去就是打好的rocketmq-console-ng-2.0.0.jar包.


然后在运行上一步打好的jar包: 命令

java -jar rocketmq-console-ng-2.0.0.jar

运行成功后，访问http://localhost:8080/ 就可以看到rocketmq的控制台了。如图：

2、RocketMqTemplate使用

在实际开发中Rocketmq一般都使用RocketMqTemplate在发送和消费消息。在使用时先准备好环境配置：

2.1 安装spring-rocketmq的本地仓库
打开rocketmq-spring在github的开源地址 https://github.com/apache/rocketmq-spring
将其下载然后通过mvn打包到本地：

mvn install -Dmaven.skip.test=true

2.2 新增依赖

    <dependency>
           <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-spring-boot-starter</artifactId>
            <version>2.0.4</version>
        </dependency>

2.3 在yml配置文件中添加rocketmq的配置

rocketmq:
  name-server: 192.168.2.107:9876
  producer:
    group: my-group

2.4 书写一个测试类 ProducerTest

package com.yangguotest.learning;

import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest(classes = LearningApplication.class)
public class ProducerTest {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    @Test
    public void testMq(){
        rocketMQTemplate.convertAndSend("springboot-rocketmq","hello mq");
    }
}

运行测试类，执行成功，去控制台看一下是否有这个topic.

使用rocketMQTemplate消息发送成功。over，下一章继续深入学习rocketmq。谁让我司要用呢！哎，我只想划水的