Spring Cloud 快速入門

文章參考於 史上最簡單的 SpringCloud 教程 | 終章

Spring Cloud 是一個微服務框架，與 Spring Boot 結合，開發簡單。將一個大工程項目，分成多個小 web 服務工程，可以分別獨立擴展，又可以共同合作。

環境

1. spring 官網的 sts 3.9.2，就是有spring 相關插件的eclipse；
2. apache maven 3.5.4，配置阿里雲鏡像
3. jdk1.8
4. Spring Cloud Finchley版本
5. Spring Boot 2.0.3

Spring Cloud 組件

服務注冊中心、服務、斷路器、配置中心

服務的注冊與發現 - Eureka

使用 Eureka 來實現服務注冊中心、服務提供者和服務消費者。

服務注冊中心

一個服務注冊中心，所有的服務都在注冊中心注冊，負載均衡也是通過在注冊中心注冊的服務來使用一定策略來實現。

1.新建一個 Spring Boot 工程，用來管理服務，elipse右鍵 -> new -> Spring Starter Project :

點擊 next ，選擇 Cloud Discovery 下的 Eureka Server 組件

生成的 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>
<span class="hljs-tag">&lt;<span class="hljs-name">groupId</span>&gt;</span>com.beigege.cloud<span class="hljs-tag">&lt;/<span class="hljs-name">groupId</span>&gt;</span>
<span class="hljs-tag">&lt;<span class="hljs-name">artifactId</span>&gt;</span>eureka-server<span class="hljs-tag">&lt;/<span class="hljs-name">artifactId</span>&gt;</span>
<span class="hljs-tag">&lt;<span class="hljs-name">version</span>&gt;</span>0.0.1-SNAPSHOT<span class="hljs-tag">&lt;/<span class="hljs-name">version</span>&gt;</span>
<span class="hljs-tag">&lt;<span class="hljs-name">packaging</span>&gt;</span>jar<span class="hljs-tag">&lt;/<span class="hljs-name">packaging</span>&gt;</span>

<span class="hljs-tag">&lt;<span class="hljs-name">name</span>&gt;</span>eureka-server<span class="hljs-tag">&lt;/<span class="hljs-name">name</span>&gt;</span>
<span class="hljs-tag">&lt;<span class="hljs-name">description</span>&gt;</span>spring cloud學習<span class="hljs-tag">&lt;/<span class="hljs-name">description</span>&gt;</span>

<span class="hljs-tag">&lt;<span class="hljs-name">parent</span>&gt;</span>
    <span class="hljs-tag">&lt;<span class="hljs-name">groupId</span>&gt;</span>org.springframework.boot<span class="hljs-tag">&lt;/<span class="hljs-name">groupId</span>&gt;</span>
    <span class="hljs-tag">&lt;<span class="hljs-name">artifactId</span>&gt;</span>spring-boot-starter-parent<span class="hljs-tag">&lt;/<span class="hljs-name">artifactId</span>&gt;</span>
    <span class="hljs-tag">&lt;<span class="hljs-name">version</span>&gt;</span>2.0.3.RELEASE<span class="hljs-tag">&lt;/<span class="hljs-name">version</span>&gt;</span>
    <span class="hljs-tag">&lt;<span class="hljs-name">relativePath</span> /&gt;</span> <span class="hljs-comment">&lt;!-- lookup parent from repository --&gt;</span>
<span class="hljs-tag">&lt;/<span class="hljs-name">parent</span>&gt;</span>

<span class="hljs-tag">&lt;<span class="hljs-name">properties</span>&gt;</span>
    <span class="hljs-tag">&lt;<span class="hljs-name">project.build.sourceEncoding</span>&gt;</span>UTF-8<span class="hljs-tag">&lt;/<span class="hljs-name">project.build.sourceEncoding</span>&gt;</span>
    <span class="hljs-tag">&lt;<span class="hljs-name">project.reporting.outputEncoding</span>&gt;</span>UTF-8<span class="hljs-tag">&lt;/<span class="hljs-name">project.reporting.outputEncoding</span>&gt;</span>
    <span class="hljs-tag">&lt;<span class="hljs-name">java.version</span>&gt;</span>1.8<span class="hljs-tag">&lt;/<span class="hljs-name">java.version</span>&gt;</span>
    <span class="hljs-tag">&lt;<span class="hljs-name">spring-cloud.version</span>&gt;</span>Finchley.RELEASE<span class="hljs-tag">&lt;/<span class="hljs-name">spring-cloud.version</span>&gt;</span>
