Nacos微服务注册管理中心与服务通信

ops/2024/9/23 7:32:43/

参照springboot-alibaba-ribbon项目学习

E:\Codes\Idea_java_works\apesource\springboot\微服务\springboot_alibaba_ribbon

Nacos 微服务注册中心-discover

Nacos 是⼀个更易于构建云原⽣应⽤的动态服务发现、配置管理和服务管理平台。简单来说 Nacos 就是 注册中⼼ + 配置中⼼的组合，提供简单易⽤的特性集，帮助我们解决微服务开发必会涉及到的服务注册 与发现，服务配置，服务管理等问题。 Nacos 还是 Spring Cloud 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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><!--    父工程--><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.3.RELEASE</version><relativePath/> <!-- lookup parent from repository --></parent><!--    项目基本信息--><groupId>com.ape</groupId><artifactId>springboot_alibaba_demo01</artifactId><version>0.0.1-SNAPSHOT</version><name>springboot_alibaba_demo01</name><description>springboot_alibaba_demo01</description><!--    声明为父pom文件--><packaging>pom</packaging><!--    父项目的子模块--><modules><module>shop_common</module><module>shop_user</module><module>shop_product</module><module>shop_order</module></modules><!--    依赖版本锁定--><properties><java.version>8</java.version><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><spring-cloud.version>Greenwich.RELEASE</spring-cloud.version><spring-cloud-alibaba.version>2.1.1.RELEASE</spring-cloud-alibaba.version></properties><!--dependencyManagement所包含的坐标，子项目不会直接继承，需要声明才可继承--><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><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies></dependencyManagement><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

用来注册和管理微服务。

运行命令startup.cmd -m standalone

使用方法：

  1. 创建好一个微服务项目（父项目与多个子项目）
  2. 在每个子项目pom.xml中导入依赖（注意版本应该与springboot版本一致）
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId><version>2.1.3.RELEASE</version>
</dependency>
  1. 在配置文件中写端口
spring:application:name: server-order #服务名称datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/yuanjiuyuanexcise?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&serverTimezone=Asia/Shanghainame: rootpassword: 123456cloud: # 配置端口nacos: discovery:server-addr: 127.0.0.1:8848
server:port: 8090

注意：一定是127.0.0.1这个主机号 如果是localhost 后期使用getHost()方法会获得到当前IP地址而不是主机号

如果后期使用Feign或者Ribbon做通信就无所谓

//返回所有叫server-product的服务，是一个List，我们只有一个server-product服务所以直接get(0)
ServiceInstance serviceInstance = discoveryClient.getInstances("server-product").get(0);
String url = serviceInstance.getHost() + ":" + serviceInstance.getPort();
  1. 启动类中使用 @EnableDiscoveryClient 注解开启微服务注册
  2. 浏览器输入localhost:8848/nacos 账密都是nacos 进入图形化界面查看
  3. 使用的时候 在启动类装配RestTemplate 这种方法不同服务之间发送的请求路径是写死的
@Bean
public RestTemplate restTemplate(){return new RestTemplate();
}
  1. 搭配Ribbon来让Nacos自动识别路径 添加 @LoadBalanced 负载均衡
@Bean
@LoadBalanced
public RestTemplate restTemplate(){return new RestTemplate();
}
  1. 在service的实现类内注入Mapper RestTemplate 请求路径直接写服务名即可
@Service
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements OrderService {@Autowiredprivate OrderMapper mapper;@Autowiredprivate RestTemplate restTemplate;//    先找到Product的信息 然后将信息赋值给Order 查询Product的业务在另一个服务 所以需要用到ribbon与nacos@Overridepublic Order placeOrder(int id) {Product product = restTemplate.getForObject("http://server-product/product/" + id, Product.class);Order order = new Order();order.setPid(product.getPid());order.setNumber(1);order.setUserName("周永康");order.setPPrice(product.getPPrice());order.setPName(product.getPName());order.setUid(1);mapper.insert(order);return order;}
}

Nacos 配置管理中心-config 实现热更新配置文件，无需重启服务器

  1. 导入依赖，与springboot版本一致或者与注册中心版本一致
<!--        nacos 配置坐标-->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId><version>2.1.3.RELEASE</version>
</dependency>
  1. 添加bootstrap.yaml 不能使⽤原来的application.yml作为配置⽂件，⽽是新建⼀个bootstrap.yml作为配置⽂件 配置⽂件优先级(由⾼到低):

bootstrap.properties -> bootstrap.yml -> application.properties -> application.yml

