SpringCloud學習筆記

標簽： Spring SpringCloud spring java 過濾器

SpringCloud學習筆記

??ESB企業服務總線：用來連接各個服務節點，為了集成各種不同的服務。

1.系統架構演變

目標：
??了解項目架構的演變歷程。

小結：

2.微服務架構說明

目標：
??了解SOA與微服務架構的區別以及說出微服務架構的特點。

分析：
??SOA使用了ESB組件的面向服務架構：
ESB自身實現復雜；應用服務粒度較大，所有服務之間的通信都經過ESB，會降低通信速度、部署、測試ESB比較麻煩。

小結：
??微服務架構：是一套使用小服務或者單一業務來開發單個應用的方式或途徑。

微服務架構特點：

單一職責
服務粒度小
面向服務（對外暴露REST api）
服務之間相互獨立

??與使用ESB的SOA架構的區別：微服務架構沒有使用ESB，有服務治理注冊中心；業務粒度小。

3.服務調用方式說明

目標：
???能過說出調用方式種類。

RPC和HTTP
???OSI網絡七層模型：物理層，數據鏈路層、網絡層、傳輸層、會話層、表示層、應用層

RPC：（Remote Produce Call）遠程過程調用，RPC基于Socket，工作在會話層。自定義數據格式，速度快、效率高。早期的webservice，現在的dubbo，都是RPC的典型代表。
HTTP：http其實是一種網絡傳輸協議，基于TCP，工作在應用層，規定了數據傳輸的格式。
???也可以用來進行遠程服務調用，缺點是消息封裝臃腫，優勢是對服務的調用方沒有任何技術限定，自由靈活，更服務微服務理念。

REST風格，就是通過http協議來實現的
???springcloud就是使用Rest風格進行調用的。

4.Spring RestTemplalte實例工程導入

目標：
???了解Spring RestTemplate的應用。

分析：
???一般情況下有如下三種http客戶端工具類包都可以方便的進行http服務調用：

httpClint
okHttp
JDK原生URLConnection

???spring提供了RestTemplate的工具類對上述的3種http客戶端工具類進行了封裝，可在spring項目中使用，RestTemplate進行服務調用。

小結：
???此時啟動的是兩個服務！需要單獨創建數據庫和Controller。

//對應創建數據庫實體
@Setter
@Getter
public class User {
    private String id;
    private String username;
    private String password;
    private String name;
    private String age;
    private String sex;
    private Data birthday;
    private String node;
    private Data created;
    private Data update;

@RunWith(SpringRunner.class)
@SpringBootTest(classes = HttpDemoApplication.class,webEnvironment = SpringBootTest.WebEnvironment.DEFINED_PORT)
public class RestTemplateTest {

    @Autowired
    private RestTemplate restTemplate;

    @Test
    public void test() {
        String url = "http://localhost:8080/user";
        //restTemplate可以對json格式字符串進行反序列化
        User user = restTemplate.getForObject(url,User.class);
        System.out.println(user);
    }
}

5.Spring Cloud概述

目標：
???Spring Cloud整合的組件和版本特征。

小結：
???整合的組件有很多常見組件

Eureka：注冊中心
Zuul、Gateway：網關
Ribbon：負載均衡
Feign：服務調用
Hystrix：熔斷器

版本特征：以英文單詞命名（倫敦地鐵站名）

6.創建微服務工程

目標：
???創建微服務工程父工程haotian-spring-cloud、用戶服務工程user-service、服務消費工程consumer-demo。

分析：
需求：查詢數據庫中的用戶數據并輸出到瀏覽器。

父工程haotian-springcloud：填補你家spring boot父坐標和管理其他組件的依賴
用戶服務user-service：整合mybatis查詢數據中的用戶數據；提供查詢用戶服務
服務消費工程consumer-demo：利用查詢用戶服務獲取用戶數據并輸出到瀏覽器

小結：

添加依賴

		<!---spring Cloud-->
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-dependencies</artifactId>
			<version>${spring-cloud}</version>
            <type>pom</type>
            <scope>import</scope>
		</dependency>

???通過scope的import可以繼承spring-cloud-dependencies工程中的依賴。

7.搭建配置user-service工程

目標：
???配置user-service工程并能夠根據用戶id查詢數據庫中用戶。

分析：
需求：可以訪問http://localhost9091/user/2輸出用戶數據

實現步驟：

添加啟動器依賴（web、通用Mapper）；
創建啟動引導類和配置文件；
修改配置文件中的參數；
編寫測試代碼（userMapper、UserService、UserController）；
測試

小結：

添加啟動器依賴

 	  <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <!--通用Mapper啟動器-->
            <dependency>
                <groupId>tk.mybatis</groupId>
                <artifactId>mapper-spring-boot-starter</artifactId>
            </dependency>
            <!--Mysql驅動-->
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
            </dependency>
      <dependencies>

編寫配置文件