<span class="hljs-tag">&lt;/<span class="hljs-name">properties</span>&gt;</span>

<span class="hljs-tag">&lt;<span class="hljs-name">dependencies</span>&gt;</span>
    <span class="hljs-tag">&lt;<span class="hljs-name">dependency</span>&gt;</span>
        <span class="hljs-tag">&lt;<span class="hljs-name">groupId</span>&gt;</span>org.springframework.boot<span class="hljs-tag">&lt;/<span class="hljs-name">groupId</span>&gt;</span>
        <span class="hljs-tag">&lt;<span class="hljs-name">artifactId</span>&gt;</span>spring-boot-starter-test<span class="hljs-tag">&lt;/<span class="hljs-name">artifactId</span>&gt;</span>
        <span class="hljs-tag">&lt;<span class="hljs-name">scope</span>&gt;</span>test<span class="hljs-tag">&lt;/<span class="hljs-name">scope</span>&gt;</span>
    <span class="hljs-tag">&lt;/<span class="hljs-name">dependency</span>&gt;</span>
    <span class="hljs-tag">&lt;<span class="hljs-name">dependency</span>&gt;</span>
        <span class="hljs-tag">&lt;<span class="hljs-name">groupId</span>&gt;</span>org.springframework.cloud<span class="hljs-tag">&lt;/<span class="hljs-name">groupId</span>&gt;</span>
        <span class="hljs-tag">&lt;<span class="hljs-name">artifactId</span>&gt;</span>spring-cloud-starter-netflix-eureka-server<span class="hljs-tag">&lt;/<span class="hljs-name">artifactId</span>&gt;</span>
    <span class="hljs-tag">&lt;/<span class="hljs-name">dependency</span>&gt;</span>
<span class="hljs-tag">&lt;/<span class="hljs-name">dependencies</span>&gt;</span>
<span class="hljs-tag">&lt;<span class="hljs-name">dependencyManagement</span>&gt;</span>
    <span class="hljs-tag">&lt;<span class="hljs-name">dependencies</span>&gt;</span>
        <span class="hljs-tag">&lt;<span class="hljs-name">dependency</span>&gt;</span>
            <span class="hljs-tag">&lt;<span class="hljs-name">groupId</span>&gt;</span>org.springframework.cloud<span class="hljs-tag">&lt;/<span class="hljs-name">groupId</span>&gt;</span>
            <span class="hljs-tag">&lt;<span class="hljs-name">artifactId</span>&gt;</span>spring-cloud-dependencies<span class="hljs-tag">&lt;/<span class="hljs-name">artifactId</span>&gt;</span>
            <span class="hljs-tag">&lt;<span class="hljs-name">version</span>&gt;</span>${spring-cloud.version}<span class="hljs-tag">&lt;/<span class="hljs-name">version</span>&gt;</span>
            <span class="hljs-tag">&lt;<span class="hljs-name">type</span>&gt;</span>pom<span class="hljs-tag">&lt;/<span class="hljs-name">type</span>&gt;</span>
            <span class="hljs-tag">&lt;<span class="hljs-name">scope</span>&gt;</span>import<span class="hljs-tag">&lt;/<span class="hljs-name">scope</span>&gt;</span>
        <span class="hljs-tag">&lt;/<span class="hljs-name">dependency</span>&gt;</span>
    <span class="hljs-tag">&lt;/<span class="hljs-name">dependencies</span>&gt;</span>
<span class="hljs-tag">&lt;/<span class="hljs-name">dependencyManagement</span>&gt;</span>
<span class="hljs-tag">&lt;<span class="hljs-name">build</span>&gt;</span>
    <span class="hljs-tag">&lt;<span class="hljs-name">plugins</span>&gt;</span>
        <span class="hljs-tag">&lt;<span class="hljs-name">plugin</span>&gt;</span>
            <span class="hljs-tag">&lt;<span class="hljs-name">groupId</span>&gt;</span>org.springframework.boot<span class="hljs-tag">&lt;/<span class="hljs-name">groupId</span>&gt;</span>
            <span class="hljs-tag">&lt;<span class="hljs-name">artifactId</span>&gt;</span>spring-boot-maven-plugin<span class="hljs-tag">&lt;/<span class="hljs-name">artifactId</span>&gt;</span>
        <span class="hljs-tag">&lt;/<span class="hljs-name">plugin</span>&gt;</span>
    <span class="hljs-tag">&lt;/<span class="hljs-name">plugins</span>&gt;</span>
