消息总线

Posted dalaoyang

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了消息总线相关的知识，希望对你有一定的参考价值。

SpringCloudBus：事件、消息总线，用于在集群（例如，配置变化事件）中传播状态变化，可与Spring Cloud Config联合实现热部署。

在上一篇写出了springcloud对微服务的集中配置，那么就出现了一个问题，如果修改配置了怎么实现不需重启服务来实现配置的更新，下面有集中解决方法。

1.使用/refresh手动刷新配置

缺点：单点刷新，如果集群服务多的话，无论是工作量还是维护上都十分麻烦。

使用上一篇的config-client服务，加入依赖，

 
   
   
 
    
  
    
    
  
  1. spring-boot-starter-actuator
    2.

pom文件如下：

 
   
   
 
    
  
    
    
  
  1. <?xml version="1.0" encoding="UTF-8"?>
    2. 
  
    
    
  
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    3. 
  
    
    
  
  3.     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    4. 
  
    
    
  
  4.     <modelVersion>4.0.0</modelVersion>
    5. 
  
    
    
  
    6. 
  
    
    
  
  6.     <groupId>com.dalaoyang</groupId>
    7. 
  
    
    
  
  7.     <artifactId>springcloud_config_client</artifactId>
    8. 
  
    
    
  
  8.     <version>0.0.1-SNAPSHOT</version>
    9. 
  
    
    
  
  9.     <packaging>jar</packaging>
    10. 
  
    
    
  
    11. 
  
    
    
  
  11.     <name>springcloud_config_client</name>
    12. 
  
    
    
  
  12.     <description>springcloud_config_client</description>
    13. 
  
    
    
  
    14. 
  
    
    
  
  14.     <parent>
    15. 
  
    
    
  
  15.         <groupId>org.springframework.boot</groupId>
    16. 
  
    
    
  
  16.         <artifactId>spring-boot-starter-parent</artifactId>
    17. 
  
    
    
  
  17.         <version>1.5.9.RELEASE</version>
    18. 
  
    
    
  
  18.         <relativePath/> <!-- lookup parent from repository -->
    19. 
  
    
    
  
  19.     </parent>
    20. 
  
    
    
  
    21. 
  
    
    
  
  21.     <properties>
    22. 
  
    
    
  
  22.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    23. 
  
    
    
  
  23.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    24. 
  
    
    
  
  24.         <java.version>1.8</java.version>
    25. 
  
    
    
  
  25.         <spring-cloud.version>Edgware.SR1</spring-cloud.version>
    26. 
  
    
    
  
  26.     </properties>
    27. 
  
    
    
  
    28. 
  
    
    
  
  28.     <dependencies>
    29. 
  
    
    
  
  29.         <dependency>
    30. 
  
    
    
  
  30.             <groupId>org.springframework.cloud</groupId>
    31. 
  
    
    
  
  31.             <artifactId>spring-cloud-starter-eureka</artifactId>
    32. 
  
    
    
  
  32.         </dependency>
    33. 
  
    
    
  
    34. 
  
    
    
  
  34.         <dependency>
    35. 
  
    
    
  
  35.             <groupId>org.springframework.boot</groupId>
    36. 
  
    
    
  
  36.             <artifactId>spring-boot-starter-test</artifactId>
    37. 
  
    
    
  
  37.             <scope>test</scope>
    38. 
  
    
    
  
  38.         </dependency>
    39. 
  
    
    
  
    40. 
  
    
    
  
  40.         <dependency>
    41. 
  
    
    
  
  41.             <groupId>org.springframework.cloud</groupId>
    42. 
  
    
    
  
  42.             <artifactId>spring-cloud-starter-config</artifactId>
    43. 
  
    
    
  
  43.         </dependency>
    44. 
  
    
    
  
    45. 
  
    
    
  
  45.         <dependency>
    46. 
  
    
    
  
  46.             <groupId>org.springframework.boot</groupId>
    47. 
  
    
    
  
  47.             <artifactId>spring-boot-starter-actuator</artifactId>
    48. 
  
    
    
  
  48.         </dependency>
    49. 
  
    
    
  
    50. 
  
    
    
  
  50.     </dependencies>
    51. 
  
    
    
  
    52. 
  
    
    
  
  52.     <dependencyManagement>
    53. 
  
    
    
  
  53.         <dependencies>
    54. 
  
    
    
  
  54.             <dependency>
    55. 
  
    
    
  
  55.                 <groupId>org.springframework.cloud</groupId>
    56. 
  
    
    
  
  56.                 <artifactId>spring-cloud-dependencies</artifactId>
    57. 
  
    
    
  
  57.                 <version>${spring-cloud.version}</version>
    58. 
  
    
    
  
  58.                 <type>pom</type>
    59. 
  
    
    
  
  59.                 <scope>import</scope>
    60. 
  
    
    
  
  60.             </dependency>
    61. 
  
    
    
  
  61.         </dependencies>
    62. 
  
    
    
  
  62.     </dependencyManagement>
    63. 
  
    
    
  
    64. 
  
    
    
  
  64.     <build>
    65. 
  
    
    
  
  65.         <plugins>
    66. 
  
    
    
  
  66.             <plugin>
    67. 
  
    
    
  
  67.                 <groupId>org.springframework.boot</groupId>
    68. 
  
    
    
  
  68.                 <artifactId>spring-boot-maven-plugin</artifactId>
    69. 
  
    
    
  
  69.             </plugin>
    70. 
  
    
    
  
  70.         </plugins>
    71. 
  
    
    
  
  71.     </build>
    72. 
  
    
    
  
    73. 
  
    
    
  
    74. 
  
    
    
  
  74. </project>
    75.

