实用篇-Eureka注册中心

news2024/11/18 9:23:20

一、提供者与消费者

服务提供者：一次业务中，被其他微服务调用的服务。(提供接口给其他微服务)

服务消费者：一次业务中，调用其他微服务的服务。(调用其他微服务提供的接口)

例如前面的案例中，order-service微服务是服务提供者，user-service微服务是服务消费者

思考：

如果服务A调用服务B，服务B调用服务C，那么服务B是什么角色 ?

一个服务既可以是提供者，也可以是消费者。所以服务B相对于服务A而言，服务B是提供者。服务B相对于服务C而言，服务B是消费者

二、Eureka原理分析

以上面的案例为例，order-service微服务和user-service微服务之间，服务调用出现的问题如下:

  • order-service去向user-service发送请求，使用的是硬编码，也就是 "http://localhost:8081/user/"+order.getUserId();
  • 硬编码每次修改需要重新打包
  • 如果user-service微服务(提供者)部署成了多实例，形成集群来应对并发，那么order-service微服务(消费者)硬编码到底是写哪个实例的地址
  • 即使你知道这些实例的地址，那么如何挑选其中一台实例来使用呢

Eureka原理

  • Eureka架构中，微服务角色有两类，一个是EurekaServer叫做服务端(注册中心)。作用是记录服务信息，心跳监控；一个是EurekaClient叫做客户端，也就是服务的提供者/消费者
  • 可以把注册中心理解为Key，我们的微服务项目理解为Value，Eureka理解为字典
  • 当微服务项目(例如user-service)启动时，会主动把自己(user-service微服务)的信息注册给注册中心
  • 注册到注册中心的微服务会每隔30秒，向注册中心发起心跳，证明自己还在健康运行
  • 多个微服务的话，注册中心就会有多个Value，一个Value就是一个微服务的信息，这些Value会放到一个列表里面
  • 当其它微服务(例如order-service)要使用某个微服务(例如user-service)时，这个微服务(order-service就会向注册中心去拉取对应微服务(user-service)的信息
  • 当注册中心有多个提供者(微服务)，那么消费者是通过负载均衡算法，在注册中心的服务列表中挑选一个

三、搭建Eureka

步骤有三步：

1、搭建注册中心(EurekaServer)。搭建EurekaServer注册中心，也就是创建一个项目(在cloud-demo项目内部创建eureka-server项目)，把这个项目做成注册中心

2、服务注册。将user-service(前面导入的服务拆分Demo)、order-service(前面导入的服务拆分Demo)都注册到eureka

3、服务发现。在order-service中完成服务拉取，然后通过负载均衡挑选一个服务，实现远程调用

1. 搭建EurekaServer注册中心

第一步: 创建一个新的项目，作为独立的微服务，用于搭建Eureka，也就是在cloud-demo工程里面新建eureka-server微服务项目

第二步: 在eureka-server微服务的pom.xml添加如下，无需配置版本，因为父工程已经配置

<?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">
    <parent>
        <artifactId>cloud-demo</artifactId>
        <groupId>cn.itcast.demo</groupId>
        <version>1.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>eureka-server</artifactId>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

    <!--添加注册中心的依赖坐标-->
    <dependencies>
<!--        eureka服务端-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
    </dependencies>

</project>

第三步: 在eureka-server微服务的src/main/java目录新建cn.itcast.eureka.EurekaApplication类，写入如下，注意加上@EnableEurekaServer注解，启动Eureka

package cn.itcast.eureka;


import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

@EnableEurekaServer
@SpringBootApplication
public class EurekaApplication {
     public static void main(String[] args) {
          SpringApplication.run(EurekaApplication.class,args);
     }
}

第四步: 在eureka-server微服务的src/main/resources目录新建File，名字为application.yml，写入如下

server:
  # 服务端口
  port: 8686

spring:
  application:
    # eureka的服务名称，因为eureka自己也是一个服务，也需要注册服务
    name: eurekaserver

eureka:
  client:
    service-url:
      # eureka的服务地址。如果有多个的话，逗号隔开
      defaultZone: http://localhost:8686/eureka

第五步: 启动eureka-server微服务。也就是运行EurekaApplication类，浏览器访问 http://localhost:8686 

2. 服务注册

这里我们实现把user-service和order-service注册到Eureka，只演示user-service

第一步：在user-service项目引入spring-cloud-start-netfix-eureka-client依赖，表示客户端

<!--引入Eureka客户端依赖-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

 第二步: 在user-service微服务的application.yml添加如下

spring:
  # Eureka相关配置
  application:
    # user的服务名称。也就是这个user-service注册到Eureka之后，这个user-service会叫什么名字
    name: userservice

eureka:
  client:
    service-url:
      # eureka的服务地址。如果有多个的话，逗号隔开。也就是把当前这个user-service微服务注册给哪个Eureka
      defaultZone: http://localhost:8686/eureka

 添加完后，user-service的application.yml文件如下，注意application是spring下的配置，要写在spring的下面

server:
  port: 8081
spring:
  datasource:
    url: jdbc:mysql://localhost:3306/cloud_user?useSSL=false
    username: root
    password:
    driver-class-name: com.mysql.jdbc.Driver
    # Eureka相关配置
  application:
    # user的服务名称。也就是这个user-service注册到Eureka之后，这个user-service会叫什么名字
      name: UserService
mybatis:
  type-aliases-package: cn.itcast.user.pojo
  configuration:
    map-underscore-to-camel-case: true
logging:
  level:
    cn.itcast: debug
  pattern:
    dateformat: MM-dd HH:mm:ss:SSS
    
eureka:
  client:
    service-url:
      # eureka的服务地址。如果有多个的话，逗号隔开。也就是把当前这个user-service微服务注册给哪个Eureka
      defaultZone: http://localhost:8686/eureka

同理，order-service也做相同操作，只是服务名修改一下 

第三步:

启动user-service。也就是运行UserApplication类，浏览器访问 http://localhost:8686，就可以看到user-service已经添加到Eureka里面

启动order-service。也就是运行OrderApplication类，浏览器访问 http://localhost:8686，就可以看到order-service已经添加到Eureka里面

当运行程序出现找不到或无法加载主类，可以尝试install一下maven工程，实在不行就全部删掉重新写一遍

IDEA复制服务实例 

上面我们启动了一个UserService服务实例，那么我们想再启动一个UserService实例，向Eureka注册多个服务，实现如下

第一步：右键服务然后点击复制配置 

第二步：设置服务名称和端口

 第三步：启动服务

第四步：打开Eureka注册中心，看到UserService的服务列表中增加了一个

也就是说，UserService的服务实例可以注册多个，当消费者想要获取服务时，可以通过负载均衡策略向服务实例发起请求 

3. 服务发现

服务发现也叫服务拉取，我们需要在order-service完成服务拉取。服务拉取是基于服务名称获取服务列表，然后再对服务列表做负载均衡

首先回想一下，前面的远程调用，我们实现了在订单项目(也就是现在的order-service微服务)去查询用户项目(也就是现在的user-service微服务)的案例需求

当时是在order-service里面使用url请求ip地址的方式，去请求user-service，从而获取user-service的用户信息

那么，学习了上面的Eureka之后，并且我们已经把order-service和user-service注册到注册中心(eureka-server)了，所以就可以在order-service里面，通过 '服务发现' 去获取user-service里面的用户信息

具体操作也非常简单，也是使用url请求的方式，但请求的路径不是ip，而是服务名称

代码实现

第一步: 在order-server微服务中的src/main/java/cn.itcast.order/service/OrderService类，修改访问的url路径，用服务名代替ip、端口。修改为如下

package cn.itcast.order.service;

import cn.itcast.order.mapper.OrderMapper;
import cn.itcast.order.pojo.Order;
import cn.itcast.order.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import java.sql.PreparedStatement;

@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请求，查询用户
        //2.1 url路径
        String url = "http://UserService:8081/user/" + order.getUserId();
        //这个方法第一个参数是访问路径，第二个参数是把响应得到的Json数据封装成实体类对象
        User user = restTemplate.getForObject(url, User.class);
        //3.封装user到Order
        order.setUser(user);
        // 4.返回
        return order;
    }
}