<span class="hljs-tag">&lt;/<span class="hljs-name">build</span>&gt;</span>

</project>
 

2.使用 @EnableEurekaServer 來說明項目是一個 Eureka：

@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApplication {

<span class="hljs-keyword">public</span> <span class="hljs-keyword">static</span> <span class="hljs-keyword">void</span> main(String[] args) {
    SpringApplication.run(EurekaServerApplication.<span class="hljs-keyword">class</span>, args);
}

}

3.修改配置文件，配置文件，可以是 application.properties 或 application.yml，這里改后綴，使用 yml，兩種格式內容都是一樣的 只是格式不同 application.yml：

http://${eureka.instance.hostname}😒{server.port}/eureka/ #服務注冊的 URL" title="" data-original-title="復制">

server:

port: 8761 #服務端口

spring:
 application:
 name: eurka-server #服務應用名稱
eureka:
 instance:
 hostname: localhost
 client:
 registerWithEureka: false #是否將自己注冊到Eureka Server，默認為true
 fetchRegistry: false #是否從Eureka Server獲取注冊信息，默認為true
 service-url:
 defaultZone: http://${eureka.instance.hostname}😒{server.port}/eureka/ #服務注冊的 URL

默認 eureka server 也是一個 eureka client，registerWithEureka: false 和 fetchRegistry: false 來表明項目是一個 Eureka Server。

4.運行 EurekaServerApplication 類，啟動項目，訪問項目 http://localhost:8761/

服務提供者

1.新建項目名為 eureka-client 的 Spring Boot 項目，跟 Eureka Server 新建一樣，只是在選擇 Spring Boot 組件的時候，不選 Eureka Server ，選擇 Eureka Client，這里為了測試，再添加一個 Web 下的 Web 組件：

2.修改配置，application.yml:

http://localhost:8761/eureka/" title="" data-original-title="復制">

server:

port: 8762

spring:
 application:
 name: service-hi #服務之間的調用都是根據這個 name
eureka:
 client:
 service-url:
 defaultZone: http://localhost:8761/eureka/

3.添加 @EnableEurekaClient 注解，並添加一個測試接口 /hi：

@SpringBootApplication
@EnableEurekaClient
@RestController
public class EurekaClientApplication {

<span class="hljs-keyword">public</span> static void main(String[] args) {
    SpringApplication.run(EurekaClientApplication.<span class="hljs-keyword">class</span>, args);
}

<span class="hljs-meta">@Value(<span class="hljs-meta-string">"<span class="hljs-subst">${server.port}</span>"</span>)</span>
String port;

<span class="hljs-meta">@RequestMapping(<span class="hljs-meta-string">"/hi"</span>)</span>
<span class="hljs-keyword">public</span> String home(<span class="hljs-meta">@RequestParam(value = <span class="hljs-meta-string">"name"</span>, defaultValue = <span class="hljs-meta-string">"beigege"</span>)</span> String name) {
    <span class="hljs-keyword">return</span> <span class="hljs-string">"hi "</span> + name + <span class="hljs-string">" ,i am from port:"</span> + port;
}

}

4.啟動 Eureka Server 和 Eureka Client 項目，訪問http://localhost:8761 ，即eureka server 的網址：

服務消費者 - Ribbon | Feign

Spring Cloud 兩種調用服務的方式，ribbon + restTemplate，和 feign。

Ribbon

ribbon 在客戶端實現了負載均衡。

啟動 Eureka Server 和 Eureka Client，修改 Eureka Client 端口，再啟動一個 Eureka Client 實例，相當於一個小的集群，訪問localhost:8761

1.新建一個 spring boot 工程，名稱為 service-ribbon，創建過程和 eureka-client 一樣，組件多選一個 Cloud Routing 下的 Ribbon，創建完成之后的 pom 文件依賴：

