SpringCloud(二) Eureka注册中心的使用

在SpringCloud(一)中,我们学会了使用RestTemplate进行远程调用,但是在调用user-service时候需要在order-service中发送http请求,请求中需要书写对应微服务的ip和端口号,十分不方便,如果此时有多个user-service实例的话,就不知道调用哪个了(除非每次调用的时候都对ip和端口号进行调整),所以本篇博客将介绍一个专门用来进行服务注册的组件----Eureka.

目录

一, Eureka的机构和作用

1.1 RestTemplate存在的问题

1.2 Eureka的结构和作用

二, Eureka的使用

2.1 Eureka的使用步骤

 2.2 搭建eureka-server

1, 创建eureka-server服务

 2, 引入eureka依赖

3, 编写启动类

4, 编写配置文件 

5, 启动eureka-server

2.3 服务注册

1, 引入依赖

2, 配置文件 

3, 启动多个user-service实例

2.4 服务发现

1, 引入依赖

2, 配置文件

3, 服务拉取和负载均衡

2.5 Eureka的使用示例


一, Eureka的机构和作用

1.1 RestTemplate存在的问题

假如我们的服务提供者user-service部署了多个实例,如图所示:

大家需要思考几个问题:

  • order-service在发起远程调用的时候,该如何得知user-service实例的ip和端口?
  • 有多个user-service实例地址,order-service调用时该如何选择?
  • order-service如何得知某个user-service实例是否依然健康,是不是已经宕机? 

1.2 Eureka的结构和作用

上述问题都需要利用SpringCloud中的注册中心来解决,其中最广为人知的注册中心就是Eureka,Eureka的结构如图所示:

order-service如何得知user-service实例地址?

获取地址信息的流程如下:

  • user-service服务实例启动后,将自己的信息注册到eureka-server(Eureka服务端),这个叫服务注册;
  • eureka-server保存服务名称到服务实例地址列表的映射关系;
  • order-service根据服务名称,拉取实例地址列表,这个叫服务发现或服务拉取.

order-service如何从多个user-service实例中选择具体端的实例?

  • order-service从实例列表中利用负载均衡算法选中其中一个实例地址;
  • 向该实例地址发起远程调用.

order-service如何得知某个user-service实例是否依然健康,是不是已经宕机?

  •  user-service会每隔一段时间(默认是30s)向eureka-service发起请求,报告自己状态,称为心跳;
  • 当超过一定时间没有心跳时,eureka-server会认为微服务实例故障,将该实例从服务列表中剔除;
  • order-service拉取服务时,就能将故障实例排除了. 

一个微服务,既可以是服务提供者,又可以是服务消费者,因此eureka将服务注册,服务发现等功能统一封装到了eureka-client端.

二, Eureka的使用

2.1 Eureka的使用步骤

  

 2.2 搭建eureka-server

首先先注册eureka中心服务端,这必须是一个独立的微服务

1, 创建eureka-server服务

在cloud-demo父工程下,创建一个子模块:

 填写模块信息:

 

填写服务信息:

 2, 引入eureka依赖

引入SpringCloud为eureka提供的starter依赖:

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

3, 编写启动类

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

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

4, 编写配置文件 

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

server:
  port: 10086 //端口可以写成任意的 只要不冲突就行
spring:
  application:
    name: eureka-server
eureka:
  client:
    service-url: 
      defaultZone: http://127.0.0.1:10086/eureka

5, 启动eureka-server

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

看到一下页面表示启动成功:

2.3 服务注册

下面,将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

3, 启动多个user-service实例

为了演示一个服务有多个实例的场景,我们添加一个SpringBoot的启动装置,再启动一个user-service

首先,复制原来的user-service启动配置:

填写信息,使用不同的端口号:

 此时有两个user-service,端口号分别是8081和8082,启动两个实例:

 此时可以看到在eureka-server的管理页面中可以看到已经注册了两个user-service实例了.

2.4 服务发现

此时,我们将order-service的逻辑修改:向eureka-server拉取user-service的信息,实现发现服务.

1, 引入依赖

服务发现和服务注册统一封装在eureka-client依赖中,因此这一步与服务注册一致,在order-service的pom文件中,引入eureka-client依赖:

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

2, 配置文件

