SpringCloud学习之SpringCloudBus

2018-04-03 726

一。spring-cloud-bus是什么？

　　回答这个问题之前，我们先回顾先前的分布式配置，当配置中心发生变化后，我们需要利用spring-boot-actuator里的refresh端点进行手动刷新：

　　根据上述示例情况：我们每次要获取最新配置时，要一个一个的通过refresh刷新服务节点，这种方式是不是非常low而且非常麻烦，那该怎么办呢？

　　大家还记得zookeeper中watch是做什么用的吗？当监控的节点数据发生变化了，那么是不是所有订阅到该节点的客户端都会触发一个订阅回调呢？这其实也类似于我们的消息总线。在微服务架构的系统中，我们通常会使用轻量级的消息代理来构建一个公有的消息主题让系统中所有微服务实例都连接上来，由于该主题中产生的消息会被所有实例监听和消费，所以我们称它为消息总线。

　　那么在分布式配置中，我们的所有服务都订阅消息总线的话，当配置改变时，配置中心通知消息总线，然后所有的服务节点接收到订阅消息后，在从配置中心获取最新的配置，是不是一个一劳永逸的过程？那么可以得到如下结构图：

二、实现分布式配置的消息总线

我先贴出：项目结构图

我们统一把配置放在config目录下

1、在对应的服务添加对应的依赖

　　首先我们先配置config-server。gradle配置文件：

dependencies {
    // testCompile group: 'junit', name: 'junit', version: '4.12'
    compile('org.springframework.cloud:spring-cloud-config-server')
    compile('org.springframework.kafka:spring-kafka')
    compile('org.springframework.cloud:spring-cloud-starter-bus-kafka')
    compile('org.springframework.cloud:spring-cloud-starter-eureka-server')
}

View Code

　　注意我们使用kafka作为消息总线的中间件

　　然后我们依次在所需的服务中添加对应的依赖

dependencies {
    // testCompile group: 'junit', name: 'junit', version: '4.12'
     compile('org.springframework.cloud:spring-cloud-starter-config')
    compile('org.springframework.kafka:spring-kafka')
    compile('org.springframework.cloud:spring-cloud-starter-bus-kafka')
    compile('org.springframework.cloud:spring-cloud-starter-eureka-server')
}

View Code

2、配置对应的application.yml

config-server的yml文件：

spring:
  application:
    name: config-server
  cloud:
    config:
      server:
        git:
          uri: file://${user.home}/IdeaProjects/spring-cloud
          repos:
            local:
              pattern: '**/local'
              uri: file://${user.home}/IdeaProjects/spring-cloud
              searchPaths: config
          search-paths: config
      label: master
  kafka:
    bootstrap-servers: localhost:9092
server:
  port: 8888
endpoints:
  refresh:
    sensitive: false
  bus:
    sensitive: false

View Code

这里面注意要把端点先开放出来，然后进行kafka的相关配置，其余服务的配置文件也进行这样的操作，使其能与消息总线通讯。

3、依次启动服务

　　当服务启动成功时，SpringBootActuator给我们提供一个/bus/refresh端点，同时我们可以在kafka主题里面找到相应的topics,其名字为springCloudBus:

4、访问Config-Server的/bus/refesh

　　我们先使用kafka的消费端来监听一下消息内容。运行：

 ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic springCloudBus

　　紧接着我们在访问 http://localhost:8888/bus/refresh 刷新config-server的配置

　　然后我们可以发现消费端，订阅到如下消息：

　　其中：type为消息的事件类型

　　　　　timestamp 为消息的时间戳

　　　　 orginService:消息的来源服务实例

　　　　　destinationService:消息的目标服务实例，**代表了总线上的所有服务实例

　　　　　在本例子中，我们可以看到每个服务的ackId都来自于 type为RefreshRemoteApplicationEvent的服务ID

5、运行服务