	server:
	  port: 9091
	spring:
      datasource:
        driver-class-name: com.mysql.jdbc.Driver
        url: jdbc.mysql://localhost:3306/springcloud
        username: root
        password: root
    
    mybatis:
      type-aliases-package: com.haotian.user.pojo

8.搭建配置consumer-demo工程

目標：
???編寫測試類使用restTemplate訪問user-service的路徑根據id查詢用戶。

分析：
需求：訪問http://localhost:8080/consumer/2使用RestTemplate獲取http://localhost:9091/user/2的數據。
實現步驟：

添加啟動器依賴；
創建啟動引導類（注冊RestTemplate）和配置文件；
編寫測試diamante（ConsumerController中使用restTemplate訪問服務獲取數據）；
測試

小結：

服務管理
- 如何自動注冊和發現
- 如何實現狀態監管
- 如何實現動態路由
服務如何實現負載均衡
服務如何解決容載問題
服務如何實現統一配置

上述問題都可以用Spring Cloud的各種組件解決。

9.Eureka注冊中心說明

目標：
???說出Eureka的主要功能。

小結：
???Eureka的主要功能是進行服務管理，定期檢查服務狀態，返回服務地址列表。
在這里插入圖片描述

10.搭建eureka-server工程

目標：
??添加Eureka對應依賴和編寫引導類搭建Eureka服務并可訪問Eureka服務界面。
分析：
??Eureka是服務注冊中心就，只做服務注冊；自身并不提供服務也不消費服務。可以搭建web工程使用Eureka，可以使用Spring Boot方式搭建。

搭建步驟：

創建工程；
添加啟動器依賴；
編寫啟動引導類（添加Eureka服務注解）和配置文件；
修改配置文件（端口，應用名稱…）；
啟動測試；

小結：

啟用依賴

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

添加配置文件

  server:
    port: 10086
  spring:
    application:
      name: eureka-server
  eureka:
    client:
      service-url:
        # eureka 服務地址，如果是集群的話；需要指定其他集群eureka地址
        defaultZone: http://127.0.0.1:10086/eureka
      # 不注冊自己
      register-with-eureka: false
      # 不拉取服務
      fetch-refistery: false

11.服務注冊與發現

目標：
??將user-service的服務注冊到eureka并在consumer-demo中根據服務名稱調用。

分析：

服務注冊：在服務提供工程user-service上添加Eureka客戶端依賴；自動將服務注冊到EurekaServer服務地址列表。
- 添加改造
- 改造啟動引導類；添加開啟Eureka客戶端發現的注解；
- 修改配置文件；設置Eureka服務地址
服務發現：在服務消費工程consumer-demo上添加Eureka客戶端依賴；可以使用工具類根據服務名稱獲取對應的服務地址列表。
- 添加依賴；
- 改造啟動引導類；添加開啟Eureka客戶端發現的注解；
- 修改配置文件；設置Eureka服務地址；
- 改造處理器類ConsumerController，可以使用工具類DisconveryClient根據服務名稱獲取對應服務地址列表。

小結：

添加Eureka客戶端依賴；

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

添加啟動引導類注解；

@EnableDiscoveryClient //開啟Eureka客戶端發現功能

@SpringBootApplication
@EnableDiscoveryClient //開啟Eureka客戶端發現功能
public class HttpDemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(HttpDemoApplication.class, args);
    }
    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
}

修改配置；

   spring:
     application:
       name: consumer-demo
   eureka:
     client:
       service-url:
         defaultZone: http://127.0.0.1:10086/eureka

12.Eureka Server高可用配置

目標：
??可以啟動兩臺eureka-server實例；在eureka管理界面看到兩個實例。

分析：
??Eureka Server是一個web應用，可以啟動多個實例（配置不同端口）保證Eureka Server的高可用。

小結：
??高可用配置：將Eureka Server作為一個服務注冊到其他Eureka Server，這個多個Eureka Server之間就能夠相互發現對方，同步服務，實現Eureka Server集群。

13.Eureka客戶端服務配置

目標：
??配置eureka客戶端user-service的注冊，續約等配置項，配置eureka客戶端的consumer-demo獲取服務間隔時間；了解失效剔除和自我保護。

分析：

eureka客戶端工程
- user-service服務提供
  - 服務地址使用ip方式
  - 續約
Eureka服務端工程eureka-server
- 失效剔除
- 自我保護

小結：

user-service

eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka
  
  instance:
    # 更傾向使用ip地址，而不是host名
    perfer-ip-address: true
    # ip地址
    ip-address: 127.0.0.1
    # 續約間隔，默認30秒
    lease-renewal-insterval-in-seconds: 5
    # 服務失效時間，默認60秒
    lease-expiration-duration-in-seconds: 5

consumer-demo

eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka
     # 獲取服務地址列表間隔時間，默認30秒
     registry-fetch-interval-seconds: 10

eureka-server