http://localhost:8761/eureka/" title="" data-original-title="復制">

server:

port: 8764

spring:
 application:
 name: service-ribbon
eureka: 
 client: 
 service-url: 
 defaultZone: http://localhost:8761/eureka/

ServiceRibbonApplication 加上 @EnableEurekaClient 注解

2.向 Spring 注入一個 bean: restTemplate，並添加 @LoadBalanced 注解，表明這個 restTemplate 開啟負載均衡功能：

@SpringBootApplication
@EnableEurekaClient
public class ServiceRibbonApplication {

<span class="hljs-function"><span class="hljs-keyword">public</span> <span class="hljs-keyword">static</span> <span class="hljs-keyword">void</span> <span class="hljs-title">main</span><span class="hljs-params">(String[] args)</span> </span>{
    SpringApplication.run(ServiceRibbonApplication.class, args);
}

<span class="hljs-meta">@Bean</span>
<span class="hljs-meta">@LoadBalanced</span>
<span class="hljs-function">RestTemplate <span class="hljs-title">restTemplate</span><span class="hljs-params">()</span> </span>{
    <span class="hljs-keyword">return</span> <span class="hljs-keyword">new</span> RestTemplate();
}

}

3.寫一個接口用來調用之前的 service-hi 服務的 /hi 接口：
新建 service 層，名叫 HelloService，調用 /hi 接口，這里用服務名 SERVICE-HI 代替具體的 URL：

@Service
public class HelloService {

<span class="hljs-meta">@Autowired</span>
RestTemplate restTemplate;

<span class="hljs-keyword">public</span> <span class="hljs-built_in">String</span> hiService(<span class="hljs-built_in">String</span> name) {
    <span class="hljs-keyword">return</span> restTemplate.getForObject(<span class="hljs-string">"http://SERVICE-HI/hi?name="</span>+name,<span class="hljs-built_in">String</span>.class);
}

}

新建 controller 層，調用 service 層：

@RestController
public class HelloControler {

<span class="hljs-meta">@Autowired</span>
HelloService helloService;
<span class="hljs-meta">@RequestMapping(value = <span class="hljs-meta-string">"/hi"</span>)</span>
<span class="hljs-keyword">public</span> String hi(<span class="hljs-meta">@RequestParam</span> String name){
    <span class="hljs-keyword">return</span> helloService.hiService(name);
}

}

4.啟動 service-ribbon 工程，多次訪問該工程的 /hi 接口，即 localhost:8764/hi?name=test：

hi test ,i am from port:8762
hi test ,i am from port:8763

上面交替顯示，說明實現了負載均衡，ribbon 會在客戶端發送請求時做一個負載均衡。

Feign

整合了 Ribbon，具有負載均衡的能力，整合了Hystrix，具有熔斷的能力.

1.創建一個 spring boot工程，創建過程和 eureka-client 一樣，多添加一個組件 Cloud Routing 下的 Feign，項目名叫 service-feign，創建完后的 pom 文件依賴：

http://localhost:8761/eureka/" title="" data-original-title="復制">

server:

port: 8765

spring:
 application:
 name: service-feign
eureka:
 client:
 serviceUrl: 
 defaultZone: http://localhost:8761/eureka/

SericeFeignApplication 上添加 @EnableEurekaClient 和 @EnableFeignClients 注解：

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients
public class SericeFeignApplication {

<span class="hljs-keyword">public</span> <span class="hljs-keyword">static</span> <span class="hljs-keyword">void</span> main(String[] args) {
    SpringApplication.run(SericeFeignApplication.<span class="hljs-keyword">class</span>, args);
}

}

2.寫一個 SchedualServiceHi 接口，通過@ FeignClient（“服務名”），來指定調用哪個服務，@GetMapping("接口名")，來向接口發送 Get 請求，@RequestParam 是請求參數：

@FeignClient(value = "service-hi")
public interface SchedualServiceHi {

<span class="hljs-meta">@GetMapping(<span class="hljs-meta-string">"/hi"</span>)</span>
String sayHiFromClientOne(<span class="hljs-meta">@RequestParam(value = <span class="hljs-meta-string">"name"</span>)</span> String name);

}

寫一個 controller 層測試 SchedualServiceHi 接口：

