RocketMQ集成Spring Cloud Config

痛定思痛。 2023-06-21 08:49 1阅读 0赞

# 前言 #

项目运行前需安装好RocketMQ与环境变量配置，对Rocket相关知识不熟悉的可按照以下文章顺序后再阅读该文：

*  [RocketMQ安装配置][RocketMQ]
 *  [RocketMQ概念模型][RocketMQ 1]
 *  [RocketMQ快速集成SpringBoot][RocketMQ_SpringBoot]

# 注册中心(eureka)模块 #

*  **依赖配置**：
    
        <dependencies>
              <dependency>
                  <groupId>org.springframework.cloud</groupId>
                  <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
              </dependency>
          </dependencies>
        
        
          <dependencyManagement>
              <dependencies>
                  <dependency>
                      <groupId>org.springframework.cloud</groupId>
                      <artifactId>spring-cloud-dependencies</artifactId>
                      <version>Greenwich.SR1</version>
                      <type>pom</type>
                      <scope>import</scope>
                  </dependency>
              </dependencies>
          </dependencyManagement>
 *  **application.yml**(正常情况建议eureka放到bootstrap.yml中)：
    
        server:
          port: 8000
        eureka:
          client:
            service-url:
              defaultZone: http://localhost:${server.port}/eureka
            fetch-registry: false
            register-with-eureka: false
        spring:
          application:
            name: registry-center
 *  **EurekaApplication**
    
        @SpringBootApplication
        @EnableEurekaServer
        public class EurekaApplication {
            public static void main(String[] args) {
                SpringApplication.run(EurekaApplication.class);
            }
        }

# 配置中心模块 #

*  **依赖配置：**
    
        <dependencies>
              <dependency>
                  <groupId>org.springframework.cloud</groupId>
                  <artifactId>spring-cloud-config-server</artifactId>
              </dependency>
              <dependency>
                  <groupId>org.springframework.cloud</groupId>
                  <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
              </dependency>
          </dependencies>
        
          <dependencyManagement>
              <dependencies>
                  <dependency>
                      <groupId>org.springframework.cloud</groupId>
                      <artifactId>spring-cloud-dependencies</artifactId>
                      <version>Greenwich.SR1</version>
                      <type>pom</type>
                      <scope>import</scope>
                  </dependency>
              </dependencies>
          </dependencyManagement>
 *  **application.yml**
    
        server:
          port: 8001
        spring:
          application:
            name: config-center
 *  **bootstrap.yml**
    
        spring:
          cloud:
            config:
              server:
        	git:
        	  uri: https://gitee.com/Wilson-He/spring-boot-series.git
        	  username: Wilson-He
        	  force-pull: true
        	  password:
        	  # 配置文件在uri下的目录
        	  search-paths: /config-server-properties
        eureka:
          client:
            service-url:
              defaultZone: http://localhost:8000/eureka
 *  **ConfigServerApplication**
    
        @SpringBootApplication
         @EnableDiscoveryClient
         @EnableConfigServer
         public class ConfigServerApplication {
             public static void main(String[] args) {
                 SpringApplication.run(ConfigServerApplication.class, args);
             }
         }
 *  **配置文件**  
    在\{spring.cloud.git.uri去.git\}/\{spring.cloud.git.search-paths\}下添加配置文件，如上例添加的配置文件目录路径为https://gitee.com/Wilson-He/spring-boot-series下的config-server-properties目录，在项目中添加配置文件**rocketmq-test.properties**：
    
        rocketmq.topic=spring-boot-topic
          rocketmq.name-server=127.0.0.1:9876
          rocketmq.topic.user=spring-cloud-user-topic
          rocketmq.topic.order=spring-cloud-order-topic
          rocketmq.consumer-group.user=spring-cloud-user-group
          rocketmq.consumer-group.order=spring-cloud-order-group

# 生产者模块 #

