1.Netty IdleStateHandler心跳机制
2.Spring Cloud Eureka源码分析之心跳续约及自我保护机制

Netty IdleStateHandler心跳机制

       Netty的IdleStateHandler心跳机制在TCP长连接中扮演重要角色，确保连接的心跳心跳有效性。它并非严格的监控监控PING-PONG交互，而是源码源码客户端主动发送心跳，服务器接收但不回复，网站网站以节省网络资源。心跳心跳色温源码当双方长时间无数据交互，监控监控即进入idle状态时，源码源码IdleStateHandler会定时检测，网站网站如超时则触发userEventTriggered()方法。心跳心跳

       Netty提供了IdleStateHandler来处理空闲连接和超时问题，监控监控它在服务器端添加处理器，源码源码每五秒检查一次读操作，网站网站五秒内无数据读取则触发事件。心跳心跳客户端则每四秒发送心跳，监控监控通过write()方法检测，四秒内无写操作同样触发事件。IdleStateHandler构造器中，可以自定义readerIdleTime和writerIdleTime，黑牛指标源码设置读写空闲超时时间。

       源码中，IdleStateHandler通过定时任务监控channelRead()和write()方法的调用，一旦超时，会执行userEventTrigger()。服务端仅响应客户端的心跳，避免大规模响应带来的资源浪费。然而，这样设计意味着客户端无法感知服务端的源码库 最大非正常下线，如网络故障。

       为了实现双向心跳感知，可能需要在ChannelInactive()方法中进行补充，以应对非正常下线情况。总的来说，IdleStateHandler在Netty中负责维护连接的活性，但双向心跳机制在某些场景下更为全面。

Spring Cloud Eureka源码分析之心跳续约及自我保护机制

       Eureka Server 判断服务不可用的机制是基于心跳续约的健康检查。客户端每秒发起一次心跳续约请求，图片源码示例服务端通过该机制检测服务提供者的状态。心跳续约的周期可以调整，通过配置参数来修改。客户端的续约流程主要在 DiscoveryClient.initScheduledTasks 方法中实现，其中 renewalIntervalInSecs=s，即默认周期为秒。续约线程 HeartbeatThread 调用 renew() 方法，将请求发送到 Eureka Server 的 "apps/" + appName + '/' + id 地址，以更新服务端的小照域名授权源码最后一次心跳时间。

       服务端在收到心跳请求时，调用 InstanceResource 类的 renewLease 方法进行续约处理。续约实现主要涉及两个步骤：从应用对应的实例列表中获取实例信息，然后调用 Lease.renew() 方法进行续约。续约过程更新了服务端记录的服务实例的最后一次心跳时间。

       Eureka 提供了一种自我保护机制，以避免因网络问题导致健康服务被误删除的情况。该机制在服务端收到的心跳请求低于特定比例（默认为%）时启动，以保护服务实例免于过期被剔除，保证集群的稳定和健壮性。开启自我保护机制的配置项为 eureka.server.enable-self-preservation，并默认开启。若服务客户端与注册中心之间出现网络故障，Eureka Server 会检测到低于%的正常心跳请求，进而自动进入自我保护状态。

       自我保护机制的阈值设置通过配置参数进行调整，具体计算公式为：（服务实例总数 * 0.）。例如，对于个服务实例，预期每分钟收到的续约请求数量为个。若实际收到的续约请求数量低于这个值，Eureka Server 将触发自我保护机制。此外，预期续约数量会随着服务注册和下线的变化而动态调整。当服务提供者主动下线时，需要更新客户端数量，反之则需增加。每隔分钟，自我保护阈值自动更新一次，以适应服务动态变化的场景。

       在 Eureka Server 启动时，通过 EurekaServerBootstrap 类的 contextInitialized 方法初始化 Eureka Server 的上下文，包括配置预期每分钟收到的续约客户端数量（expectedNumberOfClientsSendingRenews）。在 openForTraffic 方法中，初始化 expectedNumberOfClientsSendingRenews 和 numberOfRenewsPerMinThreshold 值，以确保自我保护机制正常运行。这些值会根据服务注册和下线情况动态调整，以维持系统的稳定性和准确性。