第二步: 负载均衡。在order-server微服务中的OrderApplication引导类修改为如下，主要是给RestTemplate加上@LoadBalanced注解

package cn.itcast.order;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@MapperScan("cn.itcast.order.mapper")
@SpringBootApplication
public class OrderApplication {

    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class, args);
    }

    /**
     * 创建RestTemplate并注入Spring容器
     * @return
     */
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

}

第三步: 重新启动在order-server微服务的OrderApplication引导类，浏览器输入

http://localhost:8080/order/101，并向user-service微服务发送多次请求

总结：服务发现，就是将请求url中的ip地址替换成服务名称，然后根据负载均衡策略去调用服务

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

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

相关文章

系列七、动态代理

系列七、动态代理

一、概述 二、Jdk动态代理案例 2.1、Star /*** Author : 一叶浮萍归大海* Date: 2023/10/27 17:16* Description:*/ public interface Star {/*** 唱歌* param name 歌曲名字* return*/String sing(String name);/*** 跳舞*/void dance(); } 2.2、BigStar /*** Author : 一叶…
阅读更多...
AcWing 1.2.1 最长上升子序列模型 + 动态规划 + 图解（详细）

AcWing 1.2.1 最长上升子序列模型 + 动态规划 + 图解（详细）

&#xff08;1&#xff09;acwing 4557. 最长上升子序列 4557. 最长上升子序列 - AcWing题库 给定一个长度为 N 的整数序列 a1,a2,…,aN。请你计算该序列的最长上升子序列的长度。上升子序列是指数值严格单调递增的子序列 输入格式 第一行包含整数 N第二行包含 N个整数 a1,a…
阅读更多...
LLM系列 | 23：多模态大模型：浦语·灵笔InternLM-XComposer解读、实战和思考

LLM系列 | 23：多模态大模型：浦语·灵笔InternLM-XComposer解读、实战和思考

引言 ​简介 模型解读 模型架构 训练 实战 环境准备 本地实测 服务部署 总结 引言 谁念西风独自凉&#xff0c;萧萧黄叶闭疏窗&#xff0c;沉思往事立残阳。 Created by DALLE 3 小伙伴们好&#xff0c;我是《小窗幽记机器学习》的小编&#xff1a;卖热干面的小女孩…
阅读更多...
在Golang中理解错误处理

在Golang中理解错误处理

处理Golang中临时错误和最终错误的策略和示例 作为一名精通Golang的开发人员&#xff0c;您了解有效的错误处理是编写健壮可靠软件的关键因素。在复杂系统中&#xff0c;错误可能采取各种形式&#xff0c;包括临时故障和最终失败。在本文中&#xff0c;我们将探讨处理Golang中…
阅读更多...
源码解析SpringMVC之RequestMapping注解原理

源码解析SpringMVC之RequestMapping注解原理

1、启动初始化 核心&#xff1a;得到应用上下文中存在的全部bean后依次遍历&#xff0c;分析每一个目标handler & 目标方法存在的注解RequestMapping&#xff0c;将其相关属性封装为实例RequestMappingInfo。最终将 uri & handler 之间的映射关系维护在类AbstractHand…
阅读更多...
Java入门篇 之 数据类型（简单介绍）

Java入门篇 之 数据类型（简单介绍）

博主回归学习状态的第三篇文章&#xff0c;希望对大家有所帮助 今日份励志文案:你若决定灿烂&#xff0c;山无遮&#xff0c;海无拦 加油&#xff01; Java中一共存在2种数据类型 1 . 基本数据类型,基本数据类型四种和八种之说(具体看下图) 四种说的是&#xff0c;整数型&…
阅读更多...
vscode打开settings.json方法

vscode打开settings.json方法

cmd shift p&#xff0c;输入setting Open Workspace Settings 也会打开UI设置界面&#xff1b; Open User Settings (JSON) 会打开用户设置 settings.json 文件&#xff1b; Open Workspace Settings (JSON) 会打开工作区设置 settings.json 文件 vscode存在两种设置 sett…
阅读更多...
损失函数和目标函数|知识补充

损失函数和目标函数|知识补充

这张图中&#xff0c;横坐标size表示房屋的大小&#xff0c;纵坐标price表示房屋的价格&#xff0c;现在需要建立模型来表示两者之间的关系。 对于给定的输入x&#xff0c;模型会有一个输出f(x)&#xff0c;用一个函数来度量拟合的程度&#xff0c;也就是真实值和预测值之间的…
阅读更多...
前端工程化面试题及答案【集合】

前端工程化面试题及答案【集合】

前言&#xff1a; 欢迎浏览和关注本专栏《 前端就业宝典 》&#xff0c; 不管是扭螺丝还是造火箭&#xff0c; 多学点知识总没错。 这个专栏是扭螺丝之上要造火箭级别的知识&#xff0c;会给前端工作学习的小伙伴带来意想不到的帮助。 本专栏将前端知识拆整为零&#xff0c;主要…
阅读更多...
工业相机常见的工作模式、触发方式

工业相机常见的工作模式、触发方式

参考&#xff1a;机器视觉——工业相机的触发应用(1) - 知乎 工业相机常见的工作模式一般分为&#xff1a; 触发模式连续模式同步模式授时同步模式 触发模式&#xff1a;相机收到外部的触发命令后&#xff0c;开始按照约定时长进行曝光&#xff0c;曝光结束后输出一帧图像。…
阅读更多...
子集生成算法：给定一个集合，枚举所有可能的子集

子集生成算法：给定一个集合，枚举所有可能的子集

给定一个集合&#xff0c;枚举所有可能的子集。 &#xff08;为简单起见&#xff0c;本文讨论的集合中没有重复元素&#xff09; 1、方法一&#xff1a;增量构造法 第一种思路是一次选出一个元素放到集合中&#xff0c;程序如下&#xff1a; void print_subset(int n, int …
阅读更多...
C++系列之list的模拟实现

C++系列之list的模拟实现

&#x1f497; &#x1f497; 博客:小怡同学 &#x1f497; &#x1f497; 个人简介:编程小萌新 &#x1f497; &#x1f497; 如果博客对大家有用的话&#xff0c;请点赞关注再收藏 &#x1f31e; list的节点类 template struct list_Node { public: list_Node* _prev; list_…
阅读更多...
Tomcat服务部署和优化

Tomcat服务部署和优化

目录 一、Tomcat&#xff1a; 1、Tomcat作用&#xff1a; 2、Tomcat的核心组件&#xff1a; 3、servlet作用&#xff1a; 4、Tomcat的核心功能&#xff1a; 二、tomcat配置 一、Tomcat&#xff1a; 是一个开源的web应用服务器&#xff0c;nginx主要处理静态页面&#xff…
阅读更多...
不再受害：如何预防和应对.mallab勒索病毒攻击

不再受害：如何预防和应对.mallab勒索病毒攻击

导言&#xff1a; 我们的数据成了我们的珍宝&#xff0c;但也成了黑客们追逐的目标。其中&#xff0c;.mallab勒索病毒就是一个充满阴谋和神秘的数字威胁&#xff0c;它采用高度复杂的方法将您的数据锁在数字牢笼中。本文91数据恢复将深入探讨.mallab勒索病毒的起源、工作方式…
阅读更多...
【RabbitMQ 实战】12 镜像队列

【RabbitMQ 实战】12 镜像队列

一、镜像队列的概念 RabbitMQ的镜像队列是将消息副本存储在一组节点上&#xff0c;以提高可用性和可靠性。镜像队列将队列中的消息复制到一个或多个其他节点上&#xff0c;并使这些节点上的队列保持同步。当一个节点失败时&#xff0c;其他节点上的队列不受影响&#xff0c;因…
阅读更多...
视频转换器WinX HD Video Converter mac中文特点介绍

视频转换器WinX HD Video Converter mac中文特点介绍

WinX HD Video Converter mac是一款功能强大的视频转换器&#xff0c;它可以将各种不同格式的视频文件转换为其他视频格式&#xff0c;以便用户在各种设备上进行播放。WinX HD Video Converter是一个功能强大、易于使用的视频转换器&#xff0c;适用于各种类型的用户&#xff0…
阅读更多...
可图性判断（图论）

可图性判断（图论）

如图所示&#xff1a; 1.去arr[i]首元素&#xff0c; 后面arr[i]个元素减一 2.排序&#xff0c;以此类推 3.最后如果出现负数则不可图 4.最后元素为0&#xff0c;则可图 问题 L: Degree Sequence of Graph G代码如下&#xff1a;
阅读更多...
C#版字节跳动SDK - SKIT.FlurlHttpClient.ByteDance

C#版字节跳动SDK - SKIT.FlurlHttpClient.ByteDance

前言 在我们日常开发工作中对接第三方开放平台&#xff0c;找一款封装完善且全面的SDK能够大大的简化我们的开发难度和提高工作效率。今天给大家推荐一款C#开源、功能完善的字节跳动SDK&#xff1a;SKIT.FlurlHttpClient.ByteDance。 项目官方介绍 可能是全网唯一的 C# 版字节…
阅读更多...
基于nodejs+vue全国公考岗位及报考人数分析

基于nodejs+vue全国公考岗位及报考人数分析

目 录 摘 要 I ABSTRACT II 目 录 II 第1章 绪论 1 1.1背景及意义 1 1.2 国内外研究概况 1 1.3 研究的内容 1 第2章 相关技术 3 2.1 nodejs简介 4 2.2 express框架介绍 6 2.4 MySQL数据库 4 第3章 系统分析 5 3.1 需求分析 5 3.2 系统可行性分析 5 3.2.1技术可行性&#xff1a;…
阅读更多...
iOS的应用生命周期

iOS的应用生命周期

在iOS的原生开发中&#xff0c;我们需要特别关注两个东西&#xff1a;AppDelegate和ViewController。我们主要的编码工作就是在AppDelegate和ViewControlle这两个类中进行的。它们的类图如下图所示&#xff1a; AppDelegate是应用程序委托对象&#xff0c;它继承了UIResponder类…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023