基於docker部署的微服務架構(四): 配置中心

前言

在微服務架構中,因爲服務數量衆多,若是使用傳統的配置文件管理方式,配置文件分散在各個項目中,不易於集中管理和維護。在 spring cloud 中使用 config-server 集中管理配置文件,可使用 gitsvn本地資源目錄 來管理配置文件,在集成了 spring cloud bus 以後還能夠經過一條 post 請求,讓全部鏈接到消息總線的服務,從新從 config-server 拉取配置文件,很是方便。前端

建立config-server

新建一個maven工程,修改pom.xml引入 spring cloud 依賴:java

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.4.2.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 配置文件,在配置文件內容:git

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: 8888

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8000/eureka/

這裏使用 git 做爲配置文件管理,searchPaths 指定配置文件所在的目錄,usernamepassword 分別git倉庫的用戶名和密碼。web

這裏把 config-server-demo 也註冊到 eureka,這樣在 eureka 註冊的服務,就能夠經過指定 config-server-demoserviceId ,從 config-server-demo 拉取配置文件,這樣的話在 config-server 改變url時,就不須要修改代碼了,並且在多實例狀況下也能夠負載均衡。spring

java 目錄中建立一個包 demo ,在包中建立啓動入口 ConfigServerApplication.javadocker

@EnableDiscoveryClient
@SpringBootApplication
@EnableConfigServer
public class ConfigServerApplication {

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

}

這裏使用了 @EnableConfigServer 註解,設置此工程爲配置中心。bootstrap

在服務註冊中心已經運行的狀況下,運行 ConfigServerApplication.java 中的 main 方法,啓動配置中心。
訪問服務註冊中心頁面 http://localhost:8000, 能夠看到已經成功註冊了 CONFIG-SERVER-DEMO 配置中心。跨域

修改配置文件加載方式

至此配置中心已經建立好了,咱們把以前的項目 service-gateway-demoadd-service-demo 拿過來改造一下,讓這兩個項目從配置中心加載配置文件。
service-gateway-demoadd-service-demo 增長maven依賴:網絡

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

刪除以前的配置文件 application.ymlapplication-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: 10000
        multiplier: 2
        maxInterval: 60000
        maxAttempts: 10

eureka:
  client:
    serviceUrl:
        defaultZone: http://localhost:8000/eureka/

bootstrap.yml 在加載順序上先於 application.yml ,經常使用於配置一些初始化的配置項。

這裏主要看下 spring.cloud.config 節點下的配置, profilelabel 這兩個配置一塊兒決定加載哪一個配置文件。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.enabledspring.cloud.discovery.serviceId,這兩個配置項配置了從服務註冊中心獲取 config-server-demo 的地址,而不使用傳統url的方式。
spring.cloud.config.failFastspring.cloud.config.retry 聯合配置失敗重試策略。

git 倉庫的 master 分支下的 spring-cloud-2.0/config-repo 目錄中新增兩個配置文件:add-service-demo-dev.ymlservice-gateway-demo-dev.yml
add-service-demo-dev.yml:

server:
  port: 8100

這裏只須要配置端口便可,註冊中心的地址已經在 bootstrap.yml 中進行了配置。

service-gateway-demo-dev.yml:

server: port: 80

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

啓動 add-service-demoservice-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-demoadd-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", 200);
        returnMap.put("msg", "操做成功");
        returnMap.put("result", a + b);
        return returnMap;
    }

}

這裏增長了一個 @RefreshScope 註解,代表 AddController 這個 Bean 中的配置可動態刷新。

先啓動 config-server-demo,配置服務啓動完畢後,啓動 add-service-demoservice-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-demoservice-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 環境下部署 zookeeperkafka ,以及使用 log4j2kafka appender 把微服務中的日誌聚合輸出到 kafka 中,爲後邊搭建 ELK 日誌統計分析環境作準備。

相關文章
相關標籤/搜索