搭建簡單Cloud架構（One）

一、父項目搭建

新建maven項目pom文件修改

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.mmh</groupId>
    <artifactId>mmh-parent</artifactId>
    <version>1.0-SNAPSHOT</version>
    <packaging>pom</packaging>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.4.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <!-- 根據自己需求添加jar -->
    <dependencies>
        <!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.16.14</version>
            <scope>provided</scope>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.33</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.0.11</version>
        </dependency>
    </dependencies>
    <modules>
        <module>mmh-models</module>
        <module>mmh-eureka</module>
    </modules>
</project>

刪除不必要的子文件夾，如src、mvn之類的留下pom和iml就OK

在父項目基礎上創建子項目。

二、Eureka的搭建

創建檢查pom是否引入eureka坐標

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-netflix-eureka-server</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter</artifactId>
</dependency>

注意<parent>標簽填寫父項目的信息

<parent>
    <artifactId>mmh-parent</artifactId>
    <groupId>com.mmh</groupId>
    <version>2.0-SNAPSHOT</version>
</parent>

父項目<modules>標簽加入此項目

好了不墨跡了，0.0重點來啦：啟動類加上@EnableEurekaServer

application.yml 配置文件配置eureka的服務端。

spring:
    application:
        name: xxx

server:
    port: 8761 #啟動端口

eureka:
    client:
        registerWithEureka: false  #false:不作為一個客戶端注冊到注冊中心
        fetchRegistry: false      #為true時，可以啟動，但報異常：Cannot execute request on any known server

啟動訪問localhost:8761

看到如下界面則成功搭建Eureka的服務端

 附Eureka客戶端使用方法：

 引入客戶端坐標：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

啟動類加入Client的坐標：

@EnableEurekaClient

配置文件application.yml：

eureka:
  client:
    service-url:
        defaultZone: http://localhost:8761/eureka/
  instance:
    prefer-ip-address: true
    ip-address: 127.0.0.1
    instance-id: ${spring.application.name}:${eureka.instance.ip-address}:${server.port} # 狀態顯示格式

配置即可發現服務：

 

Eureka密碼配置

依賴坐標：

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-security</artifactId>
</dependency>

配置文件：

服務端

# 安全認證的配置
security:
  basic:
    enabled: true
  user:
    name: admin  # 用戶名
    password: 123456   # 用戶密碼

客戶端

eureka:
  client:
    service-url:
        defaultZone: http://admin:123456@localhost:8761/eureka/

 其他配置：

eureka:
    client:
        fetch-registry: true # 是否需要去檢索尋找服務，默認是true
        registry-fetch-interval-seconds: 5 # 表示eureka client間隔多久去拉取服務注冊信息，默認為30秒，對于gateway，如果要迅速獲取服務注冊狀態，可以縮小該值，比如5秒
    instance:
        health-check-url-path: /xxx/health # 修改實例的狀態頁面地址,相對路徑，也支持絕對路徑，例如需要支持https,默認為/info
        lease-expiration-duration-in-seconds: 90 # 表示eureka server至上一次收到client的心跳之后，等待下一次心跳的超時時間;超時移除該instance
        lease-renewal-interval-in-seconds: 5 # 表示eureka client發送心跳給server端的頻率,默認5秒

        status-page-url-path: /yyy/info # 修改健康監控地址,相對路徑，也支持絕對路徑，例如需要支持https,默認為/health

三、服務注冊與發現j集成Ribbon負載

Ribbon坐標依賴：

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

啟動類：

package com.yst.test;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@EnableEurekaClient
public class YstTestApplication {
    @Bean
    @LoadBalanced // 這里是重點 加上它才能使用ribbon負載
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

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

一個測試接口：

package com.yst.test.rest;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

/**
 * @program: yst-parent
 * @description: mmh
 * @author: Mr.Miao
 * @create: 2018-08-28 11:28
 **/
@RestController
@RequestMapping("/test")
public class TestController {
    @Autowired
    private RestTemplate restTemplate;
    @GetMapping("/getName")
    public String getName(){
        /*
         * 使用restTemplate調用，YST-RIBBON-ONE 為服務名 即spring.application.name
         * 啟動兩個 YST-RIBBON-ONE 則會進行負載調用
         */
        return restTemplate.getForObject("http://YST-RIBBON-ONE/ribbon/demo",String.class);
    }
}

兩個微服務：

package com.yst.ystribbonone.rest;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @program: yst-parent
 * @description: mmh
 * @author: Mr.Miao
 * @create: 2018-08-28 17:21
 **/
@RestController
@RequestMapping("/ribbon")
public class OneController {
    @GetMapping("/demo")
    public String getName(){
        System.out.println("demo1");
        return "demo1";
    }
}

