SpringCloud之Ribbon使用示例解析

更新時(shí)間：2023年06月22日 10:06:19 作者：天還下著毛毛雨

這篇文章主要為大家介紹了SpringCloud之Ribbon使用示例解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

正文

Ribbon 是一個(gè)獨(dú)立的組件，是用來進(jìn)行遠(yuǎn)程接口調(diào)用的，代碼如下

通過 getForObject 方法可以掉到用 micro-order 服務(wù)的，order/list 接口。

然后在調(diào)用期間會存在負(fù)載均衡，micro-order 服務(wù)對應(yīng)有幾個(gè)服務(wù)實(shí)例就會根據(jù)負(fù)載均衡算法選擇某一個(gè)去調(diào)用。

1. 測試代碼

1.1. 啟動(dòng)兩個(gè)訂單服務(wù)

端口號分別為9011,9012

1.2. 改造獲取訂單接口

返回當(dāng)前服務(wù)實(shí)例的占用的端口號,用來判斷當(dāng)前服務(wù)是哪個(gè)實(shí)例

@RequestMapping("/order")
@RestController
public class OrderController {
    @Value("${server.port}")
    String port;
    @GetMapping("/list")
    public String getOrderList(String username) {
        return "該服務(wù)端口號：" + port + ",這是用戶 ：" + username + " 所有的訂單信息";
    }
}

1.3. 調(diào)用用戶服務(wù)的獲取訂單接口,

@RequestMapping("/user")
@RestController
public class UserController {
    @Autowired
    private RestTemplate restTemplate;
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
    @GetMapping("/orderList")
    public String getOrderList(String username) {
        return restTemplate.getForObject("http://" + "micro-order" + "/order/list?username=" + username, String.class);
    }
}

會發(fā)現(xiàn),對訂單服務(wù)的調(diào)用會存在負(fù)載均衡,在兩個(gè)訂單服務(wù)之間切來切去。

2. Ribbon 配置

2.1. Application.properties 配置

# 關(guān)閉 ribbon 訪問注冊中心 Eureka Server 發(fā)現(xiàn)服務(wù)，但是服務(wù)依舊會注冊。
#true 使用 eureka false 不使用。如果是false，那么表示要調(diào)用的服務(wù)列表從下面這個(gè)參數(shù)中獲取,不然就從eureka-server中獲取,這樣擴(kuò)容服務(wù)提供方的話，需要改配置文件與動(dòng)態(tài)擴(kuò)容的理念相悖，不建議大家使用
ribbon.eureka.enabled=true
spring.cloud.loadbalancer.retry.enabled=true
###指定調(diào)用的節(jié)點(diǎn)
###ribbon.eureka.enabled=false
##micro-order.ribbon.listOfServers=localhost:8001
##單位 ms ,請求連接超時(shí)時(shí)間
#micro-order.ribbon.ConnectTimeout=1000
##單位 ms ,請求處理的超時(shí)時(shí)間
#micro-order.ribbon.ReadTimeout=2000
#micro-order.ribbon.OkToRetryOnAllOperations=true
##切換實(shí)例的重試次數(shù)
#micro-order.ribbon.MaxAutoRetriesNextServer=2
##對當(dāng)前實(shí)例的重試次數(shù) 當(dāng) Eureka 中可以找到服務(wù)，但是服務(wù)連不上時(shí)將會重試
#micro-order.ribbon.MaxAutoRetries=2
##配置負(fù)載均衡
#micro.order.ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RandomRule
#micro-order.ribbon.NFLoadBalancerPingClassName=com.netflix.loadbalancer.PingUrl

2.2 代碼配置

2.2.1. 使用@RibbonClients 加載針對某一個(gè)服務(wù)的ribbon配置

這個(gè)配置類只針對 micro-order 服務(wù)，微服務(wù)系統(tǒng)里面有很多服務(wù)，這就可以區(qū)別化配置。

/*
* 這個(gè)是針對 micro-order服務(wù)的 ribbon配置
* */
@Configuration
@RibbonClients(value = {
        @RibbonClient(name = "micro-order",configuration = RibbonLoadBalanceMicroOrderConfig.class)
})
// 也可以這樣，只加載一個(gè)針對某個(gè)服務(wù)的ribbon配置
//@RibbonClient(name = "micro-order",configuration = RibbonLoadBalanceMicroOrderConfig.class
public class LoadBalanceConfig {
}

2.2.2. 配置 configuration

配置類的時(shí)候，一定要注意，配置類不能陪@ComponentScan 注解掃描到，如果被掃描到了則該配置類就是所有服務(wù)共用的配置了。

/*
* 這個(gè)類最好不要出現(xiàn)在啟動(dòng)類的@ComponentScan掃描范圍
* 如果出現(xiàn)在@ComponentScan掃描訪問，那么這個(gè)配置類就是每個(gè)服務(wù)共用的配置了
* */
@Configuration
public class RibbonLoadBalanceMicroOrderConfig {
//    @RibbonClientName
    private String name = "micro-order";
    @Bean
    @ConditionalOnClass
    public IClientConfig defaultClientConfigImpl() {
        DefaultClientConfigImpl config = new DefaultClientConfigImpl();
        config.loadProperties(name);
        config.set(CommonClientConfigKey.MaxAutoRetries,2);
        config.set(CommonClientConfigKey.MaxAutoRetriesNextServer,2);
        config.set(CommonClientConfigKey.ConnectTimeout,2000);
        config.set(CommonClientConfigKey.ReadTimeout,4000);
        config.set(CommonClientConfigKey.OkToRetryOnAllOperations,true);
        return config;
    }
    /*
    * 判斷服務(wù)是否存活
    * 不建議使用
    * */
//    @Bean
//    public IPing iPing() {
//        //這個(gè)實(shí)現(xiàn)類會去調(diào)用服務(wù)來判斷服務(wù)是否存活
//        return new PingUrl();
//    }
    // 配置負(fù)載均衡，默認(rèn)是輪訓(xùn)
    @Bean
    public IRule ribbonRule() {
        //線性輪訓(xùn)
        new RoundRobinRule();
        //可以重試的輪訓(xùn)
        new RetryRule();
        //根據(jù)運(yùn)行情況來計(jì)算權(quán)重
        new WeightedResponseTimeRule();
        //過濾掉故障實(shí)例，選擇請求數(shù)最小的實(shí)例
        new BestAvailableRule();
        return new RandomRule();
    }
}