【玩转Springcloud Alibaba系列】使用Nacos 实现服务注册与负载均衡

发布于：2022-07-26 ⋅ 阅读:(451) ⋅ 点赞:(0)

?个人主页：啊陈晓

?学习方向：java后端开发

?我的上一篇文章：【玩转Rabbitmq系列】02:Rabbitmq保姆级安装教程与基本消息模型实战

?如果我的文章对你有帮助，点赞、收藏、留言都是对我最大的动力

【玩转Springcloud Alibaba系列】文章直通车~ 

【玩转Springcloud Alibaba系列】 Nacos 实现服务注册中心与负载均衡

 未完待续.........

现在让我们正式开启进入今天的正文 

文章目录

前言

最近正在学习SpringCloud Alibaba系列的内容， SpringCloud Alibaba是国产的微服务开发一站式解决方案，它与原有 Spring Cloud 兼容的同时对微服务生态进行扩展，通过添加少量的配置注解，便可实现更符合国情的微服务架构。

相比 Spring Cloud 官方标准，Spring Cloud Alibaba 提供了更完整的功能、更好用的API，目前 SpringCloud Alibaba 已经逐渐成为甚至已经成为了的国内的微服务技术标准，所以作为一名后端程序员，SpringCloud Alibaba是我们必须要了解和学习的一项技术。在接下俩的学习过程中，我会将我所学的知识和内容加以整理，通过文章的方式分享给大家，希望能给大家在SpringCloud Alibaba的学习上带来帮助！！

 一、什么是Nacos

Nacos属于阿里巴巴的一个开源的项目，通过一组简单的特性集，Nacos能够帮助用户实现服务动态发现、服务配置、服务元数据及流量管理。nacos主要提供三种功能：服务注册与发现、动态配置服务、动态DNS服务。

简单来说，Nacos本质上是集成了动态配置服务、负载均衡、动态DNS服务的一个服务注册中心，那市面上服务注册中心技术这么多，像Eureka、Zookepper、Cosul都可以作为服务注册中心。那我们为什么要学习Nacos呢？

 

二.简单分析为什么我们要学习Nacos

我们先来看看市面上各大服务注册中心的对比：

各种注册中心
服务注册与发现框架 CAP原则 控制台管理 社区活跃度
Eureka AP 支持 低（2.x闭源）
Zookepper CP 不支持 中
Cosul CP 支持 高
Nacos CP、AP 支持 高

这里简单为大家说说表格中的CAP模型 

CAP原则又称CAP定理，指的是在一个分布式系统中，一致性（Consistency）、可用性（Availability）、分区容错性（Partition tolerance）。CAP 原则指的是，这三个要素最多只能同时实现两点，不可能三者兼顾。

一致性（Consistency）：同一时间看到的数据是一致的

可用性（Availability）   ：所有的请求都会得到响应

  

在CAP中，一致性和可用性只能满足其中一种。如表中所示，Eureka支持AP，Zookeeper和Consul支持CP，而Nacos中写明为CP、AP并不是表示Nacos能够同时满足CP和AP原则，而是相较于其他注册中心，Nacos能够在AP、CP两种模式中进行切换，根据不同的需求选择对应的模式。

除此之外，我们再来看看选择Nacos的其他原因：

  • Eureaka2.x闭源

  • HashiCorp官宣，禁止其旗下Consul等软件在国内使用

  • 相较于其他注册中心，zookpeer没有控制台管理

  • 相较Eureka,nacos使用的raft协议,nacos集群的一致性要远大于eureka集群

  • nacos集成了动态配置和负载均衡等功能，功能更加强大

  • nacos背靠国内大厂，社区活跃度高

就目前来说，Nacos相较于其他注册中心有着不小的优势，使用nacos来实现服务注册是个非常不错的选择。

三.nacos安装

1.环境准备

环境要求
JDK8及更高版本
Maven环境

2.安装包下载 

官网直通车：https://nacos.io/zh-cn/

通过网址进入Nacos官网:

按下图中的步骤下载安装包

 等待资源包下载完成，后将资源包解压，进入文件bin目录运行下面的命令

startup.cmd -m standalone

出现如下图所示结果则证明安装成功

运行成功后我们访问： http://localhost:8848/nacos

默认账号密码都是nacos

出现下图所示结果则证明nacos环境搭建完成

 

 四、服务注册实战

1.先创建一个简单的springcloud父项目

在cloud2022项目中的pom.xml导入SpringCloud Alibaba依赖和一些常规依赖