在Controller类上加入@RefreshScope注解，由于上一篇controller写在了启动类上，所以直接加在启动类上，代码如下：

 
   
   
 
    
  
    
    
  
  1. package com.dalaoyang;
    2. 
  
    
    
  
    3. 
  
    
    
  
  3. import org.springframework.beans.factory.annotation.Value;
    4. 
  
    
    
  
  4. import org.springframework.boot.SpringApplication;
    5. 
  
    
    
  
  5. import org.springframework.boot.autoconfigure.SpringBootApplication;
    6. 
  
    
    
  
  6. import org.springframework.cloud.context.config.annotation.RefreshScope;
    7. 
  
    
    
  
  7. import org.springframework.web.bind.annotation.RequestMapping;
    8. 
  
    
    
  
  8. import org.springframework.web.bind.annotation.RestController;
    9. 
  
    
    
  
    10. 
  
    
    
  
  10. @SpringBootApplication
    11. 
  
    
    
  
  11. @RestController
    12. 
  
    
    
  
  12. @RefreshScope
    13. 
  
    
    
  
  13. public class SpringcloudConfigClientApplication {
    14. 
  
    
    
  
    15. 
  
    
    
  
  15.     public static void main(String[] args) {
    16. 
  
    
    
  
  16.         SpringApplication.run(SpringcloudConfigClientApplication.class, args);
    17. 
  
    
    
  
  17.     }
    18. 
  
    
    
  
    19. 
  
    
    
  
    20. 
  
    
    
  
  20.     @Value("${title}")
    21. 
  
    
    
  
  21.     String title;
    22. 
  
    
    
  
    23. 
  
    
    
  
  23.     @RequestMapping("/getTitle")
    24. 
  
    
    
  
  24.     public String getTitle(){
    25. 
  
    
    
  
  25.         return title;
    26. 
  
    
    
  
  26.     }
    27. 
  
    
    
  
    28. 
  
    
    
  
  28. }
    29.

配置文件新增配置management.security.enabled=false，在刷新时关闭安全验证。

代码如下：

 
   
   
 
    
  
    
    
  
  1. spring.application.name=config-client
    2. 
  
    
    
  
  2. spring.cloud.config.label=master
    3. 
  
    
    
  
  3. spring.cloud.config.profile=test
    4. 
  
    
    
  
  4. spring.cloud.config.uri= http://localhost:9000/
    5. 
  
    
    
  
    6. 
  
    
    
  
  6. 
  
    
    
  
  7. eureka.client.service-url.defaultZone=http://eureka.dalaoyang.cn/eureka/
    8. 
  
    
    
  
    9. 
  
    
    
  
  9. ## 刷新时，关闭安全验证
    10. 
  
    
    
  
  10. management.security.enabled=false
    11.

分别启动项目config-server，config-client。访问http://localhost:8080/getTitle，结果如下图

修改git上配置，修改为dalaoyangtestchange，在次请求，结果没有改变，使用postman或者其他工具post请求http://localhost:8080/getTitle看到返回如下结果。

消息总线

在次访问http://localhost:8080/getTitle，如下图

消息总线

2.使用springcloudbus刷新配置

springcloudbus需要使用轻量消息代理，本文使用rabbitmq，启动rabbitmq如下图：

消息总线

访问http://localhost:15672/#/如下图

消息总线