eureka:
  client:
    service-url:
      # eureka 服務地址，如果是集群的話；需要指定其他的集群eureka地址
      defaultZone: http://127.0.0.1:10086/eureka
    # 不注冊自己
    register-with-eureka: false
    # 不拉取服務
    fetch-registry: false
  server:
    # 服務失效剔除時間間隔，默認60秒
    eviction-interval-timer-in-ms: 60000
    # 關閉自我保護模式（默認是打開的）
    enable-self-preservation: false

14.負載均衡Ribbon簡介

目標：
??描述負載均衡Ribbon的作用。

分析：
??負載均衡是一個算法，可以通過該算法實現從地址列表中獲取一個地址進行服務調用。
??在Spring Cloud中提供了負載均衡：Ribbon

小結：
??Ribbon提供了輪詢、隨機兩種負載均衡算法（默認是輪詢）可以實現從地址列表中使用負載均衡算法獲取地址進行服務調用。

15.Ribbon負載均衡應用

目標：
??配置啟動兩個用戶服務，在consumer-demo中使用服務名實現根據用戶id獲取用戶。

分析：
需求：可以使用RestTemplate訪問http://user-service/user/2獲取服務數據。

??可以使用Ribbon負載均衡；在執行RestTemplate發送地址請求的時候，使用負載均衡攔截器攔截，根據服務名獲取服務地址列表，使用Ribbon負載均衡算法從服務地址列表中選擇一個服務地址，訪問該地址獲取服務數據。

實現步驟：

啟動多個user-service實例（9091，9092）；
修改RestTemplate實例化方法，添加負載均衡注解；
修改ConsumerController
測試

小結：
??在序列化RestTemplate的時候使用@LoadBalanced，服務地址直接可以使用服務名。

16.熔斷器Hystrix簡介

目標：
??了解熔斷器Hystrix的作用。

小結：
??Hystrix是一個延遲容錯庫，用于隔離訪問遠程服務，防止出現級聯失敗。

17.線程隔離&服務降級

目標：

??了解什么是線程隔離和服務降級。

分析：
Hystrix解決雪崩效應：

線程隔離：用戶請求不直接訪問服務，而是使用線程池中空閑的線程訪問服務。加速失敗判斷時間。
服務降級：及時返回服務調用失敗的結果，讓線程不因為等待服務而阻塞。

小結：

添加依賴

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

開啟熔斷

	@SpringBootApplication//SpringBoot啟動
	@EnableDiscoveryClient //開啟Eureka客戶端發現功能
	@EnableCircuitBreaker // 開啟熔斷
	//包含上面三個注解	
	@SpringCloudApplication	
	public class UserApplication{
           public static void main(String[] args) {
        SpringApplication.run(UserApplication.class, args);
    }
    }

降級邏輯

@RestController
@RequestMapping("/consumer")
@Slf4j
@DefaultProperties(defaultFallback = "defaultFallback") //指定服務默認降級方法
public class ConsumerController{
    
    @Autowired
    private RestTemplate restTemplate;
    
    @Autowired
    private DiscoveryClient discoveryClient;
    
    @GetMapping("/{id}")
    //@HystrixCommand(fallbackMethod = "queryByIdFallback") //指定服務降級方法
    @HystrixCommand //開啟服務降級
    public String queryById(@PathVariable Long id){
        String url = "http://user-service/user" + id;
        return restTemplate.getForObject(url,String.class);
    }
    
    //指定服務降級方法
    public String queryByIdFallback(Long id){
        log.error("查詢用戶信息失敗，id：{}"，+id);
        return "對不起，網絡太擁擠了！";
    }
    
        //默認服務降級方法
    public String defaultFallback（）{
        return "默認提示：對不起，網絡太擁擠了！";
    }
}

修改超時配置

	hystrix:
	  command:
	    default:
	      execution:
	        isolation:
	          thread:
	            timeoutInMillisecondes: 2000

18. 服務熔斷

目標：
??了解服務熔斷工作原理。

小結：
在這里插入圖片描述

狀態機有3個狀態：
	Closed：關閉狀態（斷路器關閉），所有請求都正常訪問。
	Open：打開狀態（斷路器打開），所有請求都會被降級，Hystrix會對請求情況計數，當一定時間內失敗請求百分比達到閾值，則觸發熔斷，斷路器會完全打開，默認失敗比例的閾值是50%，請求次數最少不低于20次。
	Half Open：半開狀態，不是永久的，斷路器打開后會進入休眠時間（默認是55）。隨后斷路器會自動進入半開狀態，此時會釋放部分請求通過，若這些請求都是健康的，則會關閉短路器，否則繼續保持打開，再次進行休眠計時。

