微服务 Eureka

Eureka

Eureka是Netflix开源的一个用于构建基于微服务架构的服务发现和注册中心技术。在微服务架构中,系统被拆分成多个小型、自治的服务,每个服务负责特定的业务功能。这些服务需要能够相互发现和通信,这就是Eureka所提供的功能。

Eureka主要包括两个角色:Eureka Server和Eureka Client。

Eureka Server:

Eureka Server是一个服务注册中心,用于管理和维护所有微服务的注册信息。每个微服务在启动时会向Eureka Server注册自己的信息,包括服务名称、IP地址、端口等。Eureka Server维护了一个服务注册表,记录了所有已注册的微服务,以及它们的相关信息。其他微服务可以通过向Eureka Server发送请求来发现其他可用的微服务。

Eureka Client:

Eureka Client是各个微服务的客户端,用于注册自己以及发现其他微服务。当微服务启动时,它会注册到Eureka Server,同时定期向Eureka Server发送心跳,以保持注册信息的更新。Eureka Client还能从Eureka Server获取其他微服务的信息,从而实现了服务之间的发现与通信。

Eureka优势

动态发现和注册:微服务架构中,服务的部署和扩展很频繁,使用Eureka可以实现动态注册和发现微服务,使得新加入或移除的服务能够自动被其他服务感知,无需手动配置。

高可用性:Eureka支持多个Eureka Server之间的相互注册和复制,以实现高可用性。如果一个Eureka Server发生故障,其他Eureka Server仍然能够提供服务发现的功能。

负载均衡:Eureka Client可以根据服务的负载情况进行负载均衡,选择合适的实例进行请求转发。

自我保护机制:Eureka具备自我保护机制,当某个时刻注册中心出现网络分区故障或者注册信息不稳定时,Eureka会保护已注册的服务实例,不会将其剔除,确保整体系统的稳定性。

总之,Eureka技术为微服务架构提供了方便的服务发现和注册能力,帮助构建高效、弹性、可扩展的分布式系统。虽然Netflix已经宣布停止维护Eureka,但它的基本概念和思想仍然被广泛应用于各种微服务架构中。

为什么要引入Eureka来动态发现和注册?

现代企业开发一般要求利用微服务去对业务进行治理,例如公司有两个服务分别是user服务和order服务(同时这两个服务会对应两个独立的数据库user和order)。由于这两个数据库对于对方来说相互独立,我想进行两个库之间的关联查询是不可能的。
这时可以利用远程调用的方法解决这个问题

spring 提供了RestTemplate来支持实现远程调用,可以在配置类文件中进行RestTemplate restTemplate()的Bean注册。

我们这里在order-service的OrederApplication中注册RestTemplate

@SpringBootApplication
public class OrderApplication {public static void main(String[] args) {SpringApplication.run(OrderApplication.class, args);}// 创建RestTemplate注入Spring容器@Bean@LoadBalanced  // 引入负载均衡的注解public RestTemplate restTemplate(){return new RestTemplate();}
}

修改order-service中的OrderService来获取user对象,其中http://localhost:8081/user/{id}用户查询地址;利用restTemplate.getForObject(请求是get就用get;请求是post就用postForObject就行)向http://localhost:8081/user/{id}服务查询需要的user对象。
返回的对象一般来说是JSON类型,所以restTemplate可以自动进行类型转换,第二个参数User.class告诉restTemplate返回的类型。
至此我们就通过RestTemplate进行跨数据的方法。

@Service
public class OrderService {@Autowiredprivate OrderMapper orderMapper;@Autowiredprivate RestTemplate restTemplate;public Order queryOrderById(Long orderId) {// 1.查询订单Order order = orderMapper.findById(orderId);// 2.利用RestTemplate发起http请求,来查询用户System.out.println(order);String url = "http://localhost:8081/user"+order.getUserId();User user = restTemplate.getForObject(url, User.class);// 封装对象order.setUser(user);// 4.返回return order;}
}

但是上面请求最大的问题就是,我给的路径是固定的;一般而言大规模开发的过程中不会在代码中给出明确的路径(因为port变更是经常发生的)。

为此我们就需要引入Eureka服务器。

Eureka服务

创建Eureka微服务

注册中心服务端:eureka-server,这必须是一个独立的微服务。
在这里插入图片描述
为该服务引入依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency>

编写启动类:给eureka-server服务编写一个启动类,一定要添加一个@EnableEurekaServer注解,开启eureka的注册中心功能:

package com....;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {public static void main(String[] args) {SpringApplication.run(EurekaApplication.class, args);}
}

编写配置文件:编写一个application.yml文件,内容如下:

server:port: 10086  # 服务地址
spring:application:name: eureka-server # 2. 微服务的名称
eureka:client:service-url: # 3. 服务地址信息,尤里卡自己也是一个微服务,会将自己也注册到地址上(为了尤里卡集群通信)defaultZone: http://127.0.0.1:10086/eureka

启动微服务,然后在浏览器访问:http://127.0.0.1:10086

在这里插入图片描述

服务注册

下面,我们将user-service注册到eureka-server中去。

1)引入依赖:在user-service的pom文件中,引入下面的eureka-client依赖:

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

2)配置文件:在user-service中,修改application.yml文件,添加服务名称、eureka地址:

spring:application:name: userservice
eureka:client:service-url:defaultZone: http://127.0.0.1:10086/eureka

