微服务篇-C 深入理解第一代微服务（SpringCloud）_VIII 深入理解Bus消息总线

原创作者：田超凡（程序员田宝宝）

版权所有，引用请注明原作者，严禁复制转载

Part 1 理论部分

1 配置文件如何刷新？

在SpringCloud中，配置文件的刷新有手动刷新和实时刷新两种方式。

手动刷新使用Actuator端点实现，

实时刷新使用SpringCloud Bus消息总线实现。

2 什么是SpringCloud Bus消息总线？

在微服务架构中，通常会使用轻量级的消息代理来构建一个共用的消息主题连接到各个微服务实例，它广播的消息会被注册中心中所有的微服务实例监听和消费，这就是消息总线。

SpringCloud中也有对应的解决方案，SpringCloud Bus将分布式的节点用轻量的消息代理连接起来，可以很容易搭建消息总线，配合SpringCloud Config实现微服务应用配置信息的动态更新。

需要注意的是，消息总线并不属于消息中间件，消息总线只是为了能够整合消息中间件实现服务之间的消息通讯，类似于消息代理，从应用程序中传入消息并执行一些特别的操作，市面上开源的消息中间件有很多，比如ActiveMQ，RabbitMQ，Kafka，RocketMQ等等，目前SpringCloud Bus消息总线仅支持整合RabbitMQ和Kafka消息中间件。

Part 2 实践部分

Git环境搭建

使用码云环境搭建git服务器端 

Git服务器上传配置文件

命名规范 服务名称-版本.yml 例如configclient_dev.yml

搭建Eureka 注册中心

搭建config-server

Maven依赖

     <parent>

           <groupId>org.springframework.boot</groupId>

           <artifactId>spring-boot-starter-parent</artifactId>

           <version>2.0.2.RELEASE</version>

     </parent>

     <dependencies>

           <!-- SpringBoot整合Web组件 -->

           <dependency>

                <groupId>org.springframework.boot</groupId>

                <artifactId>spring-boot-starter-web</artifactId>

           </dependency>

           <!--spring-cloud 整合 config-server -->

           <dependency>

                <groupId>org.springframework.cloud</groupId>

                <artifactId>spring-cloud-config-server</artifactId>

                <version>2.0.2.RELEASE</version>

           </dependency>

           <!-- SpringBoot整合eureka客户端 -->

           <dependency>

                <groupId>org.springframework.cloud</groupId>

                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>

                <version>2.0.2.RELEASE</version>

           </dependency>

     </dependencies>

     <!-- 注意： 这里必须要添加， 否者各种依赖有问题 -->

     <repositories>

           <repository>

                <id>spring-milestones</id>

                <name>Spring Milestones</name>

                <url>https://repo.spring.io/libs-milestone</url>

                <snapshots>

                     <enabled>false</enabled>

                </snapshots>

           </repository>

     </repositories>

application.yml

###服务注册到eureka地址

eureka:

  client:

    service-url:

           defaultZone: http://localhost:8100/eureka

spring:

  application:

    ####注册中心应用名称

    name: config-server

  cloud:

    config:

      server:

        git:

          ###git环境地址

          uri: https://gitee.com/ittcf/config_003.git

          ####搜索目录

          search-paths:

            - config 

      ####读取分支     

      label: master

####端口号     

server:

  port: 8888

启动config-server

@SpringBootApplication

@EnableEurekaClient

@EnableConfigServer

public class AppConfigServer {

      public static void main(String[] args) {

            SpringApplication.run(AppConfigServer.class, args);

      }

}

读取配置文件http://127.0.0.1:8888/configclient-dev.yml

搭建config-client

Maven依赖

