使用Spring Cloud Kubernetes时如何获取当前运行实例的instanceId

方案1：直接注入Registration获取（推荐） #

Spring Cloud 统一提供了Registration抽象，代表当前服务实例的注册元数据，Spring Cloud Kubernetes已经自动完成了该Bean的装配，直接注入即可拿到当前实例的instanceId，和DiscoveryClient返回的实例列表中的instanceId完全匹配：

import org.springframework.cloud.client.serviceregistry.Registration;
import org.springframework.beans.factory.annotation.Autowired;

// 你的业务类
public class InstanceService {
    @Autowired
    private Registration registration;

    public String getCurrentInstanceId() {
        // 直接返回当前实例的instanceId
        return registration.getInstanceId();
    }
}

该方案不需要额外配置，只要你已经正确引入Spring Cloud Kubernetes Discovery相关依赖即可使用。

方案2：从环境变量获取匹配 #

Spring Cloud Kubernetes默认使用Pod名称作为instanceId的核心组成部分，你可以在Deployment配置中将Pod名称注入为环境变量：

# deployment.yaml 中的env配置片段
spec:
  containers:
  - name: foo-service
    image: your-foo-service-image
    env:
    - name: CURRENT_POD_NAME
      valueFrom:
        fieldRef:
          fieldPath: metadata.name

之后在代码中读取该环境变量，既可以直接当作当前实例的标识，也可以和discoveryClient.getInstances("foo-service")返回的实例列表中的instanceId做匹配，筛选出当前实例：

import org.springframework.core.env.Environment;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.beans.factory.annotation.Autowired;

public class InstanceService {
    @Autowired
    private Environment environment;
    @Autowired
    private DiscoveryClient discoveryClient;

    public ServiceInstance getCurrentInstance() {
        String podName = environment.getProperty("CURRENT_POD_NAME");
        return discoveryClient.getInstances("foo-service")
                .stream()
                .filter(instance -> instance.getInstanceId().contains(podName))
                .findFirst()
                .orElseThrow(() -> new RuntimeException("当前实例未找到"));
    }
}

内容的提问来源于stack exchange，提问作者Mark