SpringCloud注册中心部署Eureka流程详解

 更新时间:2022年11月14日 09:52:49   作者:麻侬  
Eureka是Netflix开发的服务发现框架,本身是一个基于REST的服务,主要用于定位运行在AWS域中的中间层服务,以达到负载均衡和中间层服务故障转移的目的

今天我们开始正式编码,如何创建spring boot项目这篇文章就不再讲述,如果想要了解可以阅读我之前的创建springboot项目

首先我们先进行Spring cloud五大组件之一的注册中心,之前文章已经讲过注册中心的介绍,今天我们来部署Netflix的Eureka,进行单机部署以及高可用部署,并开发生产者以及消费者来进行测试eureka的注册消费。(ps:系列文章使用的Spring cloud版本为2021.0.4,对应的spring boot版本2.6.11)

1、Eureka服务

我们在主工程目录下面新创建一个Module,名字eureka-server,引入下面的依赖

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

这个子工程只是作为eureka的注册中心,无需引入其他jar包。

创建配置文件application.yml

server:
  port: 8761
eureka:
  instance:
    hostname: localhost
  client:
    registerWithEureka: false
    fetchRegistry: false
    serviceUrl:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
spring:
  application:
  name: eureka-server

registerWithEureka:是否将自己注入到注册中心,因为本身就是Eureka服务,默认为true,所以这里设置为false;

fetchRegistry:是否从注册中心获取注册列表,后续进行集群部署的时候需要获取其他Eureka服务,这里是单点的所以设置为false;

因为eureka已经停止维护,所以目前没有找到相关的配置网页,感兴趣的同学可以自己点进去源码进行查询更多的配置以及配置的作用,因为eureka不是我们的重点所以这里就不一一进行解释了。

创建服务启动类EurekaServerApplication.class。

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

@EnableEurekaServer 此注解是Eureka服务server端注解,如果是服务客户端client,需要注解为@EnableEurekaClient。

至此我们的一个Eureka服务就创建完成了,启动之后我们就获取了一个单节点的注册中心。

2、服务提供者

依然是spring boot项目的三板斧,创建项目引入依赖、创建配置文件、创建启动类。创建Module命名provider-eureka8001,引入依赖

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
        <version>2.6.11</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
        <version>2.6.11</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
</dependencies>

这里健康检测相关的依赖之前引入错误,这里需要注意使用的是starter-actuator

创建配置文件application.yml,填写下面内容

server:
  port: 8001
spring:
  application:
    name: provider
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/

spring.application.name是项目的名称,后面eureka服务注册列表将会使用此值;

eureka.client.serviceUrl.defaultZone是Eureka注册中心的注册地址,如果Eureka服务部署在另外的地方,需要对应修改ip跟端口,这里本地部署直接localhost即可。

创建启动类ProviderEureka8001Application.class

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

这里作为服务客户端使用@EnableEurekaClient

在provider项目创建接口类ProviderController.class,作为服务提供接口

@RestController
@RequestMapping("/provider")
public class ProviderController {
    @Value("${server.port}")
    private String port;
    @GetMapping("/getPort")
    public String getPort(){
        return "访问服务的端口为:" + port;
    }
}

3、服务消费者

创建服务消费者consumer-eureka8002,引入maven依赖

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
        <version>2.6.11</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
        <version>2.6.11</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
</dependencies>

创建配置文件application.yml

server:
  port: 8002
spring:
  application:
    name: comsumer
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/

创建启动文件ConsumerEureka8002Application.class

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

4、服务调用测试

启动上面三个服务,访问eureka管理页面,默认为http://localhost:8761

可以看到,我们的两个服务provider以及consumer已经全部注册成功,测试调用我们配置Ribbon作为调用负载均衡,来进行测试服务是否可以调用。

在consumer项目配置Ribbon的负载均衡注入RibbonConfig

@Configuration
public class RibbonConfig {
    @Bean
    @LoadBalanced
    public RestTemplate loadBalancedRestTemplate(){
        return new RestTemplate();
    }
}

在consumer项目创建消费的ConsumerController,这里调用的方式为http:// + 服务提供者注册名称(spring.application.name),这里是提供者的名字provider,加上服务的path。

@RestController
@RequestMapping("/consumer")
public class ConsumerController {
    @Autowired
    private RestTemplate loadBalancedRestTemplate;
    @GetMapping("/getProviderPort")
    public String getProviderPort(){
        return loadBalancedRestTemplate.getForObject("http://provider/provider/getPort",String.class);
    }
}

重启我们的消费者项目,在网页里面输入请求地址http://localhost:8002/consumer/getProviderPort,可以看到访问成功且返回的是provider的端口号

到此我们使用eureka作为服务注册中心并尝试编写服务生产消费的学习就结束了,后续Eureka集群部署方式也比较简单,就是另外创建一个EurekaServer服务,配置文件、启动类、依赖引入都与之前的Eureka服务一样,这里需要修改两个Eureka服务的配置文件,将各自的服务都注入到对方的列表中去。

