SpringCloud（第 013 篇）電影微服務(wù)使用定制化 Feign 在客戶端進行負載均衡調(diào)度并為 Feign 配置帳號密碼登錄認(rèn)證 Eureka

SpringCloud（第 013 篇）電影微服務(wù)使用定制化 Feign 在客戶端進行負載均衡調(diào)度并為 Feign 配置帳號密碼登錄認(rèn)證 Eureka

一、大致介紹

1、定制 Feign 實現(xiàn)訪問遠端微服務(wù)；
2、為 Feign 配置帳號密碼來登錄認(rèn)證 Eureka 服務(wù)發(fā)現(xiàn)模塊；
3、修改 Feign 的日志打印級別；
4、定制 Feign 也毫不掩飾的支持負載均衡調(diào)度功能；

二、實現(xiàn)步驟

2.1 添加 maven 引用包

<?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>

    <artifactId>springms-consumer-movie-feign-custom</artifactId>
    <version>1.0-SNAPSHOT</version>
    <packaging>jar</packaging>

    <parent>
        <groupId>com.springms.cloud</groupId>
        <artifactId>springms-spring-cloud</artifactId>
        <version>1.0-SNAPSHOT</version>
    </parent>

    <dependencies>
        <!-- web模塊 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!-- 客戶端發(fā)現(xiàn)模塊 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
        </dependency>

        <!-- Java HTTP 客戶端開發(fā)的工具的模塊 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-feign</artifactId>
        </dependency>
    </dependencies>

</project>

2.2 添加應(yīng)用配置文件（springms-consumer-movie-feign-custom\src\main\resources\application.yml）

spring:
  application:
    name: springms-consumer-movie-feign-custom
server:
  port: 8050
eureka:
  client:
#    healthcheck:
#      enabled: true
    serviceUrl:
      defaultZone: http://admin:admin@localhost:8761/eureka
  instance:
    prefer-ip-address: true
    instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${spring.application.instance_id:${server.port}}

logging:
  level:
    com.springms.cloud.feign.UserFeignCustomClient: DEBUG


# 解決第一次請求報超時異常的方案，因為 hystrix 的默認(rèn)超時時間是 1 秒，因此請求超過該時間后，就會出現(xiàn)頁面超時顯示 ：
#
# 這里就介紹大概三種方式來解決超時的問題，解決方案如下：
#
# 第一種方式：將 hystrix 的超時時間設(shè)置成 5000 毫秒
# hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds: 5000
#
# 或者：
# 第二種方式：將 hystrix 的超時時間直接禁用掉，這樣就沒有超時的一說了，因為永遠也不會超時了
# hystrix.command.default.execution.timeout.enabled: false
#
# 或者：
# 第三種方式：索性禁用feign的hystrix支持
feign.hystrix.enabled: false ## 索性禁用feign的hystrix支持

# 超時的issue：https://github.com/spring-cloud/spring-cloud-netflix/issues/768
# 超時的解決方案： http://stackoverflow.com/questions/27375557/hystrix-command-fails-with-timed-out-and-no-fallback-available
# hystrix配置： https://github.com/Netflix/Hystrix/wiki/Configuration#execution.isolation.thread.timeoutInMilliseconds

2.3 添加實體用戶類User（springms-consumer-movie-feign-custom\src\main\java\com\springms\cloud\entity\User.java）

package com.springms.cloud.entity;

import java.math.BigDecimal;

public class User {

    private Long id;

    private String username;

    private String name;

    private Short age;

    private BigDecimal balance;