<parent>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-parent</artifactId>

            <version>2.0.1.RELEASE</version>

      </parent>

      <dependencyManagement>

            <dependencies>

                  <dependency>

                        <groupId>org.springframework.cloud</groupId>

                        <artifactId>spring-cloud-bus-parent</artifactId>

                        <version>2.0.0.RC2</version>

                        <type>pom</type>

                        <scope>import</scope>

                  </dependency>

            </dependencies>

      </dependencyManagement>

      <dependencies>

            <!-- SpringBoot整合Web组件 -->

            <dependency>

                  <groupId>org.springframework.boot</groupId>

                  <artifactId>spring-boot-starter-web</artifactId>

            </dependency>

            <dependency>

                  <groupId>org.springframework.cloud</groupId>

                  <artifactId>spring-cloud-config-client</artifactId>

                  <version>2.0.2.RELEASE</version>

            </dependency>

            <!-- SpringBoot整合eureka客户端 -->

            <dependency>

                  <groupId>org.springframework.cloud</groupId>

                  <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>

                  <version>2.0.2.RELEASE</version>

            </dependency>

            <!--核心jar包 -->

            <dependency>

                  <groupId>org.springframework.cloud</groupId>

                  <artifactId>spring-cloud-starter-bus-amqp</artifactId>

            </dependency>

            <!-- actuator监控中心 -->

            <dependency>

                  <groupId>org.springframework.boot</groupId>

                  <artifactId>spring-boot-starter-actuator</artifactId>

            </dependency>

      </dependencies>

      <!-- 注意： 这里必须要添加， 否者各种依赖有问题 -->

      <repositories>

            <repository>

                  <id>spring-milestones</id>

                  <name>Spring Milestones</name>

                  <url>https://repo.spring.io/libs-milestone</url>

                  <snapshots>

                        <enabled>false</enabled>

                  </snapshots>

            </repository>

      </repositories>

application.yml

spring:

  application:

    ####注册中心应用名称

    name:  configclient

  cloud:

    config:

    ####读取后缀

      profile: dev

      ####读取config-server注册地址

      discovery:

        service-id: config-server

        enabled: true

#####    eureka服务注册地址   

eureka:

  client:

    service-url:

           defaultZone: http://localhost:8100/eureka   

server:

  port: 8882

启动config-client

@RestController

public class ConfigClientController {

      // 年龄

      @Value("${userAge}")

      private String userAge;

      @RequestMapping("/userAge")

      public String userAge() {

            return userAge;

      }

}

@SpringBootApplication

@EnableEurekaClient

public class AppConfigClient {

      public static void main(String[] args) {

            SpringApplication.run(AppConfigClient.class, args);

      }

}

使用消息总线

三个微服务项目中都加上该依赖信息

Maven依赖

      <!--核心jar包 -->

            <dependency>

                  <groupId>org.springframework.cloud</groupId>

                  <artifactId>spring-cloud-starter-bus-amqp</artifactId>

            </dependency>

            <!-- actuator监控中心 -->

            <dependency>

                  <groupId>org.springframework.boot</groupId>

                  <artifactId>spring-boot-starter-actuator</artifactId>

            </dependency>

配置文件

###开启bus刷新

management:

  endpoints:

    web:

      exposure:

        include: bus-refresh

刷新接口 http://127.0.0.1:8882/actuator/bus-refresh

本文部分素材转载自蚂蚁课堂

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/782196.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Hive详解（4）

Hive详解（4）

Hive 窗口函数 分析函数 聚合函数&#xff0c;例如sum&#xff0c;avg&#xff0c;max&#xff0c;min等 移位函数 lag(colName, n)&#xff1a;以当前行为基础&#xff0c;来处理第前n行的数据 lead(colName, n)&#xff1a;以当前行为基础&#xff0c;来处理第后n行的数据 …
阅读更多...
CSS：样式

CSS：样式

1. 引入方式 <!-- 方式一&#xff1a;行内式 通过元素的style属性引入样式 语法&#xff1a;style"样式1&#xff1a;值; 样式2&#xff1a;值; ... " 缺点&#xff1a;1.代码复用率低&#xff0c;不利于维护。比如&#xff1a;定义多个相同的按钮要重复书写 2.cs…
阅读更多...
Intellij IDEA / Android studio 可持续开发笔记

Intellij IDEA / Android studio 可持续开发笔记

Intellij 的Java/安卓工具链有着一种不可持续性&#xff0c;这种不可持续性体现在多个方面。 首先是不可持续运行。IDEA 使用时间越长&#xff0c;内存占用越大&#xff0c;从不主动释放。运行时间越长&#xff0c;日志越多&#xff0c;从不主动清理。 然后是不完整的开源&am…
阅读更多...
用html实现一个手风琴相册设计