新建项目springcloud_bus，同时改造config-client，pom文件加入bus依赖，代码如下：

 
   
   
 
    
  
    
    
  
  1. <?xml version="1.0" encoding="UTF-8"?>
    2. 
  
    
    
  
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    3. 
  
    
    
  
  3.     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    4. 
  
    
    
  
  4.     <modelVersion>4.0.0</modelVersion>
    5. 
  
    
    
  
    6. 
  
    
    
  
  6.     <groupId>com.dalaoyang</groupId>
    7. 
  
    
    
  
  7.     <artifactId>springcloud_bus</artifactId>
    8. 
  
    
    
  
  8.     <version>0.0.1-SNAPSHOT</version>
    9. 
  
    
    
  
  9.     <packaging>jar</packaging>
    10. 
  
    
    
  
    11. 
  
    
    
  
  11.     <name>springcloud_bus</name>
    12. 
  
    
    
  
  12.     <description>springcloud_bus</description>
    13. 
  
    
    
  
    14. 
  
    
    
  
  14.     <parent>
    15. 
  
    
    
  
  15.         <groupId>org.springframework.boot</groupId>
    16. 
  
    
    
  
  16.         <artifactId>spring-boot-starter-parent</artifactId>
    17. 
  
    
    
  
  17.         <version>1.5.9.RELEASE</version>
    18. 
  
    
    
  
  18.         <relativePath/> <!-- lookup parent from repository -->
    19. 
  
    
    
  
  19.     </parent>
    20. 
  
    
    
  
    21. 
  
    
    
  
  21.     <properties>
    22. 
  
    
    
  
  22.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    23. 
  
    
    
  
  23.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    24. 
  
    
    
  
  24.         <java.version>1.8</java.version>
    25. 
  
    
    
  
  25.         <spring-cloud.version>Edgware.SR1</spring-cloud.version>
    26. 
  
    
    
  
  26.     </properties>
    27. 
  
    
    
  
    28. 
  
    
    
  
  28.     <dependencies>
    29. 
  
    
    
  
  29.         <dependency>
    30. 
  
    
    
  
  30.             <groupId>org.springframework.cloud</groupId>
    31. 
  
    
    
  
  31.             <artifactId>spring-cloud-starter-eureka</artifactId>
    32. 
  
    
    
  
  32.         </dependency>
    33. 
  
    
    
  
    34. 
  
    
    
  
  34.         <dependency>
    35. 
  
    
    
  
  35.             <groupId>org.springframework.boot</groupId>
    36. 
  
    
    
  
  36.             <artifactId>spring-boot-starter-test</artifactId>
    37. 
  
    
    
  
  37.             <scope>test</scope>
    38. 
  
    
    
  
  38.         </dependency>
    39. 
  
    
    
  
    40. 
  
    
    
  
  40.         <dependency>
    41. 
  
    
    
  
  41.             <groupId>org.springframework.cloud</groupId>
    42. 
  
    
    
  
  42.             <artifactId>spring-cloud-starter-config</artifactId>
    43. 
  
    
    
  
  43.         </dependency>
    44. 
  
    
    
  
    45. 
  
    
    
  
  45.         <dependency>
    46. 
  
    
    
  
  46.             <groupId>org.springframework.boot</groupId>
    47. 
  
    
    
  
  47.             <artifactId>spring-boot-starter-actuator</artifactId>
    48. 
  
    
    
  
  48.         </dependency>
    49. 
  
    
    
  
    50. 
  
    
    
  
  50.         <dependency>
    51. 
  
    
    
  
  51.             <groupId>org.springframework.cloud</groupId>
    52. 
  
    
    
  
  52.             <artifactId>spring-cloud-starter-bus-amqp</artifactId>
    53. 
  
    
    
  
  53.         </dependency>
    54. 
  
    
    
  
  54.     </dependencies>
    55. 
  
    
    
  
    56. 
  
    
    
  
  56.     <dependencyManagement>
    57. 
  
    
    
  
  57.         <dependencies>
    58. 
  
    
    
  
  58.             <dependency>
    59. 
  
    
    
  
  59.                 <groupId>org.springframework.cloud</groupId>
    60. 
  
    
    
  
  60.                 <artifactId>spring-cloud-dependencies</artifactId>
    61. 
  
    
    
  
  61.                 <version>${spring-cloud.version}</version>
    62. 
  
    
    
  
  62.                 <type>pom</type>
    63. 
  
    
    
  
  63.                 <scope>import</scope>
    64. 
  
    
    
  
  64.             </dependency>
    65. 
  
    
    
  
  65.         </dependencies>
    66. 
  
    
    
  
  66.     </dependencyManagement>
    67. 
  
    
    
  
    68. 
  
    
    
  
  68.     <build>
    69. 
  
    
    
  
  69.         <plugins>
    70. 
  
    
    
  
  70.             <plugin>
    71. 
  
    
    
  
  71.                 <groupId>org.springframework.boot</groupId>
    72. 
  
    
    
  
  72.                 <artifactId>spring-boot-maven-plugin</artifactId>
    73. 
  
    
    
  
  73.             </plugin>
    74. 
  
    
    
  
  74.         </plugins>
    75. 
  
    
    
  
  75.     </build>
    76. 
  
    
    
  
    77. 
  
    
    
  
    78. 
  
    
    
  
  78. </project>
    79.

