《Spring Cloud Config与Bus整合实现微服务配置自动刷新》

news2024/10/19 1:32:25

目录

  • Config与Bus整合自动刷新
    • 步骤1：安装RabbitMQ并启动
      • RabbitMQ的安装
    • 步骤2：创建项目
      • 创建Eureka Server
      • 创建config-server
    • 步骤3： 添加依赖
    • 步骤4：Config Client
    • 步骤5：测试运行
    • 问题一
    • 问题二
  • 总结

Config与Bus整合自动刷新

微服务A的所有实例都通过Spring Cloud Bus消息总线连接到了一起，每个实例都会从Config Server订阅配置更新事件并获取配置信息。当其中一个微服务节点的/ous/refresh端点被请求时，该实例就会向Spring Cloud Bus消息总线发送一个配置更新事件，其他实例通过Spring Cloud Bus消息总线获得该事件后也会从Config Server获取最新的配置信息并更新配置。
在这里插入图片描述
在这里插入图片描述

步骤：

1.安装RabbitMQ并启动

2.添加依赖

3.修改配置文件

4.改造Config Client

5.测试运行

步骤1：安装RabbitMQ并启动

RabbitMQ的安装

1.下载erlang，原因在于RabbitMQ服务端代码是使用并发式语言erlang编写的，下载地址：erlang，双击.eerlangxe文件进行安装就好，安装完成之后创建一个名为ERLANG_HOME的环境变量，其值指向erlang的安装目录，同时将%ERLANG_HOME%\bin加入到Path中。
在这里插入图片描述
最后打开cmd命令行，输入erl，如果出现erlang的版本信息就表示erlang语言环境安装成功
在这里插入图片描述
2.下载RabbitMQ，下载地址：RabbitMQ，同样双击.exe进行安装就好(注意：默认的安装目录是C:/Program Files/…，这个目录中是存在空格符的，我们需要改变安装目录，貌似RabbitMQ安装目录中是不允许有空格的)。

3.安装RabbitMQ-Plugins，这个相当于是一个管理界面，方便我们在浏览器界面查看RabbitMQ各个消息队列以及exchange的工作情况，安装方法是：打开命令行cd进入rabbitmq的sbin目录，输入：rabbitmq-plugins enable rabbitmq_management命令，稍等会会发现出现plugins安装成功的提示，默认是安装6个插件。
在这里插入图片描述
4.插件安装完之后，在浏览器输入http://localhost:15672进行验证，你会看到下面界面，输入用户名：guest，密码：guest 就可以进入管理界面。
在这里插入图片描述
在这里插入图片描述

步骤2：创建项目

Eureka Server，config-server，config-client

创建Eureka Server

1）使用Spring Initializr方式创建一个名称为eureka-server的Spring Boot项目，将Artifact命名为eureka-server，在pom.xml文件中添加Eureka Server依赖。

方便测试效果，新建一个eureka-server项目作为Config Server的注册中心，
将eureka-server端口号设置为8761。
在这里插入图片描述
在加载不出来添加，要与springboot版本相符
在这里插入图片描述

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.6.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.bushuo</groupId>
    <artifactId>eureka-server</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>eureka-server</name>
    <description>Demo project for Spring Boot</description>
    <url/>
    <licenses>
        <license/>
    </licenses>
    <developers>
        <developer/>
    </developers>
    <scm>
        <connection/>
        <developerConnection/>
        <tag/>
        <url/>
    </scm>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>

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

            <artifactId>

                spring-cloud-starter-netflix-eureka-server

            </artifactId>

        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
    <dependencyManagement>

        <dependencies>

            <dependency>

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

                <artifactId>spring-cloud-dependencies</artifactId>

                <version>Finchley.SR2</version>

                <type>pom</type>

                <scope>import</scope>

            </dependency>

        </dependencies>

    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

2）：添加Eureka的相关配置

在全局配置文件application.yml中添加Eureka的相关配置信息。
在这里插入图片描述

  • fetch-registry:
    设置false 时，该Eureka客户端不会从Eureka Server获取服务注册表的信息。这意味着它不会尝试拉取其他服务的信息，通常这在自身就是Server的情况下使用。
  • register-with-eureka:
    设置为 false 时，Eureka 客户端不注册到 Eureka Server。即不将自身信息注册到服务注册表。在 Eureka Server 节点配置中常用，因 Eureka Server 本身无需注册到其他 Eureka Server，单实例时是。

