springCloud -- 中级篇(2)

本系列笔记涉及到的代码在GitHub上，地址：https://github.com/zsllsz/cloud

本文涉及知识点：

  • 服务配置中心之config；

  • 服务消息总线之bus(会用到rabbitmq)；

欢迎大家关注我的公众号 javawebkf，目前正在慢慢地将简书文章搬到公众号，以后简书和公众号文章将同步更新，且简书上的付费文章在公众号上将免费。

一、服务配置中心之springCloud Config

1、是什么？
springCloud学到现在，已经新建了十四五个module，每个module都有yml，不方便管理，所以配置中心就应运而生了。我们可以把微服务相同的配置抽到配置中心里面去，比如数据源的配置。假如某一天需要换数据源，只需要修改配置中心的配置即可，而不用每个微服务的yml都去改。没错，以前学的zookeeper也有这功能。spring config 分为服务端和客户端两部分，服务端也称分布式配置中心，是一个独立的微服务应用；客户端则是通过指定的配置中心来管理应用资源以及业务相关的配置内容，并在启动的时候从配置中心加载配置信息。

2、能干嘛？

  • 集中管理配置文件
  • 不同环境不同配置，动态化的配置更新，分环境部署
  • 运行期间动态调整配置
  • 配置发生变化时不需要重启即可使用新的配置
  • 将配置信息以rest接口形式暴露

3、config服务端配置与测试：

  • 首先在github上新建一个仓库，然后新建一个config-dev.yml文件，内容随意，如下图：
github仓库
  • 新建名为cloud-config-center-3344的module；
  • pom.xml：
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator </artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-devtools</artifactId>
    <scope>runtime</scope>
    <optional>true</optional>
</dependency>
<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <optional>true</optional>
</dependency>
<!-- eureka client -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-config-server</artifactId>
</dependency>
  • yml：
server:
  port: 3344
  
spring:
  application:
    name: cloud-config-center
  cloud:
    config:
      server:
        git:
          uri: git@github.com:zsllsz/springcloud-config.git # github仓库地址
          search-paths:
          - springcloud-config # 搜索目录
      label: master # 读取的分支
eureka:
  client:
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka
  • 主启动：
@SpringBootApplication
@EnableConfigServer
public class ConfigMain3344 {

    public static void main(String[] args) throws Exception {
        SpringApplication.run(ConfigMain3344.class, args);
    }
}

启动后7001注册中心，然后启动3344，访问http://localhost:3344/master/config-dev.yml，看看能否读取到config-dev.yml中的内容：

读取配置成功

如果读取的是master，那么http://localhost:3344/master/config-dev.yml中的master可以省略，因为默认就是读master；如果读其他分支，比如dev，那就在配置中写成dev，然后访问的url将master换成dev即可。url还可以是这样：http://localhost:3344/config/dev/master，这里表示读取config-dev文件，分支为master。如果用lable表示分支，application表示文件名，profiles表示环境，那么url形式有如下几种：

  • /lable/application-profile.yml
  • /application-profile.yml（只能读master）
  • /application/profile/lable

4、config客户端配置与测试：

  • 修改github上的config-dev.yml，将内容改成符合yml文件格式的内容，比如这样：
  • 新建名为cloud-config-client-3355的module；
  • pom.xml：
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator </artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-devtools</artifactId>
    <scope>runtime</scope>
    <optional>true</optional>
</dependency>
<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <optional>true</optional>
</dependency>
<!-- eureka client -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-config</artifactId>
</dependency>
  • bootstrap.yml：注意，以前的yml是application.yml，它是用户级的资源配置，现在要新建一个bootstrap.yml，这个是系统级的，优先级更高。
server:
  port: 3355
  
spring:
  application:
    name: config-client
  # config 配置
  cloud:
    config:
      label: master # 分支
      name: config # 文件名
      profile: dev # 环境
      # 以上三个组合起来就是表示读取master上的config-dev.yml
      uri:
      - http://localhost:3344 # 配置中心地址
      
