Eureka是spring cloud中的一个负责服务注册与发现的组件。遵循着CAP理论中的A(可用性)P(分区容错性)。

一个Eureka中分为eureka server和eureka client。其中eureka server是作为服务的注册与发现中心。eureka client既可以作为服务的生产者,又可以作为服务的消费者。具体结构如下图:

上图中我们首先会启动一个或多个Eureka server,这些eureka server同步保留着所有的服务信息。然后我们启动不同的eureka client,向服务端发起服务注册和服务查询。不论我们是向那个eureka server进行的注册,最终都会同步给所有配置好的eureka server。我们获取的服务信息,也同样都是一致的。

eureka server实现

spring cloud是基于spring boot进行的开发,因此我们需要创建一个spring boot项目,同时在里面添加eureka server包。

        <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>

添加完成后,在我们的启动类中添加注解@EnableEurekaServer

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

然后是一些配置信息在配置文件中配置:

#服务端口
server.port=8077
#服务名称
spring.application.name=eureka-server
#服务地址
eureka.instance.hostname=localhost#不向注册中心注册自己
eureka.client.register-with-eureka=false
#取消检索服务
eureka.client.fetch-registry=false
#开启注册中心的保护机制,默认是开启
eureka.server.enable-self-preservation=true
#设置保护机制的阈值,默认是0.85。
eureka.server.renewal-percent-threshold=0.5#注册中心路径,如果有多个eureka server,在这里需要配置其他eureka server的地址,用","进行区分,如"http://address:8888/eureka,http://address:8887/eureka"
eureka.client.service-url.default-zone=http://${eureka.instance.hostname}:${server.port}/eureka

配置完成后,我们运行启动类,可以看到打印出来的信息里面,eureka server已经启动。

这个时候可以进入地址http://localhost:8077,查看注册中心:

eureka client服务注册

同样的先添加eureka client的包

        <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>

然后在启动类中添加注解@EnableEurekaClient。

@SpringBootApplication
// 注意:服务端配置的是EnableEurekaServer,客户端配置的是EnableEurekaClient
@EnableEurekaClient
public class UserServerApplication {public static void main(String[] args) {SpringApplication.run(UserServerApplication.class, args);}}

在这里我们可以创建一个controller,用来提供一个服务,并填写返回值。

@RestController
public class UserController {@GetMapping("users/{id}")public String getUser(@PathVariable("id") String id) {System.out.println("接收到请求[/users/" + id + "]");return "testUser";}}

在配置文件中添加配置信息:

#服务端口
server.port=7001
#服务名称
spring.application.name=user
#服务地址
eureka.instance.hostname=localhost#注册中心路径,表示我们向这个注册中心注册服务,如果向多个注册中心注册,用“,”进行分隔
eureka.client.serviceUrl.defaultZone=http://localhost:8077/eureka
#心跳间隔5s,默认30s。每一个服务配置后,心跳间隔和心跳超时时间会被保存在server端,不同服务的心跳频率可能不同,server端会根据保存的配置来分别探活
eureka.instance.lease-renewal-interval-in-seconds=5
#心跳超时时间10s,默认90s。从client端最后一次发出心跳后,达到这个时间没有再次发出心跳,表示服务不可用,将它的实例从注册中心移除
eureka.instance.lease-expiration-duration-in-seconds=10

然后我们运行启动类,查看打印出来的日志信息,红框内容表示用eureka注册服务user,状态为up。

这时我们再访问我们的注册中心地址:http://localhost:8077,里面已经有了一个服务实例USER了。

如果这个时候我们再把服务关掉,查看eureka server的控制台打印:

注意看时间,不是在我们关掉服务的时候立即检测出来,而是差不多120秒后,先打印一个WARN,服务USER已经超出过期时间。然后打印一个INFO,将服务USER的实例从注册中心移除。

eureka client服务消费者

上面我们创建了一个注册中心和一个注册的服务,下面我们再通过eureka client来调用所注册的服务。

在eureka中,实际上是不区分服务的消费者和服务生产者的,一个服务的消费者,同样也可以是一个服务的生产者。因此我们首先要做的就是再创建一个eureka client。这个enreka client命名为roleServer

创建好eureka client后,我们创建一个配置类,创建RestTemplate来进行服务间的连接

@Configuration
public class RestConfig {@Bean@LoadBalanced //负载均衡public RestTemplate restTemplate() {return new RestTemplate();}}

然后在Controller中进行服务的调用:

@RestController
public class RoleController {// 这里配置的是我们要调用的服务实例名,我们要调用USER服务,因此这里的地址是USERprivate String rest_url_prefix = "http://user";@Autowiredprivate RestTemplate restTemplate;@GetMapping("roles/{id}")public String getRole(@PathVariable("id") String id) {System.out.println("接收到请求[/roles/" + id + "]");// 调用USER服务中的/users/{id}服务return restTemplate.getForObject(rest_url_prefix + "/users/" + id, String.class);}}

配置完成,运行启动类,我们首先在服务注册中心可以看到这两个服务实例

我们访问ROLE服务中定义的请求路径:http://localhost:7003/roles/1,可以看到页面返回了我们在USER服务中的定义的返回值"testUser":

由此,我们的一个euraka注册中心、服务生产者、服务消费者均已经创建完成。

转载于:https://www.cnblogs.com/yxth/p/10845640.html

微服务Eureka使用详解相关推荐