3）：在项目启动类添加@EnableEurekaServer注解

在项目启动类EurekaServerApplication上添加@EnableEurekaServer注解开启Eureka Server功能。

在这里插入图片描述

4）测试运行 http://localhost:8761
在这里插入图片描述

创建config-server

在config-4下创建config-server，添加依赖，添加配置，在启动类添加注解

可以参考操作
依赖
在这里插入图片描述
配置bootstrap
在这里插入图片描述
添加启动类注解
在这里插入图片描述

步骤3： 添加依赖

Config Server和Config Client与Spring Cloud Bus整合实现配置自动刷新。改造Config Server与Config Client，在各自的pom.xml配置文件中添加spring-cloud-starter-bus-amqp依赖实现配置自动更新与spring-boot-starter-actuator依赖监控系统健康情况的工具。

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

        <artifactId>spring-cloud-starter-bus-amqp</artifactId>
         <version>2.0.0.RELEASE</version>
    </dependency>

    <dependency>

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

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


    </dependency>

修改配置文件

改造Config Server和Config Client的配置文件，在配置文件中设置rabbitmq属性的相关配置，包括主机地址、端口号、用户名和密码，如下所示。
在这里插入图片描述

spring:
  application:
    name: config-client
  cloud:
    config:
      server:
        git:
          uri: https://gitee.com/nobyebye/hello.git
          username: #自己的gitee用户名
          password: #密码
          label: master
  profiles:
    active: dev
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest
server:
  port: 8001
management:
  endpoints:
    web:
      exposure:
        include: "bus-refresh"

步骤4：Config Client

config-client的bootstrap.yml
在这里插入图片描述
添加控制器
在这里插入图片描述

Config Client，在需要动态刷新配置的类ConfigClientApplication上加上注解@RefreshScope。在这里插入图片描述
要在gitee的配置文件添加foo，不然没有注解
在这里插入图片描述

步骤5：测试运行

在这里插入图片描述

依次启动config-server、config-client项目。启动成功后，使用浏览器访问http://localhost:8002/foo
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
打开cmd输入命令：curl -X POST http://localhost:8769/actuator/bus-refresh。
在这里插入图片描述

在这里插入图片描述

实现Config与Bus整合自动刷新后，系统能做到实时检测配置变更并自动应用，无需额外的人工干预，减少了系统中断时间和重启操作。这不仅提高了系统的稳定性，还能显著提升运维和开发的效率。

问题一

idea运行多个端口，没有services的窗口，点击edit Configurations
在这里插入图片描述

点击Templates->+ springboot,apply,ok了
在这里插入图片描述

在这里插入图片描述

窗口出来了
在这里插入图片描述

问题二

整合Bus自动刷新改进了之前的什么问题？

  1. 手动刷新繁琐：以往配置更新后需要手动重启各服务实例，耗时且麻烦。自动刷新可以省去这一过程，让更新更简单快捷。

  2. 减少服务中断：手动重启会导致短暂的服务中断。自动刷新避免了重启，提升了服务的连续性和可用性。

  3. 配置一致性：手动更新可能导致不同实例间配置不一致，带来同步问题。自动刷新确保所有实例同步更新，保持一致性。

  4. 降低运维复杂性：自动刷新减少了手动操作，降低运维负担，避免人为失误。

  5. 提高实时性：配置更新可实时应用，服务能更快地响应变化，提高了系统的适应性和灵活性。

总结

通过整合Spring Cloud Config与Bus实现配置自动刷新，可以在无需重启服务的情况下更新微服务配置。该机制减少了运维干预，提升了系统的稳定性和运维效率，尤其在快速变更的环境中十分实用。

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

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

相关文章

Java爬虫：从入门到精通实战指南

Java爬虫：从入门到精通实战指南

在信息技术飞速发展的今天&#xff0c;数据已成为最宝贵的资源之一。Java作为一种成熟且功能强大的编程语言&#xff0c;不仅在企业级应用开发中占据主导地位&#xff0c;也成为了编写爬虫程序的理想选择。Java爬虫能够自动化地从网页或API中提取数据&#xff0c;为数据分析、机…
阅读更多...
一篇文章带你走进Java集合中的HashMap

一篇文章带你走进Java集合中的HashMap

文章目录 一、了解常见的数据结构二叉平衡树AVL树红黑树 二、HashMap的实现原理HashMap的jdk1.7和jdk1.8有什么区别&#xff1f; 三、HashMap put的具体流程四、HashMap的扩容机制五、HashMap的寻址算法**第一步&#xff1a;** 计算对象的hashCode第二步&#xff1a; 二次哈希第…
阅读更多...
基于springboot的学习平台系统

