[TOC]
# 简介
服务提供者要向EurekaServer注册服务,并且完成服务续约等工作。
> 服务注册
服务提供者在启动时,会检测配置属性中的:`eureka.client.register-with-erueka=true`参数是否正确,事实上默认就是true。如果值确实为true,则会向EurekaServer发起一个Rest请求,并携带离己的元数据信息,
Eureka Server会把这些信息保存到一个双层Map结构中。
* 第一层Map的Key就是服务id,一般是配置中的spring.application.name属性
* 第二层Map的key是服务的实例id。一般`host+serviceld+port`,例如:`locahost:user-service:8081`
* 值则是服务的实例对象,也就是说一个服务,可以同时启动多个不同实例,形成集群。
> 服务续约
在注册服务完成以后,服务提供者会维持一个心跳(定时向EurekaServer发起Rest请求),告诉EurekaServer. 这个叫服务的续约(renew)
~~~
eureka:
instance:
# 表示eureka client间隔多久去拉取服务注册信息,默认为30秒,如果要迅速获取服务注册状态,可以缩小该值
lease-renewal-interval-in-seconds: 5 # 心跳时间,即服务续约间隔时间(缺省为30s)
# 表示eureka server至上一次收到client的心跳之后,等待下一次心跳的超时时间,在这个时间内若没收到下一次心跳,则将移除该instance。
# 默认为90秒
# 如果该值太大,则很可能将流量转发过去的时候,该instance已经不存活了。
# 如果该值设置太小了,则instance则很可能因为临时的网络抖动而被摘除掉。
# 该值至少应该大于 leaseRenewalIntervalInSeconds
lease-expiration-duration-in-seconds: 15 # 发呆时间,即服务续约到期时间(缺省为90s)
~~~
默认情况每30秒服务会向注册中心发送一个心跳,证明自己还活着.
如果超过90秒没有发心跳,Eureka会认为该服务已经宕机,会从服务列表中移除.
> 获取服务列表
当服务消费者启动,会检测`eureka.client.fetch-registry=true`参数的值,如果为true,则会从Eureka
Server服务的列表只读备份,然后缓存在本地。并且每隔30秒会重新获取并更新数据。我们可以通过下面的参数来修改:
~~~
eureka:
instance:
registry-fetch-interval-seconds:30
~~~
> 服务下线
当服务进行正常关闭操作时,它会触发一个服务下线的REST请求给Eureka Server,告诉服务注册中心:“我要下线了”。服务中心接受到请求之后,将该服务置为下线状态。
> 失效别除
有时我们的服务可能由于内存溢出或网络故障等原因使得服务不能正常的工作,而服务注册中心并未收到“服务下
线”的请求。相对于服务提供者的“服务续约”操作,服务注册中心在启动时会创建一个定时任务,默认每隔一段时
间(默认为60秒)将当前清单中超时(默认为90秒)没有续约的服务剔除,这个操作被称为失效剔除。
可以通过`eureka.server.eviction-interval-timer-in-ms`参数对其进行修改,单位是毫秒。
# 配置信息
Eureka包含四部分配置
1. instance : 当前Eureka Instance实例配置信息
2. client : Eureka Client客户端特性配置
3. server : Eureka Server注册中心特性配置
4. dashboard : Eureka Server注册中心仪表盘配置
## Eureka Instance 实例信息配置
Eureka Instance的配置信息全部保存在`org.springframework.cloud.netflix.eureka.EurekaInstanceConfigBean`配置类中,实际上它是com.netflix.appinfo.EurekaInstanceConfig的实现类,替代了netflix的com.netflix.appinfo.CloudInstanceConfig的默认实现。
Eureka Instance的配置信息全部以eureka.instance.xxx的格式配置。
| 配置属性 | 解释 | 默认值 |
| --- | --- | --- |
| appname | 应用名,首先获取spring.application.name的值,如果取值为空,则取默认unknown | unknown |
| appGroupName | 应用组名 | null |
| instanceEnabledOnit | 实例注册到Eureka上是,是否立刻开启通讯。有时候应用在准备好服务之前需要一些预处理 | false |
| nonSecurePort | 非安全的端口 | 80 |
| securePort | 安全的端口 | 443 |
| nonSecurePortEnabled | 是否开启非安全端口通讯 | true |
| securePortEnabled | 是否开启安全端口通讯 | false |
| leaseRenewalIntervalInSeconds | 实例续约间隔时间(s) | 30 |
| leaseExpirationDurationInSeconds | 实例超时时间,表示最大leaseExpirationDurationInSeconds秒后没有续约,Server就认为他不可用了,随之就会将其剔除(s) | 90 |
| virtualHostName | 虚拟主机名,首先获取spring.application.name的值,如果取值为空,则取默认unknown。 | unknown |
| instanceId | 注册到eureka上的唯一实例ID,不能与相同appname的其他实例重复 | |
| secureVirtualHostName | 安全虚拟主机名,首先获取spring.application.name的值,如果取值为空,则取默认unknown | unknown |
| metadataMap | 实例元数据,可以供其他实例使用。比如spring-boot-admin在监控时,获取实例的上下文和端口 | HashMap |
| dataCenterInfo | 实例部署的数据中心。如AWS、MyOwn | new |MyDataCenterInfo(DataCenterInfo.Name.MyOwn) |
| ipAddress | 实例的IP地址 | null |
| statusPageUrlPath | 实例状态页相对url | "/actuator/info" |
| statusPageUrl | 实例状态页绝对url | url |
| homePageUrlPath | 实例主页相对URL | / |
| healthCheckUrlUrlPath | 实例健康检查相对URL | "/actuator/health" |
| healthCheckUrl | 实例健康检查绝对URL | null |
| secureHealthCheckUrl | 实例安全的健康检查绝对URL | null |
| namespace | 配置属性的命名空间(Spring Cloud中被忽略) | "eureka" |
| hostname | 主机名,不配置的时候讲根据操作系统的主机名来获取 | null |
| preferIpAddress | 是否优先使用IP地址作为主机名的标识 | false
|
## Eureka Client客户端特性配置
Eureka Client客户端特性配置是对作为Eureka客户端的特性配置,包括Eureka注册中心,本身也是一个Eureka Client。Eureka Client特性配置全部在`org.springframework.cloud.netflix.eureka.EurekaClientConfigBean`中,实际上它是`com.netflix.discovery.EurekaClientConfig`的实现类,替代了netxflix的默认实现
Eureka Client客户端特性配置全部以eureka.client.xxx的格式配置。
| 配置属性 | 解释 | 默认值 |
| :-- | --: | :-: |
| enabled | 是否启用 Eureka client | `true` |
| registryFetchIntervalSeconds | 定时从 Eureka Server 拉取服务注册信息的间隔时间 (s) | `30` |
| instanceInfoReplicationIntervalSeconds | 定时将实例信息(如果变化了)复制到 Eureka Server 的间隔时间。(InstanceInfoReplicator 线程) | `30` |
| initialInstanceInfoReplicationIntervalSeconds | 首次将实例信息复制到 Eureka Server 的延迟时间。(InstanceInfoReplicator 线程) | `40` |
| eurekaServiceUrlPollIntervalSeconds | 拉取 Eureka Server 地址的间隔时间(Eureka Server 有可能增减) | `300` |
| proxyPort | Eureka Server 的代理端口 | `null` |
| proxyHost | Eureka Server 的代理主机名 | `null` |
| proxyUserName | Eureka Server 的代理用户名 | `null` |
| proxyPassword | Eureka Server 的代理密码 | `null` |
| eurekaServerReadTimeoutSeconds | 从 Eureka Server 读取信息的超时时间 (s) | `8` |
| eurekaServerConnectTimeoutSeconds | 连接 Eureka Server 的超时时间 | `5` |
| backupRegistryImpl | Eureka Client 第一次启动时获取服务注册信息的调用的回溯实现。Eureka Client 启动时首次会检查有没有 BackupRegistry 的实现类,如果有实现类,则优先从这个实现类里获取服务注册信息 | `null` |
| eurekaServerTotalConnections | Eureka client 连接 Eureka Server 的链接总数 | `200` |
| eurekaServerTotalConnectionsPerHost | Eureka client 连接单台 Eureka Server 的链接总数 | `50` |
| eurekaServerURLContext | 当 Eureka server 的列表在 DNS 中时,Eureka Server 的上下文路径。如 http://xxxx/eureka | `null` |
| eurekaServerPort | 当 Eureka server 的列表在 DNS 中时,Eureka Server 的端口 | `null` |
| eurekaServerDNSName | 当 Eureka server 的列表在 DNS 中时,且要通过 DNSName 获取 Eureka Server 列表时,DNS 名字 | `null` |
| region | 实例所属区域 | `us-east-1` |
| eurekaConnectionIdleTimeoutSeconds | Eureka Client 和 Eureka Server 之间的 Http 连接的空闲超时时间 | `30` |
| heartbeatExecutorThreadPoolSize | 心跳(续约)执行器线程池大小 | `2` |
| heartbeatExecutorExponentialBackOffBound | 心跳执行器在续约过程中超时后的再次执行续约的最大延迟倍数。默认最大延迟时间 =`10 * eureka.instance.leaseRenewalIntervalInSeconds` | `10` |
| cacheRefreshExecutorThreadPoolSize | cacheRefreshExecutord 的线程池大小(获取注册信息) | `2` |
| cacheRefreshExecutorExponentialBackOffBound | cacheRefreshExecutord 的再次执行的最大延迟倍数。默认最大延迟时间 =`10 *eureka.client.registryFetchIntervalSeconds` | `10` |
| serviceUrl | Eureka Server 的分区地址。默认添加了一个 defualtZone。也就是最常用的配置`eureka.client.service-url.defaultZone=xxx` | `new HashMap();serviceUrl.put(DEFAULT_ZONE, DEFAULT_URL)` |
| registerWithEureka | 是否注册到 Eureka Server | `true` |
| preferSameZoneEureka | 是否使用相同 Zone 下的 Eureka server | `true` |
| logDeltaDiff | 是否记录 Eureka Server 和 Eureka Client 之间注册信息的差异 | `false` |
| disableDelta | 是否开启增量同步注册信息 | `false` |
| fetchRemoteRegionsRegistry | 获取注册服务的远程地区,以逗号隔开 | `null` |
| availabilityZones | 可用分区列表。用逗号隔开 | `HashMap` |
| filterOnlyUpInstances | 是否只拉取 UP 状态的实例 | `true` |
| fetchRegistry | 是否拉取注册信息 | `true` |
| shouldUnregisterOnShutdown | 是否在停止服务的时候向 Eureka Server 发起 Cancel 指令 | `true` |
| shouldEnforceRegistrationAtInit | 是否在初始化过程中注册服务 | `false` |
## Eureka Server注册中心端配置
Eureka Server注册中心端的配置是对注册中心的特性配置。Eureka Server的配置全部在`org.springframework.cloud.netflix.eureka.server.EurekaServerConfigBean`里,实际上它是`com.netflix.eureka.EurekaServerConfig`的实现类,替代了netflix的默认实现
Eureka Server的配置全部以eureka.server.xxx的格式进行配置
| 配置属性 | 解释 | 默认值 |
| :-- | --: | :-: |
| enableSelfPreservation | 是否开启自我保护 | `true` |
| renewalPercentThreshold | 自我保护续约百分比阀值因子。如果实际续约数小于续约数阀值,则开启自我保护 | `0.85` |
| renewalThresholdUpdateIntervalMs | 续约数阀值更新频率 | `15 * 60 * 1000` |
| peerEurekaNodesUpdateIntervalMs | Eureka Server 节点更新频率 | `10 * 60 * 1000` |
| enableReplicatedRequestCompression | 是否启用复制请求压缩 | `false` |
| waitTimeInMsWhenSyncEmpty | 当从其他节点同步实例信息为空时等待的时间 | `5 * 60 * 1000` |
| peerNodeConnectTimeoutMs | 节点间连接的超时时间 | `200` |
| peerNodeReadTimeoutMs | 节点间读取信息的超时时间 | `200` |
| peerNodeTotalConnectionsPerHost | 单个节点间连接总数 | `500` |
| peerNodeConnectionIdleTimeoutSeconds | 节点间连接空闲超时时间 | `30` |
| retentionTimeInMSInDeltaQueue | 增量队列的缓存时间 | `3 * MINUTES` |
| deltaRetentionTimerIntervalInMs | 清理增量队列中过期的频率 | `30 * 1000` |
| evictionIntervalTimerInMs | 剔除任务频率 | `60*1000` |
| responseCacheAutoExpirationInSeconds | 注册列表缓存超时时间(当注册列表没有变化时) | `180` |
| responseCacheUpdateIntervalMs | 注册列表缓存更新频率 | `30 * 1000` |
| useReadOnlyResponseCache | 是否开启注册列表的二级缓存 | `true` |
| disableDelta | 是否为 client 提供增量信息 | `false` |
| maxThreadsForStatusReplication | 状态同步的最大线程数 | `1` |
| maxElementsInStatusReplicationPool | 状态同步队列的最大容量 | `10000` |
| syncWhenTimestampDiffers | 当时间差异时是否同步 | `true` |
| registrySyncRetries | 注册信息同步重试次数 | `0` |
| registrySyncRetryWaitMs | 注册信息同步重试期间的时间间隔 | `30 * 1000` |
| maxElementsInPeerReplicationPool | 节点间同步事件的最大容量 | `10000` |
| minThreadsForPeerReplication | 节点间同步的最小线程数 | `5` |
| maxThreadsForPeerReplication | 节点间同步的最大线程数 | `20` |
| maxTimeForReplication | 节点间同步的最大时间,单位为毫秒 | `30000` |
| disableDeltaForRemoteRegions | 是否启用远程区域增量 | `false` |
| remoteRegionConnectTimeoutMs | 远程区域连接超时时间 | `1000` |
| remoteRegionReadTimeoutMs | 远程区域读取超时时间 | `1000` |
| remoteRegionTotalConnections | 远程区域最大连接数 | `1000` |
| remoteRegionTotalConnectionsPerHost | 远程区域单机连接数 | `500` |
| remoteRegionConnectionIdleTimeoutSeconds | 远程区域连接空闲超时时间 | `30` |
| remoteRegionRegistryFetchInterval | 远程区域注册信息拉取频率 | `30` |
| remoteRegionFetchThreadPoolSize | 远程区域注册信息线程数 | `20` |
## Eureka Server 注册中心仪表盘配置
注册中心仪表盘的配置主要是控制注册中心的可视化展示。以`eureka.dashboard.xxx`的格式配置
**配置列表:**
| 配置属性 | 解释 | 默认值 |
| :-- | --: | :-: |
| path | 仪表盘访问路径 | `/` |
| enabled | 是否启用仪表盘 | `` |
# Self Preservation Mode(自我保护模式)
1. 服务的正常退出流程。
eureka要求当client退出的时候,它显示的调用"注销"接口. 进行优雅退出.
2. self preservation mode是一种保护/容错机制
它主要是用来避免由于网络抖动或者故障带来的连接失败,看下面2种情况。
* 网络故障,或者若网,导致server没有收到client的心跳信息,这时候其实client服务是活着的
* 及时client和server直接断开了,但是服务A已经跟服务B建立了连接
3. 看几个重要的配置参数
* eureka.instance.lease-renewal-interval-in-seconds=30
这个标识多久发送一次心跳
* eureka.instance.lease-expiration-duration-in-seconds=90
这个标识server过多久还没有收到来自客户端的心跳,就认为client已经挂了,把他踢掉的时间
* eureka.server.eviction-interval-timer-in-ms=5000
每隔多久进行一次检查,看是不是有挂了的client[关联一个定时器]
* eureka.server.renewal-threshold-update-interval-ms=6000
每隔多久计算一次期望的每分钟收到的心跳的次数[关联一个定时器]
* eureka.server.renewal-percent-threshold=0.85
计算每分钟最小心跳次数的threshold,
* 还有一个定时器,每分钟执行一次,计算上一分钟实际收到的心跳次数.
4. 案例说明
有2个服务,A 和 B, 假设配置的参数值就是上面的值
4.1 任何服务连续3次发生心跳失败(超过了90秒),就会被踢掉
4.2 正常情况,1分钟应收到的心跳次数是2(每分钟的次数)*2(服务的数量),最小次数是 2(每分钟的次数)*2(服务的数量)*0.85=3
4.3 每分钟计算一次最小的心跳次数(对应上面的3.4)
4.4 若实际的心跳次数小于最小的心跳次数,启动自我保护模式
综上,自我保护模式是一种应对网络异常的安全保护措施。它的架构哲学是宁可同时保留所有微服务(健康的微服务和不健康的微服务都会保留),也不盲目注销任何健康的微服务。使用自我保护模式,可以让Eureka集群更加的健壮、稳定。
当我们在本地调试基于Eureka的程序时,基本上都会碰到这样一个问题,在服务注册中心的信息面板中出现类似的红色警告信息:
~~~
EMERGENCY! EUREKA MAY BE INCORRECTLY CLAIMING INSTANCES ARE UP WHEN THEY’RE NOT.
RENEWALS ARE LESSER THAN THRESHOLD AND HENCE THE INSTANCES ARE NOT BEING EXPIRED JUST TO BE SAFE.
~~~
# server端
~~~
@EnableEurekaServer
@SpringBootApplication
public class EurekaServer {
public static void main(String[] args) {
SpringApplication.run(EurekaServer.class, args);
}
}
~~~
~~~
<dependencies>
<!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-netflix-eureka-server -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
</dependencies>
~~~
配置文件
~~~
# 单机版
# (registerWithEureka, fetchRegistry, hostname)
# 无参数启动
spring:
application:
name: eureka-server
server:
port: 10086
address: 0.0.0.0
eureka:
datacenter: cloud # 修改Eureka监控页面的System Status Data center
environment: test # 修改Eureka监控页面的System Status Environment
instance:
hostname: jdxia.local # Eureka 实例主机名,每一个 Eureka Server 都有自己的实例名
server:
enable-self-preservation: false # 关闭自我保护模式(默认为打开)
# eviction-interval-timer-in-ms: 5000 # 续期时间,即扫描失效服务的间隔时间(缺省为60*1000ms)
client:
fetchRegistry: false # 表示是否从 Eureka Server 服务注册表中获取注册信息,默认为 true。同理自身本身就是服务端,而且是单机模式,不需要同步其他的 Eureka Server节点的数据,故而设置为 false
registerWithEureka: false # 表示是否将自己注册到 Eureka Server 服务注册表中,默认为 true。因为当前应用本身就是 Eureka Server,所以设置为 false。Eureka Server 无需注册,Eureka Client 才需要像 Server 端进行注册。
service-url:
defaultZone: http://${eureka.instance.hostname}/eureka/
~~~
访问: [http://0.0.0.0:10086/](http://0.0.0.0:10086/)
# client端
~~~
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
~~~
在启用类上加入@EnableEurekaClient注解即可,通过该注解,项目下所有被@RestController注解的对外服务接口将可通过注册-发布的方式对外提供服务。
~~~
@EnableDiscoveryClient
@SpringBootApplication
@MapperScan("com.jdxia.user.mapper")
public class UserApplication {
public static void main(String[] args) {
SpringApplication.run(UserApplication.class);
}
}
~~~
配置文件
要名字,Eureka需要
~~~
spring:
application:
name: consumer-server
eureka:
instance:
# 表示eureka client间隔多久去拉取服务注册信息,默认为30秒,如果要迅速获取服务注册状态,可以缩小该值
lease-renewal-interval-in-seconds: 5 # 心跳时间,即服务续约间隔时间(缺省为30s)
# 表示eureka server至上一次收到client的心跳之后,等待下一次心跳的超时时间,在这个时间内若没收到下一次心跳,则将移除该instance。
# 默认为90秒
# 如果该值太大,则很可能将流量转发过去的时候,该instance已经不存活了。
# 如果该值设置太小了,则instance则很可能因为临时的网络抖动而被摘除掉。
# 该值至少应该大于 leaseRenewalIntervalInSeconds
lease-expiration-duration-in-seconds: 15 # 发呆时间,即服务续约到期时间(缺省为90s)
client:
registry-fetch-interval-seconds: 10 # 拉取服务注册信息间隔(缺省为30s)
service-url:
defaultZone: http://127.0.0.1:10086/eureka
~~~
# 消费者
~~~
spring:
application:
name: consumer-server
eureka:
instance:
lease-renewal-interval-in-seconds: 5 # 心跳时间,即服务续约间隔时间(缺省为30s)
lease-expiration-duration-in-seconds: 15 # 发呆时间,即服务续约到期时间(缺省为90s)
client:
registry-fetch-interval-seconds: 10 # 拉取服务注册信息间隔(缺省为30s)
service-url:
defaultZone: http://127.0.0.1:10086/eureka
~~~
~~~
@Autowired
private DiscoveryClient discoveryClient;
~~~
~~~
//根据服务id获取实例
List<ServiceInstance> list = discoveryClient.getInstances("user-service");
//从实例中取出ip和端口
ServiceInstance serviceInstance = list.get(0);
~~~
client也可以通过直接写注册服务方的名字也可以调用
这边的restTemplate直接用注入的就行.
如果是要用ip那种,那restTemplate需要new,注入的会报`java.lang.IllegalStateException: No instances available for`
~~~
String url = "http://user-service/user/" + id;
System.out.println(url);
String user = restTemplate.getForObject(url, String.class);
~~~
# 单机多集群版
单文件版本
可以将application-server1.yml和application-server2.yml的配置信息都放到原application.yml配置中,
通过`‘---’` 三横杠模加spring.profiles模式来启动,同时增加启动参数: `--spring.profiles.active=config-server1`
**hosts**
~~~
0.0.0.0 peer1
0.0.0.0 peer2
0.0.0.0 peer3
~~~
**application.yml**
~~~
spring:
application:
name: mima-cloud-eureka-ha
profiles:
active: peer1
---
server:
port: 8762
spring:
profiles: peer1
eureka:
instance:
hostname: peer1
prefer-ip-address: true
instance-id: ${spring.application.name}:${server.port}
client:
serviceUrl:
defaultZone: http://peer2:8763/eureka/,http://peer3:8764/eureka/
---
server:
port: 8763
spring:
profiles: peer2
eureka:
instance:
hostname: peer2
prefer-ip-address: true
instance-id: ${spring.application.name}:${server.port}
client:
serviceUrl:
defaultZone: http://peer1:8762/eureka/,http://peer3:8764/eureka/
---
server:
port: 8764
spring:
profiles: peer3
eureka:
instance:
hostname: peer3
prefer-ip-address: true
instance-id: ${spring.application.name}:${server.port}
client:
serviceUrl:
defaultZone: http://peer1:8762/eureka/,http://peer2:8763/eureka
~~~
配置文件是通过三个Eureka Server互相注册,这里有四段配置,第一段配置为公共配置,配置了应用名称,第二段为名peer1的配置,第三段为peer2的配置,第三段为peer3的配置。在项目启动可以通过
\--spring.profiles.active={配置名称} 来启动不同的配置。
**eureka客户端修改eureka服务端的地址**
~~~
eureka:
instance:
prefer-ip-address: true
instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${server.port}
client:
serviceUrl:
defaultZone: http://peer1:8762/eureka/,http://peer2:8763/eureka/,http://peer3:8764/eureka/
#defaultZone: http://127.0.0.1:8762/eureka/,http://127.0.0.1:8763/eureka/,http://127.0.0.1:8764/eureka/
~~~
启动eurekaClient客户端
启动eurekaServer服务端
因使用eureka集群,启动的时候需要指定配置文件:
启动peer1节点命令:
`java -jar D:\\jar\\eurekaServer\\eurekaServerHigh.jar--spring.profiles.active=peer1`
启动peer2节点命令:
`java -jar D:\\jar\\eurekaServer\\eurekaServerHigh.jar--spring.profiles.active=peer2`
启动peer3节点命令:
`java -jar D:\\jar\\eurekaServer\\eurekaServerHigh.jar--spring.profiles.active=peer3`
![](https://img.kancloud.cn/20/94/209473949134971636d6084155c02f5e_1023x361.png)
`program arguments: xxxx`
---
**多文件方式**
如果你的配置是application-server1.yml
这种多文件配置
idea中
![](https://img.kancloud.cn/dc/90/dc90100aedc0ea2beca4a20ad7dad578_2450x1332.png)
# 主动下线
1. 为了让注册中心马上知道服务要下线, 可以向eureka 注册中心发送delete 请求
格式为 `/eureka/apps/{application.name}/`
下面是下线一个hello-service的例子。
![](https://img.kancloud.cn/70/cf/70cf6e6592629fc6ea20a24da785dab9_756x274.png)
**值得注意的是,Eureka客户端每隔一段时间(默认30秒)会发送一次心跳到注册中心续约。如果通过这种方式下线了一个服务,而没有及时停掉的话,该服务很快又会回到服务列表中。**
所以,可以先停掉服务,再发送请求将其从列表中移除
2. 客户端主动通知注册中心下线
如果你的eureka客户端是是一个spring boot应用,可以通过调用以下代码通知注册中心下线。
~~~
DiscoveryManager.getInstance().shutdownComponent();
~~~
~~~
@RestController
public class HelloController {
@Autowired
private DiscoveryClient client;
@RequestMapping(value = "/hello", method = RequestMethod.GET)
public String index() {
java.util.List<ServiceInstance> instances = client.getInstances("hello-service");
return "Hello World";
}
@RequestMapping(value = "/offline", method = RequestMethod.GET)
public void offLine(){
DiscoveryManager.getInstance().shutdownComponent();
}
}
~~~
![](https://img.kancloud.cn/c2/60/c26009b7ebbb75011163e968fee1af05_639x180.png)
# 常见问题
**解决spring cloud eureka服务注册出现的`Error creating bean with name 'org.springframework.cloud.netflix...`问题**
在pom文件中加入以下依赖
~~~
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>25.1-jre</version>
</dependency>
<dependency>
<groupId>com.diffplug.guava</groupId>
<artifactId>guava-cache</artifactId>
<version>19.0.0</version>
</dependency>
~~~
- 基础
- 编译和安装
- classpath到底是什么?
- 编译运行
- 安装
- sdkman多版本
- jabba多版本
- java字节码查看
- 数据类型
- 简介
- 整形
- char和int
- 变量和常量
- 大数值运算
- 基本类型包装类
- Math类
- 内存划分
- 位运算符
- 方法相关
- 方法重载
- 可变参数
- 方法引用
- 面向对象
- 定义
- 继承和覆盖
- 接口和抽象类
- 接口定义增强
- 内建函数式接口
- 多态
- 泛型
- final和static
- 内部类
- 包
- 修饰符
- 异常
- 枚举类
- 代码块
- 对象克隆
- BeanUtils
- java基础类
- scanner类
- Random类
- System类
- Runtime类
- Comparable接口
- Comparator接口
- MessageFormat类
- NumberFormat
- 数组相关
- 数组
- Arrays
- string相关
- String
- StringBuffer
- StringBuilder
- 正则
- 日期类
- Locale类
- Date
- DateFormat
- SimpleDateFormat
- Calendar
- 新时间日期API
- 简介
- LocalDate,LocalTime,LocalDateTime
- Instant时间点
- 带时区的日期,时间处理
- 时间间隔
- 日期时间校正器
- TimeUnit
- 用yyyy
- 集合
- 集合和迭代器
- ArrayList集合
- List
- Set
- 判断集合唯一
- Map和Entry
- stack类
- Collections集合工具类
- Stream数据流
- foreach不能修改内部元素
- of方法
- IO
- File类
- 字节流stream
- 字符流Reader
- IO流分类
- 转换流
- 缓冲流
- 流的操作规律
- properties
- 序列化流与反序列化流
- 打印流
- System类对IO支持
- commons-IO
- IO流总结
- NIO
- 异步与非阻塞
- IO通信
- Unix的IO模型
- epoll对于文件描述符操作模式
- 用户空间和内核空间
- NIO与普通IO的主要区别
- Paths,Path,Files
- Buffer
- Channel
- Selector
- Pipe
- Charset
- NIO代码
- 多线程
- 创建线程
- 线程常用方法
- 线程池相关
- 线程池概念
- ThreadPoolExecutor
- Runnable和Callable
- 常用的几种线程池
- 线程安全
- 线程同步的几种方法
- synchronized
- 死锁
- lock接口
- ThreadLoad
- ReentrantLock
- 读写锁
- 锁的相关概念
- volatile
- 释放锁和不释放锁的操作
- 等待唤醒机制
- 线程状态
- 守护线程和普通线程
- Lamda表达式
- 反射相关
- 类加载器
- 反射
- 注解
- junit注解
- 动态代理
- 网络编程相关
- 简介
- UDP
- TCP
- 多线程socket上传图片
- NIO
- JDBC相关
- JDBC
- 预处理
- 批处理
- 事务
- properties配置文件
- DBUtils
- DBCP连接池
- C3P0连接池
- 获得MySQL自动生成的主键
- Optional类
- Jigsaw模块化
- 日志相关
- JDK日志
- log4j
- logback
- xml
- tomcat
- maven
- 简介
- 仓库
- 目录结构
- 常用命令
- 生命周期
- idea配置
- jar包冲突
- 依赖范围
- 私服
- 插件
- git-commit-id-plugin
- maven-assembly-plugin
- maven-resources-plugin
- maven-compiler-plugin
- versions-maven-plugin
- maven-source-plugin
- tomcat-maven-plugin
- 多环境
- 自定义插件
- stream
- swing
- json
- jackson
- optional
- junit
- gradle
- servlet
- 配置
- ServletContext
- 生命周期
- HttpServlet
- request
- response
- 乱码
- session和cookie
- cookie
- session
- jsp
- 简介
- 注释
- 方法,成员变量
- 指令
- 动作标签
- 隐式对象
- EL
- JSTL
- javaBean
- listener监听器
- Filter过滤器
- 图片验证码
- HttpUrlConnection
- 国际化
- 文件上传
- 文件下载
- spring
- 简介
- Bean
- 获取和实例化
- 属性注入
- 自动装配
- 继承和依赖
- 作用域
- 使用外部属性文件
- spel
- 前后置处理器
- 生命周期
- 扫描规则
- 整合多个配置文件
- 注解
- 简介
- 注解分层
- 类注入
- 分层和作用域
- 初始化方法和销毁方法
- 属性
- 泛型注入
- Configuration配置文件
- aop
- aop的实现
- 动态代理实现
- cglib代理实现
- aop名词
- 简介
- aop-xml
- aop-注解
- 代理方式选择
- jdbc
- 简介
- JDBCTemplate
- 事务
- 整合
- junit整合
- hibernate
- 简介
- hibernate.properties
- 实体对象三种状态
- 检索方式
- 简介
- 导航对象图检索
- OID检索
- HQL
- Criteria(QBC)
- Query
- 缓存
- 事务管理
- 关系映射
- 注解
- 优化
- MyBatis
- 简介
- 入门程序
- Mapper动态代理开发
- 原始Dao开发
- Mapper接口开发
- SqlMapConfig.xml
- map映射文件
- 输出返回map
- 输入参数
- pojo包装类
- 多个输入参数
- resultMap
- 动态sql
- 关联
- 一对一
- 一对多
- 多对多
- 整合spring
- CURD
- 占位符和sql拼接以及参数处理
- 缓存
- 延迟加载
- 注解开发
- springMVC
- 简介
- RequestMapping
- 参数绑定
- 常用注解
- 响应
- 文件上传
- 异常处理
- 拦截器
- springBoot
- 配置
- 热更新
- java配置
- springboot配置
- yaml语法
- 运行
- Actuator 监控
- 多环境配置切换
- 日志
- 日志简介
- logback和access
- 日志文件配置属性
- 开机自启
- aop
- 整合
- 整合Redis
- 整合Spring Data JPA
- 基本查询
- 复杂查询
- 多数据源的支持
- Repository分析
- JpaSpecificationExecutor
- 整合Junit
- 整合mybatis
- 常用注解
- 基本操作
- 通用mapper
- 动态sql
- 关联映射
- 使用xml
- spring容器
- 整合druid
- 整合邮件
- 整合fastjson
- 整合swagger
- 整合JDBC
- 整合spingboot-cache
- 请求
- restful
- 拦截器
- 常用注解
- 参数校验
- 自定义filter
- websocket
- 响应
- 异常错误处理
- 文件下载
- 常用注解
- 页面
- Thymeleaf组件
- 基本对象
- 内嵌对象
- 上传文件
- 单元测试
- 模拟请求测试
- 集成测试
- 源码解析
- 自动配置原理
- 启动流程分析
- 源码相关链接
- Servlet,Filter,Listener
- springcloud
- 配置
- 父pom
- 创建子工程
- Eureka
- Hystrix
- Ribbon
- Feign
- Zuul
- kotlin
- 基本数据类型
- 函数
- 区间
- 区块链
- 简介
- linux
- ulimit修改
- 防止syn攻击
- centos7部署bbr
- debain9开启bbr
- mysql
- 隔离性
- sql执行加载顺序
- 7种join
- explain
- 索引失效和优化
- 表连接优化
- orderby的filesort问题
- 慢查询
- show profile
- 全局查询日志
- 死锁解决
- sql
- 主从
- IDEA
- mac快捷键
- 美化界面
- 断点调试
- 重构
- springboot-devtools热部署
- IDEA进行JAR打包
- 导入jar包
- ProjectStructure
- toString添加json模板
- 配置maven
- Lombok插件
- rest client
- 文档显示
- sftp文件同步
- 书签
- 代码查看和搜索
- postfix
- live template
- git
- 文件头注释
- JRebel
- 离线模式
- xRebel
- github
- 连接mysql
- 选项没有Java class的解决方法
- 扩展
- 项目配置和web部署
- 前端开发
- json和Inject language
- idea内存和cpu变高
- 相关设置
- 设计模式
- 单例模式
- 简介
- 责任链
- JUC
- 原子类
- 原子类简介
- 基本类型原子类
- 数组类型原子类
- 引用类型原子类
- JVM
- JVM规范内存解析
- 对象的创建和结构
- 垃圾回收
- 内存分配策略
- 备注
- 虚拟机工具
- 内存模型
- 同步八种操作
- 内存区域大小参数设置
- happens-before
- web service
- tomcat
- HTTPS
- nginx
- 变量
- 运算符
- 模块
- Rewrite规则
- Netty
- netty为什么没用AIO
- 基本组件
- 源码解读
- 简单的socket例子
- 准备netty
- netty服务端启动
- 案例一:发送字符串
- 案例二:发送对象
- websocket
- ActiveMQ
- JMS
- 安装
- 生产者-消费者代码
- 整合springboot
- kafka
- 简介
- 安装
- 图形化界面
- 生产过程分析
- 保存消息分析
- 消费过程分析
- 命令行
- 生产者
- 消费者
- 拦截器interceptor
- partition
- kafka为什么快
- kafka streams
- kafka与flume整合
- RabbitMQ
- AMQP
- 整体架构
- RabbitMQ安装
- rpm方式安装
- 命令行和管控页面
- 消息生产与消费
- 整合springboot
- 依赖和配置
- 简单测试
- 多方测试
- 对象支持
- Topic Exchange模式
- Fanout Exchange订阅
- 消息确认
- java client
- RabbitAdmin和RabbitTemplate
- 两者简介
- RabbitmqAdmin
- RabbitTemplate
- SimpleMessageListenerContainer
- MessageListenerAdapter
- MessageConverter
- 详解
- Jackson2JsonMessageConverter
- ContentTypeDelegatingMessageConverter
- lucene
- 简介
- 入门程序
- luke查看索引
- 分析器
- 索引库维护
- elasticsearch
- 配置
- 插件
- head插件
- ik分词插件
- 常用术语
- Mapping映射
- 数据类型
- 属性方法
- Dynamic Mapping
- Index Template 索引模板
- 管理映射
- 建立映射
- 索引操作
- 单模式下CURD
- mget多个文档
- 批量操作
- 版本控制
- 基本查询
- Filter过滤
- 组合查询
- 分析器
- redis
- String
- list
- hash
- set
- sortedset
- 发布订阅
- 事务
- 连接池
- 管道
- 分布式可重入锁
- 配置文件翻译
- 持久化
- RDB
- AOF
- 总结
- Lettuce
- zookeeper
- zookeeper简介
- 集群部署
- Observer模式
- 核心工作机制
- zk命令行操作
- zk客户端API
- 感知服务动态上下线
- 分布式共享锁
- 原理
- zab协议
- 两阶段提交协议
- 三阶段提交协议
- Paxos协议
- ZAB协议
- hadoop
- 简介
- hadoop安装
- 集群安装
- 单机安装
- linux编译hadoop
- 添加新节点
- 退役旧节点
- 集群间数据拷贝
- 归档
- 快照管理
- 回收站
- 检查hdfs健康状态
- 安全模式
- hdfs简介
- hdfs命令行操作
- 常见问题汇总
- hdfs客户端操作
- mapreduce工作机制
- 案例-单词统计
- 局部聚合Combiner
- combiner流程
- combiner案例
- 自定义排序
- 自定义Bean对象
- 排序的分类
- 案例-按总量排序需求
- 一次性完成统计和排序
- 分区
- 分区简介
- 案例-结果分区
- 多表合并
- reducer端合并
- map端合并(分布式缓存)
- 分组
- groupingComparator
- 案例-求topN
- 全局计数器
- 合并小文件
- 小文件的弊端
- CombineTextInputFormat机制
- 自定义InputFormat
- 自定义outputFormat
- 多job串联
- 倒排索引
- 共同好友
- 串联
- 数据压缩
- InputFormat接口实现类
- yarn简介
- 推测执行算法
- 本地提交到yarn
- 框架运算全流程
- 数据倾斜问题
- mapreduce的优化方案
- HA机制
- 优化
- Hive
- 安装
- shell参数
- 数据类型
- 集合类型
- 数据库
- DDL操作
- 创建表
- 修改表
- 分区表
- 分桶表
- DML操作
- load
- insert
- select
- export,import
- Truncate
- 注意
- 严格模式
- 函数
- 内置运算符
- 内置函数
- 自定义函数
- Transfrom实现
- having和where不同
- 压缩
- 存储
- 存储和压缩结合使用
- explain详解
- 调优
- Fetch抓取
- 本地模式
- 表的优化
- GroupBy
- count(Distinct)去重统计
- 行列过滤
- 动态分区调整
- 数据倾斜
- 并行执行
- JVM重用
- 推测执行
- reduce内存和个数
- sql查询结果作为变量(shell)
- youtube
- flume
- 简介
- 安装
- 常用组件
- 拦截器
- 案例
- 监听端口到控制台
- 采集目录到HDFS
- 采集文件到HDFS
- 多个agent串联
- 日志采集和汇总
- 单flume多channel,sink
- 自定义拦截器
- 高可用配置
- 使用注意
- 监控Ganglia
- sqoop
- 安装
- 常用命令
- 数据导入
- 准备数据
- 导入数据到HDFS
- 导入关系表到HIVE
- 导入表数据子集
- 增量导入
- 数据导出
- 打包脚本
- 作业
- 原理
- azkaban
- 简介
- 安装
- 案例
- 简介
- command类型单一job
- command类型多job工作流flow
- HDFS操作任务
- mapreduce任务
- hive脚本任务
- oozie
- 安装
- hbase
- 简介
- 系统架构
- 物理存储
- 寻址机制
- 读写过程
- 安装
- 命令行
- 基本CURD
- java api
- CURD
- CAS
- 过滤器查询
- 建表高级属性
- 与mapreduce结合
- 与sqoop结合
- 协处理器
- 参数配置优化
- 数据备份和恢复
- 节点管理
- 案例-点击流
- 简介
- HUE
- 安装
- storm
- 简介
- 安装
- 集群启动及任务过程分析
- 单词统计
- 单词统计(接入kafka)
- 并行度和分组
- 启动流程分析
- ACK容错机制
- ACK简介
- BaseRichBolt简单使用
- BaseBasicBolt简单使用
- Ack工作机制
- 本地目录树
- zookeeper目录树
- 通信机制
- 案例
- 日志告警
- 工具
- YAPI
- chrome无法手动拖动安装插件
- 时间和空间复杂度
- jenkins
- 定位cpu 100%
- 常用脚本工具
- OOM问题定位
- scala
- 编译
- 基本语法
- 函数
- 数组常用方法
- 集合
- 并行集合
- 类
- 模式匹配
- 异常
- tuple元祖
- actor并发编程
- 柯里化
- 隐式转换
- 泛型
- 迭代器
- 流stream
- 视图view
- 控制抽象
- 注解
- spark
- 企业架构
- 安装
- api开发
- mycat
- Groovy
- 基础