Nacos框架服务注册如何实现

本篇内容介绍了“Nacos框架服务注册如何实现”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!rpc远程调用可能存在的问题

本篇内容介绍了“Nacos框架服务注册如何实现”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!

rpc远程调用

可能存在的问题

  • 超时的问题。

  • 安全的问题。

  • 服务与服务之间URL地址管理。

在我们的微服务架构通讯,服务之间依赖关系非常大,如果通过传统的方式管理我们服务的 url 地址的情况下,-一旦地址发生变化的情况下,还需要人工修改rpc远程调用地址。

微服务服务治理

在RPC远程调用过程中,服务与服务之间依赖关系非常大,服务Url地址管理非常复杂,所以这时候需要对我们服务的url实现治理,通过服务治理可以实现服务注册与发现、负载均衡、容错等。

分布式注册中心

在 rpc 远程调用中,地址中域名和端口号/调用的方法名称,如果基于数据库实现服务 url 治理:

缺点:维护成本高、没有完全绝对实现动态智能。

每次调用该服务如果地址直接写死的话,一旦接口发生变化的情况下,这时候需要重新发布版本才可以该接口调用地址,所以需要一个注册中心统一管理我们的服务注册与发现。

注册中心概念: 我们的服务注册到我们注册中心,key为服务名称、value为该服务调用地址,该类型为集合类型。Eureka、consul、zookeeper、nacos等。

注册中心原理:

Nacos框架服务注册如何实现

服务注册:生产者项目启动的时候,会将当前服务自己的信息地址注册到注册中心。

服务发现: 消费者从我们的注册中心上获取生产者调用的地址(集合),在使用负载均衡的策略获取集群中某个地址实现本地rpc远程调用。

rpc 服务注册调用实现原理:

1、生产者启动的时候key= 服务的名称value ip 和端口号注册到我们的微服务注册中心上。

2、注册存放服务地址列表类型:key唯一,列表是list集合。

3、我们的消费者从我们注册中心.上根据服务名称查询服务地址列表(集合)。

4、消费者获取到集群列表之后,采用负载均衡器选择一个地址实现rpc远程调用。

Nacos

介绍

Nacos 可以实现分布式服务注册与发现/分布式配置中心框架。

安装

下载直接启动就可以了,nacos 是springboot项目。默认端口号是:8848,可以修改配置文件修改端口号、数据持久化方式等等。

注意:高一点版本的nacos默认是集群启动,如果你是学习使用单机版的,需要修改额外配置,改成单机版启动。

windows版本修改方式:以notepad++方式打开 startup.cmd

然后修改大概在26行的set MODE="cluster"为set MODE=“standalone”

基本使用

maven依赖

<dependencies>
    <!--  springboot 整合web组件-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        <version>0.2.2.RELEASE</version>
    </dependency>
</dependencies>

application.yml

spring:
  cloud:
    nacos:
      discovery:
        ###服务注册地址
        server-addr: www.kaicostudy.com:8848
  application:
    name: kaico-member
server:
  port: 8081

Java代码,项目为springboot项目,menber服务

@RestController
public class MenberService {
    @Value("${server.port}")
    private String serverPort;
    /**
     * 会员服务提供的接口
     *
     * @param userId
     * @return
     */
    @RequestMapping("/getUser")
    public String getUser(Integer userId) {
        return "kaico学习nacos:" + serverPort;
    }
}

启动项目之后,可以在nacos页面看到注册的服务信息。

Nacos框架服务注册如何实现

使用discoveryClient 从nacos上获取接口地址

order服务代码,后面用作restTemplate 实现远程接口调用。

@RestController
public class OrderService {
    @Autowired
    private DiscoveryClient discoveryClient;
    /**
     * 订单调用会员服务
     *
     * @return
     */
    @GetMapping("/orderToMember")
    public String orderToMember() {
        // 从注册中心上获取该注册服务列表
        List<ServiceInstance> serviceInstanceList = discoveryClient.getInstances("kaico-member");
        ServiceInstance serviceInstance = serviceInstanceList.get(0);
        URI rpcMemberUrl = serviceInstance.getUri();
        return "订单调用会员获取结果:" + rpcMemberUrl;
    }
}

使用restTemplate实现rpc远程调用

注意spring没有将 restTemplate 注入到IOC容器中,需要自己手动注入。在启动类中添加下面注入bean的方法。

@Bean("restTemplate")
public RestTemplate restTemplate(){
     return new RestTemplate();
 }

调用方法

@GetMapping("/orderToMember")
    public String orderToMember() {
        // 从注册中心上获取该注册服务列表
        List<ServiceInstance> serviceInstanceList = discoveryClient.getInstances("kaico-member");
        ServiceInstance serviceInstance = serviceInstanceList.get(0);
        URI rpcMemberUrl = serviceInstance.getUri();
		// 使用本地rest形式实现rpc调用
        String result = restTemplate.getForObject(rpcMemberUrl + "/getUser", String.class);
        return "订单调用会员获取结果:" + result;
    }

本地负载均衡算法

1、从注册中心获取服务集群的列表

2、从列表中选择一个(根据负载均衡算法来获取)

        1. 随机获取
        2. 轮训、权重
        3. 一致性 hash 计算

实现轮训代码案例:

@Component
public class RotationLoadBalancer  implements LoadBalancer {
    private AtomicInteger atomicInteger = new AtomicInteger(0);
    @Override
    public ServiceInstance getSingleAddres(List<ServiceInstance> serviceInstances) {
        int index = atomicInteger.incrementAndGet() % serviceInstances.size();
        ServiceInstance serviceInstance = serviceInstances.get(index);
        return serviceInstance;
    }
}
 @RequestMapping("/orderToMember")
    public String orderToMember() {
        // 从注册中心上获取该注册服务列表
        List<ServiceInstance> serviceInstanceList = discoveryClient.getInstances("kaico-member");
        ServiceInstance serviceInstance = loadBalancer.getSingleAddres(serviceInstanceList);
        URI rpcMemberUrl = serviceInstance.getUri();
        // 使用本地rest形式实现rpc调用
        String result = restTemplate.getForObject(rpcMemberUrl + "/getUser", String.class);
        return "订单调用会员获取结果:" + result;
    }

“Nacos框架服务注册如何实现”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注恰卡网网站,小编将为大家输出更多高质量的实用文章!

本站部分文章来自网络或用户投稿,如无特殊说明或标注,均为本站原创发布。涉及资源下载的,本站旨在共享仅供大家学习与参考,如您想商用请获取官网版权,如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。
开发者

OpenCV形状检测功能怎么实现

2022-8-3 21:12:56

开发者

ASP.NET Core 6最小API中如何使用日志和DI

2022-8-3 21:13:03

搜索