Eureka 集群搭建「建议收藏」

Eureka 集群搭建「建议收藏」一、Eureka高可用集群在实际的生产环境中,eureka常常是以集群的方式提供服务的,目的就是要保证高可用性,同时它还保证了分区容错性。这也满足了一个健壮的分布式系统所要求的CAP理论原则,即eureka保证了高可用性,分区容错性。二、Eureka集群原理Eureka的工作细节Eureka本身可以分为两大部分,EurekaServer和EurekaClient。2.1EurekaServerEurekaServer主要对外提供了三个功能:服务注册:所有的

大家好,又见面了,我是你们的朋友全栈君。

一、Eureka 高可用集群

在实际的生产环境中,eureka 常常是以集群的方式提供服务的,目的就是要保证高可用性,同时它还保证了分区容错性。这也满足了一个健壮的分布式系统所要求的 CAP 理论原则,即 eureka 保证了高可用性,分区容错性。

二、Eureka 集群原理

Eureka 的工作细节

Eureka 本身可以分为两大部分,Eureka Server 和 Eureka Client。

2.1 Eureka Server

Eureka Server 主要对外提供了三个功能:

服务注册:所有的服务都注册到 Eureka Server 上面来。

提供注册表:注册表是所有注册上来的服务的列表,Eureka Client 在调用服务时,需要获取这个注册表,一般来说,这个注册表会被缓存下来,如果缓存失效,则直接获取最新的注册表。

同步状态:Eureka Client 通过注册、心跳等机制,和 Eureka Server 同步当前客户端的状态。

2.2 Eureka Client

Eureka Client 主要用来简化每个服务和 Eureka Server 的交互。 Eureka Client 会自动拉取、更新以及缓存 Eureka Server 中的信息,这样,即使 Eureka Server 所有节点都宕机,Eureka Client 依然能够获取到想要调用服务的地址(地址可能不准确)

2.2.1 服务注册

服务提供者将自己注册到注册中心(Eureka Server),需要注意,所谓的服务提供者,只是一个业务上的分类,本质上它就是一个 Eureka Client 。当 Eureka Client 向 Eureka Server 注册时,它需要提供一些自身的元数据信息,如 IP 地址、端口、名称、运行状态等。

2.2.2 服务续约

Eureka Client 注册到 Eureka Server 上之后,事情没有结束,刚刚开始而已。注册成功后,默认情况下,Eureka Client 每隔 30 秒就要向 Eureka Server 发行一条心跳信息,告诉 Eureka Server 我还在运行

如果 Eureka Server 连续 90 秒都没有收到 Eureka Client 的续约消息(连续 3 次都没发送),它会认为 Eureka Client 已经掉线了,会将掉线的 Eureka Client 从当前的服务注册表中剔除

服务续约,有两个相关属性(一般不做修改):

# eureka.instance.lease-renewal-interval-in-seconds 表示服务续约时间
eureka.instance.lease-renewal-interval-in-seconds = 30  
# eureka.instance.lease-expiration-duration-in-seconds 表示服务时效时间
eureka.instance.lease-expiration-duration-in-seconds = 90

2.2.3 服务下线

当 Eureka Client 下线时,它会主动发送一条信息,告诉 Eureka Server ,我下线了。

2.2.4 获取注册表信息

Eureka Client 从 Eureka Server 上获取服务的注册信息,并将其缓存到本地。本地客户端,在需要调用远程服务时,会从该信息中查找远程服务所对应的的 IP 地址、端口等信息。Eureka Client 上缓存的服务注册信息会定期更新(30 秒),如果 Eureka Server 返回的注册表信息与本地缓存的注册表信息不同的话,Eureka Client 会自动处理。

这里,也涉及两个属性,一个是是否允许获取注册表信息:

eureka.client.fetch-registry = true
# Eureka Client 上缓存的服务注册信息,定期更新的时间间隔,默认为 30 秒

eureka.client.registry-fetch-interval-seconds = 30
# Eureka 集群,实际上就是启动多个 Eureka 实例,多个 Eureka 实例之间,互相注册,互相同步数据,共同组成一个 Eureka 集群。

Eureka 集群原理

在这里插入图片描述
在这个集群架构中,Eureka Server 之间通过 Replicate 进行数据同步,不同的 Eureka Server 之间不区分主从节点,所有节点都是平等的。节点之间,通过置顶 serviceUrl 来相互注册,形成一个集群,进而提高节点的可用性
在 Eureka Server 集群中,如果某个节点宕机,Eureka Client 会自动切换到新的 Eureka Server 上。每个 Eureka Server 节点,都会互相同步数据。
Eureka Server 的连接方式,可以是单线的,就是 A->B->c,此时,A 的数据也会和 C 之间相互同步。但是一般不建议这么写(假如 B 宕机,则 A 和 C 也断开联系了)。在我们配置 serviceUrl 时,可以指定多个注册地址,即 A 可以注册到 B 上,也可以同时注册到 C 上。