# 使用nacos的配置中心，配置文件由nacos管理 我们只需要导入即可  name+active+file-extension
# 优先级  bootstrap.yml > application.properties > yml > yaml
spring:application:name: server-ordercloud:nacos:config: # nacos配置中心server-addr: 127.0.0.1:8848file-extension: yml #文件类型profiles:active: dev # 指定环境
  1. 在nacos中创建配置

执行流程

配置热更新

  1. 在nacos配置管理中心的配置文件上添加 指定配置名称
# 配置热更新
config:appName: order
  1. 在controller代码中添加一个@RefreshScope注解用来热更新
@RestController
@RefreshScope // 用于配置热更新
public class NacosConfigController {@Value("${config.appName}") // 使用逐个注入private String appName;@GetMapping("/nacosconfigname")public String test(){return appName;}
}

测试接口，返回值为order 修改配置管理中心的配置文件appName: order1 返回值为order1

不同微服务共享配置

  1. 将大家冗余的配置代码抽取出来例如数据库
spring:datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/yuanjiuyuanexcise?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&serverTimezone=Asia/Shanghainame: rootpassword: 123456
  1. 在本地bootstarp.yml中添加
# 使用nacos的配置中心，配置文件由nacos管理 我们只需要导入即可  name+active+file-extension
# 优先级  bootstrap.yml > application.properties > yml > yaml
spring:application:name: server-ordercloud:nacos:config: # nacos配置中心server-addr: 127.0.0.1:8848file-extension: yml #文件类型shared-configs: server-dataBase.yml #-----------共享的配置文件-----------refreshable-dataids: server-dataBase.yml #-----------对于该配置使用热更新------------#        不同服务之间共享配置profiles:active: dev # 指定环境

Ribbon负载均衡器

负责通信（直接使用服务名即可，不需要ip端口），负载均衡。

  • com.netflix.loadbalancer.RoundRobinRule ：以轮询的⽅式进⾏负载均衡 com.netflix.loadbalancer.RandomRule ：随机策略
  • com.netflix.loadbalancer.RetryRule ：重试策略
  • com.netflix.loadbalancer.WeightedResponseTimeRule ：权重策略。会计算每个服务的权重，越⾼的被调⽤的可能性越⼤
  • com.netflix.loadbalancer.BestAvailableRule ：最佳策略。遍历所有的服务实例，过滤掉故障实例，并返回请求数最⼩的实例返回
  • com.netflix.loadbalancer.AvailabilityFilteringRule ：可⽤过滤策略。过滤掉故障和请求数超过阈值的服务实例，再从剩下的实⼒中轮询调⽤
  • ZoneAvoidanceRule： 以区域可⽤的服务器为基础进⾏服务器的选择。使⽤Zone对服务器进⾏分类，这个Zone可以理解为⼀个机房、⼀个机架等。⽽后再对Zone内的多个服务做轮询
负载均衡使用场景：当某个服务频繁访问，我们想给这个服务增加一台服务器，在springboot中的做法是下图 端口号命令：-Dserver.port=xxxx

添加一个启动器，用来模拟增加一个服务器

通信
@Bean
public RestTemplate restTemplate(){return new RestTemplate();
}
负载均衡：使用@LoadBalanced注解 意思是负载均衡 使用负载均衡的方式来通讯
@Bean
//    使用ribbon（用来通信，使用服务名即可识别ip端口）需要用到的注解 负载均衡（以负载均衡的方式通信）
@LoadBalanced
public RestTemplate restTemplate(){return new RestTemplate();
}

全局配置：使用随机负载只要当前服务发请求，不管发给谁，都使用随机负载

//    ribbon的负载策略 这个是全局随机负载
@Bean
public IRule randomRule(){return new RandomRule();
}

局部配置：当前服务只有给server-product发请求的时候才是随机负载

# ribbon局部随机策略
server-product:ribbon:NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

Feign微服务通信(RESTful风格 http请求) 使用前提：已开启nacos服务

Feign是Spring Cloud提供的⼀个声明式的伪Http客户端， 它使得调⽤远程服务就像调⽤本 地服务⼀样简单， 只需要创建⼀个接⼝并添加⼀个注解即可。 Nacos很好的兼容了Feign， Feign 默认集了Ribbon， 所以在Nacos下使⽤Fegin默认就实现了负载均衡的效果。

  1. 加⼊Fegin的依赖 版本与sprigboot版本一致
<!--        feign通信坐标-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId><version>2.1.3.RELEASE</version>
</dependency>
  1. 启动类上添加启用feign通信注解@EnableFeignClients
