Spring Cloud Alibaba Nacos服務治理平臺服務註冊、RestTemplate實現微服務之間訪問負載均衡訪問的問題

Posted on 2022-06-26 by WalkonNet

🍀Nacos簡介

Github：https://github.com/alibaba/nacos
官網文檔：https://nacos.io/zh-cn/docs/what-is-nacos.html
Nacos 提供瞭發現、配置和管理微服務能力，能快速實現動態服務發現、服務配置、服務元數據及流量管理。使用 Nacos 可以更敏捷和容易地構建、交付和管理微服務平臺。 Nacos 是構建以“服務”為中心的現代應用架構 (例如微服務范式、雲原生范式) 的服務基礎設施。

1.服務發現和服務健康監測
Nacos 支持基於 DNS 和基於 RPC 的服務發現。服務提供者使用原生SDK、OpenAPI、或一個獨立的Agent TODO註冊 Service 後，服務消費者可以使用DNS TODO 或HTTP&API查找和發現服務。
Nacos 提供對服務的實時的健康檢查，阻止向不健康的主機或服務實例發送請求。Nacos 支持傳輸層 (PING 或 TCP)和應用層 (如 HTTP、MySQL、用戶自定義）的健康檢查。對於復雜的雲環境和網絡拓撲環境中（如 VPC、邊緣網絡等）服務的健康檢查，Nacos 提供瞭 agent 上報模式和服務端主動檢測2種健康檢查模式。Nacos 還提供瞭統一的健康檢查儀表盤，幫助您根據健康狀態管理服務的可用性及流量。

2.動態配置服務
動態配置服務可以讓您以中心化、外部化和動態化的方式管理所有環境的應用配置和服務配置。
動態配置消除瞭配置變更時重新部署應用和服務的需要，讓配置管理變得更加高效和敏捷。
配置中心化管理讓實現無狀態服務變得更簡單，讓服務按需彈性擴展變得更容易。
Nacos 提供瞭一個簡潔易用的UI (控制臺樣例 Demo) 幫助您管理所有的服務和應用的配置。Nacos 還提供包括配置版本跟蹤、金絲雀發佈、一鍵回滾配置以及客戶端配置更新狀態跟蹤在內的一系列開箱即用的配置管理特性，幫助您更安全地在生產環境中管理配置變更和降低配置變更帶來的風險。

3.動態 DNS 服務
動態 DNS 服務支持權重路由，讓您更容易地實現中間層負載均衡、更靈活的路由策略、流量控制以及數據中心內網的簡單DNS解析服務。動態DNS服務還能讓您更容易地實現以 DNS 協議為基礎的服務發現，以幫助您消除耦合到廠商私有服務發現 API 上的風險。
Nacos 提供瞭一些簡單的 DNS APIs TODO 幫助您管理服務的關聯域名和可用的 IP:PORT 列表.

4.服務及其元數據管理
Nacos 能讓您從微服務平臺建設的視角管理數據中心的所有服務及元數據，包括管理服務的描述、生命周期、服務的靜態依賴分析、服務的健康狀態、服務的流量管理、路由及安全策略、服務的 SLA 以及最首要的 metrics 統計數據。

☘Spring Cloud 組件依賴版本

官網文檔：https://github.com/alibaba/spring-cloud-alibaba/wiki/%E7%89%88%E6%9C%AC%E8%AF%B4%E6%98%8E

本文參考使用組件依賴如下

☘Nacos部署

下載：https://github.com/alibaba/nacos/releases

運行bin下的startup.cmd/startup.sh。

Nacos2.* 默認改為集群運行瞭，可以隻用-m指令指定啟動方式。

Windows

rem 單機啟動
startup.cmd -m standalone
rem 集群啟動
startup.cmd -m cluster

☘訪問Nacos平臺

默認賬密：nacos/nacos

🍀Nacos服務註冊、微服務訪問、負載均衡實現

創建微服務項目，項目結構如下

root pom.xml如下：

<?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>

    <groupId>com.ber</groupId>
    <artifactId>SpringCloud</artifactId>
    <version>1.0-SNAPSHOT</version>
    <packaging>pom</packaging>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.4.2</version>
        <relativePath/>
    </parent>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <java.version>1.8</java.version>
        <spring-boot.version>2.4.2</spring-boot.version>
        <spring-cloud-alibaba.version>2021.1</spring-cloud-alibaba.version>
        <spring-cloud.version>2020.0.1</spring-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bootstrap</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>${spring-cloud-alibaba.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <modules>
        <module>ber-nacos</module>
    </modules>

</project>

nacos-consumer微服務創建

nacos-comsumer pom.xml

<?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">
    <parent>
        <artifactId>ber-nacos</artifactId>
        <groupId>com.ber</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>nacos-consumer</artifactId>
    <description>服務消費</description>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <!-- 負載均衡 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-loadbalancer</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
    </dependencies>


</project>

application.yml

spring.application.name=nacos-consumer

spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848

server.port=8891

啟動類
記得在類上加上註解@EnableDiscoveryClient，RestTemplate屬性註入增加 @LoadBalanced 註解（負載均衡）

package com.ber.nacos.consumer;

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

/**
 * @author: ber
 * @date: 2022/6/25 0025 9:30
 * -------------------------------
 * Github：https://github.com/berbai
 * Blog：https://blog.csdn.net/Ber_Bai
 */
@SpringBootApplication
@EnableDiscoveryClient
public class NacosConsumerApplication {

    @Bean
    @LoadBalanced
    RestTemplate initRestTemplate() {
        return new RestTemplate();
    }


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

創建controller訪問方法

package com.ber.nacos.consumer.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;

/**
 * @author: ber
 * @date: 2022/6/25 0025 10:58
 * -------------------------------
 * Github：https://github.com/berbai
 * Blog：https://blog.csdn.net/Ber_Bai
 */
@RestController
public class MsgController {

    private final RestTemplate restTemplate;

    @Autowired
    public MsgController(RestTemplate restTemplate) {
        this.restTemplate = restTemplate;
    }

    /**
     * 獲取消息
     *
     * @param msgStr 消息
     * @return
     */
    @GetMapping("/queryMsg/{msgStr}")
    public String getMsg(@PathVariable(value = "msgStr") String msgStr) {
        return restTemplate.getForObject("http://nacos-provider/getMsg/" + msgStr, String.class);
    }
}

☘nacos-provider微服務創建

nacos-provider pom.xml

<?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">
    <parent>
        <artifactId>ber-nacos</artifactId>
        <groupId>com.ber</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <packaging>jar</packaging>
    <artifactId>nacos-provider</artifactId>
    <description>服務提供</description>

    <dependencies>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
    </dependencies>
</project>

application.properties

server.port=8892

spring.application.name=nacos-provider

spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848

啟動類

package com.ber.nacos.provider;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

/**
 * @author: ber
 * @date: 2022/6/25 0025 14:03
 * -------------------------------
 * Github：https://github.com/berbai
 * Blog：https://blog.csdn.net/Ber_Bai
 */
@EnableDiscoveryClient
@SpringBootApplication
public class NacosProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(NacosProviderApplication.class, args);
    }
}

註解@EnableDiscoveryClient不要忘記加上。

創建controller方法，被consumer訪問的接口

package com.ber.nacos.provider.controller;

import com.ber.nacos.provider.service.MsgService;
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;

/**
 * @author: ber
 * @date: 2022/6/25 0025 14:06
 * -------------------------------
 * Github：https://github.com/berbai
 * Blog：https://blog.csdn.net/Ber_Bai
 */
@RestController
public class MsgController {
    @Autowired
    MsgService msgService;

    @GetMapping("getMsg/{msgStr}")
    public String getMsg(@PathVariable(value = "msgStr") String msgStr) {
        String res = "C服務";
        System.out.println(res + " 調用"+msgService.queryCount()+"次");
        msgService.addCount();
        return res + " 調用" + msgService.queryCount() + "次 Get " + msgStr;
    }
}

另外創建一個實體類記錄consumer微服務訪問provider微服務的次數

package com.ber.nacos.provider.entity;

import org.springframework.stereotype.Component;

import java.util.concurrent.atomic.AtomicInteger;

/**
 * @author: ber
 * @date: 2022/6/25 0025 14:09
 * -------------------------------
 * Github：https://github.com/berbai
 * Blog：https://blog.csdn.net/Ber_Bai
 */
@Component
public class CountLog {
    private AtomicInteger atomicInteger;

    public CountLog(){
        this.atomicInteger = new AtomicInteger();
    }
    public AtomicInteger getAtomicInteger() {
        return atomicInteger;
    }

    public void setAtomicInteger(AtomicInteger atomicInteger) {
        this.atomicInteger = atomicInteger;
    }
}

創建操作訪問次數的service方法

package com.ber.nacos.provider.service;

import com.ber.nacos.provider.entity.CountLog;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * @author: ber
 * @date: 2022/6/25 0025 14:13
 * -------------------------------
 * Github：https://github.com/berbai
 * Blog：https://blog.csdn.net/Ber_Bai
 */
@Service
public class MsgService {

    @Autowired
    CountLog countLog;

    public Integer queryCount() {
        return countLog.getAtomicInteger().get();
    }

    public void addCount() {
        countLog.getAtomicInteger().addAndGet(1);
    }
}

🍀測試

啟動一個consumer和一個provider微服務，訪問http://localhost:8848/nacos，使用 nacos/nacos 登陸後，可以發現服務列表中，兩個微服務已經註冊，如下圖所示。

訪問http://localhost:8891/queryMsg/hello，即consumer的接口，可以得到如下圖所示的界面

再額外啟動兩個provider微服務，測試nacos的負載均衡能力，這裡我修改瞭provider端口和接口返回的數據以標明不同的provider微服務。通過nacos控制平臺可以看到三個provider微服務已經註冊上去，如下圖所示。

再次請求http://localhost:8891/queryMsg/hello，可以發現每次請求接口，三個provider接口的內容會順序出現，如下圖所示。說明nacos默認的負載均衡方式是輪詢

通過nacos修改其中一個provider的權重，修改參考下圖

經過測試發現，負載策略還是輪詢方式，本次修改無效。

通過翻閱spring cloud alibaba源碼，發現nacos實現瞭ribbon

修改consumer的啟動類，如下所示

package com.ber.nacos.provider.service;

import com.ber.nacos.provider.entity.CountLog;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * @author: ber
 * @date: 2022/6/25 0025 14:13
 * -------------------------------
 * Github：https://github.com/berbai
 * Blog：https://blog.csdn.net/Ber_Bai
 */
@Service
public class MsgService {

    @Autowired
    CountLog countLog;

    public Integer queryCount() {
        return countLog.getAtomicInteger().get();
    }

    public void addCount() {
        countLog.getAtomicInteger().addAndGet(1);
    }
}

重啟consumer後，設置的權重已經生效。

到此這篇關於Spring Cloud Alibaba：Nacos服務治理平臺，服務註冊、RestTemplate實現微服務之間訪問，負載均衡訪問的文章就介紹到這瞭,更多相關Spring Cloud Alibaba Nacos服務內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

Spring Cloud Alibaba Nacos服務治理平臺服務註冊、RestTemplate實現微服務之間訪問負載均衡訪問的問題

目錄

🍀Nacos簡介

☘Spring Cloud 組件依賴版本

☘Nacos部署

☘訪問Nacos平臺

🍀Nacos服務註冊、微服務訪問、負載均衡實現

nacos-consumer微服務創建

☘nacos-provider微服務創建

🍀測試

推薦閱讀：

發佈留言取消回覆

近期文章

目錄

🍀Nacos簡介

☘Spring Cloud 組件依賴版本

☘Nacos部署

☘訪問Nacos平臺

🍀Nacos服務註冊、微服務訪問、負載均衡實現

nacos-consumer微服務創建

☘nacos-provider微服務創建

🍀測試

推薦閱讀：

發佈留言 取消回覆

近期文章

標籤

發佈留言取消回覆