推荐文章：Eureka Consul Adapter——打通Spring Cloud Eureka与Prometheus的桥梁

import org.springframework.cloud.netflix.eureka.EurekaRegistry;
import com.netflix.appinfo.InstanceInfo;
import com.orbitz.consul.Consul;
import com.orbitz.consul.model.agent.ImmutableRegCheck;
import com.orbitz.consul.model.agent.ImmutableRegistration;
import com.orbitz.consul.model.health.ImmutableServiceHealth;
import com.orbitz.consul.model.health.ServiceHealth;
 
public class EurekaConsulAdapter {
 
    private final EurekaRegistry registry;
    private final Consul consul;
 
    public EurekaConsulAdapter(EurekaRegistry registry, Consul consul) {
        this.registry = registry;
        this.consul = consul;
    }
 
    public void registerAllEurekaInstancesInConsul() {
        for (String appName : registry.getApplicationNames()) {
            for (InstanceInfo instance : registry.getInstancesByVipAddress(appName, false)) {
                String id = instance.getId();
                String address = instance.getIPAddr();
                int port = instance.getPort();
                String healthCheckUrl = instance.getHealthCheckUrls().get("http").get(0);
 
                ImmutableRegCheck check = ImmutableRegCheck.builder()
                        .http(healthCheckUrl)
                        .interval("10s")
                        .build();
 
                ImmutableRegistration.Builder registrationBuilder = ImmutableRegistration.builder()
                        .id(id)
                        .address(address)
                        .port(port)
                        .name(appName)
                        .check(check);
 
                ServiceHealth serviceHealth = ImmutableServiceHealth.builder()
                        .service(registrationBuilder.build())
                        .build();
 
                consul.agentClient().register(serviceHealth);
            }
        }
    }
}

这段代码展示了如何遍历Eureka服务注册中心的所有实例，并将它们注册到Consul服务注册中心。同时，它也设置了服务的健康检查URL，并定义了健康检查的间隔时间。这样，Consul可以利用这些信息来监控服务的健康状况，并在服务出现问题时采取相应的措施。