三、Eureka 集群搭建配置

1、创建项目

在这里插入图片描述

2、父项目依赖

 <!-- 统一管理jar包版本 -->
    <properties>
        <spring.boot.version>2.3.2.RELEASE</spring.boot.version>
    </properties>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring.boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <!--spring cloud Hoxton.SR1-->
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Hoxton.SR1</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

3、三个服务注册中心子模块依赖

<dependencies>
	<!--Eureka 服务端-->
	<dependency>
		<groupId>org.springframework.cloud</groupId>
		<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
	</dependency>
	<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
	</dependency>
</dependencies>

4、客户端服务提供者依赖

<dependencies>
	<!--Eureka 客户端-->
	<dependency>
		<groupId>org.springframework.cloud</groupId>
		<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
	</dependency>
	<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
	</dependency>
</dependencies>

5、三个服务注册中心配置

(1)修改 hosts 文件

由于只能在一台机器模拟三台服务器,此时必须要在主机的 hosts 文件中修改主机名,否则都默认为 localhost,则无法区分各个 Eureka 服务注册中心的实例。
windows 目录:C:\Windows\System32\drivers\etc\hosts,在末尾处添加如下映射配置。(修改主机名 hostname)

127.0.0.1 eureka8761
127.0.0.1 eureka8762
127.0.0.1 eureka8763 

(2)配置 application.properties 配置文件

1)8761

server: 
  port: 8761
  
eureka: 
  instance:
    hostname: eureka8761 	# eureka 服务端的实例名称
  client: 
    register-with-eureka: false     # false 表示不向本端注册中心注册自己。
    fetch-registry: false     # false 表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务
    service-url: 
      # Eureka 实例之间互相注册,即把自己注册到另外两个服务注册中心实例中
      defaultZone: http://eureka8762:8762/eureka/,http://eureka8763:8763/eureka/

2)8762

server: 
  port: 8761
  
eureka: 
  instance:
    hostname: eureka8762 	# eureka 服务端的实例名称
  client: 
    register-with-eureka: false     # false 表示不向本端注册中心注册自己。
    fetch-registry: false     # false 表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务
    service-url: 
      # Eureka 实例之间互相注册,即把自己注册到另外两个服务注册中心实例中
      defaultZone: http://eureka8761:8761/eureka/,http://eureka8763:8763/eureka/

3)8763

server: 
  port: 8763
  
eureka: 
  instance:
    hostname: eureka8761 	# eureka 服务端的实例名称
  client: 
    register-with-eureka: false     # false 表示不向本端注册中心注册自己。
    fetch-registry: false     # false 表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务
    service-url: 
      # 有多台服务器时,用逗号隔开
      # Eureka 实例之间互相注册,即把自己注册到另外两个服务注册中心实例中,以便于客户端的数据同步
      defaultZone: http://eureka8761:8761/eureka/,http://eureka8762:8762/eureka/

(3)Eureka 服务端注解 @EnableEurekaServer

在 3 个服务端的子项目中的启动类上分别添加注解 @EnableEurekaServer

@EnableEurekaServer 
@SpringBootApplication 
public class ApplicationMain{ 
    

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

6、启动服务集群

分别启动三个 Eureka 服务端项目。以 8761 节点为例:
在这里插入图片描述

在 hosts 文件中修改主机名后,我们可以用自定义的主机名进行访问(localhostname:8761)。如果不修改,只能用默认的 localhost:8761 进行访问。

7、将服务提供者注册到服务注册中心集群

(1)配置 application.properties 配置文件

server: 
  port: 8001
  
eureka:
  client:
    register-with-eureka: true  # 是否向注册中心注册自己
    fetchRegistry: true   # 是否从注册中心抓取已有的注册信息,默认true,集群必须设置为true
    service-url:
      # 集群中各个服务注册中心的地址
      defaultZone: http://eureka8761:8761/eureka,http://eureka8762:8762/eureka,http://eureka8763:8763/eureka
  instance:
    instance-id: servicer8001	 # 服务实例Id
    prefer-ip-address: true  #访问路径可以显示IP地址

实际上,defaultZone 中只配置集群中任意一个服务注册中心的地址,集群中其他的节点都会相互复制服务实例。

(2)Eureka 客户端注解 @EnableEurekaClient

在 3 个服务端的子项目中的启动类上分别添加注解 @EnableEurekaClient

@EnableEurekaClient 
@SpringBootApplication 
public class ApplicationMain{ 
    

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

8、启动服务提供者注册到服务注册中心集群中

(1)8671 节点
在这里插入图片描述
(2)8672 节点
在这里插入图片描述

(3)8673 节点
在这里插入图片描述

9、服务注册与发现

1、在客户端项目启动类添加 @EnableDiscoveryClient

@EnableEurekaClient 
EnableDiscoveryClient
@SpringBootApplication 
public class ApplicationMain{ 
    

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

2、查询使用注册的服务信息

要注入 DiscoveryClient 实例。

@RestController
@RequestMapping("payment")
public class PaymentController { 
   

