【微服务】服务注册与发现 - Eureka(day3)

CAP理论

P是分区容错性。简单来说,分区容错性表示分布式服务中一个节点挂掉了,并不影响其他节点对外提供服务。也就是一台服务器出错了,仍然可以对外进行响应,不会因为某一台服务器出错而导致所有的请求都无法响应。综上所述,在分布式系统中,分区容错性是必须要保证的一个特性。

C表示一致性。通俗的讲,一致性就是所有节点在某个响应时的数据都是相同的。

A表示可用性。可用性指代对所有的请求都有相应结果。

在分布式系统中,P是必须要保证的一个特性,因此可用性和一致性就不能同时保证。原因就是当一个节点收到数据之后,要传给别的节点进行复制,在这个过程中,如果有请求的话,那么就可能导致一致性出现问题。假设要保证一致性,那就得上锁,不对外响应,那么此时可用性就出现了问题。因此,分布式系统中,只存在AP理论和CP理论。

举个例子来说明一下CAP的概念。在一家生意火爆的饭店中,一道菜的原料没有了,就要告诉所有的服务员不能再下单该菜了,但是通知的过程是要浪费时间的。

一致性表示所有的服务都接到通知了,因此对客户的响应都是相同的。可用性就是不管有没有接收到通知,服务员都会给出一个响应。分区容错性是指一个服务员请假了,那也不会影响今天的饭店开门。分区容错性饭店肯定是能保证的。但是如果要保证一致性,那么在所有服务员接收到通知之前,都是不能讲话的,这就影响到了可用性。如果要保证可用性,那么所有的服务员都能讲话,但是不确定谁没有接收到信息。如果想要同时保证可用性和一致性,只有一种可能,就是饭店只有一个人,但是这种情况下,他请假,饭店就关门了,分区容错性就没有了。

服务注册和发现引入

概述

在基础工程搭建中,我们发现调用服务时是以硬编码的方式来创建URL的,但是对于微服务来说,一个服务可能有成百上千个实例,并且还会随时扩缩容。因此,我们采用这种方式是不合理的。并且,在日常管理中,对这么多的实例,我们并不能立马确定哪个实例出现了宕机等问题。因此就出现了微服务家族的第一套组件——服务注册和发现。

服务注册和发现,最重要干的事就是把所有注册到注册中心的实例给展示出来。这样,我们可以轻松的看到所有的实例运行情况。如果此时某台实例出错下线了,注册中心也能监控到,并将该实例进行剔除,不再对外进行服务。而且,有的注册中心也能支持实例的动态上下线,这样能很快的实现扩缩容,大大减少了运维开发的工作。

综上所述,服务注册和发现组件的功能大概有:服务管理、容错处理、动态扩展等。当然,不同产品也会存在一定的差异化,例如咋们中国阿里巴巴的Nacos就不止实现了服务注册和发现这个功能,还有分布式配置管理等,当然,这都是下文了。

功能图

 角色

Server,服务提供者:一次业务中,被其他服务调用的服务,也就是提供接口给其他服务。

Client,服务消费者:一次业务中,调用其他服务的服务,也就是使用接口的服务。

Registry,服务注册中心:用来保存Server的注册信息,当Server节点发生变更时,注册中心就会感知到并进行同步更新。注册中心和注册的服务存在一定机制进行通信,如果注册中心与某服务长期没有通信,也就是超过限定的阈值,那么注册中心就会下线该实例。

服务注册和服务发现

服务注册:服务提供者在启动服务时,将自身注册到注册中心中,并定期向注册中心发送心跳包表示自己还存活。

服务发现:服务消费者需要调用某服务时,就先去注册中心找到服务提供者的地址,通过该地址对服务提供者进行调用。服务发现的重要作用就是提供一个可用的服务列表给消费者。

搭建注册中心

内容

1. Eureka Server:作为注册中心,向服务提供服务注册、服务发现、健康检查等功能。

2. Eureka Client:服务提供者,服务启动时,会向注册中心提供自己的信息,例如端口号,IP地址等内容,而注册中心会保存这些信息。

步骤

1. 搭建Eureka Server。