加入rabbitmq配置，配置文件如下：

 
   
   
 
    
  
    
    
  
  1. spring.rabbitmq.host=localhost
    2. 
  
    
    
  
  2. spring.rabbitmq.port=5672
    3. 
  
    
    
  
  3. spring.rabbitmq.username=guest
    4. 
  
    
    
  
  4. spring.rabbitmq.password=guest
    5. 
  
    
    
  
    6. 
  
    
    
  
  6. ##端口号
    7. 
  
    
    
  
  7. server.port=8881
    8. 
  
    
    
  
    9. 
  
    
    
  
  9. ## 刷新时，关闭安全验证
    10. 
  
    
    
  
  10. management.security.enabled=false
    11. 
  
    
    
  
    12. 
  
    
    
  
  12. spring.application.name=config-client
    13. 
  
    
    
  
  13. spring.cloud.config.label=master
    14. 
  
    
    
  
  14. spring.cloud.config.profile=test
    15. 
  
    
    
  
  15. spring.cloud.config.uri= http://localhost:9000/
    16. 
  
    
    
  
    17. 
  
    
    
  
  17. 
  
    
    
  
  18. eureka.client.service-url.defaultZone=http://eureka.dalaoyang.cn/eureka/
    19.

启动类加入注解@RefreshScope，代码如下：

 
   
   
 
    
  
    
    
  
  1. package com.dalaoyang;
    2. 
  
    
    
  
    3. 
  
    
    
  
  3. import org.springframework.beans.factory.annotation.Value;
    4. 
  
    
    
  
  4. import org.springframework.boot.SpringApplication;
    5. 
  
    
    
  
  5. import org.springframework.boot.autoconfigure.SpringBootApplication;
    6. 
  
    
    
  
  6. import org.springframework.cloud.context.config.annotation.RefreshScope;
    7. 
  
    
    
  
  7. import org.springframework.web.bind.annotation.RequestMapping;
    8. 
  
    
    
  
  8. import org.springframework.web.bind.annotation.RestController;
    9. 
  
    
    
  
    10. 
  
    
    
  
  10. @SpringBootApplication
    11. 
  
    
    
  
  11. @RestController
    12. 
  
    
    
  
  12. @RefreshScope
    13. 
  
    
    
  
  13. public class SpringcloudBusApplication {
    14. 
  
    
    
  
    15. 
  
    
    
  
  15.     public static void main(String[] args) {
    16. 
  
    
    
  
  16.         SpringApplication.run(SpringcloudBusApplication.class, args);
    17. 
  
    
    
  
  17.     }
    18. 
  
    
    
  
    19. 
  
    
    
  
    20. 
  
    
    
  
  20.     @Value("${title}")
    21. 
  
    
    
  
  21.     String title;
    22. 
  
    
    
  
    23. 
  
    
    
  
  23.     @RequestMapping("/getTitle")
    24. 
  
    
    
  
  24.     public String getTitle(){
    25. 
  
    
    
  
  25.         return title;
    26. 
  
    
    
  
  26.     }
    27. 
  
    
    
  
  27. }
    28.

config-client加入同样依赖和配置，重启config-client，启动springcloud_bus，先去http://eureka.dalaoyang.cn/，可以看到

消息总线

先将git上配置改回dalaoyang_test，分别请求http://localhost:8881/getTitle和http://localhost:8080/getTitle结果如下：

消息总线

消息总线

然后用postman使用post请求访问http://localhost:8881/bus/refresh

再次分别请求http://localhost:8881/getTitle和http://localhost:8080/getTitle结果如下：

从图中可以看出刷新配置成功。

3.局部刷新配置，配置与第2种方法一样，只是在使用postman刷新时略加改变，在本文中使用http://localhost:8881/bus/refresh?destination=config-client:8881可以刷新服务名为config-client端口为8881的服务，如果想要刷新服务名为config-client的所有服务可以写成http://localhost:8881/bus/refresh?destination=config-client:**

源码下载 ：大老杨码云

个人网站：https://www.dalaoyang.cn


以上是关于消息总线的主要内容，如果未能解决你的问题，请参考以下文章

linux 进程间通信 dbus-glib实例详解二（上） 消息和消息总线（附代码）

linux 进程间通信 dbus-glib实例详解二（下） 消息和消息总线（ListActivatableNames和服务器的自动启动）（附代码）

从 SQL 向 Azure 服务总线队列添加消息

我最喜欢的进程之间通信方式-消息总线

我最喜欢的进程之间通信方式-消息总线

使用 Durable Functions 推送到服务总线的消息计数不可靠