微服务 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.mzph.cn/news/50011.shtml

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

相关文章

网络互联与互联网 - TCP 协议详解

文章目录 1 概述2 TCP 传输控制协议2.1 报文格式2.2 三次握手&#xff0c;建立连接2.3 四次挥手&#xff0c;释放连接 3 扩展3.1 实验演示3.2 网工软考 1 概述 在 TCP/IP 协议簇 中有两个传输协议 TCP&#xff1a;Transmission Control Protocol&#xff0c;传输控制协议&…

利用tidevice+mysql+grafana实现ios性能测试

利用tidevicemysqlgrafana实现ios性能测试 1.什么是tidevice&#xff1f; tidevice是一个可以和ios设备进行通信的工具&#xff0c;提供以下功能&#xff1a; 截图获取手机信息ipa包的安装和卸载根据bundleID 启动和停止应用列出安装应用信息模拟Xcode运行XCTest&#xff0c…

机器学习深度学习——针对序列级和词元级应用微调BERT

&#x1f468;‍&#x1f393;作者简介&#xff1a;一位即将上大四&#xff0c;正专攻机器学习的保研er &#x1f30c;上期文章&#xff1a;机器学习&&深度学习——NLP实战&#xff08;自然语言推断——注意力机制实现&#xff09; &#x1f4da;订阅专栏&#xff1a;机…

【C++设计模式】用简单工厂模式实现按汽车重量输出汽车类型

2023年8月24日&#xff0c;周四凌晨 #include<iostream>class CarType{ public:virtual std::string getType()0; };class MiniCar:public CarType{ public:std::string getType() override{return "小型车";}; };class MidSizeCar:public CarType{ public:std…

游戏出海需知:Admob游戏广告变现策略

越来越多的出海游戏公司更加重视应用内的广告变现&#xff0c;而 AdMob因为其提供的丰富的广告资源&#xff0c;稳定平台支持&#xff0c;被广泛接入采用。 Admob推出的广告变现策略包括bidding、插页式激励视频、开屏广告、各种细分功能的报告等等。 一、Bidding 竞价策略 …

CSS background 背景

background属性为元素添加背景效果。 它是以下属性的简写&#xff0c;按顺序为&#xff1a; background-colorbackground-imagebackground-repeatbackground-attachmentbackground-position 以下所有示例中的花花.jpg图片的大小是4848。 1 background-color background-col…

解决docker无法执行定时任务问题

背景 在docker里面想创建定时任务&#xff0c;但是发现时间到了并没有执行&#xff0c;第一时间想到应该是没有开启crond服务&#xff0c;然后执行systemctl status crond.service报错如下所示&#xff1a; System has not been booted with systemd as init system (PID 1).…

ReactNative 密码生成器实战

效果展示图 使用插件 Formik 负责表单校验、监听表单提交、数据校验错误信息展示 Yup 负责表单校验规则 分析页面 从上述的展示图我们可以看到的主要元素有&#xff1a;输入框、单选按钮和按钮。其中生成的密码长度不可能很大也不可能为负数和 0&#xff0c;所以我们可以限…

QGraphicsItem的缩放

QgarphicsItem是Qt视图体系中的项。QGraphicsItem本身是不支持鼠标拖动来缩放的&#xff0c;本文介绍如何通过更改鼠标事件来修改项的大小。下文代码实现的功能为&#xff1a;按住shift&#xff0c;再用鼠标拖动&#xff0c;可以改变Box的大小。 定义类Boxclass Box:public QG…

5.6 汇编语言:汇编高效数组寻址

数组和指针都是用来处理内存地址的操作&#xff0c;二者在C语言中可以互换使用。数组是相同数据类型的一组集合&#xff0c;这些数据在内存中是连续存储的&#xff0c;在C语言中可以定义一维、二维、甚至多维数组。多维数组在内存中也是连续存储的&#xff0c;只是数据的组织方…

解决问题:如何在 Git 中查看提交历史