基于springboot的学习平台系统

springbootjava学习平台作者&#xff1a;计算机学长阿伟 开发技术&#xff1a;SpringBoot、SSM、Vue、MySQL、ElementUI等&#xff0c;“文末源码”。 系统展示 【2024最新】基于JavaSpringBootVueMySQL的&#xff0c;前后端分离。 开发语言&#xff1a;Java数据库&#xff1a…
阅读更多...
2024第七届全国大学生数学竞赛暨数学精英挑战赛第二场，第一场获奖名单已公布

2024第七届全国大学生数学竞赛暨数学精英挑战赛第二场，第一场获奖名单已公布

第七届全国大学生数学竞赛暨数学精英挑战赛&#xff08;原网络挑战赛&#xff09;由浙江应用数学研究会组织举办。自2018年起已经连续举办6届&#xff0c;吸引来自全国900余所高校选手参赛&#xff0c;近三年累计参赛人数1.5万人。2024年&#xff0c;第七届全国大学生数学竞赛暨…
阅读更多...
力扣MySQL 1581

力扣MySQL 1581

先把两张表连接&#xff0c;amount为null 的正是我们需要的&#xff0c;再按customer_id聚合 select Visits.visit_id,customer_id ,Transactions.visit_id ,transaction_id ,amount from Visits left join Transactions on Visits.visit_idTransactions.visit_id 正确代码&…
阅读更多...
银河麒麟V10系统+Windows10双系统启动顺序正确修改方法

银河麒麟V10系统+Windows10双系统启动顺序正确修改方法

***正确可行方法***&#xff0c;测试OK且稳定&#xff1b; 银河麒麟桌面操作系统V10是一款适配国产软硬件平台并深入优化和创新的新一代图形化桌面操作系统&#xff0c;同源支持国内外主流处理器架构&#xff0c;并不断使能GPU、桥片、网卡等各种新硬件&#xff0c;提供更优的软…
阅读更多...
Electron+Vue实现两种方式的截屏功能

Electron+Vue实现两种方式的截屏功能

本次介绍的截屏功能一共有两种分别是在electron环境中与非electron环境中 非electron环境 这个环境下会有一些限制&#xff1a; 1.只能截浏览器中的画面 2.如果里面有iframe或者base64的图片会加载不出来&#xff08;这个会有解决办法&#xff09; yarn add -D js-web-scree…
阅读更多...
Vue详细入门（语法【三】）

Vue详细入门（语法【三】）

今天滴的学习目标&#xff01;&#xff01;&#xff01; Vue组件是什么&#xff1f;组件的特性和优势Vue3计算属性Vue3监听属性 在前面Vue详细入门&#xff08;语法【一】——【二】&#xff09;当中我们学习了Vue有哪些指令&#xff0c;它的核心语法有哪些&#xff1f;今天我们…
阅读更多...
大模型学习方法之——大模型技术学习路线，小白也能学会大模型

大模型学习方法之——大模型技术学习路线，小白也能学会大模型

技术学习无非涵盖三个方面&#xff0c;理论&#xff0c;实践和应用 大模型技术爆火至今已经有两年的时间了&#xff0c;而且大模型技术的发展潜力也不言而喻。因此&#xff0c;很多人打算学习大模型&#xff0c;但又不知道该怎么入手&#xff0c;因此今天就来了解一下大模型的…
阅读更多...
java-uniapp小程序-引导关注公众号、判断用户是否关注公众号

java-uniapp小程序-引导关注公众号、判断用户是否关注公众号

目录 1、前期准备 公众号和小程序相互关联 准备公众号文章 注册公众号测试号 微信静默授权的独立html 文件 2&#xff1a; 小程序代码 webview页面代码 小程序首页代码 3&#xff1a;后端代码 1&#xff1a;增加公众号配置项 2&#xff1a;读取公众号配置项 3&…
阅读更多...
【学习笔记】什么是MongoDB

【学习笔记】什么是MongoDB

文章目录 MongoDB 简介体系结构数据模型MongoDB 的特点 MongoDB 简介 学习一个东西就跟认识一个人一样&#xff0c;下面有情MongoDB来做个自我介绍 大家好&#xff0c;俺是MongoDB&#xff0c;是一个开源、高性能、无模式的文档型数据库&#xff0c;当初的设计俺就是用于简化开…
阅读更多...
学习笔记（202410）

