白话文实战Nacos（保姆级教程）

前言

上一篇博客 我们创建好了微服务项目，本篇博客来体验一下Nacos作为注册中心和配置中心的功能。

注册中心

如果我们启动了一个Nacos注册中心，那么微服务比如订单服务，启动后就可以连上注册中心把自己注册上去，这过程就是服务注册。每个微服务，比如商品服务都应该注册上去，这些微服务是集群化启动的，在多台机器都有，也都应该注册到注册中心。这样注册中心就会保存一个微服务和它所在的机器清单列表，某一天订单服务想要调用商品服务，就先要问一下注册中心这些商品服务在哪些机器上，注册中心会给它返回服务器列表，这样订单服务就可以随便挑一台机器，发起远程调用，这个过程就是服务发现。

注册中心的两个核心功能就是服务注册和服务发现。

在这里插入图片描述

Nacos安装

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service的首字母简称，一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。

  1. 官网
    https://nacos.io/docs/next/quickstart/quick-start/

  2. 下载安装

  • 下载版本：
    在这里插入图片描述
    直接下载解压即可：

  • 启动命令

切换到bin目录，cmd中输入启动命令即可
在这里插入图片描述

startup.cmd -m standalone

在这里插入图片描述

启动成功后我们可以访问nacos：

http://localhost:8848/nacos
在这里插入图片描述
重要的两个功能，一个是配置管理，就是作为配置中心，另外一个是服务管理，就是作为注册中心。

注册中心-服务注册

服务注册流程如下：
在这里插入图片描述

我们来到创建好的项目中进行服务注册测试，先以订单服务为例，先启动这个微服务，由于每个微服务都是springboot的web应用，而我们最大的项目cloud-demo已经继承了springboot，所以每个微服务也是springboot应用，我们只需要在微服务pom文件中导入web依赖，来开发web项目即可。

在这里插入图片描述

在这里插入图片描述

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
</dependency>

由于要把自己注册到注册中心，所以还要导入alibaba-nacos-discovery依赖，但是我们在services中已经做了公共导入，它下面的每个模块默认都有这个依赖了：

<!-- 服务发现 -->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

来到service-order模块来启动微服务，需要先编写一个主程序（OrderMainApplication）：

在这里插入图片描述

springboot主程序需要的第一个注解叫@SpringBootApplication，代表它是一个springboot应用：

package com.example.order;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class OrderMainApplication {public static void main(String[] args) {SpringApplication.run(OrderMainApplication.class, args);}
}

启动之前先编写一下配置文件：
在这里插入图片描述

这个写好后，就可以启动微服务进行测试，看看能不能把自己注册到注册中心：

在这里插入图片描述
来到nacos注册中心：
在这里插入图片描述

可以看到service-order实例数为1，健康实例数为1，说明注册到nacos了。

同样把service-product也注册上来。端口用9000：
在这里插入图片描述
只要每个服务配置了nacos地址，只要启动了，就会自动连上nacos注册自己。而且我们从启动日志也能看到
在这里插入图片描述

来到nacos服务列表中查询：
在这里插入图片描述

那再注册中心注册的微服务都是什么东西呢？可以点进详情查看，其实就是微服务的名字以及其所在服务的ip和端口：
在这里插入图片描述
我们现在看到的实例数都是1，是因为我们是单机模式，代表之启动了一个微服务，如果启动多个效果是什么呢？我们可以在本机通过启动不同端口的方式模拟一个集群。
在这里插入图片描述
在这里插入图片描述

在这里插入图片描述
在这里插入图片描述
同理为了查看效果，我们把商品模块复制两份进行启动，端口分别为9001和9002，然后把所有微服务全部启动
在这里插入图片描述

这样我们就在本机通过不同端口模拟启动一个集群，当我们所有服务都启动完成后：
在这里插入图片描述
我们去nacos服务列表查询：
在这里插入图片描述
这样服务注册的功能，我们就测试通过了，其实非常简单，只要引入了nacos-discovery依赖，配置了nacos地址，项目启动自己就会注册到注册中心，而注册中心保存的就是所有服务的可以访问的ip和对应的端口列表。

注意：测试期间cmd窗口不能关闭，否则相当于nacos服务就没有运行。

注册中心-服务发现