可以使用以下命令查看 Git 中的提交历史&#xff1a; git log这将显示当前分支上的所有提交历史。每个提交的输出包括提交哈希&#xff08;SHA-1 值&#xff09;、作者、日期和提交注释。 您也可以添加一些选项&#xff0c;以获取更详细的提交历史&#xff1a; --oneline 显示…

idea的断点调试

1、行断点 首先在代码的最左侧点击会显示红色的圆圈 第二步在main方法中右键选中debug run进行运行 会出现下面图片的情况 出现上图之后&#xff0c;点击console 下一步 这个时候就可以看到调试的结果了 6、方法调用栈&#xff1a;这里显示了该线程调试所经过的所有方法&…

“深入解析JVM内部结构与工作原理:揭秘Java虚拟机的奥秘“

标题&#xff1a;深入解析JVM内部结构与工作原理&#xff1a;揭秘Java虚拟机的奥秘 摘要&#xff1a;本文将深入探讨Java虚拟机&#xff08;JVM&#xff09;的内部结构和工作原理&#xff0c;帮助开发者更好地理解JVM的运行机制&#xff0c;从而提高Java程序的性能和稳定性。 …

C语言小白急救 指针进阶讲解1

文章目录 指针一、 字符指针二、 指针数组三、数组指针1.数组的地址2.数组指针3.数组指针的应用 四、数组参数、指针参数1. 一维数组传参2.二维数组传参3.一级指针传参4.二级指针传参 五、函数指针1.函数的地址2.函数指针3.练习 指针 指针的概念&#xff1a; 1.指针就是个变量…

Redis性能配置优化

1、内存优化 Redis的性能取决于可用内存的大小。如果内存不足&#xff0c;Redis将开始交换&#xff08;swap&#xff09;&#xff0c;这会极大影响性能。因此&#xff0c;首先我们需要确保Redis所用内存的数量合理。 对于合理的内存使用&#xff0c;我们需要对Redis的maxmemory…

跨越边界:从前端切图仔走进iOS开发(Swift版--上集)

本文简介 点赞 关注 收藏 学会了 本文将以前端开发者的视角&#xff0c;和各位工友进入iOS开发的世界。 本文以实战为导向&#xff0c;快速掌握iOS开发这个技能。 无论你是想要扩展技能领域&#xff0c;还是对iOS开发充满好奇&#xff0c;花一个下午学习本文都能打开iOS开…

微服务中间件--http客户端Feign

http客户端Feign http客户端Feigna.Feign替代RestTemplateb.自定义Feign的配置c.Feign的性能优化d.Feign的最佳实践分析e.Feign实现最佳实践(方式二) http客户端Feign a.Feign替代RestTemplate 以前利用RestTemplate发起远程调用的代码&#xff1a; String url "http:…

【ARM】Day9 cortex-A7核I2C实验(采集温湿度)

1. 2、编写IIC协议&#xff0c;采集温湿度值 iic.h #ifndef __IIC_H__ #define __IIC_H__ #include "stm32mp1xx_gpio.h" #include "stm32mp1xx_rcc.h" #include "led.h" /* 通过程序模拟实现I2C总线的时序和协议* GPIOF ---> AHB4* I2C1_S…

Baidu World 2023,定了!

1. 定了&#xff0c;Baidu World 2023 终于定了&#xff0c;今年的 Baidu World 将会于 2023-10-17 日在北京首钢园正式召开&#xff0c;主题为『生成未来 / PROMPT THE WORLD』&#xff0c;这也是近4年来 Baidu World 再次恢复线下举行。 有些小伙伴们如果还不知道什么是 Baid…

tda4 videnc-test-app: CONTINUOUS and STEPWISE FRAMEINTERVALS not supported

/* videnc-test-app */ https://git.ti.com/cgit/jacinto7_multimedia/ git clone https://git.ti.com/git/jacinto7_multimedia/videnc-test-app.git // 编译 ./autogen.sh ./configure --enable-maintainer-mode --buildi386-linux --hostaarch64-none-linux CC/home/share…