4 SpringBoot整合RocketMQ实现消息发送和接收

忘是亡心i 2021-09-09 12:52 473阅读 0赞

我们使用主流的SpringBoot框架整合RocketMQ来讲解，使用方便快捷；

最终项目结构如下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBAamF2YTEyMzRf5bCP6ZSL_size_10_color_FFFFFF_t_70_g_se_x_16]

具体步骤如下：

## **第一步：我们新建一个父项目`rocketmq-test`,pom类型，主要是依赖管理，包括版本的管理，以及管理module子项目** ##

pom.xml：

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <packaging>pom</packaging>
        <modules>
            <module>rocketmq-provider</module>
            <module>rocketmq-consumer</module>
        </modules>
        <groupId>com.java1234</groupId>
        <artifactId>rocketmq-test2</artifactId>
        <version>1.0-SNAPSHOT</version>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <maven.compiler.source>1.8</maven.compiler.source>
            <maven.compiler.target>1.8</maven.compiler.target>
            <springboot.version>2.3.2.RELEASE</springboot.version>
            <rocketmq.version>2.2.0</rocketmq.version>
        </properties>
    
        <dependencyManagement>
    
            <dependencies>
    
                <dependency>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-dependencies</artifactId>
                    <version>${springboot.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
    
    
                <dependency>
                    <groupId>org.apache.rocketmq</groupId>
                    <artifactId>rocketmq-spring-boot-starter</artifactId>
                    <version>${rocketmq.version}</version>
                </dependency>
            </dependencies>
    
        </dependencyManagement>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

## **第二步：新建消息生产者`rocketmq-provider`子项目** ##

`pom.xml`加下依赖：

新建项目配置文件`application.yml`，指定name-server，以及producer-group组

rocketmq:
      name-server: 127.0.0.1:9876
      producer:
        group: producer-demo1

新建消息生产者Service类`ProducerService`

package com.java1234.rocketmq;
    
    import org.apache.rocketmq.spring.core.RocketMQTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    /** * 消息生产者 * @author java1234_小锋 * @site www.java1234.com * @company 南通小锋网络科技有限公司 * @create 2021-08-22 22:16 */
    @Component("producerService")
    public class ProducerService { 
    
        @Autowired
        private RocketMQTemplate rocketMQTemplate;
    
        /** * 发送简单消息 */
        public void sendMessage(){ 
            for(int i=0;i<10;i++){ 
                rocketMQTemplate.convertAndSend("java1234-rocketmq","rocketmq大爷，你好！"+i);
            }
        }
    }

SpringBoot给我们提供了`RocketMQTemplate`模板类，我们利用这个类可以以多种形式发送消息；

另外这个类我们要加下`@Component`注解，让Spring来管理实例，方便其他地方获取bean来使用；

发送方法指定Topic主题`java1234-rocketmq`；

启动类获取`ProducerService`实例，调用发送消息方法

package com.java1234;
    
    import com.java1234.rocketmq.ProducerService;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.context.ConfigurableApplicationContext;
    
    @SpringBootApplication
    public class RocketmqTestApplication { 
    
        public static void main(String[] args) { 
            ConfigurableApplicationContext run = SpringApplication.run(RocketmqTestApplication.class, args);
            ProducerService producerService = (ProducerService) run.getBean("producerService");
            producerService.sendMessage();
        }
    
    }

我们获取`ProducerService`实例，调用`sendMessage`方法发送消息；

## **第三步：新建消息消费者`rocketmq-consumer`子项目** ##

`pom.xml`加下依赖：

新建项目配置文件`application.yml`，指定name-server，以及consumer-group组

server:
      port: 8084
      servlet:
        context-path: /
    
    rocketmq:
      name-server: 127.0.0.1:9876
      consumer:
        group: consumer-demo1

新建消息消费者Service类`ConsumerService`，监听消息，消费消息

package com.java1234.rocketmq;
    
    import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
    import org.apache.rocketmq.spring.core.RocketMQListener;
    import org.springframework.stereotype.Component;
    
    /** * 消息消费者 * @author java1234_小锋 * @site www.java1234.com * @company 南通小锋网络科技有限公司 * @create 2021-08-22 22:40 */
    @RocketMQMessageListener(topic = "java1234-rocketmq",consumerGroup ="${rocketmq.consumer.group}" )
    @Component
    public class ConsumerService implements RocketMQListener<String> { 
    
        @Override
        public void onMessage(String s) { 
            System.out.println("收到消息内容："+s);
        }
    }

消费者类要实现`RocketMQListener`接口，以及动态指定消息类型String。

类上要加上\*\*@RocketMQMessageListener\*\*注解，指定topic主题`java1234-rocketmq`，以及消费者组`${rocketmq.consumer.group}`

同样这个类上也要加上`@Component`注解，让Spring来管理bean实例；

## **第四步：测试** ##

先启动`rocketmq-consumer`项目，监听消息  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBAamF2YTEyMzRf5bCP6ZSL_size_24_color_FFFFFF_t_70_g_se_x_16]

再启动`rockeqmq-provider`项目，发送消息  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBAamF2YTEyMzRf5bCP6ZSL_size_24_color_FFFFFF_t_70_g_se_x_16 1]

消息消费者端收到消息：

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-FHisxaxU-1629954682429)(C:\\Users\\java1234\\Desktop\\RocketMQ\\课件\\RocketMQ分布式消息队列课件.assets\\image-20210826130935332.png)\]][img-FHisxaxU-1629954682429_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826130935332.png]

测试OK，成功消费！

说明：这个是锋哥的RocketMQ备课笔记，等备课完，会发布配套的视频教程，如有需要，可以先加锋哥WX：java3459 欢迎白嫖

> 微信搜一搜公众号【java1234】关注这个放荡不羁的程序员，关注后回复【资料】有我准备的一线大厂笔试面试资料以及简历模板。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBAamF2YTEyMzRf5bCP6ZSL_size_10_color_FFFFFF_t_70_g_se_x_16]: /images/20210901/7afe4ad68d6c41158ff4248c966f5ac8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBAamF2YTEyMzRf5bCP6ZSL_size_24_color_FFFFFF_t_70_g_se_x_16]: /images/20210901/2d76b81c0c4f4ecaa2c9003625d0435b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBAamF2YTEyMzRf5bCP6ZSL_size_24_color_FFFFFF_t_70_g_se_x_16 1]: /images/20210901/6a9b2620c58d451384f76014eb0106e8.png
[img-FHisxaxU-1629954682429_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826130935332.png]: /images/20210901/55f93e794b3a4d969a7f144148dc2f01.png