Ribbon 本地負(fù)載均衡器

在SpringCloud第一代中使用Ribbon、SpringCloud第二代中直接采用自研發(fā) loadbalancer 即可，默認(rèn)使用的Ribbon。

本地負(fù)載均衡與Nginx 的區(qū)別

本地負(fù)載均衡器基本的概念：我們的消費(fèi)者服務(wù)從我們的注冊(cè)中心獲取到集群地址列表，緩存到本地，讓后本地采用負(fù)載均衡策略（輪訓(xùn)、隨機(jī)、權(quán)重、hash一致性等），獲取接口列表地址，采用算法獲取選擇一個(gè)接口地址實(shí)現(xiàn)本地的rpc遠(yuǎn)程的。本地負(fù)載均衡器是從注冊(cè)中心獲取到集群地址列表，本地實(shí)現(xiàn)負(fù)載均衡算法，既本地負(fù)載均衡器。

Nginx是客戶端所有的請(qǐng)求統(tǒng)一都交給我們的Nginx處理，讓后在由Nginx實(shí)現(xiàn)負(fù)載均衡轉(zhuǎn)發(fā)，屬于服務(wù)器端負(fù)載均衡器。

應(yīng)用場(chǎng)景：

Nginx屬于服務(wù)器負(fù)載均衡，應(yīng)用于Tomcat/Jetty服務(wù)器等，而我們的本地負(fù)載均衡器，屬于客戶端負(fù)載均衡，應(yīng)用于在微服務(wù)架構(gòu)中rpc框架中，rest、openfeign、dubbo。

基本使用

注入 restTemplate，加上 @LoadBalanced 注解。

@Bean("restTemplate")
@LoadBalanced // 實(shí)現(xiàn)本地的負(fù)載均衡
public RestTemplate restTemplate(){
    return new RestTemplate();
}

請(qǐng)求路徑上可以換成服務(wù)的名稱

@RequestMapping("/orderToMember")
public String orderToMember() {
     // 使用本地rest形式實(shí)現(xiàn)rpc調(diào)用
     String result = restTemplate.getForObject("http://kaico-member/getUser", String.class);
     return "訂單調(diào)用會(huì)員獲取結(jié)果:" + result;
 }

使用 loadBalancerClient 實(shí)現(xiàn)負(fù)載均衡

@RequestMapping("/orderToMember")
public String orderToMember() {
    // 使用本地rest形式實(shí)現(xiàn)rpc調(diào)用
    ServiceInstance choose = loadBalancerClient.choose("kaico-member");
    return "獲取結(jié)果:" + choose;
}

原理分析

ServiceInstance choose = loadBalancerClient.choose(“kaico-member”); 從這行代碼分析，

客戶端負(fù)載均衡器源碼：

根據(jù)serviceId獲取服務(wù)

可以支持的算法：默認(rèn)是輪訓(xùn)

openfeign

openFeign是一個(gè)Web聲明式的Http客戶端調(diào)用工具，提供接口和注解形式調(diào)用。

openfeign客戶端作用:是一個(gè)Web聲明式的Http客戶端遠(yuǎn)程遠(yuǎn)程調(diào)用工具，底層是封裝 HttpClient 技術(shù)。

openfeign屬于 SpringCloud 自己研發(fā)，而 feign 是 netflix 研發(fā)的。

基本使用

提供服務(wù)方

接口

public interface MenberService {
    /**
     * 提供會(huì)員接口
     *
     * @param userId
     * @return
     */
    @GetMapping("/getUser")
    String getUser(@RequestParam("userId") Long userId);
}

接口的實(shí)現(xiàn)類

@RestController
public class MenberServiceImpl  implements MenberService {
    @Value("${server.port}")
    private String serverPort;
    @Override
    public String getUser(Long userId) {
        return "我是會(huì)員服務(wù)端口號(hào)為:" + serverPort;
    }
}

此時(shí)，服務(wù)方提供的接口已經(jīng)準(zhǔn)備好了

接下來編寫接口調(diào)用方的代碼：

1、引入maven 依賴

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

2、啟動(dòng)類上開啟openfeign 注解：@EnableFeignClients

3、編寫 feignClient 接口

@FeignClient(name = "kaico-member")
public interface MenberServiceFeign{
    /**
     * 提供會(huì)員接口
     *
     * @param userId
     * @return
     */
    @GetMapping("/getUser")
    String getUser(@RequestParam("userId") Long userId);
}

4、直接調(diào)用 MenberServiceFeign 接口的方法

@Autowired
private MenberServiceFeign menberServiceFeign;
@RequestMapping("/orderToMember")
public String orderToMember() {
    //測(cè)試openfeign 調(diào)用接口
    String user = menberServiceFeign.getUser(1L);
    return "獲取結(jié)果:" + user;
}

總結(jié)：調(diào)用方在編寫feignClient 接口代碼時(shí)，只要方法代碼和注解和提供方法接口代碼一致即可，不要求類的全路徑名稱一致。然后在接口類上加上注解@FeignClient(name = “kaico-member”)并指定服務(wù)名稱。openfeign默認(rèn)是支持負(fù)載均衡：輪訓(xùn)算法（ribbon）

微服務(wù)的服務(wù)名稱不能有下劃線。

到此這篇關(guān)于Java Ribbon與openfeign區(qū)別和用法講解的文章就介紹到這了,更多相關(guān)Java Ribbon與openfeign內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論