springcloudbus与啥联合实现热部署

Posted

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了springcloudbus与啥联合实现热部署相关的知识，希望对你有一定的参考价值。

Spring Cloud Bus:事件、消息总线,用于在集群(例如,配置变化事件)中传播状态变化,可与Spring Cloud Config联合实现热部署。 Spring Cloud Netflix:针对多种Netflix组件提供的开发工具包,其中包括Eureka、Hystrix、Zuul、Archaius等。 Netflix Eureka:云端负载均衡,一个基于 REST 的服务,用于定位服务,以实现云端的负载均衡和中间层服务器的故障转移。 Netflix Hystrix:容错管理工具,旨在通过控制服务和第三方库的节点,从而对延迟和故障提供更强大的容错能力。 Netflix Zuul:边缘服务工具,是提供动态路由,监控,弹性,安全等的边缘服务。 Netflix Archaius:配置管理API,包含一系列配置管理API,提供动态类型化属性、线程安全配置操作、轮询框架、回调机制等功能。 Spring Cloud for Cloud Foundry:通过Oauth2协议绑定服务到CloudFoundry,CloudFoundry是VMware推出的开源PaaS云平台。 Spring Cloud Sleuth:日志收集工具包,封装了Dapper,Zipkin和HTrace操作。 Spring Cloud Data Flow:大数据操作工具,通过命令行方式操作数据流。 Spring Cloud Security:安全工具包,为你的应用程序添加安全控制,主要是指OAuth2。 参考技术A Spring Cloud Bus:事件、消息总线,用于在集群(例如,配置变化事件)中传播状态变化,可与Spring Cloud Config联合实现热部署。 Spring Cloud Netflix:针对多种Netflix组件提供的开发工具包,其中包括Eureka、Hystrix、Zuul、Archaius等。 Netflix Eureka:云端负载均衡,一个基于 REST 的服务,用于定位服务,以实现云端的负载均衡和中间层服务器的故障转移。 Netflix Hystrix:容错管理工具,旨在通过控制服务和第三方库的节点,从而对延迟和故障提供更强大的容错能力。 Netflix Zuul:边缘服务工具,是提供动态路由,监控,弹性,安全等的边缘服务。 Netflix Archaius:配置管理API,包含一系列配置管理API,提供动态类型化属性、线程安全配置操作、轮询框架、回调机制等功能。 Spring Cloud for Cloud Foundry:通过Oauth2协议绑定服务到CloudFoundry,CloudFoundry是VMware推出的开源PaaS云平台。 Spring Cloud Sleuth:日志收集工具包,封装了Dapper,Zipkin和HTrace操作。 Spring Cloud Data Flow:大数据操作工具,通过命令行方式操作数据流。 Spring Cloud Security:安全工具包,为你的应用程序添加安全控制,主要是指OAuth2。 参考技术B springCloud是基于SpringBoot的一整套实现微服务的框架。他提供了微服务开发所需的配置管理、服务发现、断路器、智能路由、微代理、控制总线、全局锁、决策竞选、分布式会话和集群状态管理等组件。最重要的是，跟spring boot框架一起使用的话，会让你开发微服务架构的云服务非常好的方便。 SpringBoot旨在简化创建产品级的 Spring 应用和服务，简化了配置文件，使用嵌入式web服务器，含有诸多开箱即用微服务功能。

消息总线

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


以上是关于springcloudbus与啥联合实现热部署的主要内容，如果未能解决你的问题，请参考以下文章

消息总线

Spring Cloud集成相关优质项目推荐

spring cloud微服务分布式云架构 - 集成项目简介

您将 Rails 应用程序放在服务器的啥位置？您与啥用户一起部署？

Bus：消息总线

Bus：消息总线