代码编织梦想

Bus 概述

  1. Spring Cloud Bus是用轻量的消息中间件将分布式的节点连接起来,可以用于广播配置文件的更改或者服务的监控管理。关键的思想就是,消息总线可以为微服务做监控,也可以实现应用程序之间相通信。
  2. Spring Cloud Bus 可选的消息中间件包括 RabbitMQ 和 Kafka 。config server 发给bus,bus发给RabbitMQ

在这里插入图片描述

RabbitMQ Windows 安装

一、安装Erlang

  1. 双击资料中提供的 otp_win64_22.1.exe ,选择对应安装目录,一路下一步,完成安装。

  2. 设置Erlang环境变量

    (1)新建ERLANG_HOME

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-Q8KwXu5q-1679070536579)(imgs\1585755246863.png)]

​ (2)修改环境变量path,增加Erlang变量至path,%ERLANG_HOME%\bin;

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-6Hj1d4Cc-1679070536580)(imgs\1585755661841.png)]

​ (3)打开cmd命令框,输入erl,如果能看到版本号,则Erlang安装完成。

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-S9JJWCVq-1679070536580)(imgs\1585755758154.png)]

二、安装RabbitMQ

  1. 双击资料中提供的 rabbitmq-server-3.7.7.exe ,选择对应安装目录,一路下一步,完成安装。

  2. 设置环境变量

    (1) 新建RABBITMQ_HOME

在这里插入图片描述

​ (2)修改环境变量path,增加rabbitmq变量至path,%RABBITMQ_HOME%\sbin

在这里插入图片描述

  1. 查看信息。打开cmd命令框,切换至D:\Program Files\rabbitmq_server-3.7.7\sbin目录下,输入rabbitmqctl status

在这里插入图片描述

  1. 安装插件,命令:rabbitmq-plugins.bat enable rabbitmq_management。出现下面信息表示插件安装成功。

!在这里插入图片描述

三、启动RabbitMQ

  1. 启动RabbitMQ:rabbitmq-server -detached 后台启动

  2. 停止RabbitMQ:rabbitmqctl stop

  3. rabbitmq启动成功,浏览器中http://localhost:15672,默认用户名和密码 都是 guest

在这里插入图片描述

至此,rabbitMQ安装部署完成。

Bus 快速入门

  1. 分别在 config-server 和 config-client中引入 bus依赖:bus-amqp
  2. 分别在 config-server 和 config-client中配置 RabbitMQ
  3. 在config-server中设置暴露监控断点:bus-refresh
  4. 启动测试
    在这里插入图片描述

config-server修改

<!--bus-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>

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

在这里插入图片描述

server:
  port: 9527

spring:
  application:
    name: config-server
  # spring cloud config
  cloud:
    config:
      server:
        # git 的 远程仓库地址
        git:
          uri: https://gitee.com/cheng-penga/chengpeng-config.git
      label: master # 分支配置
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest
    virtual-host: /

#将自己注册到eureka中
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka

#暴露bus刷新
management:
  endpoints:
    web:
      exposure:
        include: 'bus-refresh'

config-provider和config-consumer修改

<!--bus-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>

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

在这里插入图片描述

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/qq_40432598/article/details/129606853

springcloud-bus消息总线-爱代码爱编程

Spring Cloud Bus将轻量级消息代理程序链接到分布式系统的节点。然后可以使用此代理来广播状态更改(例如配置更改)或其他管理指令。一个关键思想是,总线就像是横向扩展的Spring Boot应用程序的分布式执行器。但是,它也可以用作应用之间的通信渠道。 本文以动态加载配置文件为例 本文使用rabbitmq,安装自行搜索引擎 以con

Springcloud-Bus消息总线-爱代码爱编程

官网 Bus消息总线概述 Spring Cloud Bus配合Spring Cloud Config使用可以实现配置的动态刷新 什么是总线 在分布式系统中通常使用消息代理来实现共用的消息主题,并让所有的微服务都连接上,所产生的的消息会被所有的消费者消费,所以叫消息总线。 基本原理 ConfigClient实例都会监听M

SpringCloud-bus 消息总线学习记录-爱代码爱编程