用html实现一个手风琴相册设计

<!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><title>手风琴相册设计</title><link rel"stylesheet" href"./style.css"> </head> <body> <h1>Accordio…
阅读更多...
Linux 著名的sudo、su是什么？怎么用？

Linux 著名的sudo、su是什么？怎么用？

一、su 什么是su&#xff1f; su命令&#xff08;简称是&#xff1a;substitute 或者 switch user &#xff09;用于切换到另一个用户&#xff0c;没有指定用户名&#xff0c;则默认情况下将以root用户登录。 为了向后兼容&#xff0c;su默认不改变当前目录&#xff0c;只设…
阅读更多...
【蓝桥杯第十三届省赛】（部分详解）

【蓝桥杯第十三届省赛】（部分详解）

九进制转十进制 #include <iostream> #include<math.h> using namespace std; int main() {cout << 2*pow(9,3)0*pow(9,2)2*pow(9,1)2*pow(9,0) << endl;return 0; }顺子日期 #include <iostream> using namespace std; int main() {// 请在此…
阅读更多...
分布式理论：CAP理论 BASE理论

分布式理论：CAP理论 BASE理论

文章目录 1. CAP定理1.1 一致性1.3 分区容错1.4 矛盾 2. BASE理论3. 解决分布式事务的思路4. 扩展 解决分布式事务问题&#xff0c;需要一些分布式系统的基础知识作为理论指导。 1. CAP定理 Consistency(一致性): 用户访问分布式系统中的任意节点&#xff0c;得到的数据必须一…
阅读更多...
python超详细知识点汇总整理

python超详细知识点汇总整理

1、注释以及编码格式的声明 单行注释&#xff1a;# &#xff08;后面放上被注释的内容&#xff09;多行注释&#xff1a;字符段落的上下加上三引号 举个例子: ‘’’ …‘’’编码格式的声明&#xff1a;#coding:utf-8 或者是 #codingutf-8 2、代码编写格式和一些琐碎说明 同…
阅读更多...
大数据设计为何要分层，行业常规设计会有几层数据

大数据设计为何要分层，行业常规设计会有几层数据

大数据设计通常采用分层结构的原因是为了提高数据管理的效率、降低系统复杂度、增强数据质量和可维护性。这种分层结构能够将数据按照不同的处理和应用需求进行分类和管理&#xff0c;从而更好地满足不同层次的数据处理和分析需求。行业常规设计中&#xff0c;数据通常按照以下…
阅读更多...
深入了解Vue中slot的应用

深入了解Vue中slot的应用

作为一个流行的JavaScript框架&#xff0c;Vue提供了许多灵活而强大的功能&#xff0c;其中之一就是slot&#xff08;插槽&#xff09;。以下详细介绍Vue中slot的用法。 一、什么是slot&#xff1f; 在Vue中&#xff0c;slot是一种用于在组件中承载内容的特殊元素。通常情况下…
阅读更多...
暴力破解pdf文档密码

暴力破解pdf文档密码

首先安装pdfcrack工具包 apt install pdfcrack 默认密码字典存储在/usr/share/wordlists里&#xff0c;是gz文件&#xff0c;将它解压并copy到pdf目录 然后使用pdfcrack破解 密码在最后一行user-password的单引号里
阅读更多...
Python面对对象 - 类的反射机制

Python面对对象 - 类的反射机制

Python面对对象类的反射机制是面向对象编程语言中比较重要的功能&#xff0c;可以动态获取对象信息以及动态调用对象。通过字符串形式的类名或属性来访问对应类或属性。 一、对象的反射 1. getattr 获取指定字符串名称的对象属性、方法&#xff1a; 当访问的属性不存在时&#…
阅读更多...
【四】【单片机】蜂鸣器，蜂鸣器模块化编程 1000HZ 鸣响 ms 毫秒，利用定时器让蜂鸣器以特定频率响 ms 毫秒