可以通過配置服務熔斷參數修改默認：

	hystrix:
	  command:
	    default:
	      execution:
	        isolation:
	          thread:
	            timeoutInMillisecondes: 2000
	      
          circuitBreaker:
            errorThresholdPercentage: 50 # 觸發熔斷錯誤比例閾值，默認值50%
            sleepWindowInMilliseconds: 1000  # 熔斷后休眠時長，默認值5秒
            requestBolumeThreshold: 10 # 熔斷觸發最小請求次數，默認值是20秒

第二天

1.Feign應用

目標：
??Feign的作用：使用Feifn實現consumer-demo代碼中調用服務。

分析：

導入啟動器依賴；
開啟Feifn功能；
編寫Feign客戶端；
編寫一個處理器ConsumerFeignController，注入Feign客戶端并使用；
測試

小結：
??Feign主要作用：自動根據參數拼接http請求地址。

啟動器依賴

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

Feign客戶端：

//聲明當前類是一個Feign客戶端，指定服務名為user-service
@FeignClient("user-service")
public interface UserClient{
    
    //http://user-service/user/123
    @GetMapping("/user/{id}")
    User queryById(@PathVariable Long id);
}

2.Feifn負載均衡及熔斷

目標：
??可以配置Feign內置Ribbon配置項和Hystrix熔斷的Fallback配置。

分析：

負載均衡
服務熔斷
請求壓縮
日志級別

都可以通過配置項在Feign中開啟使用。

小結：
??在服務消費工程consumer-demo中的配置文件

ribbon:
  ConnectTimeout: 1000 # 連接超時時長
  ReadTimeout: 2000 # 數據通信超時時長
  MaxAutoRetries: 0 # 當前服務器的重試次數
  MaxAutoRetriesNextServer: 0 # 重試多少次服務
  OKToRetryOnAllOperations: # 是否對所有的請求方式都重試

feign:
  hystrix:
    enabled: true # 開啟Feign的熔斷功能
  comperession:
    request:
      enabled: true # 開啟請求壓縮
      mime-types: text/html,application/xml,application/json # 設置壓縮的數據類型
      min-request-size: 2048 # 設置觸發壓縮的大小下限
    
    response:
      enable: true
      
logging:
  level:
   com.haotian: debug

3.Spring Cloud Gateway網關簡介

目標：
??Spring Cloud Gateway網關的作用。

小結：
??Spring Cloud Gateway的核心就是一系列的過濾器，可以將客戶端的請求轉發到不同的微服務。主要作用：過濾和路由。

4.Spring Cloud Gateway入門

目標：
??搭建網關服務工程測試網關服務作用。

分析：
需求：通過網關系統haotian-getaway將包含有/user的請求路由到http://127.0.0.1/user/用戶id

實現步驟:

創建工程；
添加啟動器依賴；
編寫啟動引導類和配置文件；
修改配置文件，設置路由信息；
啟動測試；

??通過網關訪問http://127.0.0.1:10010/user/8轉換到http://127.0.0.1:9091/user/8

小結：

啟動器依賴

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

配置文件

server:
  port: 10010
