SpringCloud(4) Eureka 如何主动下线服务节点

news2024/11/23 9:01:10

1.直接停掉客户端服务

执行如下命令，pid 表示客户端服务进程ID。

kill -9 pid

默认情况下，如果 Eureka Server 在 90s 内没有收到 Eureka 客户端的续约，它会将实例从其注册表中删除。

这种做法的缺点在于，如果客户端已经停止了运行，但仍然在注册中心的列表中，那么当请求到已经停止运行的客户端时，就会发生错误。

2.发送HTTP请求

1）调用DELETE接口

为了让注册中心马上知道服务要下线，可以向 Eureka 注册中心发送 DELETE 请求，格式为：

配置了用户名密码：

curl -s -X DELETE http://{username}:{password}@{eureka-ip}:{port}/eureka/apps/{application}/{instanceId}

没有配置用户名密码：

curl -s -X DELETE http://{eureka-ip}:{port}/eureka/apps/{application}/{instanceId}

注意：

1.{instanceId} 是和客户端服务的 eureka.instance.instance-id 配置对应的，格式可能有所不同，取 UP (1) - 后面的内容就好。

2.{application} 大小写都可以。

举个例子：

我有一个 Eureka 注册中心和一个客户端服务（springboot-eureka-client）：

Eureka注册中心：http://localhost:1001
客户端服务（springboot-eureka-client）：http://192.168.1.209:8081

在这里插入图片描述

如果我需要下线 springboot-eureka-client 服务，那么我可以请求如下地址：

curl -s -X DELETE "http://localhost:1001/eureka/apps/SPRINGBOOT-EUREKA-CLIENT/192.168.1.209:8081"

立即刷新页面，可以看到刚才注册的服务已经消失了。

在这里插入图片描述

由于 Eureka 客户端每隔一段时间（默认 30s）会发送一次心跳到注册中心续约。如果通过这种方式下线了一个服务，而没有及时停掉的话，该服务很快又会回到服务列表中。

2）调用状态变更接口

为了让注册中心马上知道服务要下线，可以向 Eureka 注册中心发送 PUT 请求，传递想要变更的参数。当参数值为 OUT_OF_SERVICE 的时候，服务就不会再使用这个节点了。请求格式为：

配置了用户名密码：

curl -s -X PUT http://{username}:{password}@{eureka-ip}:{port}/eureka/apps/{application}/{instanceId}/status?value=OUT_OF_SERVICE

没有配置用户名密码：

curl -s -X PUT http://{eureka-ip}:{port}/eureka/apps/{application}/{instanceId}/status?value=OUT_OF_SERVICE

相应的，如果想上线也可以用这个接口，将 value 值改为 UP 即可。

配置了用户名密码：

curl -s -X PUT http://{username}:{password}@{eureka-ip}:{port}/eureka/apps/{application}/{instanceId}/status?value=OUT_OF_SERVICE

没有配置用户名密码：

curl -s -X PUT http://{eureka-ip}:{port}/eureka/apps/{application}/{instanceId}/status?value=OUT_OF_SERVICE

补充：根据官方文档，服务的状态有 UP 、DOWN、STARTING、OUT_OF_SERVICE、UNKNOWN 共五种状态，其他状态所代表的具体含义可以自行了解下。

官方文档： https://github.com/Netflix/eureka/wiki/Eureka-REST-operations

举个例子：

我有一个 Eureka 注册中心和一个客户端服务（springboot-eureka-client）：

Eureka注册中心：http://localhost:1001
客户端服务（springboot-eureka-client）：http://192.168.1.209:8081

在这里插入图片描述

如果我需要下线 springboot-eureka-client 服务，那么我可以请求如下地址：

curl -s -X PUT "http://localhost:1001/eureka/apps/SPRINGBOOT-EUREKA-CLIENT/192.168.1.209:8081/status?value=OUT_OF_SERVICE"

请求之后，我们可以看到服务节点被标上了红色的 OUT_OF_SERVICE：

在这里插入图片描述

3.客户端主动通知注册中心下线

1）代码示例

如果 Eureka 客户端是一个 Spring Boot 应用，可以通过调用一下代码通知注册中心下线。代码示例如下：

import com.demo.common.Result;
import com.netflix.discovery.DiscoveryManager;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
 * <p> @Title RegisterController
 * <p> @Description 注册客户端Controller
 *
 * @author ACGkaka
 * @date 2023/7/12 22:16
 */
@RestController
@RequestMapping("/register")
public class RegisterController {

    @Autowired
    private DiscoveryClient discoveryClient;

    /** 获取服务实例信息 */
    @GetMapping("/getInstance")
    public Result<Object> getInstance() {
        List<ServiceInstance> instances = discoveryClient.getInstances("springboot-eureka-client");
        return Result.succeed().setData(instances);
    }

    /** 获取服务列表 */
    @GetMapping("/getServices")
    public Result<Object> getServices() {
        List<String> services = discoveryClient.getServices();
        return Result.succeed().setData(services);
    }

    /** 服务下线 */
    @GetMapping("/offline")
    public Result<Object> offline() {
        DiscoveryManager.getInstance().shutdownComponent();
        return Result.succeed();
    }
}