微服务 Eureka

news2024/10/2 3:32:22

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 {

    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private 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 {

    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private 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.coloradmin.cn/o/919401.html

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

相关文章

WSL2 window上高效运行Linux

1 WSL及优势 1.1 WSL简介 WSL&#xff08;Windows Subsystem for Linux&#xff09;是Windows操作系统中的一个功能&#xff0c;它允许用户在Windows环境下运行Linux应用程序。WSL提供了一个与Linux内核兼容的系统调用转发层&#xff0c;使得Linux二进制文件可以在Windows上直…

qt读取图像并且调整大小,避免撑爆qlable控件

qt读取图像并且调整大小&#xff0c;避免撑爆qlable控件 方式使用方式 方式 通过设置QLable的对齐方式来设置图片的对齐方式&#xff0c;自由的控制图片是显示在表格项的上下左右。 代码如下&#xff1a;QLabel *lable new QLabel(); //创建lable lable->setPixm…

stm32之16.外设定时器——TIM3

----------- 源码 void tim3_init(void) {NVIC_InitTypeDef NVIC_InitStructure;TIM_TimeBaseInitTypeDef TIM_TimeBaseStructure;//使能TIM3的硬件时钟RCC_APB1PeriphClockCmd(RCC_APB1Periph_TIM3,ENABLE);//配置TIM3的定时时间TIM_TimeBaseStructure.TIM_Period 10000-1…

rabbitmq卸载重写安装3.8版本

卸载之前的版本的rabbitmq 卸载rabbitmq 卸载前先停止rabbitmq服务 /usr/lib/rabbitmq/bin/rabbitmqctl stop查看rabbitmq安装的相关列表 yum list | grep rabbitmq卸载rabbitmq相关内容 yum -y remove rabbitmq-server.noarch 卸载erlang 查看erlang安装的相关列表 …

详细介绍线程池的使用原理、参数介绍、优点、常见构造方法、使用案例、模拟实现

前言 创建和销毁一个线程时&#xff0c;这点损耗是微不足道的&#xff0c;但是当需要频繁的创建和销毁多个线程时&#xff0c;这个成本是不可忽视的&#xff0c;于是就有大佬创建了线程池&#xff0c;借助线程池来减少其中的成本。 目录 前言 一、线程池的使用原理 二、线程…

[解决方案]Antd TreeSelect/Select placeholder失效

&#x1f50e;嘿&#xff0c;这里是慰慰&#x1f469;&#x1f3fb;‍&#x1f393;&#xff0c;会发各种类型的文章&#xff0c;智能专业&#xff0c;从事前端&#x1f43e; &#x1f389;如果有帮助的话&#xff0c;就点个赞叭&#xff0c;让我开心一下&#xff01;&#x1f…

【开个空调】语音识别+红外发射

废话少说&#xff0c;直接上空调板子&#xff1a;YAPOF3。红外接收发射模块用的某宝上发现的YF-33(遗憾解码还没搞清楚&#xff0c;不然做个lirc.conf功能才多)。最后是语音识别用的幻尔的&#xff0c;某宝自然也有&#xff0c;它是个i2c的接口。 本篇胡说八道其实纯粹为了留个…

暴力匹配或KMP算法解决字符串匹配问题

字符串匹配问题 1. 字符串匹配问题2. 解决方案2.1 暴力匹配算法2.1.1 算法步骤2.1.2 代码实现 2.2 KMP算法2.2.1 算法步骤2.2.2 next数组计算2.2.2 代码实现 3. 真题3.1 力扣 28. 找出字符串中第一个匹配项的下标3.2 力扣 459. 重复的子字符串3.3 NC149 kmp算法3.4 KMP算法 1. …

opencv进阶18-基于opencv 决策树导论

1. 什么是决策树&#xff1f; 决策树是最早的机器学习算法之一&#xff0c;起源于对人类某些决策过程 的模仿&#xff0c;属于监督学习算法。 决策树的优点是易于理解&#xff0c;有些决策树既可以做分类&#xff0c;也可以做回归。在排名前十的数据挖掘算法中有两种是决策树[1…

火山引擎发布自研视频编解码芯片

2023年8月22日&#xff0c;火山引擎视频云宣布其自研的视频编解码芯片已成功出片。经验证&#xff0c;该芯片的视频压缩效率相比行业主流硬件编码器可提升30%以上&#xff0c;未来将服务于抖音、西瓜视频等视频业务&#xff0c;并将通过火山引擎视频云开放给企业客户。 火山引…

【附安装包】Tecplot 360 EX2022安装教程

软件下载 软件&#xff1a;Tecplot 360版本&#xff1a;2022语言&#xff1a;英文大小&#xff1a;388.97M安装环境&#xff1a;Win11/Win10/Win8/Win7硬件要求&#xff1a;CPU2.5GHz 内存4G(或更高&#xff09;下载通道①百度网盘丨64位下载链接&#xff1a;https://pan.baid…

SQL注入之报错注入

文章目录 报错注入是什么&#xff1f;报错注入获取cms账号密码成功登录 报错注入是什么&#xff1f; 在注入点的判断过程中&#xff0c;发现数据库中SQL 语句的报错信息&#xff0c;会显示在页面中&#xff0c;因此可以利用报错信息进行注入。 报错注入的原理&#xff0c;就是在…

uniapp 使用permission获取录音权限

使用前&#xff0c;需要先配置权限 android.permission.RECORD_AUDIO

wazhu配置以及漏洞复现

目录 1.wazhu配置 进入官网下载 部署wazhu 修改网络适配器 重启 本地开启apache wazhu案例复现 前端页面 执行 1.wazhu配置 进入官网下载 Virtual Machine (OVA) - Installation alternatives (wazuh.com) 部署wazhu 修改网络适配器 重启 service network restart 本地…

Datawhale AI夏令营 - 用户新增预测挑战赛 | 学习笔记

数据分析与可视化 为了拟合出更好的结果就要了解训练数据之间的相互关系&#xff0c;进行数据分析是必不可少的一步 导入必要的库 # 导入库 import pandas as pd import numpy as np import matplotlib.pyplot as plt import seaborn as sns pandas库是一个强大的分析结构化…

Python框架【自定义过滤器、自定义数据替换过滤器 、自定义时间过滤器、选择结构、选择练习、循环结构、循环练习、导入宏方式 】(三)

&#x1f44f;作者简介&#xff1a;大家好&#xff0c;我是爱敲代码的小王&#xff0c;CSDN博客博主,Python小白 &#x1f4d5;系列专栏&#xff1a;python入门到实战、Python爬虫开发、Python办公自动化、Python数据分析、Python前后端开发 &#x1f4e7;如果文章知识点有错误…

【OpenMp】openmp库的介绍及安装

目录 什么是OpenMPOpenMP的工作原理Amdahl 定律Gustafson 定律openmp的库在ubuntu下的编译 什么是OpenMP OpenMP&#xff08;Open Multi-Processing&#xff09;是一种并行编程框架&#xff0c;用于在共享内存系统中实现并行计算。它是GCC编译器的一部分&#xff0c;提供了一组…

向量检索:基于ResNet预训练模型构建以图搜图系统

1 项目背景介绍 以图搜图是一种向量检索技术&#xff0c;通过上传一张图像来搜索并找到与之相关的其他图像或相关信息。以图搜图技术提供了一种更直观、更高效的信息检索方式。这种技术应用场景和价值非常广泛&#xff0c;经常会用在商品检索及购物、动植物识别、食品识别、知…

leetcode48. 旋转图像(java)

旋转图像 题目描述旋转技巧上期经典算法 题目描述 难度 - 中等 原题链接 - 旋转图像 给定一个 n n 的二维矩阵 matrix 表示一个图像。请你将图像顺时针旋转 90 度。 你必须在 原地 旋转图像&#xff0c;这意味着你需要直接修改输入的二维矩阵。请不要 使用另一个矩阵来旋转图像…

StreamPark

1、StreamPark的标语 一个神奇的框架&#xff0c;让流处理更简单 2、StreamPark的前世今生 早期用名streamx&#xff0c;加入apache孵化器之后更名为StreamPark 3、StreamPark可以为你提供什么 降低学习成本、开发门槛&#xff0c;让开发者只用关心核心的业务 简单来说&#xf…