搭建Eureka集群与负载均衡能力 eureka server集群原理
bigegpt 2024-10-20 04:27 2 浏览
技术/杨33
一、服务提供者支付模块入驻服务注册中心Eureka
1、pom.xml文件添加Eureka Client依赖
<!-- Eureka Client-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
2、application.yml配置文件添加Eureka配置
eureka:
client:
register-with-eureka: true #true表示向注册中心注册自己
fetch-registry: true #是否从EurekaServer抓取已有的注册信息
service-url:
defaultZone: http://localhost:7001/eureka/ #服务注册中心的地址
3、主启动类的类名上添加EurekaClient的注解@EnableEurekaClient
/**
* 主启动类
* @author 杨33
* @date 2020/4/25 15:45
*/
@SpringBootApplication
@EnableEurekaClient
public class PaymentMain8001 {
public static void main(String[] args) {
SpringApplication.run(PaymentMain8001.class, args);
}
}
4、启动EurekaServer模块和服务提供者支付模块
浏览器访问EurekaServer模块的web管理界面:http://localhost:7001/
EurekaServer模块的web管理界面就出现了已经注册进来的服务------支付模块。
二、Eureka集群的工作流程
- 先启动Eureka Server注册中心
- 启动服务提供者支付模块
- 支付模块启动后会把自身的信息(比如服务器别名、服务地址)注册进Eureka Server注册中心
- 服务消费者订单模块在需要调用支付模块的接口时,使用服务别名去服务注册中心获取实际的RPC远程调用地址
- 服务消费者订单模块获取到调用地址后,底层实际是利用HttpClient技术实现远程调用
- 服务消费者订单模块获得服务地址后会缓存在本地jvm内存中,默认每间隔30秒更新一次服务调用地址
三、搭建EurekaServer集群
上一章内容已经搭建了单服务的Eureka Server,搭建步骤请看:四、搭建注册中心服务端Eureka Server。
搭建Eureka集群,那么就需要两个或以上的Eureka Server。所以可以依据已经搭建的单服务快速搭建起另外一个Eureka Server,组成集群。
1、新建moudle:cloud-eureka-server7002
2、改pom.xml文件,跟cloud-eureka-server7001一样
3、修改域名映射,C:\Windows\System32\drivers\etc\hosts
127.0.0.1 eureka7001.com
127.0.0.1 eureka7002.com
4、改application.yml配置文件,两个Eureka Server的都要改。
- cloud-eureka-server7001
server:
port: 7001
eureka:
instance:
hostname: eureka7001.com #eureka服务端的实例名称
client:
register-with-eureka: false #false表示不向注册中心注册自己
fetch-registry: false #false表示自己就是服务注册中心,本职就是维护服务实例,并不需要去检索服务
service-url:
defaultZone: http://eureka7002.com:7002/eureka/ #Eureka Server集群相互注册
- cloud-eureka-server7002
server:
port: 7002
eureka:
instance:
hostname: eureka7002.com #eureka服务端的实例名称
client:
register-with-eureka: false #false表示不向注册中心注册自己
fetch-registry: false #false表示自己就是服务注册中心,本职就是维护服务实例,并不需要去检索服务
service-url:
defaultZone: http://eureka7001.com:7001/eureka/ #Eureka Server集群相互注册
5、添加启动类
最后两个服务组成了EurekaServer集群。
6、分别启动cloud-eureka-server7001、cloud-eureka-server7002的主启动类
浏览器访问http://eureka7001.com:7001/、http://eureka7002.com:7002/,可以看到两个服务已经相互注册成功。
7、服务提供者、消费者注册到EurekaServer集群的配置
application.yml配置文件改动
defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/ #集群服务
8、集群服务启动顺序
- 先启动EurekaServer7001
- 再启动EurekaServer7002
- 接着启动服务提供者服务
- 最后启动服务消费者服务
四、搭建服务提供者支付模块集群:cloud-provider-payment
之前有篇文章已经搭建了单服务的cloud-provider-payment8001,搭建步骤请看:二、在父工程下创建子工程《服务提供者支付模块》的步骤
搭建服务提供者支付模块集群,那么就需要两个或以上的模块。所以可以依据已经搭建的cloud-provider-payment8001快速搭建起另外一个支付模块cloud-provider-payment8002,组成集群。
两个支付模块有改动的地方是:
1、application.yml配置文件
- 两个模块端口不必一样
server:
port: 8002 #微服务的端口
- 微服务名称,两个支付模块都改成一样的,这样做的目的就是注册到EurekaServer服务中心的是同一个集群。
spring:
application:
name: cloud-provider-payment #注册进服务中心,并对外暴露的微服务名称
如下图:服务提供者支付模块集群CLOUD-PROVIDER-PAYMENT,包含两个单服务。
五、负载均衡设置:服务消费者订单模块调用服务提供者集群服务
之前有篇文章已经搭建了服务消费者订单模块cloud-consumer-order80,搭建步骤请看:二、创建服务消费者订单模块:cloud-consumer-order80
它要支持负载均衡调用服务提供者集群服务,那么需要在原基础之上,改动代码如下:
- OrderController类,服务提供者的URL换成集群服务名称。
/**
* 这儿使用集群服务名称,不用再关心IP和端口号
* 通过@LoadBalanced,该注解赋予了RestTemplate负载均衡的能力
*/
private static final String URL = "http://CLOUD-PROVIDER-PAYMENT";
- ContextConfig类,使用注解@LoadBalanced给RestTemplate赋予负载均衡的能力。
@Bean
@LoadBalanced
public RestTemplate getRestTemplate() {
return new RestTemplate();
}
这两个地方的名字更易于理解
实现这样的功能,只需在application.yml配置文件添加下面内容
instance:
instance-id: payment8001
prefer-ip-address: true
六、服务发现Discovery
对于注册进EurekaServer中的微服务,可以通过服务发现来获得该微服务的信息。
在某个微服务项目中对外暴漏一个接口,可以通过这个接口获取本微服务的各种信息。
- 主启动类的头部添加注解@EnableDiscoveryClient
- Controller类代码如下:
@Resource
DiscoveryClient discoveryClient;
/**
* 对外暴漏这个接口,可以通过这个接口获取本微服务的各种信息
* @return
*/
@GetMapping("/payment/discovery")
public Object discovery() {
List<String> services = discoveryClient.getServices();
for (String service : services) {
System.out.println("service信息:" + service);
}
List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PROVIDER-PAYMENT");
for (ServiceInstance instance : instances) {
System.out.println("instance信息:" + instance.getHost() + "," + instance.getPort());
}
return instances;
}
七、Eureka 组件项目宣布停止开发了
大概意思是: Eureka 2.0 的开源工作已经停止(Discontinued),依赖于开源库里面的 Eureka 2.x 分支构建的项目或者相关代码,风险自负!
替代品有Consul、ZooKeeper、Nacos。
作者:杨33,北京互联网公司在职Java开发,专注分享写作干货。欢迎关注我,期待你的点赞评论。
相关推荐
- Java 泛型大揭秘:类型参数、通配符与最佳实践
-
引言在编程世界中,代码的可重用性和可维护性是至关重要的。为了实现这些目标,Java5引入了一种名为泛型(Generics)的强大功能。本文将详细介绍Java泛型的概念、优势和局限性,以及如何在...
- K8s 的标签与选择器:流畅运维的秘诀
-
在Kubernetes的世界里,**标签(Label)和选择器(Selector)**并不是最炫酷的技术,但却是贯穿整个集群管理与运维流程的核心机制。正是它们让复杂的资源调度、查询、自动化运维变得...
- 哈希Hash算法:原理、应用(哈希算法 知乎)
-
原作者:Linux教程,原文地址:「链接」什么是哈希算法?哈希算法(HashAlgorithm),又称为散列算法或杂凑算法,是一种将任意长度的数据输入转换为固定长度输出值的数学函数。其输出结果通常被...
- C#学习:基于LLM的简历评估程序(c# 简历)
-
前言在pocketflow的例子中看到了一个基于LLM的简历评估程序的例子,感觉还挺好玩的,为了练习一下C#,我最近使用C#重写了一个。准备不同的简历:image-20250528183949844查...
- 55顺位,砍41+14+3!季后赛也成得分王,难道他也是一名球星?
-
雷霆队最不可思议的新星:一个55号秀的疯狂逆袭!你是不是也觉得NBA最底层的55号秀,就只能当饮水机管理员?今年的55号秀阿龙·威金斯恐怕要打破你的认知了!常规赛阶段,这位二轮秀就像开了窍的天才,直接...
- 5分钟读懂C#字典对象(c# 字典获取值)
-
什么是字典对象在C#中,使用Dictionary类来管理由键值对组成的集合,这类集合被称为字典。字典最大的特点就是能够根据键来快速查找集合中的值,其键的定义不能重复,具有唯一性,相当于数组索引值,字典...
- c#窗体传值(c# 跨窗体传递数据)
-
在WinForm编程中我们经常需要进行俩个窗体间的传值。下面我给出了两种方法,来实现传值一、在输入数据的界面中定义一个属性,供接受数据的窗体使用1、子窗体usingSystem;usingSyst...
- C#入门篇章—委托(c#委托的理解)
-
C#委托1.委托的定义和使用委托的作用:如果要把方法作为函数来进行传递的话,就要用到委托。委托是一个类型,这个类型可以赋值一个方法的引用。C#的委托通过delegate关键字来声明。声明委托的...
- C#.NET in、out、ref详解(c#.net framework)
-
简介在C#中,in、ref和out是用于修改方法参数传递方式的关键字,它们决定了参数是按值传递还是按引用传递,以及参数是否必须在传递前初始化。基本语义对比修饰符传递方式可读写性必须初始化调用...
- C#广义表(广义表headtail)
-
在C#中,广义表(GeneralizedList)是一种特殊的数据结构,它是线性表的推广。广义表可以包含单个元素(称为原子),也可以包含另一个广义表(称为子表)。以下是一个简单的C#广义表示例代...
- 「C#.NET 拾遗补漏」04:你必须知道的反射
-
阅读本文大概需要3分钟。通常,反射用于动态获取对象的类型、属性和方法等信息。今天带你玩转反射,来汇总一下反射的各种常见操作,捡漏看看有没有你不知道的。获取类型的成员Type类的GetMembe...
- C#启动外部程序的问题(c#怎么启动)
-
IT&OT的深度融合是智能制造的基石。本公众号将聚焦于PLC编程与上位机开发。除理论知识外,也会结合我们团队在开发过程中遇到的具体问题介绍一些项目经验。在使用C#开发上位机时,有时会需要启动外部的一些...
- 全网最狠C#面试拷问:这20道题没答出来,别说你懂.NET!
-
在竞争激烈的C#开发岗位求职过程中,面试是必经的一道关卡。而一场高质量的面试,不仅能筛选出真正掌握C#和.NET技术精髓的人才,也能让求职者对自身技术水平有更清晰的认知。今天,就为大家精心准备了20道...
- C#匿名方法(c#匿名方法与匿名类)
-
C#中的匿名方法是一种没有名称只有主体的方法,它提供了一种传递代码块作为委托参数的技术。以下是关于C#匿名方法的一些重要特点和用法:特点省略参数列表:使用匿名方法可省略参数列表,这意味着匿名方法...
- C# Windows窗体(.Net Framework)知识总结
-
Windows窗体可大致分为Form窗体和MDI窗体,Form窗体没什么好细说的,知识点总结都在思维导图里面了,下文将围绕MDI窗体来讲述。MDI(MultipleDocumentInterfac...
- 一周热门
- 最近发表
- 标签列表
-
- mybatiscollection (79)
- mqtt服务器 (88)
- keyerror (78)
- c#map (65)
- resize函数 (64)
- xftp6 (83)
- bt搜索 (75)
- c#var (76)
- mybatis大于等于 (64)
- xcode-select (66)
- mysql授权 (74)
- 下载测试 (70)
- linuxlink (65)
- pythonwget (67)
- androidinclude (65)
- logstashinput (65)
- hadoop端口 (65)
- vue阻止冒泡 (67)
- oracle时间戳转换日期 (64)
- jquery跨域 (68)
- php写入文件 (73)
- kafkatools (66)
- mysql导出数据库 (66)
- jquery鼠标移入移出 (71)
- 取小数点后两位的函数 (73)