@RestController
public class HiController {

<span class="hljs-meta">@Autowired</span>
SchedualServiceHi schedualServiceHi;

<span class="hljs-meta">@GetMapping(value = <span class="hljs-meta-string">"/hi"</span>)</span>
<span class="hljs-keyword">public</span> String sayHi(<span class="hljs-meta">@RequestParam</span> String name) {
    <span class="hljs-keyword">return</span> schedualServiceHi.sayHiFromClientOne( name );
}

}

3.啟動 service-feign，訪問localhost:8765/hi?name=test 測試，下面交替顯示，說明實現了負載均衡：

hi test ,i am from port:8762
hi test ,i am from port:8763

斷路器 - Hystrix

鏈式調用服務，其中一個服務宕機，其他服務可能會跟着異常，發生雪崩，當對一個服務的調用失敗次數到達一定閾值，斷路器會打開，執行服務調用失敗時的處理，避免連鎖故障，上面已經啟動：eureka-server、兩個 eureka-client 實例、service-ribbon 和 service-feign，下面繼續修改，分別在 service-ribbon 和 service-feign 上實現斷路器。

service-ribbon + Hystrix

1.在 pom 文件中加入 Hystrix 依賴：

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

2.在程序的啟動類 ServiceRibbonApplication 加 @EnableHystrix 注解開啟Hystrix：

@SpringBootApplication
@EnableEurekaClient
@EnableHystrix
public class ServiceRibbonApplication {

<span class="hljs-function"><span class="hljs-keyword">public</span> <span class="hljs-keyword">static</span> <span class="hljs-keyword">void</span> <span class="hljs-title">main</span><span class="hljs-params">(String[] args)</span> </span>{
    SpringApplication.run( ServiceRibbonApplication.class, args );
}

<span class="hljs-meta">@Bean</span>
<span class="hljs-meta">@LoadBalanced</span>
<span class="hljs-function">RestTemplate <span class="hljs-title">restTemplate</span><span class="hljs-params">()</span> </span>{
    <span class="hljs-keyword">return</span> <span class="hljs-keyword">new</span> RestTemplate();
}

}

3.添加熔斷方法，改造 HelloService 類，在 hiService 方法上面添加 @HystrixCommand 注解，fallbackMethod 是熔斷方法，當服務不可用時會執行，該方法，即 hiError 方法：

@Service
public class HelloService {

<span class="hljs-meta">@Autowired</span>
RestTemplate restTemplate;

<span class="hljs-meta">@HystrixCommand</span>(fallbackMethod = <span class="hljs-string">"hiError"</span>)
<span class="hljs-keyword">public</span> <span class="hljs-built_in">String</span> hiService(<span class="hljs-built_in">String</span> name) {
    <span class="hljs-keyword">return</span> restTemplate.getForObject(<span class="hljs-string">"http://SERVICE-HI/hi?name="</span>+name,<span class="hljs-built_in">String</span>.class);
}

<span class="hljs-keyword">public</span> <span class="hljs-built_in">String</span> hiError(<span class="hljs-built_in">String</span> name) {
    <span class="hljs-keyword">return</span> <span class="hljs-string">"hi,"</span>+name+<span class="hljs-string">",sorry,error!"</span>;
}

}

重啟 service-ribbon，訪問 localhost:8764/hi?name=test

hi test ,i am from port:8763

關閉兩個 eureka-client 實例，在訪問 localhost:8764/hi?name=test，瀏覽器顯示：

hi,test,sorry,error!

當服務不可用時，斷路器會迅速執行熔斷方法

service-feign + Hystrix

1.Feign 自帶斷路器，在D版本的Spring Cloud之后，它沒有默認打開。需要在配置文件中配置打開：

feign: 
  hystrix: 
    enabled: true

2.在請求接口指定熔斷實現類，fallback 指定熔斷實現類：

@FeignClient(value ="service-hi",fallback = SchedualServiceHiHystric.class)
public interface SchedualServiceHi {

<span class="hljs-meta">@GetMapping(<span class="hljs-meta-string">"/hi"</span>)</span>
String sayHiFromClientOne(<span class="hljs-meta">@RequestParam(value = <span class="hljs-meta-string">"name"</span>)</span> String name);

}


SchedualServiceHiHystric 類實現 SchedualServiceHi 接口：