服务发现也需要eureka地址,因此第二步与服务注册一致,都是配置eureka信息,在order-service中修改application.yml文件,添加服务名称.eureka地址:

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

3, 服务拉取和负载均衡

启动order-service之后可以发现order-service也被注册到了eureka-server中:

此时我们就可以去eureka-server中拉取user-service服务的实力列表,并且实现负载均衡,这一系列的操作只需要添加一些注解即可

负载均衡内容详细博客:SpringCloud(三) Ribbon负载均衡-CSDN博客

在order-service的OrderApplication中,给RestTemplate这个Bean添加一个@LoadBalance注解:

修改order-service服务中的cn.itcast.order.service包下的OrderService类中的queryOrderById方法,修改访问的url路径,用服务名代替ip,端口:

Spring会自动帮我们从eureka-server端,根据userservice这个服务名称,获取实例列表,而后完成负载均衡.

2.5 Eureka的使用示例

此时,我们已经将order-service和user-service都注册到了eureka-server中,就可以通过order-service发现服务从而给user-service服务发送http请求进而获取到用户的信息:

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

【java零基础入门到就业】第四天:Notepad++软件的下载和安装

文章目录 Notepad软件简介下载安装 Notepad软件 简介 Notepad&#xff08;又称Notepad Plus Plus&#xff09;是一款免费的文本编辑器&#xff0c;是Windows操作系统下非常受欢迎的开源软件。它提供了许多强大的功能&#xff0c;适合用于编写各种编程语言的源代码、编辑文本文…

Redis缓存穿透、击穿、雪崩问题原理和解决方案

目录 一、Redis缓存穿透1.1、缓存穿透原理1.2、缓存穿透代码演示1.3、缓存穿透解决方案解决方案一&#xff08;数据库中查询不到数据也将key进行缓存&#xff09;解决方案二&#xff08;使用布隆过滤器&#xff09; 二、Redis缓存击穿&#xff08;缓存失效&#xff09;三、Redi…

Notes/Domino中的JVM版本

大家好&#xff0c;才是真的好。 这篇内容主要写给同时关注Domino和Java的技术人员。 很多人都知道&#xff0c;从Notes/Domino R5&#xff08;1999年&#xff09;版本&#xff0c;开始自带一个Java虚拟机&#xff0c;用来支持Java应用运行。但很多人不知道&#xff0c;这个J…

【c++|opencv】二、灰度变换和空间滤波---4.高斯滤波

every blog every motto: You can do more than you think. https://blog.csdn.net/weixin_39190382?typeblog 0. 前言 1. 高斯滤波 #include <iostream> #include <opencv2/opencv.hpp> #include"Salt.h"using namespace std; using namespace cv;/…

中国人民大学与加拿大女王大学金融硕士——人生是旷野,不是一条轨道

在这个瞬息万变的时代&#xff0c;我们每个人都像是一颗流星&#xff0c;在宇宙中独自燃烧。我们每个人都有自己的梦想&#xff0c;自己的追求&#xff0c;自己的道路。然而&#xff0c;很多时候&#xff0c;我们却发现自己被现实的轨道所束缚&#xff0c;无法自由地追求自己的…

【一、http】go的http基本请求方法