server:
  port: 8761
eureka:
  instance:
    hostname: eureka-server1
  client:
    registerWithEureka: false    #我是服务端,不需要将自己注册
    fetchRegistry: false    #我是服务端,不需要进行服务发现,无需获取服务注册列表
    serviceUrl:
      defaultZone: http://eureka-server2的ip:8762/eureka #将另外一个eurekaserver2的服务进行注册

server:
  port: 8762
eureka:
  instance:
    hostname: eureka-server2
  client:
    registerWithEureka: false    #我是服务端,不需要将自己注册
    fetchRegistry: false    #我是服务端,不需要进行服务发现,无需获取服务注册列表
    serviceUrl:
      defaultZone: http://eureka-server1的ip:8762/eureka #将另外一个eurekaserver1的服务进行注册

Eureka默认会开启自我保护机制,自我保护机制是Eureka为了防止网络波动引起的服务心跳丢失问题,坚持“宁可信其有”的原则,在默认90s内没有接收到客户端的心跳依然不将其移除,取消保护机制可在Eureka Server进行下面配置:

eureka.server.enable-self-preservation=false #关闭自我保护

eureka.server.eviction-interval-timer-in-ms=3000 #超时3s自动清除

保持开启,进行自我设置保护机制可在Eureka Server使用下面配置:

eureka.instance.lease-expiration-duration-in-seconds=10 #用来修改eureka server默认接受心跳的最大时间 默认是90s

eureka.instance.lease-renewal-interval-in-seconds=5 #指定客户端多久向eureka server发送一次心跳 默认是30s

到此这篇关于SpringCloud注册中心部署Eureka流程详解的文章就介绍到这了,更多相关SpringCloud Eureka内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • SpringBoot多环境切换的灵活配置详细教程

    SpringBoot多环境切换的灵活配置详细教程

    在真实项目开发的时候,一定会有多个环境,下面这篇文章主要给大家介绍了关于SpringBoot多环境切换灵活配置的相关资料,文中通过代码介绍的非常详细,需要的朋友可以参考下
    2024-04-04
  • Spring控制bean加载顺序使用详解

    Spring控制bean加载顺序使用详解

    在使用spring框架开发过程中,我们可能会遇到某个bean被另一个bean依赖,也就是bean-b的创建必须依赖bean-a等问题,类似这样的场景还有很多,总结来说,这就涉及到bean的加载顺序问题,如何解决呢,本文将给大家列举出几种常用的解决方案,需要的朋友可以参考下
    2023-09-09
  • java中的快捷键小结

    java中的快捷键小结

    以下是myeclipse中的所有快捷键列表
    2013-03-03
  • springboot+idea+maven 多模块项目搭建的详细过程(连接数据库进行测试)

    springboot+idea+maven 多模块项目搭建的详细过程(连接数据库进行测试)

    这篇文章主要介绍了springboot+idea+maven 多模块项目搭建的详细过程(连接数据库进行测试),本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-08-08
  • 使用FeignClient调用远程服务时整合本地的实现方法

    使用FeignClient调用远程服务时整合本地的实现方法

    这篇文章主要介绍了使用FeignClient调用远程服务时整合本地的实现方法,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-03-03
  • JAVA操作MongoDB数据库实例教程

    JAVA操作MongoDB数据库实例教程

    MongoDB是一个文档型数据库,是NOSQL家族中最重要的成员之一,下面这篇文章主要给大家介绍了关于JAVA操作MongoDB数据库的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
    2023-05-05
  • SpringBoot 异步线程间数据传递的实现

    SpringBoot 异步线程间数据传递的实现

    本文主要介绍了SpringBoot 异步线程间数据传递的实现,包括异步线程的基本概念、数据传递的方式、具体实现方式等,具有一定的参考价值,感兴趣的可以了解一下
    2024-03-03
  • 解析ConcurrentHashMap: transfer方法源码分析(难点)

    解析ConcurrentHashMap: transfer方法源码分析(难点)

    ConcurrentHashMap是由Segment数组结构和HashEntry数组结构组成。Segment的结构和HashMap类似,是一种数组和链表结构,今天给大家普及java面试常见问题---ConcurrentHashMap知识,一起看看吧
    2021-06-06
  • java 浅析代码块的由来及用法

    java 浅析代码块的由来及用法

    所谓代码块是指用"{}"括起来的一段代码,根据其位置和声明的不同,可以分为普通代码块、构造块、静态块、和同步代码块。如果在代码块前加上 synchronized关键字,则此代码块就成为同步代码块
    2021-10-10
  • 一文解决pom.xml报错Dependency "xxx" not found的问题

    一文解决pom.xml报错Dependency "xxx" not f

    我们在使用maven进行jar包管理时有时会遇到pom.xml中报错Dependency “XXX” not found,所以在本文中将给大家介绍一下pom.xml报错Dependency "xxx" not found的解决方案,需要的朋友可以参考下
    2024-01-01

最新评论