【四】【单片机】蜂鸣器，蜂鸣器模块化编程 1000HZ 鸣响 ms 毫秒，利用定时器让蜂鸣器以特定频率响 ms 毫秒

蜂鸣器模块化编程 1000HZ 鸣响 ms 毫秒 //Buzzer.h #ifndef __BUZZER_H__ #define __BUZZER_H__void Buzzer_Time(unsigned int ms);#endifBuzzer.h文件中只含有一个Buzzer_Time函数&#xff0c;这个函数用来让蜂鸣器以1000HZ固定频率发声ms毫秒。 //Buzzer.c #include <REG…
阅读更多...
数据仓库的作用和价值

数据仓库的作用和价值

支持管理决策分析 支持管理决策分析 数据仓库集成了企业各类运营和外部数据,为管理者提供了全面透明的数据视图,帮助他们洞察业务动态,发现问题和机遇。 通过多维度的数据分析、预测建模等,能够为企业未来战略制定、投资规划等重大决策提供依据。 案例:沃尔玛的数据仓库囊括了…
阅读更多...
Python学习（二）

Python学习（二）

数据容器 数据容器根据特点的不同&#xff0c;如&#xff1a; 是否支持重复元素是否可以修改是否有序&#xff0c;等 分为5类&#xff0c;分别是&#xff1a; 列表&#xff08;list&#xff09;、元组&#xff08;tuple&#xff09;、字符串&#xff08;str&#xff09;、集…
阅读更多...
09_Web组件

09_Web组件

文章目录 Web组件Listener监听器ServletContextListener执行过程 Filter过滤器Filter与Servlet的执行 案例&#xff08;登录案例&#xff09; 小结Web组件 Web组件 JavaEE的Web组件&#xff08;三大Web组件&#xff09;&#xff1a; Servlet → 处理请求对应的业务Listener →…
阅读更多...
Linux利用Jenkins部署SpringBoot项目保姆级教程

Linux利用Jenkins部署SpringBoot项目保姆级教程

在当今快速发展的软件开发领域&#xff0c;持续集成和持续部署&#xff08;CI/CD&#xff09;已经成为提升开发效率、缩短产品上市时间的关键实践。Linux系统以其稳定性和开源友好性&#xff0c;成为众多开发者和企业的首选平台。而Spring Boot&#xff0c;作为一个轻量级的Jav…
阅读更多...
飞天使-k8s知识点28-kubernetes散装知识点5-helm安装ingress

飞天使-k8s知识点28-kubernetes散装知识点5-helm安装ingress

文章目录 安装helm添加仓库下载包配置创建命名空间安装 安装helm https://get.helm.sh/helm-v3.2.3-linux-amd64.tar.gztar -xf helm-v3.2.3-linux-amd64.tar.gzcd linux-amd64mv helm /usr/local/bin修改/etc/profile 文件&#xff0c;修改里面内容,然后重新启用export PATH$P…
阅读更多...
【3月比赛合集】5场可报名的「创新应用」、「数据分析」和「程序设计」大奖赛，任君挑选！

【3月比赛合集】5场可报名的「创新应用」、「数据分析」和「程序设计」大奖赛，任君挑选！

CompHub[1] 实时聚合多平台的数据类(Kaggle、天池…)和OJ类(Leetcode、牛客…&#xff09;比赛。本账号会推送最新的比赛消息&#xff0c;欢迎关注&#xff01; 以下信息仅供参考&#xff0c;以比赛官网为准 目录 创新应用赛&#xff08;2场比赛&#xff09;数据分析赛&#…
阅读更多...
深入理解 Hadoop 上的 Hive 查询执行流程

深入理解 Hadoop 上的 Hive 查询执行流程

在 Hadoop 生态系统中&#xff0c;Hive 是一个重要的分支&#xff0c;它构建在 Hadoop 之上&#xff0c;提供了一个开源的数据仓库系统。它的主要功能是查询和分析存储在 Hadoop 文件中的大型数据集&#xff0c;包括结构化和半结构化数据。Hive 在数据查询、分析和汇总方面发挥…
阅读更多...
最新文章

Copyright @ 2022~2023