@Component
public class SchedualServiceHiHystric implements SchedualServiceHi{

<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> String <span class="hljs-title">sayHiFromClientOne</span><span class="hljs-params">(String name)</span> </span>{
    <span class="hljs-keyword">return</span> <span class="hljs-string">"sorry "</span>+name;
}

}


3.訪問測試，重啟 service-feign，訪問 localhost:8765/hi?name=test:

sorry test

打開 eureka-client，再次訪問 localhost:8765/hi?name=test:

hi test ,i am from port:8762

證明斷路器起到作用，注意瀏覽器緩存。

路由網關 - Zuul

1.創建一個 spring boot 工程，名稱為 service-zuul，創建過程和 eureka-client 一樣，組件要多添加一個 Cloud Routing 下的 Zuul，pom 文件的依賴如下：

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

2.在入口 application 中添加 @EnableZuulProxy 注解，開啟路由：

@SpringBootApplication
@EnableEurekaClient
@EnableZuulProxy
public class ServiceZuulApplication {

<span class="hljs-keyword">public</span> <span class="hljs-keyword">static</span> <span class="hljs-keyword">void</span> main(String[] args) {
    SpringApplication.run(ServiceZuulApplication.<span class="hljs-keyword">class</span>, args);
}

}

application.yml 配置：

http://localhost:8761/eureka/" title="" data-original-title="復制">

server:

port: 8769

spring:
 application:
 name: service-zuul
eureka:
 client:
 serviceUrl: 
 defaultZone: http://localhost:8761/eureka/

添加路由

修改 application.yml 添加路由配置：

http://localhost:8761/eureka/

zuul:
routes:
api-a:
path: /api-a/**
service-id: service-ribbon
api-b:
path: /api-b/**
service-id: service-feign" title="" data-original-title="復制">

server:

port: 8769

spring:
 application:
 name: service-zuul
eureka:
 client:
 serviceUrl: 
 defaultZone: http://localhost:8761/eureka/
zuul:
 routes:
 api-a: 
 path: /api-a/
 service-id: service-ribbon
 api-b:
 path: /api-b/
 service-id: service-feign

8769 端口的所有 api-a 請求會轉發到 service-ribbon 工程，api-b 到 service-feign

啟動 service-zuul，訪問 localhost:8769/api-a/hi?name=test，瀏覽器顯示：

hi test ,i am from port:8762

訪問 localhost:8769/api-b/hi?name=test，瀏覽器顯示：

hi test ,i am from port:8762

說明路由成功。

過濾器

新建自定義過濾器，繼承 ZuulFilter：

@Component
public class MyFilter extends ZuulFilter {

<span class="hljs-keyword">private</span> <span class="hljs-keyword">static</span> Logger log = LoggerFactory.getLogger(MyFilter.class);

<span class="hljs-comment">/*
 * filterType：返回一個字符串代表過濾器的類型，在zuul中定義了四種不同生命周期的過濾器類型，具體如下：
 * pre：路由之前
 * routing：路由之時 
 * post： 路由之后 
 * error：發送錯誤調用 
 */</span>
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> String <span class="hljs-title">filterType</span><span class="hljs-params">()</span> </span>{
    <span class="hljs-keyword">return</span> <span class="hljs-string">"pre"</span>;
}

<span class="hljs-comment">/*
 * filterOrder：過濾的順序
 */</span>
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> <span class="hljs-keyword">int</span> <span class="hljs-title">filterOrder</span><span class="hljs-params">()</span> </span>{
    <span class="hljs-keyword">return</span> <span class="hljs-number">0</span>;
}

<span class="hljs-comment">/*
 * shouldFilter：這里可以寫邏輯判斷，是否要過濾，本文true,永遠過濾。
 */</span>
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> <span class="hljs-keyword">boolean</span> <span class="hljs-title">shouldFilter</span><span class="hljs-params">()</span> </span>{
    <span class="hljs-keyword">return</span> <span class="hljs-keyword">true</span>;
}