学习笔记（202410）

课程&#xff1a;Generative AI for Software Development 链接&#xff1a;吴恩达同步最新AI专业课&#xff0c;第54讲&#xff1a;用人工智能做软件开发--Generative AI for Software Development_哔哩哔哩_bilibili 时间&#xff1a;2024-10-12 至 概述&#xff1a;使用C…
阅读更多...
强化学习与深度强化学习：深入解析与代码实现

强化学习与深度强化学习：深入解析与代码实现

个人主页&#xff1a;chian-ocean 文章专栏 强化学习与深度强化学习&#xff1a;深入解析与代码实现 强化学习&#xff08;Reinforcement Learning, RL&#xff09;是一种机器学习方法&#xff0c;通过智能体&#xff08;agent&#xff09;与环境&#xff08;environment&am…
阅读更多...
【Linux】Linux常见指令及权限理解

【Linux】Linux常见指令及权限理解

1.ls指令 语法 &#xff1a; ls [ 选项 ][ 目录或文件 ] 功能 &#xff1a;对于目录&#xff0c;该命令列出该目录下的所有子目录与文件。对于文件&#xff0c;将列出文件名以及其他信息。 常用选项&#xff1a; -a 列出目录下的所有文件&#xff0c;包括以 . 开头的隐含文…
阅读更多...
无人机视角下火灾检测数据集 共12736张 标注文件为YOLO适用的txt格式。已划分为训练集、验证集、测试集。类别：Fire yolov5-v10通用

无人机视角下火灾检测数据集 共12736张 标注文件为YOLO适用的txt格式。已划分为训练集、验证集、测试集。类别：Fire yolov5-v10通用

无人机视角下火灾检测数据集 共12736张 标注文件为YOLO适用的txt格式。已划分为训练集、验证集、测试集。类别&#xff1a;Fire yolov5-v10通用 无人机视角下火灾检测数据集 共12736张 标注文件为YOLO适用的txt格式。已划分为训练集、验证集、测试集。类别&#xff1a;Fire yol…
阅读更多...
【Vue】Vue3.0（十）toRefs()和toRef()的区别及使用示例

【Vue】Vue3.0（十）toRefs()和toRef()的区别及使用示例

上篇文章&#xff1a;Vue】Vue&#xff08;九&#xff09;OptionsAPI与CompositionAPI的区别 &#x1f3e1;作者主页&#xff1a;点击&#xff01; &#x1f916;Vue专栏&#xff1a;点击&#xff01; ⏰️创作时间&#xff1a;2024年10月15日11点13分 文章目录 toRefs()和toRe…
阅读更多...
基于朴素贝叶斯的中文垃圾短信分类(含ui界面)

基于朴素贝叶斯的中文垃圾短信分类(含ui界面)

完整代码如下 基于朴素贝叶斯的中文垃圾短信分类、垃圾邮件分类。 可用于机器学习课程设计等。 import warnings warnings.filterwarnings(ignore) import os os.environ["HDF5_USE_FILE_LOCKING"] "FALSE" import pandas as pd import numpy as np fro…
阅读更多...
LeetCode1004.最大连续1的个数

LeetCode1004.最大连续1的个数

题目链接&#xff1a;1004. 最大连续1的个数 III - 力扣&#xff08;LeetCode&#xff09; 1.常规解法&#xff08;会超时&#xff09; 遍历数组&#xff0c;当元素是1时个数加一&#xff0c;当元素是0时且已有的0的个数不超过题目限制时&#xff0c;个数加一&#xff0c;若上…
阅读更多...
重生之我爱上了k8s！

重生之我爱上了k8s！

内容不全&#xff0c;待补充中...... 目录 一、k8s的部署 1.1.集群环境初始化 1.1.1.所有主机禁用swap 1.1.2.安装k8s部署工具 1.1.2.所有节点安装cri-docker 1.1.3.在master节点拉取K8S所需镜像 1.1.4.集群初始化 1.1.5.其他两台主机加入集群 1.1.6.安装flannel网络…
阅读更多...
微积分复习笔记 Calculus Volume 1 - 2.5 Precise Definition of a Limit

微积分复习笔记 Calculus Volume 1 - 2.5 Precise Definition of a Limit

2.5 The Precise Definition of a Limit - Calculus Volume 1 | OpenStax
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023