91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Spring Cloud Alibaba 使用 Feign+Sentinel 怎么完成熔斷

發布時間:2021-03-15 10:50:22 來源:億速云 閱讀:852 作者:TREX 欄目:開發技術

這篇文章主要講解了“Spring Cloud Alibaba 使用 Feign+Sentinel 怎么完成熔斷”,文中的講解內容簡單清晰,易于學習與理解,下面請大家跟著小編的思路慢慢深入,一起來研究和學習“Spring Cloud Alibaba 使用 Feign+Sentinel 怎么完成熔斷”吧!

Feign的使用

Feign也是網飛開發的,SpringCloud 使用 Feign 非常簡單,我下邊演示一下:
首先 服務消費者這邊肯定需要一個對應的依賴:

compile("org.springframework.cloud:spring-cloud-starter-openfeign")

需要啟用Feign的話,也得在啟動類上面加個注解 @EnableFeignClients
然后,創建一個 Feign 的接口,像這樣子

package com.skypyb.sc.feign;
import com.skypyb.sc.entity.User;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
@FeignClient("sc-demo-microservice-user")
public interface UserFeignClient {
 @RequestMapping(value = "/user/{id}",method = RequestMethod.GET)
 public User getUser(@PathVariable("id") Long id);
}

@FeignClient 注解里邊的默認屬性,也就是name屬性是一個客戶端的名字,如果使用了Eureka的話,會給他自動解析為 Eureka Server 服務注冊表中的服務。
要是配了Ribbon,也會使用默認的負載均衡策略來執行請求。
Feign默認使用SpringMVC的注解聲明請求,當然也可以用Feign自帶的注解。不過沒啥必要,還需要配置東西。
 
我上邊這個例子寫完了,實際使用的話只需要注入該類然后調用對應的方法就完事了。非常簡便。

package com.skypyb.sc.controller;
import com.skypyb.sc.entity.User;
import com.skypyb.sc.feign.UserFeignClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import java.util.List;
@RestController
@RequestMapping("/movie")
public class MovieController {
 private Logger logger = LoggerFactory.getLogger(MovieController.class);
 @Autowired
 private UserFeignClient userFeignClient;
 @GetMapping("/user/{id}")
 public User getUser(@PathVariable("id") Long id) {
  return userFeignClient.getUser(id);
 }
}

不過有幾個點需要注意
在使用@FeignClient 聲明的Feign偽裝類中:
使用 @PathVariable 注解,必須加上參數!
GET請求無法使用對象作為入參! 要不有多少參數寫多少參數(每個都要加@RequestParam(“參數名”) 注解),要不就用接受一個Map對象,也得加@RequestParam
POST請求可以接收對象,需要加上@RequestBody注解
 
 
Feign論使用的話,其實已經差不多了。
但是還有一些相關的操作也比較重要。
 
Feign 的請求都是使用的默認配置,我們其實可以實現自己的配置供 Feign 使用以實現編碼、解碼、日志記錄、驗證 等等等等。
比如我可以這么定義一個配置類:

package com.skypyb.sc.config;
import feign.Logger;
import feign.auth.BasicAuthRequestInterceptor;
import org.springframework.context.annotation.Bean;
public class FeignConfiguration {
 @Bean
 public Logger.Level feignLog() {
  return Logger.Level.FULL;
 }
 /**
  * 使用指定的用戶名和密碼驗證所有請求
  * @return
  */
 @Bean
 public BasicAuthRequestInterceptor basicAuthRequestInterceptor(){
  return new BasicAuthRequestInterceptor("user","614");
 }
}

該類配置了對應的日志記錄器,和一個簡單的效驗,以應對請求的驗證。
在對應的Feign偽裝類中,上邊的@FeignClient注解改一下,就可以使用自己寫的配置:

@FeignClient(name = "sc-demo-microservice-user", configuration = FeignConfiguration.class)

之所以在 @FeignClient 注解中指定配置,是因為我的配置類是沒有加 @Configuration 注解的,我想要實現細粒度的控制。 推薦這樣做。
如果加了@Configuration 注解,則 Spring 會將其自動解析自動應用到全局,這樣子就不方便為每個請求進行細粒度調整。

Alibaba的使用

首先肯定是要上pom.xml配置起來。加上對應的依賴。

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

接著寫個Feign接口

package com.skypyb.provider.feign;
import com.skypyb.provider.fallback.HelloServiceFallback;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
/**
 * Feign客戶端
 * 指定調用 sc-demo-alibaba-provider 的服務
 */
@FeignClient(value = "sc-demo-alibaba-provider",fallback = HelloServiceFallback.class)
public interface NacosHelloFeign {
 @RequestMapping(value = "/provider/hello/{msg}")
 String hello(@PathVariable("msg") String msg);
}

調用的話就是這樣子調用:

package com.skypyb.provider.controller;
import com.skypyb.provider.feign.NacosHelloFeign;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import javax.annotation.Resource;
@RequestMapping("/consumer")
@RestController
public class NacosConsumerController {
 @Autowired
 private LoadBalancerClient loadBalancerClient;
 @Autowired
 private RestTemplate restTemplate;
 @Resource
 private NacosHelloFeign nacosHelloFeign;
 @GetMapping(value = "/hello/{msg}")
 public String hello(@PathVariable("msg") String msg) {
  //使用 LoadBalanceClient 和 RestTemplate 結合的方式來訪問
  ServiceInstance serviceInstance = loadBalancerClient.choose("sc-demo-alibaba-provider");
  String url = String.format("http://%s:%s/provider/hello/%s",
    serviceInstance.getHost(), serviceInstance.getPort(), msg);
  return restTemplate.getForObject(url, String.class);
 }
 @GetMapping(value = "/hello/feign/{msg}")
 public String helloFeign(@PathVariable("msg") String msg) {
  return nacosHelloFeign.hello(msg);
 }
}

