日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

在 Nacos 中，服務(wù)調(diào)用主要是通過 RestTemplate + Ribbon 實(shí)現(xiàn)的，RestTemplate 是 Spring 提供的 Restful 請求實(shí)現(xiàn)類，而 Ribbon 是客戶端負(fù)載均衡器，通過 Ribbon 可以獲取服務(wù)實(shí)例的具體信息(IP 和端口號)，之后再通過 RestTemplate 加服務(wù)實(shí)例的具體信息就可以完成一次服務(wù)調(diào)用了。

創(chuàng)新互聯(lián)公司主要為客戶提供服務(wù)項目涵蓋了網(wǎng)頁視覺設(shè)計、VI標(biāo)志設(shè)計、成都全網(wǎng)營銷推廣、網(wǎng)站程序開發(fā)、HTML5響應(yīng)式網(wǎng)站建設(shè)、手機(jī)網(wǎng)站制作設(shè)計、微商城、網(wǎng)站托管及成都網(wǎng)站維護(hù)、WEB系統(tǒng)開發(fā)、域名注冊、國內(nèi)外服務(wù)器租用、視頻、平面設(shè)計、SEO優(yōu)化排名。設(shè)計、前端、后端三個建站步驟的完善服務(wù)體系。一人跟蹤測試的建站服務(wù)標(biāo)準(zhǔn)。已經(jīng)為成都資質(zhì)代辦行業(yè)客戶提供了網(wǎng)站改版服務(wù)。

而 RestTemplate + Ribbon 調(diào)用服務(wù)的實(shí)現(xiàn)方式兩種：通過代碼的方式調(diào)用服務(wù)和通過注解方式調(diào)用服務(wù)。但兩種實(shí)現(xiàn)方式的原理都是一樣的：都是通過注冊中心，將可用服務(wù)列表拉取到本地(客戶端)，再通過客戶端負(fù)載均衡器得到某個服務(wù)器的具體信息，然后請求此服務(wù)器即可，如下圖所示：

1.代碼方式調(diào)用

通過代碼的方式調(diào)用服務(wù)在實(shí)際工作中并不常用，主要是寫法太麻煩，但了解它對于后面理解注解調(diào)用方式有很大的幫助，所以我們這里重點(diǎn)來看一下。服務(wù)調(diào)用需要有兩個角色：一個是服務(wù)提供者(Provider)，另一個是服務(wù)調(diào)用者(Consumer)，接下來我們來創(chuàng)建一下這兩個角色。

1.1 創(chuàng)建服務(wù)提供者：Provider

第一步：先創(chuàng)建一個 Spring Boot 項目(Spring Cloud 項目是基于 Spring Boot 創(chuàng)建的)，添加 spring-web 和 nacos-discovery 依賴，具體依賴信息如下：

  org.springframework.boot
  spring-boot-starter-web



  com.alibaba.cloud
  spring-cloud-starter-alibaba-nacos-discovery

第二步：設(shè)置 Nacos 相關(guān)配置，在 application.yml 中添加以下配置：

spring:
  application:
    name: springcloud-nacos-provider # 項目名稱（nacos 注冊的服務(wù)名）
  cloud:
    nacos:
      discovery:
        username: nacos # nacos 登錄用戶名
        password: nacos666 # nacos 密碼
        server-addr: 127.0.0.1:8848 # nacos 服務(wù)端地址
server:
  port: 8081 # 項目啟動端口號

第三步：添加服務(wù)方法，如下代碼所示：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@SpringBootApplication
@RestController
public class HttpProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(HttpProviderApplication.class, args);
    }

    /**
     * 為客戶端提供可調(diào)用的接口
     */
    @RequestMapping("/call/{name}")
    public String call(@PathVariable String name) {
        return "I'm Provider. Received a message from: " + name;
    }
}

然后使用相同的方法再創(chuàng)建 2 個服務(wù)提供者，最終對應(yīng)的端口號分別為：

127.0.0.1:8081 127.0.0.1:8082 127.0.0.1:8083

這 3 個服務(wù)提供者分別打印的內(nèi)容是“I'm Provider...”、“I'm Provider2...”、“I'm Provider3...”，如下圖所示：

1.2 創(chuàng)建服務(wù)調(diào)用者：Consumer

本文的核心是服務(wù)調(diào)用者的實(shí)現(xiàn)代碼，它的創(chuàng)建方式和服務(wù)提供者的創(chuàng)建方式類似。第一步：創(chuàng)建一個 Spring Boot 項目，添加 spring-web 和 nacos-discovery 依賴，具體依賴內(nèi)容如下：

  org.springframework.boot
  spring-boot-starter-web



  com.alibaba.cloud
  spring-cloud-starter-alibaba-nacos-discovery