 Two跟這個Controller一樣

注意兩個微服務的spring.application.name必須一致 調用者（test）與  被調用者（one，two）都需要注冊到Eureka。

訪問http://localhost:9001/test/getName  這里的9001為調用者端口號

結果我們會發現請求進入 one 和 two 這兩個微服務并起到負載的作用。

Ribbon還用很多配置在application.yml里配置：

ribbon:
  eureka:
    enabled: true # 開啟Eureka
  ReadTimeout: 100000 # 讀取超時時間
  ConnectTimeout: 100000 # 
  MaxAutoRetries: 0
  MaxAutoRetriesNextServer: 1
  OkToRetryOnAllOperations: false

Ribbon規則的配置：

在開始之前，首先說明一下，Ribbon有兩種配置，一種是配置文件配置，一種是代碼配置，還有的話就是默認的

1、輪詢規則 RoundRobinRule 此規則只是通過循環選擇服務器。它通常用作默認規則或更高級規則的后備。

2、根據服務是否死掉或者服務處于高并發來分配權重 AvailabilityFilteringRule 此規則將跳過被視為“電路跳閘”或具有高并發連接數的服務器。默認情況下，如果RestClient最近三次無法與其建立連接，則實例會跳閘。一旦實例電路跳閘，它將在電路被認為再次關閉之前保持這種狀態30秒。然而，如果它繼續連接失敗，它將再次“電路跳閘”并且它變為“電路閉合”的等待時間將指數地增加到連續故障的數量。
3、根據響應時間分配權重 WeightedResponseTimeRule 對于此規則，每個服務器根據其平均響應時間給予權重。響應時間越長，重量就越小。該規則隨機選擇服務器，其中可能性由服務器的權重決定。要啟用WeightedResponseTimeRule，請通過API使用負載均衡器進行設置
4、隨機原則 RandomRule 

（一）配置文件配置：

  例：

service-B.ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RandomRule # service-B是注冊到Eureka的serviceID 那個大寫的東東 千萬別寫成application.name了

（二）代碼自定義配置：

例：

我們都知道@SpringBootApplication注解里有 @ComponentScan自動掃描組件，官方不推薦我們把config放入SpringBoot自動掃描的范圍內。所以我們在掃描范圍外創建了config文件夾：

TestConfiguration類如下：

package com.yst.test.config;

import com.netflix.loadbalancer.IRule;
import com.netflix.loadbalancer.RandomRule;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @program: yst-parent
 * @description: mmh
 * @author: Mr.Miao
 * @create: 2018-08-29 13:52
 **/
@Configuration
public class TestConfiguration {
    @Bean
    public IRule ribbonRule(){
        // 隨機規則 這里可以定義其他規則
        return new RandomRule();
    }
}

啟動類增加注解：

@RibbonClient(name = "Eureka的serviceID",configuration = TestConfiguration.class)

name為注冊到Eureka的serviceID，configuration為剛創建的config

多個client可以使用@RibbonClients() 里面value 可以放多個@RibbonClient()

啟動即可 其他規則自行測試。

這里總結一下，個人推薦配置文件的配置的方法，省去過多步驟，如果有需要更加靈活的規則，可以使用代碼注入Bean的方式。

優先級：配置文件>代碼>默認

接下來小伙伴們都知道，如何使用Ribbon了，但是我們發現如果項目中不使用Eureka，我們還有辦法使用Ribbon嗎？

答案是可以的，請繼續看教程：

如何使Eureka 與 Ribbon 分離？

特別簡單 只需要在 application.yml 中配置下面一段配置即可

ribbon:
  eureka:
   enabled: false
YST-RIBBON-ONE:   # 這里是還是服務名
  ribbon:
    listOfServers: localhost:9002  # 這里自定義也就是被請求者的地址 多個地址可以用 , 號隔開

我們可以直接使用Ribbon的Api：

public class MyClass {
    @Autowired
    private LoadBalancerClient loadBalancer;

    public void doStuff() {
        ServiceInstance instance = loadBalancer.choose("stores");
        URI storesUri = URI.create(String.format("http://%s:%s", instance.getHost(), instance.getPort()));
        // ... do something with the URI
    }
}

本章完 下節繼續