*  **依赖配置**
    
        <dependencies>
              <dependency>
                  <groupId>org.springframework.boot</groupId>
                  <artifactId>spring-boot-starter-web</artifactId>
              </dependency>
              <dependency>
                  <groupId>org.springframework.cloud</groupId>
                  <artifactId>spring-cloud-starter-config</artifactId>
              </dependency>
              <dependency>
                  <groupId>org.springframework.cloud</groupId>
                  <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
              </dependency>
              <dependency>
                  <groupId>org.apache.rocketmq</groupId>
                  <artifactId>rocketmq-spring-boot-starter</artifactId>
              </dependency>
          </dependencies>
 *  **application.yml**
    
        server:
          port: 9990
        spring:
          application:
            name: spring-cloud-producer
        rocketmq:
          producer:
            group: spring-cloud-producer
          name-server: 127.0.0.1:9876
 *  **bootstrap.yml**
    
        eureka:
          client:
            service-url:
              defaultZone: http://localhost:8000/eureka
        spring:
          cloud:
            config:
              discovery:
                enabled: true
                service-id: config-center
              # 加载配置中心目录下的资源文件rocketmq-test.properties
              name: rocketmq
              profile: test
 *  **CloudProducerApplication**
    
        @SpringBootApplication
          @EnableDiscoveryClient
          public class CloudProducerApplication {
              public static void main(String[] args) {
                  SpringApplication.run(CloudProducerApplication.class, args);
              }
          }
 *  **MessageSenderController**
    
        @RestController
          @RequestMapping("/send")
          public class MessageSenderController {
              @Resource
              private RocketMQTemplate rocketMQTemplate;
          
              @Value("${rocketmq.topic.user}")
              private String userTopic;
              @Value("${rocketmq.topic.order}")
              private String orderTopic;
          
              @GetMapping("/user")
              public String sendUser(@RequestParam String msg) {
                  rocketMQTemplate.send(userTopic, MessageBuilder.withPayload(msg).build());
                  return "send user success";
              }
          
              @GetMapping("/order")
              public String sendOrder(@RequestParam String msg) {
                  rocketMQTemplate.send(orderTopic, MessageBuilder.withPayload(msg).build());
                  return "send order success";
              }

# 消费者模块 #

*  **application.yml**
    
        server:
          port: 10000
        spring:
          application:
            name: spring-cloud-consumer
    
    由于配置了注册中心，`@RocketMQMessageListener`注解的`name-server`默认配置值为`${rocketmq.name-server:}`，所以只要配置中心含`rocketmq.name-server`的配置即可省略consumer的name-server配置，前文的rocketmq-test.properties已配置了该属性。
 *  **bootstrap.yml文件同Producer**
 *  ***消息监听器***
    
     *  OrderRocketMQListener
        
            @Slf4j
            @RocketMQMessageListener(consumerGroup = "${rocketmq.consumer-group.order}", topic = "${rocketmq.topic.order}")
            @Service
            public class OrderRocketMQListener implements RocketMQListener<MessageExt> {
                @Override
                public void onMessage(MessageExt message) {
                    log.info("order msg id: {}, payload: {}", message.getMsgId(), new String(message.getBody()));
                }
            }
     *  UserRocketMQListener
        
            @Slf4j
            @RocketMQMessageListener(consumerGroup = "${rocketmq.consumer-group.user}", topic = "${rocketmq.topic.user}")
            @Service
            public class UserRocketMQListener implements RocketMQListener<MessageExt> {
                @Override
                public void onMessage(MessageExt message) {
            	log.info("user msg id: {}, payload: {}", message.getMsgId(), new String(message.getBody()));
                }
            }
     *  CloudConsumerApplication
        
            @SpringBootApplication
            @EnableDiscoveryClient
            public class CloudConsumerApplication {
                public static void main(String[] args) {
            	SpringApplication.run(CloudConsumerApplication.class, args);
                }
            }

# 运行测试 #

1.  运行NameServer:`mqnamesrv`
2.  运行Broker:`mqbroker -n 127.0.0.1:9876`
3.  运行EurekaApplication
4.  运行ConfigServerApplication
5.  运行CloudConsumerApplication
6.  运行CloudProducerApplication
7.  打开`http://localhost:8000`查看应用服务是否已成功注册到注册中心  
    ![eureka][]
8.  调用CloudProducerApplication信息发送接口进行测试  
    `http://localhost:9990/send/user?msg=user msg`  
    `http://localhost:9990/send/order?msg=order msg`  
    可以看到CloudConsumerApplication控制台打印出Listener接收到的消息：  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3oyODEyNjMwOA_size_16_color_FFFFFF_t_70]

# 附 #

项目地址：[spring-rocketmq][]

[RocketMQ]: https://blog.csdn.net/z28126308/article/details/103487960
[RocketMQ 1]: https://blog.csdn.net/z28126308/article/details/103489318
[RocketMQ_SpringBoot]: https://blog.csdn.net/z28126308/article/details/103489099
[eureka]: https://img-blog.csdnimg.cn/2019121210153694.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3oyODEyNjMwOA==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3oyODEyNjMwOA_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191212102759455.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3oyODEyNjMwOA==,size_16,color_FFFFFF,t_70
[spring-rocketmq]: https://github.com/Wilson-He/spring-boot-series/tree/master/spring-rocketmq