可能有人會有疑問，本文標(biāo)題是 Spring Cloud Alibaba Nacos + Ribbon，那為什么不添加 Ribbon 的依賴呢?這是因?yàn)?Spring Cloud Alibaba Nacos 中已經(jīng)內(nèi)置了 Ribbon 框架了，打開項目的依賴樹就可以清楚的看到了，如下圖所示：

第二步：設(shè)置 Nacos 相關(guān)配置，在 application.yml 中添加以下配置：

spring:
  application:
    name: springcloud-nacos-consumer # 項目名稱（nacos 注冊的服務(wù)名）
  cloud:
    nacos:
      discovery:
        username: nacos # nacos 登錄用戶名
        password: nacos666 # nacos 密碼
        server-addr: 127.0.0.1:8848 # nacos 服務(wù)端地址
server:
  port: 8091 # 項目啟動端口號

第三步：在項目啟動類中，使用 Spring Java Config 的方式聲明 RestTemplate 對象，如下代碼所示：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
public class RibbonCodeConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(RibbonCodeConsumerApplication.class, args);
    }

    /**
     * 使用 Spring Java Config 方式聲明 RestTemplate
     */
    @Bean
    RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

第四步：使用 RestTemplate + Ribbon 的代碼方式調(diào)用服務(wù)，首先使用 Ribbon 提供的 LoadBalancerClient 對象的 choose 方法，根據(jù) Nacos 中的服務(wù) id 獲取某個健康的服務(wù)實(shí)例，服務(wù)實(shí)例中包含服務(wù)的 IP 地址和端口號，然后再使用 RestTemplate 根據(jù)獲取到的 IP 和 端口號訪問服務(wù)即可，具體實(shí)現(xiàn)代碼如下：

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.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import javax.annotation.Resource;

@RestController
public class ConsumerController {
    // Ribbon 提供的負(fù)載均衡對象
    @Resource
    private LoadBalancerClient loadBalancerClient;

    // Spring 提供進(jìn)行 Restful 請求對象
    @Resource
    private RestTemplate restTemplate;

    @GetMapping("/consumer")
    public String consumer(@RequestParam String name) {
        // 根據(jù) Ribbon 提供的對象 + Nacos 的服務(wù) id 獲取服務(wù)實(shí)例
        ServiceInstance serviceInstance = loadBalancerClient.choose("springcloud-nacos-provider");
        // 獲取服務(wù)實(shí)例中的 ip
        String ip = serviceInstance.getHost();
        // 獲取服務(wù)實(shí)例中的端口號
        int port = serviceInstance.getPort();
        // 使用 restTemplate 請求并獲取結(jié)果
        String result = restTemplate.getForObject("http://" + ip + ":" + port + "/call/" + name,String.class);
        return result;
    }
}

以上程序的執(zhí)行結(jié)果如下圖所示：

2.注解方式調(diào)用

使用注解方式調(diào)用服務(wù)就簡單多了，服務(wù)提供者的創(chuàng)建方法和上面相同，這里就不再贅述了，接下來我們來創(chuàng)建一個注解方式的服務(wù)調(diào)用者 Consumer。第一步：創(chuàng)建一個 Spring Boot 項目，添加 spring-web 和 nacos-discovery 依賴，具體依賴內(nèi)容如下：

  org.springframework.boot
  spring-boot-starter-web



  com.alibaba.cloud
  spring-cloud-starter-alibaba-nacos-discovery

第二步：設(shè)置 Nacos 相關(guān)配置，在 application.yml 中添加以下配置：

spring:
  application:
    name: springcloud-nacos-consumer # 項目名稱（nacos 注冊的服務(wù)名）
  cloud:
    nacos:
      discovery:
        username: nacos # nacos 登錄用戶名
        password: nacos666 # nacos 密碼
        server-addr: 127.0.0.1:8848 # nacos 服務(wù)端地址
server:
  port: 8092 # 項目啟動端口號

第三步：在項目啟動類中，使用 Spring Java Config 的方式聲明 RestTemplate 對象，此步驟中，需要在 RestTemplate 對象上加上 @LoadBalanced 注解，加上此注解之后就可以讓 RestTemplate 對象自動支持負(fù)載均衡了，如下代碼所示：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
public class RibbonAnnotationConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(RibbonAnnotationConsumerApplication.class, args);
    }

    @LoadBalanced // 使 RestTemplate 自動支持 Ribbon 負(fù)載均衡
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

第四步：創(chuàng)建客戶端請求方法，具體實(shí)現(xiàn)代碼如下：

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;

@RestController
public class ConsumerController {
    @Resource
    private RestTemplate restTemplate;