eureka:
  client:
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka
  • 主启动：
@SpringBootApplication
@EnableEurekaClient
public class ConfigClientMain3355 {
    public static void main(String[] args) throws Exception {
        SpringApplication.run(ConfigClientMain3355.class, args);
    }
}
  • controller：
@RestController
@RequestMapping("/config")
public class ConfigController {

    @Value("${config.info}")
    private String configInfo;
    
    @GetMapping("/info")
    public String getInfo() {
        return configInfo;
    }
}

我们在bootstrap.yml中配置了配置中心3344的访问路径，3344又会去github上找config-dev.yml，这个文件上又有config.info，所以在这个controller直接用@Value注解可以获取。最后访问这个controller，就可以在浏览器输出config-dev.yml中config.info的信息，如下：

成功获取配置信息

5、动态刷新问题：
加入github上的config-dev.yml内容修改了，3344因为是直接连接github去获取配置信息的，所以可以获取最新信息；但是3355就必须重启才能获取最新内容，这不方便。接下来配置动态刷新，即不用重启也可以获取最新配置：

  • 修改bootstrap.yml，加上如下配置：
# 暴露监控端口
management:
  endpoints:
    web:
      exposure:
        include:
        - "*"
  • 在controller中加上@RefreshScope注解，如下：
@RestController
@RequestMapping("/config")
@RefreshScope
public class ConfigController {

    @Value("${config.info}")
    private String configInfo;
    
    @GetMapping("/info")
    public String getInfo() {
        return configInfo;
    }
}

这样就搞定了，可以修改github上文件测试一下。经实测访问3355时还是没有获取到最新的配置内容，其实还需要发送一个post请求刷新3355。执行如下命令或者用postman请求都可：

curl -X POST "http://localhost:3355/actuator/refresh"


二、服务消息总线之springcloud bus

上面的config还有点麻烦的就是每次修改了github上的配置文件，想要客户端也能立即读取到最新的，需要发送一个post请求去刷新，总归还是不方便。springcloud bus就是对springcloud config的增强，配合config使用，可以实现完全自动刷新，不需要再发post请求。

1、是什么？
搭配消息中间件使用，可以实现全局广播通知。支持的消息中间件有RabbitMQ和Kafka。这个消息总线就像一个微信公众号，一个个的微服务应用就是订阅了这个公众号的人。微信公众号发了推文，每个订阅了的人都可以收到消息。这个springcloud bus就是这个公众号，它会让所有的服务都连接上来，配置文件有变化它会通知所有的服务。

2、RabbitMQ安装与配置：

  • 由于RabbitMQ是Erlang语言开发的，所以要安装Erlang，在centos上依次执行以下命令即可安装erlang：
yum install -y epel-release

wget https://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm

rpm -Uvh erlang-solutions-1.0-1.noarch.rpm

yum install -y erlang

erl -version

# 导入密钥
rpm --import https://www.rabbitmq.com/rabbitmq-release-signing-key.asc
# 安装
yum install rabbitmq-server-3.8.3-1.el7.noarch.rpm
# 启动
systemctl start rabbitmq-server
# 开启图形界面
rabbitmq-plugins enable rabbitmq_management

访问ip:15672，即可访问图形界面。默认用户名和密码都为guest，但是这个只允许用localhost访问，所以可以通过以下步骤新建用户：

# 新建admin用户，密码也为admin
rabbitmqctl add_user admin admin
# 设置权限
rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"
# 将admin设置为管理员用户
rabbitmqctl set_user_tags admin administrator
# 重启rabbitmq
systemctl restart rabbitmq-server

再次访问ip:15672，用admin就可以登陆进去了。


rabbitmq启动成功

3、springcloud bus的使用：

  • 新建名为cloud-config-client-3366的module；
  • pom.xml：
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator </artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-devtools</artifactId>
    <scope>runtime</scope>
    <optional>true</optional>
</dependency>
<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <optional>true</optional>
</dependency>
<!-- eureka client -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-config</artifactId>
</dependency>
  • bootstrap.yml：