@SpringBootApplication
@EnableDiscoveryClient // 开启微服务注册
@EnableFeignClients //使用feign通信不需要去声明ribbon负载均衡 默认集成了ribbon
public class ShopOrderApplication {public static void main(String[] args) {SpringApplication.run(ShopOrderApplication.class, args);}
}
  1. 编写一个发送请求的通信接口给Product服务发请求，就创建一个ProductServiceClient接口
package com.ape.shop_order.service;import com.ape.pojo.Product;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;/*** 这个接口用来给Product服务发送请求*/
@FeignClient("server-product")//要通信的服务名
public interface ProductServiceClient {//指定调⽤提供者的哪个⽅法//@FeignClient+@GetMapping就是⼀个完整的请求路径http://server-product/product/{id}@GetMapping("/product/{id}")Product selectById(@PathVariable int id);
}
  1. 依赖注入后直接调用接口中的通信方法
@Service
@Slf4j
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements OrderService {@Autowiredprivate OrderMapper mapper;//    使用通信ProductService接口中的通信方法@Autowiredprivate ProductServiceClient productServiceClient;@Overridepublic Order placeOrder(int id) {//       调用通信方法Product product = productServiceClient.selectById(id);Order order = new Order();order.setPid(id);order.setUserName("周永康");order.setUid(1);order.setNumber(1);order.setPName(product.getPName());order.setPPrice(product.getPPrice());mapper.insert(order);log.info(order.toString());return order;}
}
Feign使⽤优化

Feign底层发起http请求，依赖于其它的框架。其底层客户端实现包括：

URLConnection：默认实现，不⽀持连接池

Apache HttpClient ：⽀持连接池

OKHttp：⽀持连接池 因此提⾼Feign的性能主要⼿段就是使⽤连接池代替默认的URLConnection 这⾥我们⽤Apache的HttpClient来演示

<!--        feign优化 使用HttpClient支持连接池-->
<dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpclient</artifactId><version>4.5.14</version>
</dependency>

配置文件

# 配置连接池
feign:httpclient:enabled: truemax-connections: 200 #最大连接数max-connections-per-route: 50 #每个路径的最大连接数

Dubbo(PRC) 微服务通信

思想是把服务的对象加载到nacos服务器上，再供其他服务调用，这里的nacos服务器有点 IOC的味道。

使用步骤（分清楚调用者和被调用者，调用者是消费者，被调用者是生产者）

  1. 在公共服务common中定义service层里的接口ProductService这样在Product服务中的service层就不用写ProductService接口了
package com.ape.service;import com.ape.pojo.Product;
import org.springframework.web.bind.annotation.PathVariable;/**实战中，会将所有服务接⼝设计给⼀个叫做api的服务，单独维护，此处就在common服务设置*/
public interface ProductService {Product selectById(int id);
}
  1. 给product服务添加依赖 注意版本与springboot版本要匹配
<!--dubbo-->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-dubbo</artifactId><version>2.1.2.RELEASE</version>
</dependency>
  1. 添加dubbo配置
# dubbo的配置
dubbo:scan:base-packages: com.ape.shop_product.service.impl  #开启包扫描protocols:dubbo:name: dubbo  #服务协议port: -1 #服务端口 随机端口registry:address: spring-cloud://localhost # 注册中心
  1. 编写service.impl包下的ProductService实现类并且暴露出来 这个@Service是dubbo包提供的
package com.ape.shop_product.service.impl;import com.ape.pojo.Product;
import com.ape.service.ProductService;
import com.ape.shop_product.mapper.ProductMapper;
import com.baomidou.mybatisplus.extension.service.IService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.apache.dubbo.config.annotation.Service;import javax.annotation.Resource;@Service
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> implements ProductService, IService<Product> {@Resource(name = "productMapper")private ProductMapper mapper;@Overridepublic Product selectById(int id) {return mapper.selectById(id);}
}
  1. 给消费者添加依赖
<!--dubbo-->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-dubbo</artifactId><version>2.1.2.RELEASE</version>
</dependency>
  1. 给消费者添加配置
dubbo:registry:address: spring-cloud://localhost # 注册中⼼cloud:subscribed-services: server-product #定义的提供者名称
  1. 调用服务