    @GetMapping("/consumer")
    public String consumer(@RequestParam String name) {
        // 請求并獲取結(jié)果（springcloud-nacos-provider 為 Nacos 服務(wù)id）
        String result = restTemplate.getForObject("http://springcloud-nacos-provider/call/" + name, String.class);
        return result;
    }
}

以上程序的執(zhí)行結(jié)果如下圖所示：

注解實(shí)現(xiàn)原理分析

通過上述代碼我們可以看出，Nacos 實(shí)現(xiàn)調(diào)用服務(wù)的關(guān)鍵是通過 @LoadBalanced，它為 RestTemplate 賦予了負(fù)載均衡的能力，從而可以正確的調(diào)用到服務(wù)，那 @LoadBalanced 是如何實(shí)現(xiàn)的呢?要知道這個問題的答案，就得閱讀 LoadBalancerAutoConfiguration 的源碼。LoadBalancerAutoConfiguration 是實(shí)現(xiàn)客戶端負(fù)載均衡器的自動裝配類，隨著 Spring 的啟動而啟動，它的源碼內(nèi)容有很多，我們這里截取部分核心的方法來看一下：

@Bean
public SmartInitializingSingleton loadBalancedRestTemplateInitializerDeprecated(final ObjectProvider> restTemplateCustomizers) {
    return () -> {
        restTemplateCustomizers.ifAvailable((customizers) -> {
            Iterator var2 = this.restTemplates.iterator();

            while(var2.hasNext()) {
                RestTemplate restTemplate = (RestTemplate)var2.next();
                Iterator var4 = customizers.iterator();

                while(var4.hasNext()) {
                    RestTemplateCustomizer customizer = (RestTemplateCustomizer)var4.next();
                    customizer.customize(restTemplate);
                }
            }

        });
    };
}

這里的 this.restTemplates.iterator() 既所有被 @LoadBalanced 注解修飾的 RestTemplate 對象，所有被 @LoadBalanced 修飾的 RestTemplate 對象會被強(qiáng)轉(zhuǎn)為 RestTemplateCustomizer 對象，而這個對象的實(shí)現(xiàn)源碼如下：

@Bean
@ConditionalOnMissingBean
public RestTemplateCustomizer restTemplateCustomizer(final LoadBalancerInterceptor loadBalancerInterceptor) {
    return (restTemplate) -> {
        List list = new ArrayList(restTemplate.getInterceptors());
        list.add(loadBalancerInterceptor);
        restTemplate.setInterceptors(list);
    };
}

也就是所有被 @LoadBalanced 注解修飾的 RestTemplate 對象，會為其添加一個 loadBalancerInterceptor 的攔截器，攔截器的實(shí)現(xiàn)源碼如下：

public class LoadBalancerInterceptor implements ClientHttpRequestInterceptor {
    private LoadBalancerClient loadBalancer;
    private LoadBalancerRequestFactory requestFactory;

    public LoadBalancerInterceptor(LoadBalancerClient loadBalancer, LoadBalancerRequestFactory requestFactory) {
        this.loadBalancer = loadBalancer;
        this.requestFactory = requestFactory;
    }

    public LoadBalancerInterceptor(LoadBalancerClient loadBalancer) {
        this(loadBalancer, new LoadBalancerRequestFactory(loadBalancer));
    }

    public ClientHttpResponse intercept(final HttpRequest request, final byte[] body, final ClientHttpRequestExecution execution) throws IOException {
        URI originalUri = request.getURI();
        String serviceName = originalUri.getHost();
        Assert.state(serviceName != null, "Request URI does not contain a valid hostname: " + originalUri);
        return (ClientHttpResponse)this.loadBalancer.execute(serviceName, this.requestFactory.createRequest(request, body, execution));
    }
}

從上述源碼可以看出，@LoadBalanced 的執(zhí)行流程是，被 @LoadBalanced 注解修飾的 RestTemplate 對象，會被 LoadBalancerInterceptor 攔截器所攔截，攔截之后使用 LoadBalancerClient 對象，按照負(fù)載均衡的策略獲取一個健康的服務(wù)實(shí)例，然后再通過服務(wù)實(shí)例的 IP 和端口，調(diào)用實(shí)例方法，從而完成服務(wù)請求。

總結(jié)

Nacos 調(diào)用 Restful 服務(wù)是通過內(nèi)置的 Ribbon 框架實(shí)現(xiàn)的，它有兩種調(diào)用方法，通過代碼的方式或通過注解的方式完成調(diào)用。其中注解的方式使用起來比較簡單，只需要在 RestTemplate 對象上添加一個 @LoadBalanced 注解，就可以為請求對象賦予負(fù)載均衡的能力了。

網(wǎng)頁名稱：SpringCloudNacos+Ribbon調(diào)用服務(wù)的兩種方法！
鏈接地址：http://www.dlmjj.cn/article/djeopig.html