原文:http://www.jianshu.com/p/b17d65934b58%20

前言

在微服务架构中,由于服务数量众多,如果使用传统的配置文件管理方式,配置文件分散在各个项目中,不易于集中管理和维护。在 spring cloud 中使用 config-server 集中管理配置文件,可以使用 gitsvn本地资源目录 来管理配置文件,在集成了 spring cloud bus 之后还可以通过一条 post 请求,让所有连接到消息总线的服务,重新从config-server 拉取配置文件,非常方便。

创建config-server

新建一个maven工程,修改pom.xml引入 spring cloud 依赖:

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.4..RELEASE</version>
</parent> <dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-config-server</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
</dependencies> <dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Camden.SR2</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>

在 resources 目录中创建 application.yml 配置文件,在配置文件内容:

spring:
application:
name: @project.artifactId@
cloud:
config:
server:
git:
uri: https://git.oschina.net/yuelenghan/soa-demo.git
searchPaths: spring-cloud-2.0/config-repo
username: username
password: password server:
port: eureka:
client:
serviceUrl:
defaultZone: http://localhost:8000/eureka/

这里使用 git 作为配置文件管理,searchPaths 指定配置文件所在的目录,username 和password 分别git仓库的用户名和密码。

这里把 config-server-demo 也注册到 eureka,这样在 eureka 注册的服务,就可以通过指定 config-server-demo 的 serviceId ,从 config-server-demo 拉取配置文件,这样的话在 config-server 改变url时,就不需要修改代码了,而且在多实例情况下也可以负载均衡。

在 java 目录中创建一个包 demo ,在包中创建启动入口ConfigServerApplication.java

@EnableDiscoveryClient
@SpringBootApplication
@EnableConfigServer
public class ConfigServerApplication { public static void main(String[] args) {
SpringApplication.run(ConfigServerApplication.class, args);
} }

这里使用了 @EnableConfigServer 注解,设置此工程为配置中心。

在服务注册中心已经运行的情况下,运行 ConfigServerApplication.java 中的 main 方法,启动配置中心。
访问服务注册中心页面 http://localhost:8000, 可以看到已经成功注册了 CONFIG-SERVER-DEMO 配置中心。

修改配置文件加载方式

至此配置中心已经创建好了,我们把之前的项目 service-gateway-demo 和 add-service-demo 拿过来改造一下,让这两个项目从配置中心加载配置文件。
给 service-gateway-demo 和 add-service-demo 增加maven依赖:

<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-config</artifactId>
</dependency>

删除之前的配置文件 application.yml 和 application-docker.yml,新建配置文件bootstrap.yml,文件内容:

spring:
application:
name: @project.artifactId@
profiles:
active: @activatedProperties@
cloud:
config:
profile: dev
label: master
discovery:
enabled: true
serviceId: CONFIG-SERVER-DEMO
failFast: true
retry:
initialInterval:
multiplier:
maxInterval:
maxAttempts: eureka:
client:
serviceUrl:
defaultZone: http://localhost:8000/eureka/

bootstrap.yml 在加载顺序上先于 application.yml ,常用于配置一些初始化的配置项。

这里主要看下 spring.cloud.config 节点下的配置, profile 和 label 这两个配置一起决定加载哪个配置文件。label 表示配置文件所在分支,配置文件的名称为{ApplicationName}-{profile}.yml 或 {ApplicationName}-{profile}.properties
根据配置文件中的配置信息,add-service-demo 加载的配置文件为 add-service-demo-dev.yml,文件在 git 仓库的 master 分支下。service-gateway-demo 加载的配置文件为service-gateway-demo-dev.yml,文件同样在 git 仓库的 master 分支下,文件路径都为 spring-cloud-2.0/config-repo
spring.cloud.discovery.enabled 和 spring.cloud.discovery.serviceId,这两个配置项配置了从服务注册中心获取 config-server-demo 的地址,而不使用传统url的方式。
spring.cloud.config.failFast 和 spring.cloud.config.retry 联合配置失败重试策略。

在 git 仓库的 master 分支下的 spring-cloud-2.0/config-repo 目录中新增两个配置文件:add-service-demo-dev.yml 和 service-gateway-demo-dev.yml
add-service-demo-dev.yml:

server:
port:

这里只需要配置端口即可,注册中心的地址已经在 bootstrap.yml 中进行了配置。

service-gateway-demo-dev.yml:

 server:
port: zuul:
routes:
add-service-demo:
path: /add-service/**
serviceId: add-service-demo

启动 add-service-demo 和 service-gateway-demo,注意观察控制台,可以看到:
Fetching config from server at: http://config-server的IP:8888/,说明配置文件从 config-server 中拉取。

集成spring cloud bus功能

给 config-server-demoservice-gateway-demoadd-service-demo 这3个工程分别添加 spring cloud bus 的maven依赖:

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

修改 config-server-demo 的配置文件 application.yml,在 spring 节点下增加 rabbitmq的配置信息:

rabbitmq:
host: rabbitmq地址
port: 端口
username: guest
password: guest

在git仓库中修改 service-gateway-demo 和 add-service-demo 的配置文件,增加rabbitmq 的配置信息:

spring:
rabbitmq:
host: rabbitmq地址
port: 端口
username: guest
password: guest

在 add-service-demo-dev.yml 中额外增加一条用于测试的配置信息:my.info.str: test1111,修改 AddController.java,输出这条配置信息:

@RestController
@RefreshScope
public class AddController { @Value("${my.info.str}")
private String infoStr; @RequestMapping(value = "/add", method = RequestMethod.GET)
public Map<String, Object> add(Integer a, Integer b) {
System.out.println("端口为8100的实例被调用");
System.out.println("infoStr : " + infoStr);
Map<String, Object> returnMap = new HashMap<>();
returnMap.put("code", );
returnMap.put("msg", "操作成功");
returnMap.put("result", a + b);
return returnMap;
} }

这里增加了一个 @RefreshScope 注解,表明 AddController 这个 Bean 中的配置可动态刷新。

先启动 config-server-demo,配置服务启动完毕后,启动 add-service-demo 和 service-gateway-demo
打开 rabbitmq 的web管理页面,可以看到有3个 connection 连接到了 rabbitmq
访问 http://localhost/add-service/add?a=1&b=2 查看 add-service-demo 的控制台打印出的 infoStr 信息,infoStr : test1111
修改 git 仓库中的 add-service-demo-dev.yml 文件里的 my.info.str 配置,提交后发送bus 刷新的指令,向使用 spring cloud bus 的服务发送一条post请求,随便哪一个都行,这里以 config-server-demo 为例: curl -X POST http://localhost:8888/bus/refresh,发送这条 post 信息之后,查看控制台的输出日志,会发现 add-service-demo 和 service-gateway-demo 会重新加载 git 仓库中的配置文件。
再次访问 http://localhost/add-service/add?a=1&b=2,控制台输出了修改之后的 infoStr信息。

使用docker-maven-plugin打包并生成docker镜像

这里的内容和前几篇文章基本相同,都是把配置文件复制一份,修改为 docker 环境下的配置,在 pom.xml 中增加 docker 环境的profile。这里不再赘述,直接附上源码:
demo源码 spring-cloud-2.0目录

最后

目前为止,已经有了服务注册中心、配置中心、服务网关、消息总线、服务提供者和消费者,并且在网关层做了前端跨域处理。在开发层面,使用这些内容已经可以进行简单微服务的开发了。
但是在服务运维方面,尤其在服务数量不断增多的情况下,日志分散在各个工程下,如何进行日志聚合,方便的查看日志信息。服务之间互相调用出错时如何快速排查,如何熔断降级,使错误不至于影响整个服务网络。这些内容涉及到日志聚合、服务追踪、熔断器等,将在后续的文章中再做介绍。
下一篇介绍如何在 docker 环境下部署 zookeeper 和 kafka ,以及使用 log4j2 的 kafka appender 把微服务中的日志聚合输出到 kafka 中,为后边搭建 ELK 日志统计分析环境做准备。

基于docker部署的微服务架构(四): 配置中心的更多相关文章

  1. spring cloud+dotnet core搭建微服务架构:配置中心(四)

    前言 我们项目中有很多需要配置的地方,最常见的就是各种服务URL地址,这些地址针对不同的运行环境还不一样,不管和打包还是部署都麻烦,需要非常的小心.一般配置都是存储到配置文件里面,不管多小的配置变动, ...

  2. spring cloud+.net core搭建微服务架构:配置中心(四)

    前言 我们项目中有很多需要配置的地方,最常见的就是各种服务URL地址,这些地址针对不同的运行环境还不一样,不管和打包还是部署都麻烦,需要非常的小心.一般配置都是存储到配置文件里面,不管多小的配置变动, ...

  3. spring cloud+dotnet core搭建微服务架构:配置中心续(五)

    前言 上一章最后讲了,更新配置以后需要重启客户端才能生效,这在实际的场景中是不可取的.由于目前Steeltoe配置的重载只能由客户端发起,没有实现处理程序侦听服务器更改事件,所以还没办法实现彻底实现这 ...

  4. spring cloud+.net core搭建微服务架构:配置中心续(五)

    前言 上一章最后讲了,更新配置以后需要重启客户端才能生效,这在实际的场景中是不可取的.由于目前Steeltoe配置的重载只能由客户端发起,没有实现处理程序侦听服务器更改事件,所以还没办法实现彻底实现这 ...

  5. Docker从入门到掉坑(二):基于Docker构建SpringBoot微服务

    本篇为Docker从入门到掉坑第二篇:基于Docker构建SpringBoot微服务,没有看过上一篇的最好读过 Docker 从入门到掉坑 之后,阅读本篇. 在之前的文章里面介绍了如何基于docker ...

  6. 基于 Spring Cloud 的微服务架构实践指南(下)

    show me the code and talk to me,做的出来更要说的明白 本文源码,请点击learnSpringCloud 我是布尔bl,你的支持是我分享的动力! 一.引入 上回 基于 S ...

  7. Re:从 0 开始的微服务架构--(四)如何保障微服务架构下的数据一致性--转

    原文地址:http://mp.weixin.qq.com/s/eXvoJew3bjFKzLLJpS0Otg 随着微服务架构的推广,越来越多的公司采用微服务架构来构建自己的业务平台.就像前边的文章说的, ...

  8. 基于 Spring Cloud 的微服务架构实践指南(上)

    show me the code and talk to me,做的出来更要说的明白 GitHub 项目learnSpringCloud同步收录 我是布尔bl,你的支持是我分享的动力! 一. 引入 上 ...

  9. java微服务的统一配置中心

    为了更好的管理应用的配置,也为了不用每次更改配置都重启应用,我们可以使用配置中心 关于eureka的服务注册和rabbitMQ的安装使用(自动更新配置需要用到rabbitMQ)这里不赘述,只关注配置中 ...

随机推荐

  1. SharePoint 2013 &quot;通知我&quot;功能简介

    功能简介 "通知我"主要是在列表或者文档库里面的项目,有添加/删除/修改等操作,发送邮件通知设置的用户的功能:可以针对列表或者文档库设置通知,也可以针对单一项目设置通知功能,是Sh ...

  2. QUnit使用笔记-1判断方法

    QUnit是一个前端测试工具. 判断效果: html基本结构: <h1 id="qunit-header">QUnit</h1> <h2 id=&qu ...

  3. boost::algorithm(字符串算法库)

    没什么说的,需要 #include<boost/algorithm/string.hpp> 1.大小写转换 std::string s("test string"); ...

  4. python多目录字符串查找匹配

    1. 需求来自于实际工作: 需要处理一批服务器上运行的redis实例,每个redis实例可能有密码,也可能没有,有密码的,密码配置格式一定是: requirepass XXXXX # XXXX是密码 ...

  5. Ubuntu通过ADB连接手机

    参考 ubuntu14.04 下android studio连接手机 安装 adb $sudo apt install adb $sudo lsusb 得到ID为 Bus Device : ID 12 ...

  6. tomcat多端口配置

    <?xml version="1.0" encoding="UTF-8"?> <Server port="8005" sh ...

  7. 每日linux命令学习-lsattr和chattr

    lsattr和chattr命令 1. lsattr命令 作用: 显示文件属性 语法: lsattr [-adlRvV][files...] 参数: -a 显示所有文件和目录(包括隐藏文件)的属性. - ...

  8. 《剑指offer》— JavaScript(25)复杂链表的复制

    复杂链表的复制 题目描述 输入一个复杂链表(每个节点中有节点值,以及两个指针,一个指向下一个节点,另一个特殊指针指向任意一个节点),返回结果为复制后复杂链表的head.(注意,输出结果中请不要返回参数 ...

  9. pycharm专业版激活码

    K71U8DBPNE-eyJsaWNlbnNlSWQiOiJLNzFVOERCUE5FIiwibGljZW5zZWVOYW1lIjoibGFuIHl1IiwiYXNzaWduZWVOYW1lIjoiI ...

  10. T-SQL查询:WITH AS 递归计算某部门的所有上级机构或下级机构

    drop table #Area; CREATE TABLE #Area ( id INT NOT NULL, city_name NVARCHAR(100) NOT NULL, parent_id ...