什么是总线:在微服务架构的系统中,通常会使用轻量级的消息代理来构建一个公用的消息主题,并让该系统中的所有微服务实例都连接上来。由于该主题中产生的消息会被所有实例监听和消费,所以称他为消息总线。 基本原理:ConfigClient实例都监听MQ中同一个topic(默认是SpringCloudBus)。当一个服务刷新数据的时候,他会把这个消息放入topic,

SpringCloud-bus消息总线配置-爱代码爱编程

首先消息总线有两种配置方式 一种是把更新消息Post请求发给其中的一个服务端(client),再由服务端传递给其他的服务端。 另一种就是把消息Post请求发给注册端(server),注册端口在发给所有的服务端(client) 我们选择第二种配置方式 原因一:这样可以减轻服务端的压力 原因二:这样的逻辑更加清晰,减少耦合 原因三:破坏了服务的单一性,对等性,

springcloud-bus消息总线的搭建和使用-爱代码爱编程

整个项目请前往gitee查看https://gitee.com/xwb1056481167/spring-cloud查看 使用到的项目cloud-config-center-3344, 消息总线 在微服务架构的系统中,通常会使用轻量级的消息代理来构建一个公用的消息主题,并让系统中其他微服务实例都连接上来, 改主题中产生的消息会被所有

SpringCloud-Alibaba消息总线Bus(过时)-爱代码爱编程

此文章主要讲解springcloud中的消息总线Bus(不推荐)的相关知识。 Spring Cloud Bus Spring Cloud Bus是什么? Spring Cloud Bus配置Spring Cloud Config使用可以实现配置的动态刷新。 Spring Cloud Bus是用来分布式系统的节点和轻量级消息系统连接起来的框架,

SpringCloud微服务-SpringCloud Bus 消息总线-爱代码爱编程

一、概述 什么是总线 在微服务架构的系统中,通常会使用轻量级的消息代理来构建一个共用的消息主题,并让系统中所有微服务实例都连接上来。由于该主题中产生的消息会被所有实例监听和消费,所以称它为消息总线。在总线上的各个实例,都可以方便地广播一些需要让其他连接在该主题上的实例都知道的消息。 基本原理 ConfigClient实例都监听MQ中同一个topic

spring cloud config和springcloudBus消息总线-爱代码爱编程

首先下载rabbitMQ config是配置中心,多个配置中心用bus全局广播(通知其它的配置中心该配置文件已更新) 这里使用第二种,利用消息总线触发一个服务端 3344是服务端, yml配置文件: server: port: 3344 spring: application: name: cloud-config-center #注

SpringCloud-消息总线BUS-爱代码爱编程

本文我们来介绍下SpringCloud中消息总线BUS。 一、什么是消息总线bus SpringCloud Bus集成了市面上常用的消息中间件(rabbit mq,kafka等),连接微服务系统中的所有的节点,当有数据变更的时候,可以通过消息代理广播通知微服务及时变更数据,例如微服务的配置更新。 二、bus解决了什么问题 解决了微服务数据变更,及时

SpringCloud-Bus消息总线-爱代码爱编程

文章目录 前言一、概览1、Bus消息总线是什么2、作用3、基本原理4、设计思想二、使用步骤1、RabbitMQ配置2、导入库3、application.yml 前言 今天大致学了下Bus消息总线 一、概览 1、Bus消息总线是什么 Spring Cloud Bus配合Spring Cloud Config使用可以实现配置的动态刷新。

springcloud学习笔记 -爱代码爱编程

1. 消息总线简介 消息代理中间件构建了一个共用的消息主题让所有微服务实例订阅,当该消息主题产生消息时会被所有微服务实例监听和消费。 消息代理又是什么?消息代理是一个消息验证、传输、路由的架构模式,主要用来实现接收和分发

spring cloud-爱代码爱编程

  目录 配置中心 pom yml 客户端 pom yml bus一般配合config使用,以下都是在config基础上添加,pom中bus配合actuator使用 配置中心 pom <dependency> <groupId>org.springfra

【rabbitmq】federation实现消息传递_rabbitmq_federation-爱代码爱编程

RabbitMQ集群对时间非常敏感,应该在局域网中使用,不应在关于网中使用。而Federation插件可以很好地解决这个问题。这篇文章和大家分享RabbitMQ Federation的使用场景、实现原理和具体用法。 使用场景 Federation插件的目的就是解决RabbitMQ节点之间进行消息传递而不需要建立集群,这个功能在很多场景中都很有用: 在