博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
SpringCloud |第七篇: 消息总线(Bus)
阅读量:6378 次
发布时间:2019-06-23

本文共 3297 字,大约阅读时间需要 10 分钟。

hot3.png

Spring Cloud Bus 将分布式的节点用轻量的消息代理连接起来。它可以用于广播配置文件的更改或者服务之间的通讯,也可以用于监控。本文要讲述的是用Spring Cloud Bus实现通知微服务架构的配置文件的更改。

一、准备工作

本文还是基于上一篇文章来实现。按照官方文档,我们只需要在配置文件中配置 spring-cloud-starter-bus-amqp ;这就是说我们需要装rabbitMq,点击下载。

二、改造config-client

在pom文件加上起步依赖spring-cloud-starter-bus-amqp,完整的配置文件如下:

4.0.0
com.example
da-config-client
0.0.1-SNAPSHOT
jar
da-config-client
Demo project for Spring Boot
org.springframework.boot
spring-boot-starter-parent
2.0.0.RELEASE
UTF-8
UTF-8
1.8
Finchley.M8
org.springframework.cloud
spring-cloud-starter-netflix-eureka-client
org.springframework.cloud
spring-cloud-starter-config
org.springframework.boot
spring-boot-starter-web
org.springframework.boot
spring-boot-starter-actuator
org.springframework.cloud
spring-cloud-starter-bus-amqp
org.springframework.boot
spring-boot-starter-test
test
org.springframework.cloud
spring-cloud-dependencies
${spring-cloud.version}
pom
import
org.springframework.boot
spring-boot-maven-plugin
spring-milestones
Spring Milestones
https://repo.spring.io/milestone
false

在配置文件application.yml中加上RabbitMq的配置,包括RabbitMq的地址、端口,用户名、密码,代码如下:

eureka:  client:    serviceUrl:      defaultZone: http://localhost:1001/eureka/spring:  application:    name: config-client  cloud:    bus:      trace:        enabled: true    config:      name: didispace                   #只能文件名      label: master                     #指明远程仓库的分支      profile: dev                      #dev开发环境配置文件test测试环境pro正式环境      uri: http://localhost:5001/       #指明配置服务中心的网址      discovery:        enabled: true                   #是从配置中心读取文件        serviceId: config-server        #配置中心的服务名  rabbitmq:    host: 127.0.0.1    port: 5672    username: guest    password: guestserver:  port: 5002

依次启动eureka-server、config-server、config-client。

访问浏览器显示:

141119_aBWd_2940767.png

这时我们去将from的值改为“wangwu”,即改变配置文件from的值。如果是传统的做法,需要重启服务,才能达到配置文件的更新。此时,我们只需要发送post请求:,在此请求数据就会发生变化。

154745_em5X_2940767.png

另外,/bus/refresh接口可以指定服务,即使用”destination”参数,比如 “/bus/refresh?destination=customers:**” 即刷新服务名为customers的所有服务,不管ip。

转载于:https://my.oschina.net/Clarences/blog/1785658

你可能感兴趣的文章
不同工具查看代码分支diff的差异
查看>>
一文 | 跨域及其解决方案
查看>>
白话Java I/O模型
查看>>
[TsAdmin]--一款基于Vue.js+Element UI的单页无刷新(无iframe)多选项卡的后台管理系统模板...
查看>>
上传一张照片,让算法告诉你是否患有抑郁症
查看>>
VR厂商唯晶科技获2800万C+轮融资,曾开发过游戏《圣女之歌》
查看>>
Countly 19.02.1 发布,实时移动和 web 分析报告平台
查看>>
TCP连接中time_wait在开发中的影响-搜人以鱼不如授之以渔
查看>>
Oracle数据库机出新帮助不同规模企业迈向云端
查看>>
前端通信:ajax设计方案(六)--- 全局配置、请求格式拓展和优化、请求二进制类型、浏览器错误搜集以及npm打包发布...
查看>>
微服务分布式企业框架 Springmvc+mybatis+shiro+Dubbo+ZooKeeper+Redis+KafKa
查看>>
被《时代周刊》选为年度最佳发明,PS VR靠的竟然是价格
查看>>
通用唯一标识码UUID的介绍及使用。
查看>>
spring笔记--依赖注入之针对不同类型变量的几种注入方式
查看>>
Java爬虫——网易云热评爬取
查看>>
Ajax的简单学习
查看>>
无华为,不智慧:智慧城市建设为何少不了华为?
查看>>
高性能网络通信框架Netty-基础概念篇
查看>>
为npm配置taobao源
查看>>
zookeeper初探三 java客户端连接
查看>>