2. 将服务都注册到注册中心中。

3. 服务与服务之间进行调用时,先去注册中心查找被调用服务的服务列表,然后进行调用。

搭建案例

搭建注册中心

建模块

写pom文件

<?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><parent><groupId>com.wbz</groupId><artifactId>spring-cloud-test</artifactId><version>1.0-SNAPSHOT</version></parent><artifactId>cloud-server-eureka10010</artifactId><properties><maven.compiler.source>17</maven.compiler.source><maven.compiler.target>17</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><!--web通用模块--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--注册中心--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency></dependencies></project>

写yml文件

server:port: 10010spring:application:name: cloud-server-eureka10010eureka:instance:hostname: localhostclient:# 表示是否从注册中心中获取注册的服务信息,默认是true# 咋们搭建的只是一个单体的,没有其他注册中心,因此不需要同步fetch-registry: false# 表示是否将自己注册到注册中心register-with-eureka: falseservice-url:# 设置注册中心的地址,查询服务和注册服务都需要依赖这个地址defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

改启动类

/*** Eureka服务注册中心*/@EnableEurekaServer // 开启注册中心服务
@SpringBootApplication
public class EurekaServerApplication10010 {public static void main(String[] args) {SpringApplication.run(EurekaServerApplication10010.class, args);}}

启动该服务,访问URL:127.0.0.1:10010,出现如下界面就算搭建成功:

注册商品服务到注册中心

修改pom文件

        <!--Eureka--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency>

修改yml文件

eureka:client:service-url:defaultZone: http://127.0.0.1:10010/eureka/

注册订单服务到注册中心

 修改pom文件

        <!--Eureka--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency>

修改yml文件

eureka:client:service-url:defaultZone: http://127.0.0.1:10010/eureka/

把两个项目进行重新启动,再次观察Eureka的页面,发现:

硬编码解耦

订单服务中进行修改