哎,觀察我的NacosHelloFeign類,這里可以看到,我這用了一個fallback回退,這個回退指定的就是Sentinel 的實現,其實寫起來和特么的Hystrix一模一樣。不得不說SpringCloud這一點是真的做得好。

package com.skypyb.provider.fallback;
import com.skypyb.provider.feign.NacosHelloFeign;
import org.springframework.stereotype.Component;
/**
 * 熔斷類
 * 要是 Feign 的接口調用失敗(或者被快速失敗)就會走這個類的方法進行處理
 */
@Component
public class HelloServiceFallback implements NacosHelloFeign {
 @Override
 public String hello(String msg) {
  return "觸發熔斷機制~";
 }
}

哎,觀察我的NacosHelloFeign類,這里可以看到,我這用了一個fallback回退,這個回退指定的就是Sentinel 的實現,其實寫起來和特么的Hystrix一模一樣。不得不說SpringCloud這一點是真的做得好。

package com.skypyb.provider.fallback;
import com.skypyb.provider.feign.NacosHelloFeign;
import org.springframework.stereotype.Component;
/**
 * 熔斷類
 * 要是 Feign 的接口調用失敗(或者被快速失敗)就會走這個類的方法進行處理
 */
@Component
public class HelloServiceFallback implements NacosHelloFeign {
 @Override
 public String hello(String msg) {
  return "觸發熔斷機制~";
 }
}

當然,配置肯定是得配置的,他也不會直接就給你用了。
Sentinel 雖說是適配了 Feign 組件。但默認是關閉的。需要在配置文件中配置打開它,在配置文件增加以下代碼:

feign:
 sentinel:
 enabled: true

其實到現在,整個Feign的使用+熔斷限流機制就已經配完了。
不過Sentinel 比起Hystrix真正優越的地方還沒來呢。
那就是: 控制臺。
這個控制臺功能豐富、UI好看,比Hystrix那是高到不知道哪里去了。
要是用控制臺,又不得不下載代碼、打包、編譯、運行。
 
所幸,我們有神器docker。我在docker hub 上找了個鏡像,直接用就可以了,鏡像地址:https://hub.docker.com/r/bladex/sentinel-dashboard
直接執以下命令,將sentinel控制臺起開綁到8858端口

docker pull bladex/sentinel-dashboard
docker run --name sentinel -d -p 8858:8858 -d bladex/sentinel-dashboard

然后自己的yml文件也得改一下,畢竟都上控制臺了,也得把自己這個服務給注冊進去。
全部的yml文件如下所示:

spring:
 application:
 name: sc-demo-alibaba-consumer
 cloud:
 nacos:
  discovery:
  server-addr: 192.168.1.14:8848 #注冊進 nacos
 sentinel:
   transport:
   port: 18081 #這個端口的意思是自己這個服務開個端口和 sentinel 控制臺交互
   dashboard: 192.168.1.14:8858 # sentinel 控制臺的端口
server:
 port: 8081
feign:
 sentinel:
 enabled: true
management:
 endpoints:
 web:
  exposure:
  include: "*"

可以看到配置里有一個 sentinel.transport.port屬性,這個屬性的意思是在自己本體這個服務里邊,在開個新的端口專門用來和 Sentinel 控制臺交互
Sentinel 控制臺自身也有,默認端口則是8719
 
到這里就差不多了,所有東西打開,然后就可以訪問 http://ip:8858 進入Sentinel 控制臺,默認賬號密碼都是sentinel
有一點還需要注意,那就是為了確保客戶端有訪問量,Sentinel 會在客戶端首次調用的時候進行初始化,開始向控制臺發送心跳包。意思就是說你一個服務注冊進我這來,首先還是看不到的。
你得先經過別人的請求,我才會去監控你,所以在服務剛啟動的時候進入Sentinel 控制臺找不到自己的服務是很正常的,只要啟動時沒有報錯就不會有問題。

感謝各位的閱讀,以上就是“Spring Cloud Alibaba 使用 Feign+Sentinel 怎么完成熔斷”的內容了,經過本文的學習后,相信大家對Spring Cloud Alibaba 使用 Feign+Sentinel 怎么完成熔斷這一問題有了更深刻的體會,具體使用情況還需要大家實踐驗證。這里是億速云,小編將為大家推送更多相關知識點的文章,歡迎關注!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

通州市| 宽甸| 慈溪市| 积石山| 仪征市| 通山县| 汽车| 宕昌县| 韩城市| 宁南县| 静安区| 临漳县| 日喀则市| 长乐市| 丹寨县| 乌兰察布市| 五指山市| 汪清县| 五大连池市| 荃湾区| 任丘市| 白城市| 隆回县| 大悟县| 青神县| 龙川县| 南安市| 祁门县| 蓬莱市| 东阿县| 迁西县| 文化| 荔波县| 景泰县| 钦州市| 遂溪县| 和林格尔县| 军事| 巴楚县| 衡阳县| 宝鸡市|