1、http的基本请求 package mainimport ("bytes""fmt""io""net/http""net/url" )func post(){r, err : http.Post("http://httpbin.org/post", "", nil)if err ! nil {fmt.Println("ss")}de…

电子凭证会计数据标准试点深化后,企业管理的关键点在于什么?

为了加快建设数字中国、发展数字经济发展&#xff0c;并推动经济社会绿色化、低碳化发展&#xff0c;政府部门一直大力推动企业的数字化转型。 企业的经营活动也越来越活跃。企业在经营中产生了大量的票据&#xff0c;由于电子凭证分属不同的部门管理&#xff0c;数据不兼容&am…

竞赛选题 深度学习实现行人重识别 - python opencv yolo Reid

文章目录 0 前言1 课题背景2 效果展示3 行人检测4 行人重识别5 其他工具6 最后 0 前言 &#x1f525; 优质竞赛项目系列&#xff0c;今天要分享的是 &#x1f6a9; **基于深度学习的行人重识别算法研究与实现 ** 该项目较为新颖&#xff0c;适合作为竞赛课题方向&#xff0c…

IDEA远程调试代码

IDEA->RUN->Edit Configurations 端口随便选一个&#xff0c;选择调试模块&#xff0c;然后用IDEA生成的命令调试 java -agentlib:jdwptransportdt_socket,servery,suspendn,address*:8081 -jar backend-1.18.11.jar &

word插入图片不显示

段落格式要设置成非固定的。

约数之和 (普通快速幂求逆元做法)

假设现在有两个自然数 A 和 B&#xff0c;S 是 AB 的所有约数之和。 请你求出 Smod9901 的值是多少。 输入格式 在一行中输入用空格隔开的两个整数 A 和 B 。 输出格式 输出一个整数&#xff0c;代表 Smod9901 的值。 数据范围 0≤A,B≤5107 输入样例&#xff1a; …

【JavaEE初阶】 网络编程基础与Socket套接字

文章目录 &#x1f38b;网络编程基础&#x1f6a9;为什么需要网络编程&#xff1f;&#x1f6a9;什么是网络编程&#xff1f;&#x1f6a9;网络编程中的基本概念&#x1f4cc;发送端和接收端&#x1f4cc;请求和响应&#x1f4cc;客户端和服务端&#x1f4cc;常见的客户端服务端…

httpclient工具类(支持泛型转换)

1、网上搜到的httpclient工具类的问题&#xff1a; 1.1、如下图我们都能够发现这种封装的问题&#xff1a; 代码繁杂、充斥了很多重复性代码返回值单一&#xff0c;无法拿到对应的Java Bean对象及List对象集合实际场景中会对接大量第三方的OPEN API&#xff0c;下述方法的扩展…

二叉树OJ题汇总

本专栏内容为&#xff1a;leetcode刷题专栏&#xff0c;记录了leetcode热门题目以及重难点题目的详细记录 &#x1f493;博主csdn个人主页&#xff1a;小小unicorn ⏩专栏分类&#xff1a;Leetcode &#x1f69a;代码仓库&#xff1a;小小unicorn的代码仓库&#x1f69a; &…

奇偶校验码和循环冗余码

在数据链路层的传输中&#xff0c;1可能变成0&#xff0c;0可能变成1&#xff0c;这是比特差错。 为了应对比特差错&#xff0c;有两种方式&#xff0c;即自动重传请求ARQ&#xff08;Automatic Repeat-reQuest&#xff09;和前向纠错FEC&#xff08;Forward Error Correction&…

c++获取和设置环境变量

这个功能非常常用&#xff0c;但是容易忘记&#xff0c;这里做个记录。 注意&#xff0c;设置的环境变量只在当前进程中生效&#xff0c;所以在电脑中的环境变量设置区域看不到。 std::string env getenv("PATH");env "X:\\envtest";std::string newEnv…

亚马逊、美客多卖家测评:如何建立养号团队实现运营化式测评?

大家好&#xff0c;我是跨境电商测评养号7年从事经验的珑哥。养号环境软件开发&#xff0c;深度解决各跨境平台矩阵养号防关联、砍单、F号问题。关注珑哥解决更多跨境养号测评问题。 测评&#xff0c;相信这个词对于大部分跨境卖家来说&#xff0c;想必都不陌生&#xff0c;因…

LCR 166.珠宝的最高价值 + 动态规划 + 记忆化搜索 + 递推 + 空间优化

LCR 166. 珠宝的最高价值 - 力扣&#xff08;LeetCode&#xff09; 现有一个记作二维矩阵 frame 的珠宝架&#xff0c;其中 frame[i][j] 为该位置珠宝的价值。拿取珠宝的规则为&#xff1a; 只能从架子的左上角开始拿珠宝每次可以移动到右侧或下侧的相邻位置到达珠宝架子的右下…

什么是OTP认证?OTP认证服务器有哪些应用场景?

OTP是一次性密码&#xff0c;即只能使用一次的密码。它基于专门的算法&#xff0c;每隔60秒生成一个不可预测的随机数字组合。这种密码的有效期仅在一次会话或交易过程中&#xff0c;因此不容易受到重放攻击。在计算器系统或其他数字设备上&#xff0c;OTP是一种只能使用一次的…