package com.ape.shop_order.service.impl;import com.ape.pojo.Order;
import com.ape.pojo.Product;
import com.ape.service.ProductService;
import com.ape.shop_order.mapper.OrderMapper;
import com.ape.shop_order.service.OrderService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
@Slf4j
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements OrderService {@Autowiredprivate OrderMapper mapper;//dubbo 调用@Referenceprivate ProductService productService;@Overridepublic Order placeOrder(int id) {//       调用通信方法Product product = productService.selectById(id);Order order = new Order();order.setPid(id);order.setUserName("周永康");order.setUid(1);order.setNumber(1);order.setPName(product.getPName());order.setPPrice(product.getPPrice());mapper.insert(order);log.info(order.toString());return order;}
}


http://www.ppmy.cn/ops/98813.html

相关文章

【代码随想录算法训练营第42期 第三十天 | LeetCode452. 用最少数量的箭引爆气球、435. 无重叠区间、763.划分字母区间】

【代码随想录算法训练营第42期 第三十天 | LeetCode452. 用最少数量的箭引爆气球、435. 无重叠区间、763.划分字母区间】

代码随想录算法训练营第42期 第三十天 | LeetCode452. 用最少数量的箭引爆气球、435. 无重叠区间、763.划分字母区间 一、452. 用最少数量的箭引爆气球 解题代码C&#xff1a; class Solution { private:static bool cmp(const vector<int>& a, const vector<in…
阅读更多...
Windows 上设置 MySQL 的主从复制

Windows 上设置 MySQL 的主从复制

Windows 上设置 MySQL 的主从复制 一、前言1. 环境准备2. 主服务器配置3. 从服务器配置6. 测试复制7. 注意事项 一、前言 MySQL 主从复制可以在程序中通过以下方式应用&#xff1a; 读写分离&#xff1a;将写操作&#xff08;如插入、更新、删除&#xff09;发送到主服务器&am…
阅读更多...
re正则模块

re正则模块

re模块用于处理正则表达式&#xff0c;它的基本功能包括&#xff1a;匹配、查找、替换。 匹配 匹配的使用方法一般有三个参数&#xff1a;第一个参数&#xff1a;正则模式、第二个参数&#xff1a;需要处理的字符、 第三个参数&#xff1a;附加处理方法 下面列举的是一写匹…
阅读更多...
Notion使用详解

Notion使用详解

文章目录 Notion使用详解一、引言二、Notion的核心特性1、模块化设计——Block Editor2、强大的数据库功能——Database3、丰富的模板和导入功能 三、Notion的高级使用技巧1、页面和子页面的创建与管理2、内容的动态交互和展示3、跨平台同步与分享 四、总结 Notion使用详解 一…
阅读更多...
iOS 开发：Object-C 和 Swift 的区别 （AI问答）

iOS 开发：Object-C 和 Swift 的区别 （AI问答）

一&#xff1a;语言类型的区别&#xff08;最主要区别&#xff09; object-c 是动态类型语言&#xff1b; swift是静态类型语言&#xff1b; 看一下AI的回答&#xff0c;很全面~~ Objective-C 和 Swift 的语言类型区别主要体现在以下几个方面&#xff1a; 1. 静态类型 vs. 动…
阅读更多...
ASIACRYPT 2020

ASIACRYPT 2020

分类文章编号最佳论文1-3加密方案4-9后量子密码10-12消息鉴权编码13-15密码分析16-22对称密钥密码23-25侧信道分析26-29公钥密码30-37格密码38-42量子算法43-46多方计算47-58同形映射密码59-64鉴权密钥交换65-68区块链和消息轨迹69-70可更新加密71-74零知识75-80属性加密81-85B…
阅读更多...
【Java 数据结构】排序

【Java 数据结构】排序

排序 排序排序是什么排序相关概念稳定性比较排序非比较排序内部排序外部排序 常见比较排序冒泡排序基本思想代码实现 选择排序基本思想代码实现 插入排序基本思想代码实现 希尔排序基本思想代码实现 堆排序基本思想代码实现 快速排序基本思想代码实现优化其他实现寻找基准非递归…
阅读更多...
40_操作系统安全机制、linux安全加固、windows安全加固、Linux基线扫描下载、主机安全检查工具windows版本下载

40_操作系统安全机制、linux安全加固、windows安全加固、Linux基线扫描下载、主机安全检查工具windows版本下载

1.操作系统安全机制 1.1标识与鉴别 Windows:SIDLinux: UID、GID 1.1.1 SID 查看当前用户名及SID 查看所有用户名及SID C:\Users\TEACHER>wmic useraccount get name,sid Name SID Administrator S-1-5-21-80530027-1782036084-1563535153-500 Defa…
阅读更多...
最新文章

Copyright @ 2022~2023