<?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.canrioyuan</groupId>
    <artifactId>cloud2022</artifactId>
    <version>1.0-SNAPSHOT</version>
    <packaging>pom</packaging>
    <!--父工程的打包方式必须为pom：表示父工程不写代码，只在父工程的pom.xml文件中使用配置版本，
        子工程的打包方式才是war：发布在服务器上的工程，如网站或者是服务，maven会自动帮助我们指明这个工程为web工程
                        jar：默认打程jar工程，相当于打包-->
 
 
    <!-- 统一管理jar包版本 -->
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
        <junit.version>4.12</junit.version>
        <log4j.version>1.2.17</log4j.version>
        <lombok.version>1.18.24</lombok.version>
        <mysql.version>8.0.21</mysql.version>
        <druid.version>1.1.21</druid.version>
        <mybatis-plus.spring.boot.version>3.5.1</mybatis-plus.spring.boot.version>
    </properties>
 
    <!-- 子模块继承之后，提供作用：锁定版本+子module不用写groupId和version  -->
    <dependencyManagement>
        <!--只是声明依赖，并不实现引入-->
        <dependencies>
            <!--spring boot 2.2.2-->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>2.2.2.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <!--spring cloud alibaba 2.1.0.RELEASE-->
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>2.1.0.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
  <!--spring cloud Hoxton.SR1-->
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Hoxton.SR1</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>${mysql.version}</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid-spring-boot-starter</artifactId>
                <version>${druid.version}</version>
            </dependency>
            <dependency>
                <groupId>com.baomidou</groupId>
                <artifactId>mybatis-plus-boot-starter</artifactId>
                <version>${mybatis-plus.spring.boot.version}</version>
            </dependency>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>${junit.version}</version>
            </dependency>
            <dependency>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
                <version>${log4j.version}</version>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <version>${lombok.version}</version>
                <optional>true</optional>
            </dependency>
 
        </dependencies>
    </dependencyManagement>
 
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <fork>true</fork>
                    <addResources>true</addResources>
                </configuration>
            </plugin>
        </plugins>
    </build>
 
</project>

 2.编写服务提供模块

1.在cloud2022下创建一个Maven项目cloudalibaba-provider-payment9001作为服务提供者

 

 2.在pom.xml文件中添加nacos相关依赖和一些常规依赖

   <dependencies>
        <!--SpringCloud ailibaba nacos -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <!-- SpringBoot整合Web组件 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!--日常通用jar包配置-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

  3.添加并修改application.yaml

server:
  port: 9001

spring:
  application:
    name: nacos-payment-provider
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848  #配置Nacos地址

#配置使用Actuator其他端点（除了info和health）
management:
  endpoints:
    web:
      exposure:
        include: "*"

4.编写主启动类PaymentMain9001

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

@SpringBootApplication
@EnableDiscoveryClient   //开启服务发现
public class PaymentMain9001 {
    public static void main(String[] args) {
        SpringApplication.run(PaymentMain9001.class,args);
    }
}

 5.编写PaymentController

import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class PaymentController {
    @Value("${server.port}")
    private String serverPort;

    @GetMapping(value="/payment/nacos/{id}")
    public String getPayment(@PathVariable("id") Integer id){
            return "nacos service,serverport:"+serverPort+"\t id:"+id;
    }
}

3.测试

访问：http://localhost:8848/nacos

可以发现在nacos控制台中的服务列表中已经出现了我们刚刚编写的Payment服务

访问:localhost:9001/payment/nacos/5

出现如下结果则成功

至此，nacos实现服务注册成功！！

 

 四、负载均衡实战

nacos底层集成了ribbon，因此ribbon能够很轻松的实现负载均衡，我们现在在上文的基础上做出演示。

1.依样画葫芦创建跟上文中一样的服务提供模块cloudalibaba-provider-payment9002

 

 2.创建消费者服务模块

1.在cloud2022下创建一个Maven项目cloudalibaba-comsumer-nacos-order83作为服务提供者

 

 2.在pom.xml文件中添加nacos相关依赖和一些常规依赖


    <dependencies>
        <!--SpringCloud ailibaba nacos -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
        <dependency>
            <groupId>com.canrioyuan</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <!-- SpringBoot整合Web组件 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!--日常通用jar包配置-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

3. 添加并修改application.yaml

server:
  port: 83


spring:
  application:
    name: nacos-order-consumer
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848


#消费者将要去访问的微服务名称(注册成功进nacos的微服务提供者)
service-url:
  nacos-user-service: http://nacos-payment-provider

4.编写主启动类OrderNacosMain83

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


@EnableDiscoveryClient  //开启服务发现客户端
@SpringBootApplication
public class OrderNacosMain83 {
    public static void main(String[] args) {
        SpringApplication.run(OrderNacosMain83.class,args);
    }
}

5.编写配置类为容器注入用于访问Rest请求的RestTemplate 


import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

@Configuration
public class ApplicationConfig {
    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

6.编写业务类OrderNacosController

package com.canrioyuan.controller;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;

/**
 * 消费者模块
 */
@RestController
public class OrderNacosController
{
    @Resource
    private RestTemplate restTemplate;

    @Value("${service-url.nacos-user-service}")
    private String serverURL;

    @GetMapping("/consumer/payment/nacos/{id}")
    public String paymentInfo(@PathVariable("id") Long id)
    {
        return restTemplate.getForObject(serverURL+"/payment/nacos/"+id,String.class);
    }

}

7.测试

先启动:     cloudalibaba-provider-payment9001

然后启动:  cloudalibaba-provider-payment9002

最后启动:  cloudalibaba-comsumer-nacos-order83

启动完成后，我们先访问 http://localhost:8848/nacos来看看nacos控制台中服务列表，可以看到有两台服务提供端、一台服务消费端。

然后我们访问：localhost:83/consumer/payment/nacos/5刷新，可以看到服务端口在有规律的变化，负载均衡实现成功

 

 

至此，nacos实现负载均衡成功！！

总结

本文分享了SpringCloud Alibaba中的有关nacos实现服务注册和负载均衡的详细教学，在后期我将会分享更多有关SpringCloud  Alibaba的相关内容，希望能给看完文章的你带来帮助！！

至此，我们今天的教程就到此结束啦~

感谢您的阅读,希望我的文章能给你带来帮助！！！

 

本文含有隐藏内容，请 开通VIP 后查看

网站公告

今日签到

点亮在社区的每一天
去签到

热门文章

最新发布