@Slf4j
@Service
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements OrderService {/*@Resourceprivate RestTemplate restTemplate;@Overridepublic Order getOrderById(Integer id) {Order order = this.getById(id);String url = "http://127.0.0.1:8001/product/query/" + order.getProductId();Product product = this.restTemplate.getForObject(url, Product.class);order.setProduct(product);return order;}*/private final String PRODUCT_SERVICE_NAME = "cloud-provider-payment8001";@Resourceprivate RestTemplate restTemplate;@Resourceprivate DiscoveryClient discoveryClient;@Overridepublic Order getOrderById(Integer id) {// 获取订单Order order = this.getById(id);// 获取商品服务的实例List<ServiceInstance> instances = discoveryClient.getInstances(this.PRODUCT_SERVICE_NAME);// 输出日志查看获取到的实例有哪些内容log.info(instances.toString());// 获取第一个商品实例的uriString uri = instances.get(0).getUri().toString();log.info(uri);// 拼接urlString url = uri + "/product/query/" + order.getProductId();// 远程调用Product product = this.restTemplate.getForObject(url, Product.class);order.setProduct(product);// 返回结果return order;}}

在硬编码解耦中,其实就是将原来的IP和PORT进行改换。通过服务名字去注册中心查找实例然后进行调用,这样无论启动多少个实例,也不用对代码进行变动。

Eureka对于CAP理论来说,其实现的是AP理论,保证高可用。

总结与疑惑 

在我第一次学习了Eureka之后,感觉这个组件好好用,能减少代码的耦合,不过,随之而来又出现了一个问题就是当我启动多个实例之后,发现我依旧只能调用第一个服务,那原因是出在哪里呢。经过查看我的代码如下图发现,是在服务调用的时候写了只调用第一个。问题找打了,但是如何解决呢?写一个取余来判断?但是我又不确定又几个实例。在这里就不多说了,好奇的同学就赶快去看第二个组件负载均衡吧,他完美解决了这个问题。

再提一句,学习了Nacos和Consul之后,发现Eureka不香了,看到这里的同学是不是得来一句——经典白雪,赶快打在评论区吧。

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

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

相关文章

LabVIEW机床加工监控系统

随着制造业的快速发展&#xff0c;机床加工的效率与稳定性成为企业核心竞争力的关键。传统的机床监控方式存在效率低、无法远程监控的问题。为了解决这些问题&#xff0c;开发了一种基于LabVIEW的机床加工监控系统&#xff0c;通过实时监控机床状态&#xff0c;改进生产流程&am…

PhotoMaker部署文档

一、介绍 PhotoMaker&#xff1a;一种高效的、个性化的文本转图像生成方法&#xff0c;能通过堆叠 ID 嵌入自定义逼真的人类照片。相当于把一张人的照片特征提取出来&#xff0c;然后可以生成你想要的不同风格照片&#xff0c;如写真等等。 主要特点&#xff1a; 在几秒钟内…

[C语言]指针和数组

目录 1.数组的地址 2.通过指针访问数组 3.数组和指针的不同点 4.指针数组 1.数组的地址 数组的地址是什么&#xff1f; 看下面一组代码 #include <stdio.h> int main() { int arr[5] {5,4,3,2,1}; printf("&arr[0] %p\n", &arr[0]); printf(&qu…

【c++】string类 (一)

简介 由于c的历史包袱&#xff0c;c要兼容c语言&#xff0c;c的字符串要兼容c语言&#xff0c;在 C 中&#xff0c;字符串通常使用两种主要的方式来表示&#xff1a; C风格字符串&#xff08;C-style strings&#xff09;&#xff1a; 依然是以 \0 结尾的字符数组。这种表示方…

设置服务器走本地代理

勾选&#xff1a; 然后&#xff1a; git clone https://github.com/rofl0r/proxychains-ng.git./configure --prefix/home/wangguisen/usr --sysconfdir/home/wangguisen/etcmakemake install# 在最后配置成本地代理地址 vim /home/wangguisen/etc/proxychains.confsocks4 17…

Web安全 - 文件上传漏洞(File Upload Vulnerability)

文章目录 OWASP 2023 TOP 10导图定义攻击场景1. 上传恶意脚本2. 目录遍历3. 覆盖现有文件4. 文件上传结合社会工程攻击 防御措施1. 文件类型验证2. 文件名限制3. 文件存储位置4. 文件权限设置5. 文件内容检测6. 访问控制7. 服务器配置 文件类型验证实现Hutool的FileTypeUtil使用…

计算机网络:计算机网络体系结构 —— OSI 模型 与 TCP/IP 模型

文章目录 计算机网络体系结构OSI 参考模型TCP/IP 参考模型分层的必要性物理层的主要问题数据链路层的主要问题网络层的主要问题运输层的主要问题应用层的主要问题 分层思想的处理方法发送请求路由器转发接受请求发送响应接收响应 计算机网络体系结构 计算机网络体系结构是指将…

简单部署vue+springboot项目

vue 参考博客 先将vue项目打包 npm run build 再创建项目文件夹front,在front中新建nginx.conf server {listen 80;server_name localhost;# 请求体的大小限制client_max_body_size 50m;# 日志文件存放地址access_log /var/log/nginx/host.access.log main;error…

openpnp - 图像传送方向要在高级校正之前设置好

文章目录 openpnp - 图像传送方向要在高级校正之前设置好笔记图像传送方向的确定END openpnp - 图像传送方向要在高级校正之前设置好 笔记 图像传送方向和JOG面板的移动控制和实际设备的顶部摄像头/底部摄像头要一致&#xff0c;这样才能和贴板子时的实际操作方向对应起来。 …

C++ | Leetcode C++题解之第456题132模式

题目&#xff1a; 题解&#xff1a; class Solution { public:bool find132pattern(vector<int>& nums) {int n nums.size();vector<int> candidate_i {nums[0]};vector<int> candidate_j {nums[0]};for (int k 1; k < n; k) {auto it_i upper_…

测试-BUG篇

文章目录 软件测试的生命周期BUGbug的概念描述bug的要素bug级别bug的生命周期 与开发产生争执怎么办&#xff08;高频考题&#xff09; 软件测试的生命周期 软件测试贯穿于软件的整个生命周期 BUG bug的概念 是指计算机程序中存在的一个错误(error)、缺陷(flaw)、疏忽(mista…

docker环境下配置cerbot获取免费ssl证书并自动续期

文章目录 实践场景了解certbot查看nginx的映射情况操作目标配置nginx配置的ssl证书设置自动续签 实践场景 本人使用docker部署了一个nginx容器&#xff0c;通过容器卷&#xff0c;实现本地html&#xff0c;ssl&#xff0c;conf和ngiinx容器映射的&#xff0c; 经常需要手动部署…

适合跑步的开放式耳机哪个品牌好?怎么选?可入的蓝牙耳机推荐

想必很多爱晨跑的朋友&#xff0c;一定都有过这般令人困扰的经历。耳机戴久了总觉得不舒适&#xff0c;或是尺寸不合&#xff0c;或是材质欠佳&#xff0c;反正无论怎样调整&#xff0c;都很难找到最舒适的佩戴方式。而且&#xff0c;有时候戴的时间久了&#xff0c;还很容易掉…

FLUX的ID保持项目也来了! 字节开源PuLID-FLUX-v0.9.0,开启一致性风格写真新纪元!

之前的文章已经和大家介绍过字节开源的ID保持项目PuLID。随着FLUX模型的发布&#xff0c;PuLID也开源了 FLUX 版本的模型&#xff0c;不得不说FLUX的强大&#xff0c;两个月生态就赶上了SDXL。这次新发布PuLID-FLUX-v0.9.0模型&#xff0c;它为FLUX.1-dev提供了无需调整的ID定制…

4S店4S店客户管理系统小程序(lw+演示+源码+运行)

社会的发展和科学技术的进步&#xff0c;互联网技术越来越受欢迎。手机也逐渐受到广大人民群众的喜爱&#xff0c;也逐渐进入了每个用户的使用。手机具有便利性&#xff0c;速度快&#xff0c;效率高&#xff0c;成本低等优点。 因此&#xff0c;构建符合自己要求的操作系统是非…

VirtulBOX Ubuntu22安装dpdk23.11

目录 依赖包安装 Python安装 numa安装 ​编辑Python pip3安装 ​编辑pyelftools安装 meson和ninja安装 ​编辑构建与编译 Meson构建DPDK ​编辑Ninja安装DPDK ​编辑VFIO-PCI驱动安装 大页内存和IOMMU配置 ​编辑VFIO-PCI加载 ​编辑VFIO-PCI驱动绑定 ​编辑dpdk…

Linux网络操作命令与函数全面总结

1. 引言 Linux作为服务器和开发平台&#xff0c;网络操作是其核心功能之一。本文旨在全面总结Linux系统中的网络操作方法&#xff0c;包括命令行工具和编程接口&#xff0c;帮助读者深入理解Linux网络管理的机制。 2. 命令行工具 2.1 ping 命令 ping 命令用于测试网络连接和…

【Linux】信号知识三把斧——信号的产生、保存和处理

目录​​​​​​​ 1、关于信号的前置知识 1.1.什么是信号&#xff1f; 1.2.为什么要学习信号&#xff1f; 1.3.如何学习信号&#xff1f; 1.4.一些常见的信号 1.5.信号的处理方式 1.6.为什么每一个进程都可以系统调用&#xff1f; 2.信号的产生 2.1.kill命令产生信号…

计算机前沿技术-人工智能算法-大语言模型-最新研究进展-2024-09-28

计算机前沿技术-人工智能算法-大语言模型-最新研究进展-2024-09-28 目录 文章目录 计算机前沿技术-人工智能算法-大语言模型-最新研究进展-2024-09-28目录前言1. Cognitive phantoms in LLMs through the lens of latent variables摘要研究背景问题与挑战创新点算法模型实验效果…

【C++】二叉搜索树+变身 = AVL树

&#x1f680;个人主页&#xff1a;小羊 &#x1f680;所属专栏&#xff1a;C 很荣幸您能阅读我的文章&#xff0c;诚请评论指点&#xff0c;欢迎欢迎 ~ 目录 前言一、AVL树二、AVL树的实现2.1 平衡因子2.2 旋转处理2.2.1 左单旋&#xff1a;插入新节点后单纯的右边高2.2.2 …