    // 服务发现
    @Resource
    private DiscoveryClient discoveryClient;

    @GetMapping("discovery")
    public Object discovery() { 
   
        List<String> services = discoveryClient.getServices();
        services.forEach(System.out::println);
		// 获得服务名下的实例列表
        List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
        instances.forEach(instance -> { 
   
            System.out.println(instance.getServiceId() + "\t" + instance.getHost() + "\t" + instance.getPort() + "\t" + instance.getUri());
        });
        return this.discoveryClient;
    }

}

3、@EnableDiscoveryClient 和 @EnableEurekaClient

(1)共同点:都是能够让注册中心能够发现,扫描到该服务。
(2)不同点:@EnableEurekaClient 只适用于 Eureka 作为注册中心,@EnableDiscoveryClient 可以用于所有注册中心(eureka,zookeeper,consul 和 nacos)

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/130535.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • 为了写论文给 Linux “投毒”, Linux 内核维护者封杀明尼苏达大学「建议收藏」

    为了写论文给 Linux “投毒”, Linux 内核维护者封杀明尼苏达大学「建议收藏」Linux内核稳定分支的维护者GregKroah-Hartman决定禁止美国明尼苏达大学向主线Linux内核提交补丁,因为他们故意提交有安全影响的可疑代码,他们以“如果向开源计划提交代码的方式注入漏洞,开源社区将如何处理”进行了专门研究,并且还发布了一篇论文:《OntheFeasibilityofStealthilyIntroducingVulnerabilitiesinOpen-SourceSoftwareviaHypocriteCommits》论文地址:https://

    2022年7月23日
    17
  • 事业单位图形推理1000题及答案_小学生图形推理题

    事业单位图形推理1000题及答案_小学生图形推理题  2020年事业单位联考:《职测》判断推理神预测!   经过几个月的紧张备考,广大考生终于在今天走上了“战场”。经过小时的奋笔疾书,2020年下半年事业单位联考职业能力测试于今天上午拉下帷幕。根据学员的惊喜反馈,我们发现华图教育又双叒叕预测中题目了!!!   通过考生们对题目的回忆,华图教育惊喜地发现有4个考点跟我们考前给学员预测的大致相同!下面我们就一起来简单看一下:   一…

    2022年9月3日
    6
  • 图片压缩算法「建议收藏」

    图片压缩算法「建议收藏」图片压缩算法

    2022年6月18日
    41
  • 晚上不用加班了,推荐十款精选IntelliJIdea插件,效率提升N倍[通俗易懂]

    大家好,我是雷小帅,今天给大家推荐开发利器,保证你效率蹭蹭蹭上升。俗话说:"工欲善其事必先利其器",小帅从项目实战的角度在众多的idea插件中挑选了10款开发必备的神器,帮助大家在日常工作学习编码中提升开发效率。1KeyPromoterX实用指数:★★★★★装逼指数:★你还在为记不住快捷键烦恼吗,KeyPromoterX可以帮助你快速记住常用的快捷键。当你在idea中用鼠标点击菜单,它可以显示对应的快捷键以及点击次数。使用一段时间后有助于过渡到更快、无鼠标的开发。

    2022年4月18日
    28
  • Spring Aop底层原理详解(利用spring后置处理器实现AOP)

    Spring Aop底层原理详解(利用spring后置处理器实现AOP)写在前面:对于一个java程序员来说,相信绝大多数都有这样的面试经历,面试官问:你知道什么是aop吗?谈谈你是怎么理解aop的?等等诸如此类关于aop的问题。当然对于一些小白可能会一脸懵逼;对于一些工作一两年的,可能知道,哦!aop就是面向切面变成,打印日志啊,什么什么的,要是有点学习深度的呢可能会说aop底层实现利用了jdk动态代理,cglib啊什么的。很多时候可能面试就到此打住了,当然,然后也…

    2022年9月16日
    0
  • 字面量(笑笑语法)

    字面量(笑笑语法)

    2022年1月23日
    38

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号