# 設置注冊到Eureka中心的訪問名稱  
spring:
  application:
    name: api-gateway
  #配置Gateway網關信息  
  cloud:
    gateway:
      routes:
        # 路由id，可以任意
        - id: user-service-route
          # 代理的服務地址
          uri: http://127.0.0.1:9091
          # 路由斷言：可以匹配映射路徑
          predicates:
           - Path=/user/**
#指定Eureka注冊中心           
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka
  instance:
    prefer-ip-address: true

5.面向服務的路由

目標：
??使用在Eureka注冊的服務作為路由地址。

分析：
??如果將路由服務地址寫死明顯是不合理的；在Spring Cloud Gateway可以配置動態路由解決。

小結：
??面向服務的路由；只需要在配置文件中指定路由路徑類似：lb://user-service (lb 是Load Balancer 負載均衡的簡寫)

	lb 之后編寫的服務名必須要在eureka中注冊才能使用

配置文件

    server:
      port: 10010
    # 設置注冊到Eureka中心的訪問名稱  
    spring:
      application:
        name: api-gateway
      #配置Gateway網關信息  
      cloud:
        gateway:
          routes:
            # 路由id，可以任意
            - id: user-service-route
              # 代理的服務地址
              #uri: http://127.0.0.1:9091
              uri: lb://user-service
              # 路由斷言：可以匹配映射路徑
              predicates:
               #- Path=/user/**
               - Path=/api/user/**
              
              filters:
                # 添加請求路徑前綴
                #- PerfixPath=/user
              	# 1表示過濾1個路徑，2表示過濾兩個路徑，以此類推
              	- StripPerfix=1
   
     
    #指定Eureka注冊中心           
    eureka:
      client:
        service-url:
          defaultZone: http://127.0.0.1:10086/eureka
      instance:
        prefer-ip-address: true

6.路由前綴處理

目標：
??可以對請求到網關服務的地址添加或去除前綴。

分析：
提供服務的地址：http://127.0.0.1:9091/user/8

添加前綴：對請求地址添加前綴路徑之后再作為代理的服務器地址；

http://127.0.0.1:10010/8 --> http://127.0.0.1:9091/user/8 添加前綴路徑/user

去除前綴：將請求地址中路徑去除一些前綴路徑之后再作為代理服務地址；

http://127.0.0.1:10010/api/user/8 --> http://127.0.0.1:9091/user/8 去除前綴路徑/api

小結：
??客戶端的請求地址與微服務的服務地址如果不一致的時候，可以通過配置路徑過濾器實現路徑前綴的添加和去除。

配置文件：

    server:
      port: 10010
    # 設置注冊到Eureka中心的訪問名稱  
    spring:
      application:
        name: api-gateway
      #配置Gateway網關信息  
      cloud:
        gateway:
          routes:
            # 路由id，可以任意
            - id: user-service-route
              # 代理的服務地址
              #uri: http://127.0.0.1:9091
              uri: lb://user-service
              # 路由斷言：可以匹配映射路徑
              predicates:
               #- Path=/user/**
               - Path=/api/user/**
              
              filters:
                # 添加請求路徑前綴
                #- PerfixPath=/user
              	# 1表示過濾1個路徑，2表示過濾兩個路徑，以此類推。
              	- StripPerfix=1
     
    #指定Eureka注冊中心           
    eureka:
      client:
        service-url:
          defaultZone: http://127.0.0.1:10086/eureka
      instance:
        prefer-ip-address: true

7.過濾器簡介

目標：
??Gateway默認過濾器的用法和過濾器類型。

分析：

**過濾器類型：**Gateway實現方式，有兩種過濾器
- 局部過濾器：通過spring.cloud.gateway.routes.filters配置具體路由下，只作用在當前路由上；自帶的過濾器都可以配置或者自定義按照自帶過濾器的方式。
  
  spring.cloud.gateway.default.filters上會對所有路由生效也算是全局的過濾器；但是這些過濾器的實現上都是要實現GatewayFilterFactory接口。
- 全局過濾器：不需要再配置文件配置，作用在所有的路由上；實現GlobalFilter接口即可。

小結：

用法：在配置文件中指定要使用的過濾器名稱；
類型：局部，全局；
使用場景：請求鑒權，異常處理，記錄調用時長等。
配置文件

    server:
      port: 10010
    # 設置注冊到Eureka中心的訪問名稱  
    spring:
      application:
        name: api-gateway
      #配置Gateway網關信息  
      cloud:
        gateway:
          routes:
            # 路由id，可以任意
            - id: user-service-route
              # 代理的服務地址
              #uri: http://127.0.0.1:9091
              uri: lb://user-service
              # 路由斷言：可以匹配映射路徑
              predicates:
               #- Path=/user/**
               - Path=/api/user/**
              
              filters:
                # 添加請求路徑前綴
                #- PerfixPath=/user
              	# 1表示過濾1個路徑，2表示過濾兩個路徑，以此類推。
              	- StripPerfix=1
           # 默認過濾器，對所有路由都生效   	
          default-filters:
            - AddResponseHeader=X-Response-Foo, Bar
            - AddResponseHeader=abc-myname,haotian 
     
     
    #指定Eureka注冊中心           
    eureka:
      client:
        service-url:
          defaultZone: http://127.0.0.1:10086/eureka
      instance:
        prefer-ip-address: true

8.自定義局部過濾器

目標：
??按照默認過濾器編寫并配置一個自定義局部過濾器，該過濾器可以通過配置文件中的參數名稱獲取請求參數值。

分析：
需求：在過濾器（MyParamGatewayFilterFactory）中將http://localhost:10010/api/user/8?name=haotian中的參數name的值獲取到并輸出到控制臺；并且參數名是可變的，也就是不一定每次都是name;需要可以通過配置過濾器的時候做到配置參數名。

實現步驟：

配置過濾器；
編寫過濾器；
測試；

小結：

配置文件

    server:
      port: 10010
    # 設置注冊到Eureka中心的訪問名稱  
    spring:
      application:
        name: api-gateway
      #配置Gateway網關信息  
      cloud:
        gateway:
          routes:
            # 路由id，可以任意
            - id: user-service-route
              # 代理的服務地址
              #uri: http://127.0.0.1:9091
              uri: lb://user-service
              # 路由斷言：可以匹配映射路徑
              predicates:
               #- Path=/user/**
               - Path=/api/user/**
              
              filters:
                # 添加請求路徑前綴
                #- PerfixPath=/user
              	# 1表示過濾1個路徑，2表示過濾兩個路徑，以此類推。
              	- StripPerfix=1
              	- MyParam=name
           # 默認過濾器，對所有路由都生效   	
          default-filters:
            - AddResponseHeader=X-Response-Foo,Bar
            - AddResponseHeader=abc-myname,haotian 
     
     
    #指定Eureka注冊中心           
    eureka:
      client:
        service-url:
          defaultZone: http://127.0.0.1:10086/eureka
      instance:
        prefer-ip-address: true

實現過濾器

import org.springframework.stereotype.Component;
import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory;
import org.springframework.cloud.gateway.filter.GatewayFilter;
import org.springframework.http.server.reactive.ServerHttpRequest;

import java.util.Arrays;
import java.util.List;

@Component
public class MyParamGatewayFilterFactory extends AbstractGatewayFilterFactory<MyParamGatewayFilterFactory.Config> {

    static final String PARAM_NAME = "param";

    public MyParamGatewayFilterFactory(){
        super(Config.class);
    }

    public List<String> shortcutFieldOrder(){
        return Arrays.asList(PARAM_NAME);
    }


        @Override
    public GatewayFilter apply(Config config){
        return (exchange,chain) ->{
            //http://localhost:10010/api/user/8?name=haotian config.param ==> name
            //獲取請求參數中param對應的參數名的參數值

            ServerHttpRequest request = exchange.getRequest();
            if(request.getQueryParams().containsKey(config.param)){

                request.getQueryParams().get(config.param)
                        .forEach(value  ->  System.out.printf("----------局部過濾器----------",config.param, value));
            }
            return chain.filter(exchange);
        };

    }


    public static class Config{
        //對應在配置過濾器的時候指定的參數名
        private String param;

        public String getParam(){
            return param;
        }

        public void setParam(String param){
            this.param = param;
        }

    }
}

9.自定義全局過濾器

目標：
??定義一個全局過濾器檢查請求中是否攜帶有token參數。

分析：
需求：編寫全局過濾器，在過濾器中檢查請求地址是否攜帶token參數，如果token參數的值存在則放行；如果token的參數值為空或者不存在則設置返回的狀態碼為：未經授權也不再執行下去。

實現步驟：

編寫全局過濾器；
測試

小結：

編寫全局過濾器

import org.apache.commons.lang.StringUtils;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;

@Component
public class MyGlobalFilter implements GlobalFilter, Ordered {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        System.out.println("------------全局過濾器MyGlobalFilter-------------");
        String token = exchange.getRequest().getQueryParams().getFirst("token");
        if (StringUtils.isBlank(token)){
            //設置響應碼為未授權
            exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
            return exchange.getResponse().setComplete();
        }
        return chain.filter(exchange);
    }

    @Override
    public int getOrder() {
        //值越小 越先執行
        return 0;
    }
}

10.1Gateway其他配置說明

目標：
??Gateway網關的負載均衡和熔斷參數配置。

小結：

網關服務配置文件

server:
  port: 10010
# 設置注冊到Eureka中心的訪問名稱
spring:
  application:
    name: api-gateway
  #配置Gateway網關信息
  cloud:
    gateway:
      routes:
        # 路由id，可以任意
        - id: user-service-route
          # 代理的服務地址
          #uri: http://127.0.0.1:9091
          uri: lb://user-service
          # 路由斷言：可以匹配映射路徑
          predicates:
            #- Path=/user/**
            - Path=/api/user/**

          filters:
            # 添加請求路徑前綴
            #- PerfixPath=/user
            # 1表示過濾1個路徑，2表示過濾兩個路徑，以此類推。
            - StripPerfix=1
            - MyParam=name
        # 默認過濾器，對所有路由都生效
      default-filters:
        - AddResponseHeader=X-Response-Foo,Bar
        - AddResponseHeader=abc-myname,haotian

      globalcors:
        corsConfigurations:
          '[/**]':
            #allowedOrigins * # 這種寫法或者下面都可以 * 表示全部
            allowedOrigins:
              - "http://docs.spring.io"
            allowedMethods:
              - GET

#指定Eureka注冊中心
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka
  instance:
    prefer-ip-address: true


hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 6000

ribbon:
  ConnectTimeout: 1000
  ReadTimeout: 2000
  MaxAutoRetries: 0
  MaxAutoRetriesNexServer: 0

10.2Gateway跨域配置

目標：
??Gateway跨域參數配置。

分析：
跨域：在js請求訪問中，如果訪問的地址與當前服務器的域名，ip或者端口號不一致則稱為跨域請求，若不解決則不能獲取到對應的地址返回結果。

如：從http://localhost:9090中的js訪問http://localhost:9000的數據，因為端口不同，所以也是跨域請求。

小結：

配置文件

spring:
  cloud:
    gateway:
      globalcors:
        corsConfigurations:
          '[/**]':
            #allowedOrigins * # 這種寫法或者下面都可以 * 表示全部
            allowedOrigins:
              - "http://docs.spring.io"
            allowedMethods:
              - GET

上述配置表示：可以允許來自http://docs.spring.io的get請求方式獲取服務數據。

allowedOrigins指定允許訪問的服務器地址，如：http://localhost:10000也是可以的。

'[/**]'表示對所有訪問到的網關服務器的請求地址。

10.3Gateway的高可用

目標：
??了解Gateway高可用。
分析：
??啟動多個Gateway服務，自動注冊到eureka，形成集群。如果是服務內部訪問，訪問Gateway，自動負載均衡，沒有問題。

??但是，Gateway更多是外部訪問，PC端，移動端，他們無法通過Eureka進行負載均衡，那么該怎么辦？

??此時，可以使用其他的服務網關，來對Gateway進行代理，比如：Nginx

小結：

Gateway與feign的區別：

Gateway作為整個應用的流量入口，接收所有的請求，如PC，移動端等，并且將不同的請求轉發至不同的處理微服務模塊，其作用可視為Nginx；大部分情況下用作權限鑒定，服務端流量控制。
Feign則是將當前微服務的部分服務接口暴露出來，并且主要用于各個微服務之間的服務調用。

Gateway網關一般直接給終端請求使用；Fegin一般用在微服務之間調用。

11.Spring Cloud Config分布式配置中心

目標：
??分布式配置中心的作用。

分析：
??配置中心本質也是一個微服務，同樣需要注冊到Eureka服務注冊中心！

小結：
在這里插入圖片描述
??spring cloud config作用：可以通過在git倉庫中的配置文件實現其他所有微服務的配置文件的修改。

12.搭建配置中心微服務

目標：
??創建碼云的遠程公開git倉庫，搭建配置中心微服務config-server

分析：

創建git倉庫：創建碼云
搭建配置中心config-server：使用spring boot方式搭建和配置

小結：
在這里插入圖片描述

配置中心依賴

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

配置中心的配置文件

server:
  port: 12000
spring:
  application:
    name: config-server
 # git配置文件地址
  cloud:
    config:
      server:
        git:
        	#gitee文件地址
          uri: https://gitee.com/rzbd/haotian-config.git
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka

在gitee中修改了配置文件會在配置中心服務及時更新。

13.獲取配置中心配置

目標：
??改造用戶微服務user-service,配置文件信息不再由微服務項目提供，而是從配置中心獲取。

分析：
需求：將服務提供工程user-service的application.yml配置文件刪除，修改為從配置中心config-server中讀取。

實現步驟：

添加啟動器依賴；
修改配置文件；
啟動測試

小結：

創建配置文件

在新建的倉庫中創建需要被統一配置管理的配置文件。
配置文件的命名方式：{application}--{profile}.yml或{application}--{profile}.properties
application為應用名稱
profile用于分區開發環境。測試環境。生產環境等
如user-dev.yml，表示用戶微服務開發環境下使用的配置文件。

??將原來的application.yml刪除；然后添加bootstrap.yml配置文件，該文件也是springboot的默認配置文件，其內容經常配置一些項目中固定的配置項，如果是項目中經常變動的應該配置到application.yml中，現在使用了配置中心則應該配置到git倉庫中對應的配置文件。

配置中心依賴

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

配置文件bootstrap.yml

spring:
  cloud:
    config:
      # 要與倉庫中的配置文件的application保持一致
      name: user
      # 要與倉庫中的配置文件profile保持一致
      profile: dev
      # 要與倉庫中的配置文件所屬的版本（分支）一樣
      label: master
      discovery:
        # 使用配置中心
        enabled: true
        # 配置中心服務名
        service-id: config-server
  # 配置rabbit信息，如果是都與默認值一致則不需要配置
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka

14.Spring Cloud Bus

目標：
??了解Spring Cloud Bus的作用.

小結：
??Spring Cloud Bus作用：將git倉庫的配置文件更新，在不重啟系統的情況下實現及時同步到各個微服務。

15.Spring Cloud Bus的應用

目標：
??啟動RabbitMQ通過修改碼云中的配置文件后發送Post請求實現及時更新用戶微服務中的配置項。

分析：
需求：在碼云的git倉庫中修改user-dev.yml，實現不重啟user-service的情況下可以及時更新配置文件。

實現步驟：

啟動RabbitMQ；
修改配置中心config-server；
修改服務提供工程user-service;
測試；

小結：

config-server的依賴添加

<dependency>
	<groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-bus</artifactId>
</dependency>
<dependency>
	<groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
</dependency>

config-server的配置文件添加內容

server:
  port: 12000
spring:
  application:
    name: config-server
 # git配置文件地址
  cloud:
    config:
      server:
        git:
          uri: https://gitee.com.haotian/haotian-config.git
# 配置rabbitmq信息，如果都是默認值則不需要配置
   rabbitmq:
     host: localhost
     port: 5672
     username: guest
     password: guest

eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka

management:
  endpoint:
    dev:
      exposure:
        # 暴露觸發消息總線地址
        include: bus-refresh

user-service的依賴添加內容

 <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-config</artifactId>
      <version>2.1.1.RELEASE</version>
    </dependency>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-bus</artifactId>
      <version>2.1.0.RELEASE</version>
    </dependency>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
      <version>2.1.0.RELEASE</version>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-actuator</artifactId>
      <version>2.3.0.RELEASE</version>
    </dependency>

user-service的配置文件添加內容

spring:
  cloud:
    config:
      # 要與倉庫中的配置文件的application保持一致
      name: user
      # 要與倉庫中的配置文件profile保持一致
      profile: dev
      # 要與倉庫中的配置文件所屬的版本（分支）一樣
      label: master
      discovery:
        # 使用配置中心
        enabled: true
        # 配置中心服務名
        service-id: config-server
  # 配置rabbit信息，如果是都與默認值一致則不需要配置
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka

UserController的修改

@RestController
@RequestMapping("/user")
@Reference //刷新配置
public class UserController {
    
    @Autowired
    private UserService userService;
    @Value("${test.name}")
    private String name;
    
    @GetMapping("/{id}")
    public User queryById(@PathVariable Long id){
        
        return userService.queryById(id);
    }
}

16.Spring Cloud 體系技術綜合應用說明

目標：
??了解Spring Cloud中的Eureka、Gateway、Config、Bus、Feign等技術的綜合應用。

小結：
在這里插入圖片描述

本文鏈接：https://blog.csdn.net/weixin_45606229/article/details/106485901

智能推薦

SpringCloud學習筆記

SpringCloud學習筆記 ESB企業服務總線：用來連接各個服務節點，為了集成各種不同的服務。 1.系統架構演變目標：了解項目架構的演變歷程。小結：集中式架構垂直拆分分布式架構 SOA面向服務架構微服務架構 2.微服務架構說明目標：了解SOA與微服務架構的區別以及說出微服務架構的特點。分析： &emsp...

注冊中心-Eureka Spring Cloud 封裝了 Netflix 公司開發的 Eureka 模塊來實現服務注冊和發現。Eureka 采用了 C-S 的設計架構。Eureka Server 作為服務注冊功能的服務器，它是服務注冊中心。而系統中的其他微服務，使用 Eureka 的客戶端連接到 Eureka Server，并維持心跳連接。這樣系統的維護人員就可以通過 Eureka Server ...

SpringCloud學習筆記------Feign

feign有假裝的意思為什么要叫假裝？ Feign可以把Rest的請求進行隱藏，偽裝成類似SpringMVC的Controller一樣。你不用再自己拼接url，拼接參數等等操作，一切都交給Feign去做。快速入門先用起來，我們在使用的時候揭開它神秘的面紗吧導入依賴 pom.xml 引入： Feign的客戶端寫一個Controller dao層啟...

SpringCloud學習筆記

介紹 Spring Cloud是一系列技術的有序整合。它利用Spring Boot的開發便利性巧妙地簡化了分布式系統基礎設施的開發。 Spring Boot擅長的是集成，把世界上最好的框架集成到自己項目中，Spring Cloud也是一樣，把非常流行的微服務的技術整合到一起。 Spring Cloud從架構層面上降低了對大型系統構建的要求和難度，使我們以非常低的成本（技術或者硬件）搭建一套高效、分...

SpringCloud 學習筆記

SpringCloud 學習筆記文章目錄 SpringCloud 學習筆記 1 簡介 1.1 什么是 SpringCloud 1.2 SpringCloud 能干什么 2. 微服務 2.1 什么是微服務 2.2 微服務與微服務架構 2.3 微服務架構的四個核心問題 2.4 微服務優缺點 2.5 微服務技術棧有哪些？ 2.6 為什么選擇 SpringCloud 作為微服務架構 1. 選型依據 2....

SpringCloud學習筆記

SpringCloud學習筆記

1.系統架構演變

2.微服務架構說明

3.服務調用方式說明

4.Spring RestTemplalte實例工程導入

5.Spring Cloud概述

6.創建微服務工程

7.搭建配置user-service工程

8.搭建配置consumer-demo工程

9.Eureka注冊中心說明

10.搭建eureka-server工程

11.服務注冊與發現

12.Eureka Server高可用配置

13.Eureka客戶端服務配置

14.負載均衡Ribbon簡介

15.Ribbon負載均衡應用

16.熔斷器Hystrix簡介

17.線程隔離&服務降級

18. 服務熔斷

第二天

1.Feign應用

2.Feifn負載均衡及熔斷

3.Spring Cloud Gateway網關簡介

4.Spring Cloud Gateway入門

5.面向服務的路由

6.路由前綴處理

7.過濾器簡介

8.自定義局部過濾器

9.自定義全局過濾器

10.1Gateway其他配置說明

10.2Gateway跨域配置

10.3Gateway的高可用

11.Spring Cloud Config分布式配置中心

12.搭建配置中心微服務

13.獲取配置中心配置

14.Spring Cloud Bus

15.Spring Cloud Bus的應用

16.Spring Cloud 體系技術綜合應用說明

智能推薦

猜你喜歡