SpringCloud（第 013 篇）電影微服務使用定製化Feign負載均衡調度併爲Feign配置賬號密碼登陸認證Eureka
SpringCloud（第 013 篇）電影微服務使用定製化 Feign 在客戶端進行負載均衡調度併爲 Feign 配置賬號密碼登陸認證 Eureka
-java
1、大體介紹
一、定製 Feign 實現訪問遠端微服務； 二、爲 Feign 配置賬號密碼來登陸認證 Eureka 服務發現模塊； 三、修改 Feign 的日誌打印級別； 四、定製 Feign 也絕不掩飾的支持負載均衡調度功能；
2、實現步驟
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>
<!-- 客戶端發現模塊 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<!-- Java HTTP 客戶端開發的工具的模塊 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-feign</artifactId>
</dependency>
</dependencies>
</project>
2.2 添加應用配置文件（springms-consumer-movie-feign-customsrcmainresourcesapplication.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 的默認超時時間是 1 秒，所以請求超過該時間後，就會出現頁面超時顯示 ：
#
# 這裏就介紹大概三種方式來解決超時的問題，解決方案以下：
#
# 第一種方式：將 hystrix 的超時時間設置成 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-customsrcmainjavacomspringmscloudentityUser.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 添加訪問遠端服務 Feign 客戶端（springms-consumer-movie-feign-customsrcmainjavacomspringmscloudfeignUserFeignCustomClient.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請求的客戶端，FeignClient 註解地方採用了自定義的配置。
*
* 註解FeignClient的傳參：表示的是註冊到 Eureka 服務上的模塊名稱。
*
* @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 添加登陸認證Eureka服務 Feign 客戶端（springms-consumer-movie-feign-customsrcmainjavacomspringmscloudfeignUserFeignCustomSecondClient.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請求的客戶端，FeignClient 註解地方採用了自定義的配置。
*
* 註解FeignClient的傳參：表示的是註冊到 Eureka 服務上的模塊名稱。
*
* @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 添加訪問遠端服務配置類（springms-consumer-movie-feign-customsrcmainjavacomspringmsconfigTestFeignCustomConfiguration.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 添加登陸認證Eureka服務配置（springms-consumer-movie-feign-customsrcmainjavacomspringmsconfigTestEurekaAuthConfiguration.java）
package com.springms.config;
import feign.auth.BasicAuthRequestInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* 認證配置，因爲 UserFeignCustomSecondClient 訪問 http://localhost:8761/ 須要密碼登陸，因此纔有了此配置的出現。
*
* @author hmilyylimh
*
* @version 0.0.1
*
* @date 2017/9/19
*
*/
@Configuration
public class TestEurekaAuthConfiguration {
/**
* 此方法主要配置登陸 Eureka 服務器的賬號與密碼。
*
* @return
*/
@Bean
public BasicAuthRequestInterceptor basicAuthRequestInterceptor(){
return new BasicAuthRequestInterceptor("admin", "admin");
}
}
2.8 添加Web訪問層Controller（springms-consumer-movie-feign-customsrcmainjavacomspringmscloudcontrollerMovieFeignCustomController.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 添加電影微服務啓動類（springms-consumer-movie-feign-customsrcmainjavacomspringmscloudMsConsumerMovieFeignCustomApplication.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;
/**
*
* 電影微服務使用定製化 Feign 在客戶端進行負載均衡調度併爲 Feign 配置賬號密碼登陸認證 Eureka。
*
* Feign: Java HTTP 客戶端開發的工具。
*
* 註解 EnableFeignClients 表示該電影微服務已經接入 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微服務 】】】】】】已啓動.");
}
}
3、測試
/**************************************************************************************** 1、電影微服務使用定製化Feign在客戶端進行負載均衡調度併爲Feign配置賬號密碼登陸認證Eureka（測試接入 Feign 模塊）： 一、註解：EnableFeignClients 二、啓動 springms-discovery-eureka 模塊服務，啓動1個端口； 三、啓動 springms-provider-user 模塊服務，啓動1個端口； 四、啓動 springms-consumer-movie-feign-custom 模塊服務； 五、在瀏覽器輸入地址http://localhost:8050/movie/1 能夠看到信息成功的被打印出來； 總結：說明接入 Feign 已經成功經過測試； ****************************************************************************************/ /**************************************************************************************** 2、電影微服務使用定製化Feign在客戶端進行負載均衡調度併爲Feign配置賬號密碼登陸認證Eureka（測試登陸 Eureka 服務器須要認證配置）： 一、註解：EnableFeignClients 二、啓動 springms-discovery-eureka 模塊服務，啓動1個端口； 三、啓動 springms-provider-user 模塊服務，啓動1個端口； 四、啓動 springms-consumer-movie-feign-custom 模塊服務； 五、在瀏覽器輸入地址 http://localhost:8050/springms-provider-user 能夠看到信息成功的被打印出來； 總結：說明 TestEurekaAuthConfiguration 類中配置的賬號密碼已經生效，能夠正常訪問 Eureka 服務； ****************************************************************************************/ /**************************************************************************************** 3、電影微服務使用定製化Feign在客戶端進行負載均衡調度併爲Feign配置賬號密碼登陸認證Eureka（測試接入 Feign 模塊進行負載均衡）： 一、註解：EnableFeignClients 二、啓動 springms-discovery-eureka 模塊服務，啓動1個端口； 三、啓動 springms-provider-user 模塊服務，啓動3個端口（7900、789九、7898）； 四、啓動 springms-consumer-movie-feign-custom 模塊服務； 五、在瀏覽器輸入地址http://localhost:8050/movie/1 連續刷新9次，正常狀況能夠看到 springms-provider-user 的3個端口輪詢打印用戶日誌信息； 總結：一、說明接入 Feign 已經成功的在客戶端進行了負載均衡處理； 二、之因此會在客戶端進行輪詢打印日誌信息，是由於沒有配置調度算法，而默認的調度算法就是輪詢，因此會出現輪詢打印日誌信息； ****************************************************************************************/ /**************************************************************************************** 4、電影微服務使用定製化Feign在客戶端進行負載均衡調度併爲Feign配置賬號密碼登陸認證Eureka（配置日誌級別）： 一、application.yml 修改：logging.level.com.springms.cloud.feign.UserFeignCustomClient: DEBUG 二、編寫 TestFeignCustomConfiguration 新增日誌級別的方法 三、啓動 springms-discovery-eureka 模塊服務，啓動1個端口； 四、啓動 springms-provider-user 模塊服務，啓動1個端口； 五、啓動 springms-consumer-movie-feign-custom 模塊服務； 六、在瀏覽器輸入地址http://localhost:8050/springms-provider-user 能夠看到控制檯中 DEBUG 日誌級別的信息成功的被打印出來； ****************************************************************************************/
4、下載地址
https://gitee.com/ylimhhmily/SpringCloudTutorial.gitgit
SpringCloudTutorial交流QQ羣: 235322432github
SpringCloudTutorial交流微信羣: 微信溝通羣二維碼圖片連接web
歡迎關注，您的確定是對我最大的支持!!!算法
相關文章
- 1. springcloud+eureka+feign負載均衡
- 2. SpringCloud負載均衡-Feign
- 3. SpringCloud之Feign負載均衡
- 4. SpringCloud --- Feign負載均衡
- 5. 【微服務】Ribbon和Feign負載均衡
- 6. Feign負載均衡
- 7. SpringCloud與微服務Ⅶ --- Feign負載均衡
- 8. SpringCloud（第 012 篇）微服務接入 Feign 負載均衡經過 FeignClient 調用遠程 Http 微服務
- 9. Spring Cloud（Greenwich.SR1） - 服務負載均衡feign
- 10. 5、SpringCloud之Feign負載均衡
- 更多相關文章...
- • Hibernate事務的配置 - Hibernate教程
- • 爲什麼使用 XML Schemas? - XML Schema 教程
- • Spring Cloud 微服務實戰(三) - 服務註冊與發現
- • IntelliJ IDEA 代碼格式化配置和快捷鍵
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. 融合阿里雲，牛客助您找到心儀好工作
- 2. 解決jdbc(jdbctemplate)在測試類時不報錯在TomCatb部署後報錯
- 3. 解決PyCharm GoLand IntelliJ 等 JetBrains 系列 IDE無法輸入中文
- 4. vue+ant design中關於圖片請求不顯示的問題。
- 5. insufficient memory && Native memory allocation (malloc) failed
- 6. 解決IDEA用Maven創建的Web工程不能創建Java Class文件的問題
- 7. [已解決] Error: Cannot download ‘https://start.spring.io/starter.zip?
- 8. 在idea讓java文件夾正常使用
- 9. Eclipse啓動提示「subversive connector discovery」
- 10. 帥某-技巧-快速轉帖博主文章（article_content）
歡迎關注本站公眾號,獲取更多信息
相關文章
- 1. springcloud+eureka+feign負載均衡
- 2. SpringCloud負載均衡-Feign
- 3. SpringCloud之Feign負載均衡
- 4. SpringCloud --- Feign負載均衡
- 5. 【微服務】Ribbon和Feign負載均衡
- 6. Feign負載均衡
- 7. SpringCloud與微服務Ⅶ --- Feign負載均衡
- 8. SpringCloud（第 012 篇）微服務接入 Feign 負載均衡經過 FeignClient 調用遠程 Http 微服務
- 9. Spring Cloud（Greenwich.SR1） - 服務負載均衡feign
- 10. 5、SpringCloud之Feign負載均衡