    public Long getId() {
        return this.id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public String getUsername() {
        return this.username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getName() {
        return this.name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Short getAge() {
        return this.age;
    }

    public void setAge(Short age) {
        this.age = age;
    }

    public BigDecimal getBalance() {
        return this.balance;
    }

    public void setBalance(BigDecimal balance) {
        this.balance = balance;
    }

}

2.4 添加訪問遠端服務(wù) Feign 客戶端（springms-consumer-movie-feign-custom\src\main\java\com\springms\cloud\feign\UserFeignCustomClient.java）

package com.springms.cloud.feign;

import com.springms.cloud.entity.User;
import com.springms.config.TestFeignCustomConfiguration;
import feign.Param;
import feign.RequestLine;
import org.springframework.cloud.netflix.feign.FeignClient;

/**
 * 用戶Http請求的客戶端，F(xiàn)eignClient 注解地方采用了自定義的配置。
 *
 * 注解FeignClient的傳參：表示的是注冊到 Eureka 服務(wù)上的模塊名稱。
 *
 * @author hmilyylimh
 *
 * @version 0.0.1
 *
 * @date 2017/9/19
 *
 */
@FeignClient(name = "springms-provider-user", configuration = TestFeignCustomConfiguration.class)
public interface UserFeignCustomClient {

    /**
     * 這里的注解 RequestLine、Param 是 Feign 的配置新的注解，詳細請參考鏈接：https://github.com/OpenFeign/feign
     *
     * @param id
     * @return
     */
    @RequestLine("GET /simple/{id}")
    public User findById(@Param("id") Long id);
}


/****************************************************************************************
 參考代碼如下：

    interface GitHub {
        @RequestLine("GET /repos/{owner}/{repo}/contributors")
        List<Contributor> contributors(@Param("owner") String owner, @Param("repo") String repo);
    }

    static class Contributor {
        String login;
        int contributions;
    }

    public static void main(String... args) {
        GitHub github = Feign.builder().decoder(new GsonDecoder()).target(GitHub.class, "https://api.github.com");

        // Fetch and print a list of the contributors to this library.
        List<Contributor> contributors = github.contributors("OpenFeign", "feign");
        for (Contributor contributor : contributors) {
            System.out.println(contributor.login + " (" + contributor.contributions + ")");
        }
    }
 ****************************************************************************************/

2.5 添加登錄認(rèn)證Eureka服務(wù) Feign 客戶端（springms-consumer-movie-feign-custom\src\main\java\com\springms\cloud\feign\UserFeignCustomSecondClient.java）

package com.springms.cloud.feign;

import com.springms.config.TestEurekaAuthConfiguration;
import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;

/**
 * 用戶Http請求的客戶端，F(xiàn)eignClient 注解地方采用了自定義的配置。
 *
 * 注解FeignClient的傳參：表示的是注冊到 Eureka 服務(wù)上的模塊名稱。
 *
 * @author hmilyylimh
 *
 * @version 0.0.1
 *
 * @date 2017/9/19
 *
 */
@FeignClient(name = "xxx", url = "http://localhost:8761/", configuration = TestEurekaAuthConfiguration.class)
public interface UserFeignCustomSecondClient {

    @RequestMapping(value = "/eureka/apps/{serviceName}")
    public String findEurekaInfo(@PathVariable("serviceName") String serviceName);
}

2.6 添加訪問遠端服務(wù)配置類（springms-consumer-movie-feign-custom\src\main\java\com\springms\config\TestFeignCustomConfiguration.java）

package com.springms.config;

import feign.Contract;
import feign.Logger;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * 自定義配置。
 *
 * 不和 com.springms.cloud 在同級目錄，因為文檔有說明，該配置文件不需要被掃描到。
 *
 * @author hmilyylimh
 *
 * @version 0.0.1
 *
 * @date 2017/9/19
 *
 */
@Configuration
public class TestFeignCustomConfiguration {

    @Bean
    public Contract feignContract(){
        return new feign.Contract.Default();
    }

    /**
     * 日志級別配置
     *
     * @return
     */
    @Bean
    Logger.Level feignLoggerLevel(){
        return Logger.Level.FULL;
    }
}

2.7 添加登錄認(rèn)證Eureka服務(wù)配置（springms-consumer-movie-feign-custom\src\main\java\com\springms\config\TestEurekaAuthConfiguration.java）

package com.springms.config;

import feign.auth.BasicAuthRequestInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * 認(rèn)證配置，由于 UserFeignCustomSecondClient 訪問 http://localhost:8761/ 需要密碼登錄，所以才有了此配置的出現(xiàn)。
 *
 * @author hmilyylimh
 *
 * @version 0.0.1
 *
 * @date 2017/9/19
 *
 */
@Configuration
public class TestEurekaAuthConfiguration {

    /**
     * 此方法主要配置登錄 Eureka 服務(wù)器的帳號與密碼。
     *
     * @return
     */
    @Bean
    public BasicAuthRequestInterceptor basicAuthRequestInterceptor(){
        return new BasicAuthRequestInterceptor("admin", "admin");
    }
}

2.8 添加Web訪問層Controller（springms-consumer-movie-feign-custom\src\main\java\com\springms\cloud\controller\MovieFeignCustomController.java）

package com.springms.cloud.controller;

import com.springms.cloud.entity.User;
import com.springms.cloud.feign.UserFeignCustomClient;
import com.springms.cloud.feign.UserFeignCustomSecondClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

/**
 * 自定義 Feign 控制器。
 *
 * @author hmilyylimh
 *
 * @version 0.0.1
 *
 * @date 2017/9/19
 *
 */
@RestController
public class MovieFeignCustomController {

    @Autowired
    private UserFeignCustomClient userFeignCustomClient;

    @Autowired
    private UserFeignCustomSecondClient userFeignCustomSecondClient;

    @GetMapping("/movie/{id}")
    public User findById(@PathVariable Long id) {
        return userFeignCustomClient.findById(id);
    }

    @GetMapping("/{serviceName}")
    public String findEurekaInfo(@PathVariable String serviceName){
        return userFeignCustomSecondClient.findEurekaInfo(serviceName);
    }
}

2.9 添加電影微服務(wù)啟動類（springms-consumer-movie-feign-custom\src\main\java\com\springms\cloud\MsConsumerMovieFeignCustomApplication.java）

package com.springms.cloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.feign.EnableFeignClients;

/**
 *
 * 電影微服務(wù)使用定制化 Feign 在客戶端進行負載均衡調(diào)度并為 Feign 配置帳號密碼登錄認(rèn)證 Eureka。
 *
 * Feign: Java HTTP 客戶端開發(fā)的工具。
 *
 * 注解 EnableFeignClients 表示該電影微服務(wù)已經(jīng)接入 Feign 模塊。
 *
 * @author hmilyylimh
 *
 * @version 0.0.1
 *
 * @date 2017/9/19
 *
 */
@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients
public class MsConsumerMovieFeignCustomApplication {

    public static void main(String[] args) {
        SpringApplication.run(MsConsumerMovieFeignCustomApplication.class, args);
        System.out.println("【【【【【【 電影自定義Feign微服務(wù) 】】】】】】已啟動.");
    }
}

三、測試

/****************************************************************************************
 一、電影微服務(wù)使用定制化Feign在客戶端進行負載均衡調(diào)度并為Feign配置帳號密碼登錄認(rèn)證Eureka（測試接入 Feign 模塊）：

 1、注解：EnableFeignClients
 2、啟動 springms-discovery-eureka 模塊服務(wù)，啟動1個端口；
 3、啟動 springms-provider-user 模塊服務(wù)，啟動1個端口；
 4、啟動 springms-consumer-movie-feign-custom 模塊服務(wù)；
 5、在瀏覽器輸入地址http://localhost:8050/movie/1 可以看到信息成功的被打印出來；

 總結(jié)：說明接入 Feign 已經(jīng)成功通過測試；
 ****************************************************************************************/

/****************************************************************************************
 二、電影微服務(wù)使用定制化Feign在客戶端進行負載均衡調(diào)度并為Feign配置帳號密碼登錄認(rèn)證Eureka（測試登錄 Eureka 服務(wù)器需要認(rèn)證配置）：

 1、注解：EnableFeignClients
 2、啟動 springms-discovery-eureka 模塊服務(wù)，啟動1個端口；
 3、啟動 springms-provider-user 模塊服務(wù)，啟動1個端口；
 4、啟動 springms-consumer-movie-feign-custom 模塊服務(wù)；
 5、在瀏覽器輸入地址 http://localhost:8050/springms-provider-user 可以看到信息成功的被打印出來；

 總結(jié)：說明 TestEurekaAuthConfiguration 類中配置的帳號密碼已經(jīng)生效，可以正常訪問 Eureka 服務(wù)；
 ****************************************************************************************/

/****************************************************************************************
 三、電影微服務(wù)使用定制化Feign在客戶端進行負載均衡調(diào)度并為Feign配置帳號密碼登錄認(rèn)證Eureka（測試接入 Feign 模塊進行負載均衡）：

 1、注解：EnableFeignClients
 2、啟動 springms-discovery-eureka 模塊服務(wù)，啟動1個端口；
 3、啟動 springms-provider-user 模塊服務(wù)，啟動3個端口（7900、7899、7898）；
 4、啟動 springms-consumer-movie-feign-custom 模塊服務(wù)；
 5、在瀏覽器輸入地址http://localhost:8050/movie/1 連續(xù)刷新9次，正常情況可以看到 springms-provider-user 的3個端口輪詢打印用戶日志信息；

 總結(jié)：1、說明接入 Feign 已經(jīng)成功的在客戶端進行了負載均衡處理；
 2、之所以會在客戶端進行輪詢打印日志信息，是因為沒有配置調(diào)度算法，而默認(rèn)的調(diào)度算法就是輪詢，所以會出現(xiàn)輪詢打印日志信息；
 ****************************************************************************************/

/****************************************************************************************
 四、電影微服務(wù)使用定制化Feign在客戶端進行負載均衡調(diào)度并為Feign配置帳號密碼登錄認(rèn)證Eureka（配置日志級別）：

 1、application.yml 修改：logging.level.com.springms.cloud.feign.UserFeignCustomClient: DEBUG
 2、編寫 TestFeignCustomConfiguration 新增日志級別的方法
 3、啟動 springms-discovery-eureka 模塊服務(wù)，啟動1個端口；
 4、啟動 springms-provider-user 模塊服務(wù)，啟動1個端口；
 5、啟動 springms-consumer-movie-feign-custom 模塊服務(wù)；
 6、在瀏覽器輸入地址http://localhost:8050/springms-provider-user 可以看到控制臺中 DEBUG 日志級別的信息成功的被打印出來；
 ****************************************************************************************/

四、下載地址

https://gitee.com/ylimhhmily/SpringCloudTutorial.git

SpringCloudTutorial交流QQ群: 235322432

SpringCloudTutorial交流微信群: 微信溝通群二維碼圖片鏈接

歡迎關(guān)注，您的肯定是對我最大的支持!!!

<上一篇????????首頁????????下一篇>

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容