同样的方法在order-service中也能注册,注册后重启服务可以看到(三个应用都出现在列表上了):
在这里插入图片描述
order服务拉取就可以进行修改,吧原来固定的url改成动态的微服务名称即可

http://user-server/user/

@Service
public class OrderService {@Autowiredprivate OrderMapper orderMapper;@Autowiredprivate RestTemplate restTemplate;public Order queryOrderById(Long orderId) {// 1.查询订单Order order = orderMapper.findById(orderId);// 2.利用RestTemplate发起http请求,来查询用户System.out.println(order);String url = "http://user-server/user/"+order.getUserId();User user = restTemplate.getForObject(url, User.class);// 封装对象order.setUser(user);// 4.返回return order;}
}

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

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

相关文章

Unity 之NavMeshAgent 组件(导航和路径寻找的组件)

文章目录 **作用**&#xff1a;**属性和方法**&#xff1a;**用途**&#xff1a;**注意事项**&#xff1a; NavMeshAgent 是Unity引擎中用于导航和路径寻找的组件。它可以使游戏对象在场景中自动找到可行走的路径&#xff0c;并在避免障碍物的情况下移动到目标位置。 以下是关于…

openCV实战-系列教程3:形态学操作(腐蚀操作/膨胀操作/开运算/闭运算/梯度计算/礼帽和黑帽)、源码解读

1、腐蚀操作 1.1 腐蚀 首先读进来并打印一张图 img cv2.imread(yzy.jpg) cv2.imshow(img, img) cv2.waitKey(0) cv2.destroyAllWindows() 这个图片出现了一些毛刺&#xff0c;看着挺难受 执行一个腐蚀操作&#xff0c;再将图片打印出来&#xff1a; kernel np.ones((3,3…

Angular安全专辑之二——‘unsafe-eval’不是以下内容安全策略中允许的脚本源

一&#xff1a;错误出现 这个错误的意思是&#xff0c;拒绝将字符串评估为 JavaScript&#xff0c;因为‘unsafe-eval’不是以下内容安全策略中允许的脚本源。 二&#xff1a;错误场景 testEval() {const data eval("var sum2 new Function(a, b, return a b); sum2(em…

七、任务优先级和Tick

1、任务与中断的优先级 (1)相同优先级任务轮流执行。 (2)高优先级任务打断低优先级任务。 (3)中断可以打断所有优先级的任务。 2、任务优先级 (1)优先级的取值范围是&#xff1a;0~(configMAX_PRIORITIES – 1)&#xff0c;数值越大优先级越高。 (2)FreeRTOS会确保最高优…

DataFrame.query()--Pandas

1. 函数功能 Pandas 中的一个函数&#xff0c;用于在 DataFrame 中执行查询操作。这个方法会返回一个新的 DataFrame&#xff0c;其中包含符合查询条件的数据行。请注意&#xff0c;query 方法只能用于筛选行&#xff0c;而不能用于筛选列。 2. 函数语法 DataFrame.query(ex…

xcode15 change

jump to define 由原先的 control command left click 改为command left click

【Alibaba中间件技术系列】「RocketMQ技术专题」小白专区之领略一下RocketMQ基础之最!

应一些小伙伴们的私信&#xff0c;希望可以介绍一下RocketMQ的基础&#xff0c;那么我们现在就从0开始&#xff0c;进入RocketMQ的基础学习及概念介绍&#xff0c;为学习和使用RocketMQ打好基础&#xff01; RocketMQ是一款快速地、可靠地、分布式、容易使用的消息中间件&#…

无涯教程-Perl - unshift函数

描述 此函数按顺序将LIST中的元素放在ARRAY的开头。这与shift()相反。 语法 以下是此函数的简单语法- unshift ARRAY, LIST返回值 此函数返回ARRAY中新元素的数量。 例 以下是显示其基本用法的示例代码- #!/usr/bin/perl -warray ( 1, 2, 3, 4);print "Value of a…

Ribbon:使用Ribbon实现负载均衡

Ribbon实现的是实线走的 建立三个数据库 /* SQLyog Enterprise v12.09 (64 bit) MySQL - 5.7.25-log : Database - db01 ********************************************************************* *//*!40101 SET NAMES utf8 */;/*!40101 SET SQL_MODE*/;/*!40014 SET OLD_UNIQ…

安防视频云平台EasyNVR视频汇聚平台硬件无法进入服务器的问题处理方法

EasyNVR是基于RTSP/Onvif协议的视频接入、处理及分发的安防视频云平台&#xff0c;可提供的视频能力包括&#xff1a;设备接入、实时视频直播、录像、云存储、录像回放与检索、告警、级联等&#xff0c;平台可支持将接入的视频流进行全平台、全终端的分发&#xff0c;分发的视频…

Hi-TRS:骨架点视频序列的层级式建模及层级式自监督学习

论文题目&#xff1a;Hierarchically Self-Supervised Transformer for Human Skeleton Representation Learning 论文下载地址&#xff1a;https://www.ecva.net/papers/eccv_2022/papers_ECCV/papers/136860181.pdf 代码地址&#xff1a;https://github.com/yuxiaochen1103…

类与对象(中)

类与对象&#xff08;中&#xff09; 一、类的六个默认成员函数二、构造函数1、概念2、代码3、特点4、编译器生成的默认构造函数的作用&#xff08;1&#xff09;内置类型&#xff08;基本类型&#xff09;和自定义类型的概念&#xff08;2&#xff09;作用&#xff08;3&#…