　　我们先通过gradle的build任务进行打包会得到如下文件：xxxx.jar与xxx.jar.orginal

　　那么进入到对应目录下启动两个服务并注册到注册中心命令如下：

java -Dserver.port=8300 -Dspring.profiles.active=local -jar xxxx.jar
java -Dserver.port=8200 -Dspring.profiles.active=local -jar xxxx.jar

　　注意一定不要在application.yml配置如上参数，否则通过(-Dxxx=xxx)系统变量设置的值将不会生效

　　此时我们更改config对应的配置并commit后，在运行步骤4，就可以拿到最新的结果了，再次附上相关代码：

　　StudentConfig:

package com.hzgj.lyrk.order.config;

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;

@ConfigurationProperties(prefix = "student")
@Configuration
public class StudentConfig {

    private String name;

    private String age;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getAge() {
        return age;
    }

    public void setAge(String age) {
        this.age = age;
    }

    @Override
    public String toString() {
        return "StudentConfig{" +
                "name='" + name + '\'' +
                ", age='" + age + '\'' +
                '}';
    }
}

View Code

　　order-server-local:

student:
  name: student_local
  age: 17

View Code

微信关注我们

原文链接：https://yq.aliyun.com/articles/613228

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

入选Gartner和Forrester报告的阿里云AnalyticDB是如何实现PB级数据分析毫秒级响应

前言 2018年3月13日，Forrester发布了最新的云化数据仓库分析报告（ Now Tech: Cloud Data Warehouse, Q1 2018），阿里巴巴同亚马逊，谷歌，微软四个世界级云厂商共同进入领先者阵营。同时今年二月份Gartner发布的分析型数据管理平台报告中（ Magic Quadrant for Data Management Solutions for Analytics），阿里巴巴第一次参评即进入魔力四象限。这体现了阿里巴巴多年来在打造 DT商业过程中的大量数据分析技术积累。阿里巴巴的整套数据分析平台基于阿里飞天分布式系统打造，其核心的产品包括大数据计算服务MaxCompute 和分析型数据库AnalyticDB，以及数加DataWorks 等。其中AnalyticDB作为分布式分析型数据库，更是承

2018-04-04

616

P2P网络架构比特币采用了基于国际互联网（Internet）的P2P（peer-to-peer）网络架构。P2P是指位于同一网络中的每台计算机都彼此对等，各个节点共同提供网络服务，不存在任何“特殊”节点。每个网络节点以“扁平（flat）”的拓扑结构相互连通。在P2P网络中不存在任何服务端（server）、中央化的服务、以及层级结构。P2P网络的节点之间交互运作、协同处理：每个节点在对外提供服务的同时也使用网络中其他节点所提供的服务。P2P网络也因此具有可靠性、去中心化，以及开放性。比特币网络”是按照比特币P2P协议运行的一系列节点的集合。除了比特币P2P协议之外，比特币网络中也包含其他协议。例如Stratum协议就被应用于挖矿、以及轻量级或移动端比特币钱包之中。网关（gateway）路由服务器提供这些协议，使用比特币P2P协议接入比特币网络，并把网络拓展到运行其他协议的各个节点。例如，Stratum服务器通过Stratum协议将所有的Stratum挖矿节点连接至比特币主网络、并将Stratum协议桥接（bridge）至比特币P2P协议之上。我们使用“扩展比特币网络（extended b...

2018-04-04

651

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。

SpringCloud学习之SpringCloudBus

一。spring-cloud-bus是什么？

二、实现分布式配置的消息总线

1、在对应的服务添加对应的依赖

2、配置对应的application.yml

3、依次启动服务

4、访问Config-Server的/bus/refesh

5、运行服务

入选Gartner和Forrester报告的阿里云AnalyticDB是如何实现PB级数据分析毫秒级响应

精通比特币系列---比特币网络

相关文章

发表评论

资源下载

优质分享App

Mario

Spring

Sublime Text

欢迎您来访！