基于DNS搭建高可用Eureka注册中心
按Alt + 回车键,将会生成eureka-server.zip,解压缩后得到一个maven 项目,将该项目录入IDE。
我们首先来看一下pom文件,可以看出项目中引用了spring-cloud-starter-netflix-eureka-server, 并且springboot 的版本号为:2.1.2.RELEASE, Spring Cloud的版本号为:Greenwich.RC2RC2 表示还没有正式发布,只是第二个Release Candidate。
接下来我们只需要两个步骤,
a、修改EurekaServerApplication, 在@SpringBootApplication的注解上面,加入一个新的注解:@EnableEurekaServer
b、在resources 目录中加入application.yml 文件, 并配置以下信息:
一个简单的Eureka 注册中心就已经可以使用了,我们运行一下这个spring boot 应用,找开浏览器:localhost:8761,即可看到我们的注册中心就已经运行启来了。并且EUREKA-SERVER也注册到自己的注册中心了。
单节点的注册中心已经搭建完毕,但单节点的注册中心存在单点故障的可能,不能用于生产环境。生产环境的Eureka一般采用集群方式进行部署。
通过client.serviceUrl.defaultZone配置多个peer节点,因为是在单机上测试,所以修改了host文件,并且使用不同的端口号来启动注册中心。正式的生产环境请根据自己的实际情况进行配置,比如:第一台Eureka的IP地址为:192.168.0.100,则defaultZone配置其他三台注册中心
依次启动4台注册中心,打开网页:
可以看到其它三台注册中心已经出现在已注册的replicas和可用的replicas列表里边。
如上图所示,4台注册中心,每台注册中心需要配置其他三台服务器,以Eureka 1为例,其配置如下:
注册中心是本应该是无状态的,可以横向扩展。但由于每台注册中心的配置都不一样,所以扩展起来比较麻烦,需要修改配置文件,这样就无法做到快速的扩容。
微服务客户端需要配置注册中心的地址,使用的是如下的配置:
由于配置的是固定的IP地址,如果我们要扩容注册中心,增加新的注册中心节点,那我们就需要修改微服务客户端的配置文件,将新的注册中心节点进入的服务器列表中。试想一下,如果有几十个微服务,每个微服务有4个节点,那将会要修改上百个配置文件。很显然这种方式不太可取,从软件设计角度来说,违反了开闭原则。
其实Eureka 注册中心还有另一种高可用配置方式,基于DNS。Eureka天生就可以部署在像AWS这样的公有云上,并且可以跨Region,跨Available Zone部署。虽然我们不用部署在云端,依然可以利用这一特性,我们可以把Region看作我们数据中心的机房,Avaiable Zone 看作是机房中的网络区域,结合内部DNS服务来实现高可用的注册中心。
画重点:
a. region: default,配置地区
b. useDnsForFetchingServiceUrls,表示基于DNS获取服务信息
c. eurekaServerDNSName: eureka.txzq.com.cn,配置域名服务器名称
键:txt.default.eureka.txzq.com.cn 值:shenzhen.eureka.txzq.com.cn
键:txt.shenzhen.eureka.txzq.com.cn 值:172.18.10.1 172.18.10.2 172.18.10.3 172.18.10.4
第一条记录表示,default 区域,包含了哪些可用区,我们用shenzhen表示是深圳机房,txt记录的值就设置为:shenzhen.eureka.txzq.com.cn
第二第记录表示 , shenzhen机房有哪些服务器,多台服务器使用空格格开。
如果在本地测试,需要搭建一台自己的DNS服务器,可以参考我的另一篇文章: 基于Docker快速搭建DNS Server
Client View是指DNS服务应用到哪一个网段,比如:172.18.10.0/24网段的IP连接到BIND服务器,才会解析指定的域名。
在添加域名的时候,需要指定Client View,这里我们选择我们刚刚创建的View_172.18.10.0,指的是只有在这个网段的IP访问这台DNS服务器,才能解析。
添加完一级域名后我们刷一下这个ZONE,然后设置一下本地DNS服务器
DNS域名服务器验证通过后,我们接下来就可以在为这个域名添加我们所需要的txt 记录了。
到这里我们的准备工作就已经基本完成了。使用Maven将注册中心编译成,输出jar包。新建一个Eureka的docker镜像,并启动4个容器。基于DNS的注册中心就搭建完毕了。
你只需要对DNS记录进行变更,就可以实现动态的、快速扩容/缩容了。
关于如何将Eureka部署到Docker,请参考另一篇文章:
Eureka(二)使用配置详解
最近在做一个基于cloud的项目。以前用dubbo的我第一次接触cloud觉得简直方便的不得了。尤其是看一个实操视频。除了主播磨磨唧唧的搭建基础项目的时间。感觉整个项目干货一个小时都能提炼出来。。
真正开始做了的时候,基于钻研探索的精神。因为视频中和大多数网上帖子中eureka的配置一般只有短短四行(不是夸张。真的是只有四行)。所以我不管是脑抽还是热爱学习,反正是想找找一共eureka配置参数都有什么。。然后顺便写个文章记录下使用过程。
这里有一个特别注意的问题就是cloud 和boot和各种组件的版本问题。我在这提一下因为这个是我踩过的坑~~~所以先提一下。
eureka分两种配置:
1,依赖(我这里用的spring boot1.5.21版本,所以和2以后的不一样):
2,在启动类上添加服务端注解(关于这个注解有的版本哪怕不添加也会默认):
3,在配置文件中配置eureka服务端的相关配置:
这里说到重头戏了,其实必须配置的也就三四条。剩下都是可选项。我会在每一条后面特别声明是否必须配置的。
1,依赖(我这里用的spring boot1.5.21版本,所以和2以后的不一样):
这里要着重说一下,第一个依赖是作为eureka的客户端的依赖。第二个则是feign的依赖,用于服务之间相互调用的。我觉得很有必要所以一起放在这里,如果有的人觉得用不到第二个可以不导入。
2,在启动类上添加客户端注解(关于这个注解有的版本哪怕不添加也会默认):
3,在配置文件中配置eureka客户端的相关配置:
对了,这里有两个注意点:
-更改Eureka更新频率将打破服务器的自我保护功能,生产环境下不建议自定义这些配置。
-eureka.client.healthcheck.enabled=true 只应该在application.yml/properties中设置。如果设置在bootstrap.yml中将会导致一些不良的副作用,例如在Eureka中注册的应用名称是UNKNOWN等。
到这里你们用eureka搭建的boot+cloud微服务已经可以起来啦~~然后此文主要是参考了一个帖子~~那么大佬把eureka的所有属性从官网文档整理出来的~~~膜拜一波~~~然后有兴趣的可以跳转过去看看~~~
eureka参数大全
然后如果有比较了解的亲们或者说我上述观点哪里有偏颇~~欢迎指出~~!!!
喏,手打不易,大家动动小手喜欢分享转发关注评论啥的~~~~
SpringCloud之Eureka Feign简介
1、Eureka注册中心
现在公司项目大多采用前后端分离架构,服务层被拆分成了很多的微服务,为方便管理Spring Cloud给我们提供了服务注册中心来管理微服务。
1.1、Eureka简介
Spring Cloud Eureka 是对Netflix公司的Eureka的二次封装,它实现了服务治理的功能,Spring Cloud Eureka提
供服务端与客户端,服务端即是Eureka服务注册中心,客户端完成微服务向Eureka服务的注册与发现。服务端和
客户端均采用Java语言编写。下图显示了Eureka Server与Eureka Client的关系:
Eureka Server是服务端,负责管理各各微服务结点的信息和状态。
在微服务上部署Eureka Client程序,远程访问Eureka Server将自己注册在Eureka Server。
微服务需要调用另一个微服务时从Eureka Server中获取服务调用地址,进行远程调用。
1.2、Eureka Server搭建
1.2.1、单机环境搭建
1、父工程引入Maven依赖:
org.springframework.cloud
spring‐cloud‐dependencies
Finchley.SR1
pom
import
2、在Eureka Server工程添加:
org.springframework.cloud
spring‐cloud‐starter‐netflix‐eureka‐server
3、在SpringBoot启动类添加@EnableEurekaServer注解,标识这是一个Eureka服务:
@EnableEurekaServer//标识这是一个Eureka服务
@SpringBootApplication
publicclassGovernCenterApplication{
publicstaticvoidmain(String[] args){
SpringApplication.run(GovernCenterApplication.class, args);
}
}
4、在application.yml中配置Rureka:
server:
port:50101#服务端口
spring:
application:
name:xc‐govern‐center#指定服务名
eureka:
client:
registerWithEureka:false#服务注册,是否将自己注册到Eureka服务中
fetchRegistry:false#服务发现,是否从Eureka中获取注册信息
serviceUrl:#Eureka客户端与Eureka服务端的交互地址,高可用状态配置对方的地址,单机状态配置自己(如果不配置则默认本机8761端口)
defaultZone:
server:
enable‐self‐preservation:false#是否开启自我保护模式,开发模式建议关闭
eviction‐interval‐timer‐in‐ms:60000#服务注册表清理间隔(单位毫秒,默认是60*1000)
5、启动Eureka Server,浏览50101端口:
上图红色提示信息:
THE SELF PRESERVATION MODE IS TURNED OFF.THIS MAY NOT PROTECT INSTANCE EXPIRY IN CASE OF
NETWORK/OTHER PROBLEMS.
自我保护模式被关闭。在网络或其他问题的情况下可能不会保护实例失效。
Eureka Server有一种自我保护模式,当微服务不再向Eureka Server上报状态,Eureka Server会从服务列表将此
服务删除,如果出现网络异常情况(微服务正常),此时Eureka server进入自保护模式,不再将微服务从服务列
表删除。
至此,Eureka服务端已经搭建完成,下面进行服务注册,将微服务注册到Eureka服务端进行管理。
1.3、服务注册
1、在需要注册的微服务中,添加依赖:
org.springframework.cloud
spring‐cloud‐starter‐netflix‐eureka‐client
2、配置application.yml:
eureka:
client:
registerWithEureka:true#服务注册开关
fetchRegistry:true#服务发现开关
serviceUrl:#Eureka客户端与Eureka服务端进行交互的地址,多个中间用逗号分隔
defaultZone:${EUREKA_SERVER:}
instance:
prefer‐ip‐address:true#将自己的ip地址注册到Eureka服务中
ip‐address:${IP_ADDRESS:127.0.0.1}
instance‐id:${spring.application.name}:${server.port}#指定实例id
3、启动类上加注解@EnableDiscoveryClient ,表示它是一个Eureka的客户端
4、刷新Eureka Server查看注册情况
同理可将需要注册的服务注册到Eureka Server。
2、Feign远程调用
服务层被拆分成了很多的微服务,服务与服务之间难免发生交互调用,这时候就需要用到远程调用,接下来带大家入门及使用
2.1Ribbon
1、简介
Ribbon是Netflix公司开源的一个负载均衡的项目(),它是一个基于HTTP、TCP的客户端负载均衡器,通过负载均衡来实现系统的高可用、集群扩容等功能。
如下图是服务端负载均衡架构图:
用户请求先到达负载均衡器(也相当于一个服务),负载均衡器根据负载均衡算法将请求转发到微服务。负载均衡算法有:轮训、随机、加权轮训、加权随机、地址哈希等方法,负载均衡器维护一份服务列表,根据负载均衡算法将请求转发到相应的微服务上,所以负载均衡可以为微服务集群分担请求,降低系统的压力。
客户端负载均衡架构图:
客户端负载均衡与服务端负载均衡的区别在于客户端要维护一份服务列表,Ribbon从Eureka Server获取服务列表,Ribbon根据负载均衡算法直接请求到具体的微服务,中间省去了负载均衡服务。
2、测试Ribbon
Spring Cloud引入Ribbon配合 restTemplate 实现客户端负载均衡。Java中远程调用的技术有很多,如:webservice、socket、rmi、Apache HttpClient、OkHttp等,互联网项目使用基于http的客户端较多,下面介绍使用的是OkHttp。
首先加入Maven依赖:
!--如果依赖了spring-cloud-starter-eureka,会自动添加spring-cloud-starter-ribbon依赖--
org.springframework.cloud
spring‐cloud‐starter‐ribbon
com.squareup.okhttp3
okhttp
在application.yml中配置Ribbon参数:
ribbon:
MaxAutoRetries:2#最大重试次数,当Eureka中可以找到服务,但是服务连不上时将会重试
MaxAutoRetriesNextServer:3#切换实例的重试次数
OkToRetryOnAllOperations:false#对所有操作请求都进行重试,如果是get则可以,如果是post,put等操作没有实现幂等的情况下是很危险的,所以设置为false
ConnectTimeout:5000#请求连接的超时时间
ReadTimeout:6000#请求处理的超时时间
负载均衡测试:
启动两个cms服务,端口要不一致
定义RestTemplate,使用@LoadBalanced注解:
@Bean
@LoadBalanced
publicRestTemplaterestTemplate(){
returnnewRestTemplate(newOkHttp3ClientHttpRequestFactory());
}
远程调用cms的查询页面接口:
//负载均衡调用
@Test
publicvoidtestRibbon(){
//服务id
String serviceId =\"XC‐SERVICE‐MANAGE‐CMS\";
for(inti=0;i10;i++){
//通过服务id调用
ResponseEntity forEntity = restTemplate.getForEntity(\"http://\"+ serviceId
+\"/cms/page/get/5a754adf6abb500ad05688d9\", CmsPage.class);
CmsPage cmsPage = forEntity.getBody();
System.out.println(cmsPage);
}
}
添加@LoadBalanced注解后,restTemplate会走LoadBalancerInterceptor拦截器,此拦截器中会通过RibbonLoadBalancerClient查询服务地址,打断点观察每次调用的服务地址和端口,可以看到两个cms服务会轮流被调用。
2.2Feign
简介:
Feign是Netflix公司开源的轻量级rest客户端,使用Feign可以非常方便的实现Http 客户端。Spring Cloud引入Feign并且集成了Ribbon实现客户端负载均衡调用。
使用:
添加Maven依赖:
dependency
groupIdorg.springframework.cloud/groupId
artifactIdspring‐cloud‐starter‐openfeign/artifactId
/dependency
dependency
groupIdcom.netflix.feign/groupId
artifactIdfeign‐okhttp/artifactId
/dependency
定义FeignClient接口:
@FeignClient(value = \"XC_SERVICE_MANAGE_CMS\")
publicinterfaceCmsPageClient{
//微服务接口路径
@GetMapping(\"/cms/page/get/{id}\")
publicCmsPagefindById(@PathVariable(\"id\")String id);
}
启动类添加@EnableFeignClients注解
测试:
@RunWith(SpringRunner.class)
@SpringBootTest
publicclassFeignTest{
@Autowired
CmsPageClient cmsPageClient;//接口代理对象,由Feign生成代理对象
@Test
publicvoidtestFeign(){
//发起远程调用
CmsPage cmsPage = cmsPageClient.findById(\"5a754adf6abb500ad05688d9\");
System.out.println(cmsPage);
}
}
Feign工作原理:
1、 启动类添加@EnableFeignClients注解,Spring会扫描标记了@FeignClient注解的接口,并生成此接口的代理对象
2、 @FeignClient(value = XcServiceList.XC_SERVICE_MANAGE_CMS)即指定了cms的服务名称,Feign会从注册中心获取cms服务列表,并通过负载均衡算法进行服务调用。
3、在接口方法 中使用注解@GetMapping(\"/cms/page/get/{id}\"),指定调用的url,Feign将根据url进行远程调用。
九、(Eureka篇)集群Eureka 搭建
参照《七、(Eureka篇)单机Eureka 服务端和客户端配置》( )来新建
cloud-eureka-server-7001 的 yml 文件修改如下。
同理,cloud-eureka-server-7002 的 yml 文件修改如下图
hosts文件地址:C:\\Windows\\System32\\drivers\\etc,需要用管理员权限才能修改。
在浏览器中分别输入 和 ,可以看到他们之间相互注册
该地址就是 支付模块 中 yml 配置的服务名
使用 @LoadBalanced 赋予 RestTemplate 负载均衡的能力。
修改 cloud-consumer-order80 服务的配置类 ApplicationContextConfig.java
(1)先启动 EurekaServer 的所有节点:7001和7002。
(2)启动支付模块:8001 和 8002
(3)启动消费者模块:80
actuator 可以用来监控、管理、控制 springBoot项目,比如健康检查、资源使用情况,接口访问情况等。可以通过常用的 http 接口访问的方式来实现。
我们的目的是为了像下图一样:
在 application.yml 中加入针对实例的如下配置即可:
eureka搭建指南
相比于zk,eureka关注于高可用性。所以,eureka在一致性上不太强制,可以说是注册中心最优秀的选择了。
强一致性的系统就像是,你向集群写入一条数据,集群需要完全同步或者同步半数以上,才给你返回个ack。
高可用性提现在于,服务注册之后注册的节点数据同步完成了,但是并未完全同步节点即可完成注册;而且每个注册节点是相互独立的,不存在选举可以跨机房部署。
pom文件同上
输入
使用REST接口检查服务信息