<span class="hljs-comment">/*
 * run：過濾器的具體邏輯。可以很復雜，包括查sql，nosql去判斷該請求到底有沒有權限訪問，
 * 這里是判斷請求有沒有 token 參數
 */</span>
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> Object <span class="hljs-title">run</span><span class="hljs-params">()</span> </span>{
    RequestContext ctx = RequestContext.getCurrentContext();
    HttpServletRequest request = ctx.getRequest();
    log.info(String.format(<span class="hljs-string">"%s &gt;&gt;&gt; %s"</span>, request.getMethod(), request.getRequestURL().toString()));
    Object accessToken = request.getParameter(<span class="hljs-string">"token"</span>);
    <span class="hljs-keyword">if</span>(accessToken == <span class="hljs-keyword">null</span>) {
        log.warn(<span class="hljs-string">"token is empty"</span>);
        ctx.setSendZuulResponse(<span class="hljs-keyword">false</span>);
        ctx.setResponseStatusCode(<span class="hljs-number">401</span>);
        <span class="hljs-keyword">try</span> {
            ctx.getResponse().getWriter().write(<span class="hljs-string">"token is empty"</span>);
        }<span class="hljs-keyword">catch</span> (Exception e){}

        <span class="hljs-keyword">return</span> <span class="hljs-keyword">null</span>;
    }
    log.info(<span class="hljs-string">"ok"</span>);
    <span class="hljs-keyword">return</span> <span class="hljs-keyword">null</span>;
}

}

重啟 service-zuul 訪問 localhost:8769/api-a/hi?name=test，瀏覽器顯示

token is empty

加上 token 參數：localhost:8769/api-a/hi?name=test&token=666

hi test ,i am from port:8762

分布式配置中心

遠程資源庫

1.這里在 碼雲 注冊一個賬號，用來創建存儲配置的資源庫，在碼雲上創建一個名叫 SpringCloudConfig 項目：

2.新建一個配置文件 config-client-dev.properties，也可以是 yml 配置文件，內容為 test = version 1，然后提交：

2.默認是 master 分支，新建一個分支，名字叫 aa：

修改 aa 分支中的 config-client-dev.properties 配置文件的 test 屬性為 version 2：

config-server

1.新建 spring boot 項目，組件選擇 Cloud Config 中的 Config Server，pom 中的依賴：

@SpringBootApplication
@EnableConfigServer
public class ConfigServerApplication {

<span class="hljs-keyword">public</span> <span class="hljs-keyword">static</span> <span class="hljs-keyword">void</span> main(String[] args) {
    SpringApplication.run(ConfigServerApplication.<span class="hljs-keyword">class</span>, args);
}

}


application.yml 配置文件，如果是公開的不需要填寫用戶名密碼：

https://gitee.com/candy-boy/SpringCloudConfig #配置git倉庫地址，后面的.git可有可無
username: #訪問git倉庫的用戶名，碼雲登陸用戶名
password: #訪問git倉庫的用戶密碼，碼雲登陸密碼" title="" data-original-title="復制">

server:

port: 8888

spring:
 application:
 name: config-server
 cloud:
 config:
 server:
 git:
 uri: https://gitee.com/candy-boy/SpringCloudConfig #配置git倉庫地址，后面的.git可有可無 
 username: #訪問git倉庫的用戶名，碼雲登陸用戶名
 password: #訪問git倉庫的用戶密碼，碼雲登陸密碼

2.訪問測試，啟動程序，訪問配置文件，可以如下訪問：

• {application}/{profile}[/{label}]

  如 localhost:8888/config-client/dev，即訪問 config-client-dev.properties，其中 {application} 就是 最后一道橫線前面的 config-client，{profile} 是最后一道橫線后面到點，即 dev，{label} 指的是資源庫的分支，不填則為默認分支，剛創建的資源庫，默認分支是 master，訪問結果如下：

其他訪問方式如：

/{application}/{profile}[/{label}]
/{application}-{profile}.yml
/{label}/{application}-{profile}.yml
/{application}-{profile}.properties
/{label}/{application}-{profile}.properties

如果是下面這樣，可能是用戶名或密碼錯誤：

3.測試其他分支，訪問 aa 分支下的 config-client-dev.properties，localhost:8888/config-client/dev/aa

config-client

待續....

            </div>

posted @ 2019-01-24 10:39  星朝  閱讀( 2104)  評論( 0)  編輯  收藏

刷新評論 刷新頁面 返回頂部

Copyright © 2020 星朝
Powered by .NET Core on Kubernetes