server:
  port: 3366
  
spring:
  application:
    name: config-client
  # config 配置
  cloud:
    config:
      label: master # 分支
      name: config # 文件名
      profile: dev # 环境
      # 以上三个组合起来就是表示读取master上的config-dev.yml
      uri:
      - http://localhost:3344 # 配置中心地址
      
eureka:
  client:
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka
  
# 暴露监控端点    
management:
  endpoints:
    web:
      exposure:
        include:
        - "*"
  • 主启动类：
@SpringBootApplication
@EnableEurekaClient
public class ConfigClientMain3366 {
    public static void main(String[] args) throws Exception {
        SpringApplication.run(ConfigClientMain3366.class, args);
    }
}
  • controller：
@RestController
@RequestMapping("/config")
@RefreshScope
public class ConfigClientController {
    @Value("${config.info}")
    private String configInfo;

    @GetMapping("/info")
    public String getInfo() {
        return configInfo;
    }
}

上面还没用到bus。bus的通知思想有两种，一种是广播通知一个客户端，进而通知到所有的客户端；另一种是bus广播通知服务端，服务端再通知所有的客户端。一般情况使用第二种方式，即通知服务端，通知这个带头大哥即可。

下面开始使用springcloud bus

  • 修改3344的pom，新增如下依赖：
<!-- rabbitmq的支持 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
  • 修改3344的yml，添加rabbitmq和bus相关配置，如下：
  # mq相关配置
  rabbitmq:
    host: 192.168.0.106
    port: 5672
    username: admin
    password: admin
# bus配置
management:
  endpoints:
    web:
      exposure:
        include:
        - 'bus-refresh'
  • 修改3355的pom，添加如下依赖：
<!-- rabbitmq的支持 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
  • 修改3355的yml，添加如下配置：
  # mq相关配置
  rabbitmq:
    host: 192.168.0.106
    port: 5672
    username: admin
    password: admin
  • 3366和3355做一样的修改。
  • 依次启动7001，3344，3355，3366
  • 3344、3355和3366先访问一次配置文件
  • 然后修改github上config-dev.yml的内容
  • 3344此时可以访问到修改后的内容，因为它是带头大哥，直连github的，但是3355和3366此时还没有获取到最新的，因为RabbitMQ还没进行广播通知；
  • 执行如下命令：
curl -X POST http://localhost:3344/actuator/bus-refresh
  • 刷新了带头大哥3344，叫它去通知3355和3366，再次去访问3355和3366，发现也能获取到最新的配置了。这就是bus和rabbitmq的功劳。如下图，在rabbitmq上有一个topic叫springCloudBus，3344、3355和3366都订阅了这个topic。当github上的配置发生改变时，我们就发一个post请求去通知3344，然后所有订阅了该topic的服务都会收到通知去更新配置。
rabbitmq

4、定点通知：
上面演示的是通知所有订阅了该topic的服务，即3355和3366都通知到了。如果我想只通知3355，又当如何？发送post请求的时候指定发给谁就行了，公式就是：

curl -X POST http://localhost:3344/actuator/bus-refresh/客户端的服务名:服务端口

服务名就是config客户端的微服务名字，即3344和3355的spring.application.name，比如只通知3355，那么执行如下命令即可：

curl -X POST http://localhost:3344/actuator/bus-refresh/config-client:3355
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
禁止转载，如需转载请通过简信或评论联系作者。
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 219,366评论 6赞 508
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 93,521评论 3赞 395
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 165,689评论 0赞 356
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 58,925评论 1赞 295
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 67,942评论 6赞 392
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 51,727评论 1赞 305
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 40,447评论 3赞 420
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 39,349评论 0赞 276
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 45,820评论 1赞 317
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,990评论 3赞 337
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 40,127评论 1赞 351
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 35,812评论 5赞 346
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 41,471评论 3赞 331
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 32,017评论 0赞 22
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,142评论 1赞 272
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 48,388评论 3赞 373
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 45,066评论 2赞 355