想要通过代码获取到注册中心中注册的所有微服务以及所在机器的ip地址和端口列表，可以通过下面流程进行：
在这里插入图片描述

以商品服务为例，先标注开启服务发现功能注解

package com.example.product;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;@EnableDiscoveryClient // 开启服务发现功能
@SpringBootApplication
public class ProductMainApplication {public static void main(String[] args) {SpringApplication.run(ProductMainApplication.class, args);}
}

编写一个测试类来测试一下服务发现的api如何使用，测试类的包名要和主程序的包名一样：

在这里插入图片描述

要写单元测试，首先得在项目中导入测试依赖：

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope>
</dependency>

测试类代码：

package com.example.product;import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;import java.util.List;@SpringBootTest
public class DiscoveryTest {@AutowiredDiscoveryClient discoveryClient;@Testvoid discoveryClientTest() {for (String service : discoveryClient.getServices()) {System.out.println(service);// 获取ip+portList<ServiceInstance> instances = discoveryClient.getInstances(service);for (ServiceInstance instance : instances) {System.out.println(instance.getHost() + ":" + instance.getPort());}}}
}

运行测试代码：
在这里插入图片描述

除了使用DiscoveryClient，nacos组件也提供了叫做NacosServiceDiscovery，用哪个都可以，唯一的区别就是DiscoveryClient是Spring家族的规范，无论你用哪个注册中心，都可以用它的api，而NacosServiceDiscovery是引入nacos时用的api

package com.example.product;import com.alibaba.cloud.nacos.discovery.NacosServiceDiscovery;
import com.alibaba.nacos.api.exception.NacosException;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.cloud.client.ServiceInstance;import java.util.List;@SpringBootTest
public class DiscoveryTest {@AutowiredNacosServiceDiscovery nacosServiceDiscovery;@Testvoid nacosServiceDiscoveryTest() throws NacosException {for (String service : nacosServiceDiscovery.getServices()) {System.out.println(service);// 获取ip+portList<ServiceInstance> instances = nacosServiceDiscovery.getInstances(service);for (ServiceInstance instance : instances) {System.out.println(instance.getHost() + ":" + instance.getPort());}}}
}

在这里插入图片描述

这两个api仅作为了解，我们要进行远程调用，第一步就是要服务发现，但是服务发现后来要封装成自动化的过程，无需我们调用底层代码。我们要做的仅仅就是在每个微服务中引入@EnableDiscoveryClient注解，因为微服务之间可能要互相调用，因此在每个微服务中服务发现功能是必备的。

注册中心-编写微服务api

上面我们测试了服务发现功能，基于它可以实现微服务之间的调用，基本流程就是：
在这里插入图片描述
我们模拟一个场景来实现上面的流程：
在这里插入图片描述
我们来编码实现上面的业务流程，我们先来编写商品服务，由于远程调用都是发起http请求，所以我们在商品服务里面编写一个controller。这controller可以按照商品id查询商品：
在这里插入图片描述

这里由于要写javabean类，需要用到Lombok，每个模块都要用，所以这里在services模块的pom中添加lombok依赖：
在这里插入图片描述

我们这里就快速简单生成controller、service、bean
在这里插入图片描述

代码如下：
Product类：

package com.example.product.bean;import lombok.Data;import java.math.BigDecimal;@Data
public class Product {private Long id;private BigDecimal price;private String productName;private int num;
}

ProductController类：

package com.example.product.controller;import com.example.product.bean.Product;
import com.example.product.service.ProductService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
public class ProductController {@AutowiredProductService productService;// 查询商品@RequestMapping("/product/{id}")public Product getProduct(@PathVariable("id") Long productId) {

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/web/69472.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

docker 安装 Prometheus、Node Exporter 和 Grafana

docker 安装 Prometheus、Node Exporter 和 Grafana

Docker Compose 配置文件 docker-compose.yml services:prometheus:image: prom/prometheus:latestcontainer_name: prometheusvolumes:- ./prometheus.yml:/etc/prometheus/prometheus.yml # 挂载配置文件 - prometheus_data:/prometheus # 持久化数据存储 command:- --…
阅读更多...
RocketMQ、RabbitMQ、Kafka 的底层实现、功能异同、应用场景及技术选型分析

RocketMQ、RabbitMQ、Kafka 的底层实现、功能异同、应用场景及技术选型分析

1️⃣ 引言 在现代分布式系统架构中&#xff0c;&#x1f4e9;消息队列&#xff08;MQ&#xff09;是不可或缺的组件。它在系统&#x1f517;解耦、&#x1f4c9;流量削峰、⏳异步处理等方面发挥着重要作用。目前&#xff0c;主流的消息队列系统包括 &#x1f680;RocketMQ、&…
阅读更多...
C语言基础08：运算符+流程控制总结

C语言基础08：运算符+流程控制总结

运算符 算术运算符 结果&#xff1a;数值 、-、*、\、%、&#xff08;正&#xff09;、-&#xff08;负&#xff09;、、-- i和i 相同点&#xff1a;i自身都会增1 不同点&#xff1a;它们运算的最终结果是不同的。i&#xff1a;先使用&#xff0c;后计算&#xff1b;i&am…
阅读更多...
Node.js开发属于自己的npm包（发布到npm官网）

Node.js开发属于自己的npm包（发布到npm官网）

在 Node.js 中开发并发布自己的 npm 包是一个非常好的练习&#xff0c;可以帮助我们更好地理解模块化编程和包管理工具&#xff0c;本篇文章主要阐述如何使用nodejs开发一个属于自己的npm包&#xff0c;并且将其发布在npm官网。在开始之前确保已经安装了 Node.js 和 npm。可以在…
阅读更多...
如何在RTACAR中配置IP多播（IP Multicast）

如何在RTACAR中配置IP多播（IP Multicast）

一、什么是IP多播 IP多播&#xff08;IP Multicast&#xff09;是一种允许数据包从单一源地址发送到多个目标地址的技术&#xff0c;是一种高效的数据传输方式。 多播地址是专门用于多播通信的IP地址&#xff0c;范围从 224.0.0.0到239.255.255.255 与单播IP地址不同&#x…
阅读更多...
android的DataBinding的使用

android的DataBinding的使用

参考&#xff1a; Android基础入门&#xff1a;dataBinding的简单使用 Android DataBinding的使用
阅读更多...
12.翻转、对称二叉树，二叉树的深度

12.翻转、对称二叉树，二叉树的深度

反转二叉树 递归写法 很简单 class Solution { public:TreeNode* invertTree(TreeNode* root) {if(rootnullptr)return root;TreeNode* tmp;tmproot->left;root->leftroot->right;root->righttmp;invertTree(root->left);invertTree(root->right);return …
阅读更多...
网络安全行业的冬天

网络安全行业的冬天

冬天已经来了&#xff0c;春天还会远吗&#xff1f;2022年10月28日&#xff0c;各个安全大厂相继发布了财报&#xff0c;纵观2022年前三季度9个月&#xff0c;三六零亏了19亿&#xff0c;奇安信亏了11亿&#xff0c;深信服亏了6亿&#xff0c;天融信亏了4亿&#xff0c;安恒亏了…
阅读更多...
MYSQL索引与视图

MYSQL索引与视图

一、新建数据库 mysql> create database mydb15_indexstu; mysql> use mydb15_indexstu; 二、新建表 &#xff08;1&#xff09;学生表Student mysql> create table Student(-> Sno int primary key auto_increment,-> Sname varchar(30) not null unique,-…
阅读更多...
深度优先搜索（DFS）——八皇后问题与全排列问题

深度优先搜索（DFS）——八皇后问题与全排列问题

&#xff08; ^ _ ^ &#xff09; 数据结构好难哇&#xff08;哭 1.BFS和DFS 数据结构空间性质DFSstackO(h)不具有最短性质BFSqueueO(2^h)具有最短路性质 空间上DFS占优势&#xff0c;但是BFS具有最短性 &#xff08;若所有权重都是1&#xff0c;则BFS一定最短&#xff09;&…
阅读更多...
Flink 内存模型各部分大小计算公式

Flink 内存模型各部分大小计算公式

Flink 的运行平台 如果 Flink 是运行在 yarn 或者 standalone 模式的话&#xff0c;其实都是运行在 JVM 的基础上的&#xff0c;所以首先 Flink 组件运行所需要给 JVM 本身要耗费的内存大小。无论是 JobManager 或者 TaskManager &#xff0c;他们 JVM 内存的大小都是一样的&a…
阅读更多...
Vue07

Vue07

一、Vuex 概述 目标&#xff1a;明确Vuex是什么&#xff0c;应用场景以及优势 1.是什么 Vuex 是一个 Vue 的 状态管理工具&#xff0c;状态就是数据。 大白话&#xff1a;Vuex 是一个插件&#xff0c;可以管理 Vue 通用的数据 (多组件共享的数据)。例如&#xff1a;购物车数…
阅读更多...
Linux内核中的软中断与NAPI机制：高效处理网络数据包

Linux内核中的软中断与NAPI机制：高效处理网络数据包

在现代操作系统中，中断处理是系统性能的关键因素之一，尤其是在处理高负载的网络数据包时。Linux内核通过软中断（SoftIRQ）和NAPI（New API）机制，实现了高效的网络数据包处理。本文将深入探讨软中断和NAPI机制的原理、实现方式以及它们在处理网络数据包中的作用。 一、软中…
阅读更多...
Linux 安装 Ollama

Linux 安装 Ollama

1、下载地址 Download Ollama on Linux 2、有网络直接执行 curl -fsSL https://ollama.com/install.sh | sh 命令 3、下载慢的解决方法 1、curl -fsSL https://ollama.com/install.sh -o ollama_install.sh 2、sed -i s|https://ollama.com/download/ollama-linux|https://…
阅读更多...
Docker Desktop无法安装报错（求助记录中）

Docker Desktop无法安装报错（求助记录中）

之前Docker Desktop无法使用&#xff0c;报了一个注册表的错误&#xff08;忘记截图&#xff09;我想着更新安装下应该就好了&#xff0c;结果Docker Desktop一直无法安装&#xff0c;花了几天都没解决。同时我的window11更新也出现下载错误 - 0x80040154异常,启动或关闭Window…
阅读更多...
Docker入门（Windows）

Docker入门（Windows）

视频链接&#xff1a;Docker | 狂神说 环境说明 Windows For Docker WSL2 概念 Docker是什么&#xff1f; 百度百科&#xff1a;百度百科 Docker 是一个开源的平台&#xff0c;它利用操作系统级虚拟化技术来打包和运行应用程序。通过使用容器化技术&#xff0c;Docker 提…
阅读更多...
kafka生产者之发送模式与ACK

kafka生产者之发送模式与ACK

文章目录 Kafka的发送模式Kafka的ack机制发送模式与ack的关联重试次数总结 在Kafka中&#xff0c;发送模式与ack机制紧密相关&#xff0c;它们共同影响着消息发送的可靠性和性能。 Kafka的发送模式 发后即忘&#xff08;Fire and Forget&#xff09;&#xff1a;生产者发送消息…
阅读更多...
STM32 RTC亚秒

STM32 RTC亚秒

rtc时钟功能实现&#xff1a;rtc模块在stm32内部&#xff0c;由电池或者主电源供电。如下图&#xff0c;需注意实现时仅需设置一次初始化。 1、stm32cubemx 代码生成界面设置&#xff0c;仅需开启时钟源和激活日历功能。 2、生成的代码,需要对时钟进行初始化&#xff0c;仅需…
阅读更多...
kafka服务端之延时操作实现原理

kafka服务端之延时操作实现原理

文章目录 背景案例延时生产实现原理延时拉取实现原理 总结 背景 上篇我们说到了kafka时间轮是延时操作内部实现的重要数据结构&#xff0c;这篇我们来说下kafka内部的延时操作实现原理。这里我们以延时生产和延时拉取为例说明延时操作的实现原理。 案例 延时生产 我们知道如…
阅读更多...
【算法】动态规划专题⑥ —— 完全背包问题 python

【算法】动态规划专题⑥ —— 完全背包问题 python

目录 前置知识进入正题模板 前置知识 【算法】动态规划专题⑤ —— 0-1背包问题 滚动数组优化 完全背包问题是动态规划中的一种经典问题&#xff0c;它与0-1背包问题相似&#xff0c;但有一个关键的区别&#xff1a;在完全背包问题中&#xff0c;每种物品都有无限的数量可用。…
阅读更多...
最新文章

Copyright @ 2022~2023