  1. Apollo微服务配置中心详解

    Apollo微服务配置中心详解 前言 一.Apollo架构 (一)简介 (二)角色介绍 (三)服务端实现 (四)客服端实现 二.Apollo部署 (一)准备数据库 (二)配置服务 1. 手动部署 (1 ...

  2. java实现的微服务架构_详解Java 微服务架构

    一.传统的整体式架构 传统的整体式架构都是模块化的设计逻辑,如展示(Views).应用程序逻辑(Controller).业务逻辑(Service)和数据访问对象(Dao),程序在编写完成后被打包部署为 ...

  3. 首席架构师推荐:史上最全微服务架构简史详解!

    本文将介绍微服务架构和相关的组件,介绍他们是什么以及为什么要使用微服务架构和这些组件.本文侧重于简明地表达微服务架构的全局图景,因此不会涉及具体如何使用组件等细节. 要理解微服务,首先要先理解不是微服 ...

  4. 你从未见过的,最全微服务架构实战详解,干货满满

    前言 随着各行各业的快速发展,业务规模的不断扩大,不可避免地造成原有架构不能够适应快速的增长和变化.这时,微服务就进入大家的视野. 但微服务并不是一个全新的架构,更不是一个包治百病的架构.它同样也会给 ...

  5. 你从未见过的,最全微服务架构实战详解,干货满满!

    前言 随着各行各业的快速发展,业务规模的不断扩大,不可避免地造成原有架构不能够适应快速的增长和变化.这时,微服务就进入大家的视野. 但微服务并不是一个全新的架构,更不是一个包治百病的架构.它同样也会给 ...

  6. Sonic 开源移动端云真机测试平台 - 设备中心接入安卓设备实例演示,Agent端服务部署过程详解

    Sonic 开源移动端云真机测试平台 - Agent端服务部署与安卓设备接入演示 一加8手机连接效果图展示 第一章:环境准备 ① agent-sources 资源包下载 ② Android SDK安装 ...

  7. NodeJS+Express+mySQL服务端开发详解

    NodeJS+Express+mySQL服务端开发详解 随着NodeJS的发展,现在已经被很多人熟知,NodeJS已经成为了前端开发人员必备的技能.本文不会对NodeJS过多介绍 如果你感兴趣可以访问 ...

  8. 我的世界服务器怎么找到指定路径,[小白]MC服务端目录详解

    服务器的前期准备工作都做好了,是时候上传服务端到服务器了.不过--先等等,在上传前你应该先了解一下服务端目录的结构以便于后期的维护! 如图所示的是MCPC+1.6.4的服务端结构示意图,其他开服端基本 ...

  9. Nuxt SSR 服务端渲染 详解

    Nuxt SSR 服务端渲染 详解 1.Nuxt项目构建 2.Nuxt的生命周期 2.1 nuxtServerInit 钩子 2.2 middleware 中间件 2.3 validate 数据校验 ...

  10. 瑞芯微RK PX30中文详解(带开源资料)简介

    瑞芯微RK PX30中文详解(带开源资料)简介 非常感谢您选择九鼎创展PX30开发平台,本文档讲述PX30开发平台的硬件资源,电路原理以及支持的接口等. PX30开发板是基于瑞芯微PX30的一款高端开 ...

最新文章

  1. 对着电脑笑了二十分钟(2)
  2. R语言非独立多分组非参数检验、Kruskal–Wallis检验进行非独立多分组非参数检验(Nonparametric multiple comparisons)、当ANOVA不满足条件的情况下
  3. Scala in depth 6 Scala的类型系统 上
  4. 谈谈我对sku的理解(3)----页面效果
  5. 在实际使用中 mysql所支持的触发器有_计算机二级考试MySQL数据库每日一练 12月26日...
  6. 什么是闭合GOP和开放GOP?
  7. 安装 paddleocr 报错 gcc: error trying to exec ‘cc1‘: execvp: 没有那个文件或目录
  8. 关于协方差矩阵的理解
  9. winform读写config文件
  10. python刷课思路_江西干部网络学院-刷课思路
  11. 递归构造格雷码c语言,递归构造格雷码
  12. 群论基础速成(2):子群,陪集,正规子群,商群
  13. Notepad JSON格式化
  14. 智能手表的突破和新发展机遇
  15. 如何完成计算机的安装程序,如何安装计算机系统程序.doc
  16. 彩色图像高频与低频成分的分解
  17. Python nose测试大法
  18. 使用PayPal补习注册(2/3):PayPal项目的真实注册
  19. 数据探针 Mysql 数据库
  20. Java finally 的用法,看这一篇就够了

热门文章

  1. 雷布斯被骗200w??一行代码值两百万?雷军公开小米新logo翻车了?
  2. 两年经验,尽然斩获多家巨头offer,如:蚂蚁、头条、PingCAP~
  3. 每一个都能笑抽的39个奇葩代码注释
  4. 8 种单例模式写法,助你搞定面试!
  5. 不要网上乱拷贝代码了!一段网上找的代码把公司服务器崩了!
  6. 党媒发声IT圈里的35岁现象
  7. 19 个如此好玩有趣的 Linux 命令,你玩过几个呢?
  8. 从技术的角度看区块链
  9. 吴裕雄 python 神经网络——TensorFlow 花瓣分类与迁移学习(3)
  10. 002649:springboot下mybatis运行原理