SpringCloud Consul自定义服务注册

SpringCloud自定义consul服务注册器，获取特定的本地地址进行注册，注销的时候检查并注销其他无效实例

package com.mk.springcloud.config;import com.ecwid.consul.v1.ConsulClient;
import com.ecwid.consul.v1.agent.model.NewService;
import com.ecwid.consul.v1.health.HealthServicesRequest;
import com.ecwid.consul.v1.health.model.Check;
import com.ecwid.consul.v1.health.model.HealthService;
import lombok.SneakyThrows;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.consul.discovery.ConsulDiscoveryProperties;
import org.springframework.cloud.consul.discovery.HeartbeatProperties;
import org.springframework.cloud.consul.discovery.TtlScheduler;
import org.springframework.cloud.consul.serviceregistry.ConsulRegistration;
import org.springframework.cloud.consul.serviceregistry.ConsulServiceRegistry;
import org.springframework.stereotype.Service;import java.net.Inet4Address;
import java.util.*;@Service
public class ConsulRegistry extends ConsulServiceRegistry {private ConsulDiscoveryProperties properties;private ConsulClient consulClient;@Value("${spring.application.name}")private String applicationName;public ConsulRegistry(ConsulClient client, ConsulDiscoveryProperties properties, @Autowired(required = false) TtlScheduler ttlScheduler, HeartbeatProperties heartbeatProperties) {super(client, properties, ttlScheduler, heartbeatProperties);this.properties = properties;this.consulClient = client;}@SneakyThrows@Overridepublic void register(ConsulRegistration reg) {//获取服务器的ipString address = Inet4Address.getLocalHost().getHostAddress();NewService newService = reg.getService();newService.setAddress(address);newService.getCheck().setHttp("http://" + address + ":" + reg.getService().getPort() + properties.getHealthCheckPath());newService.setId(reg.getService().getName() + "-" + address + ":" + reg.getService().getPort() + "-" + UUID.randomUUID().toString().replace("-",""));super.register(reg);}@Overridepublic void deregister(ConsulRegistration reg) {super.deregister(reg);//查询no pass的服务实例HealthServicesRequest request = HealthServicesRequest.newBuilder().setPassing(false).build();List<HealthService> services = consulClient.getHealthServices(applicationName, request).getValue();for (HealthService service : services) {for (Check check : service.getChecks()) {//注销无效实例if (check.getStatus() != Check.CheckStatus.PASSING) {consulClient.agentServiceDeregister(check.getServiceId());}}}}
}

SpringCloud Consul自定义服务注册相关推荐

Consul微服务注册与发现
Consul微服务注册与发现概念安装与运行服务提供者服务消费者总结:Eureka.Zookeeper.Consul 的异同概念 1.什么是Consul? Consul是一套开源的分布式服务 ...
.net core grpc consul 实现服务注册服务发现负载均衡(二)
在上一篇 .net core grpc 实现通信(一) 中,我们实现的grpc通信在.net core中的可行性,但要在微服务中真正使用,还缺少服务注册,服务发现及负载均衡等,本篇我们将在 .net ...
Node.js + Consul 实现服务注册、健康检查、配置中心
Node.js + Consul 实现服务注册.健康检查.配置中心在这篇文章中: 初始化 Consul 客户端服务注册与健康检查配置Consul管理控制台服务配置中心实现在Nodejs中进行 ...
一个故事，一段代码告诉你如何使用不同语言（GolangC#）提供相同的能力基于Consul做服务注册与发现
文章目录引言什么是微服务传统服务微服务什么是服务注册与服务发现为什么要使用不同的语言提供相同的服务能力服务协调器服务注册 Golang C#(.NetCore3.1) 服务发现通过H ...
『注册中心』Consul微服务注册中心的使用及相关集群搭建
Consul目录一.概念篇--注册中心 1. 什么是注册中心 2. 为什么要使用注册中心 3. 注册中心类型 4. 注册中心的优点二.概念篇--Consul 1. 什么是Consul 2. Con ...
SpringCloud学习之（十八）SpringCloud Alibaba Nacos服务注册和配置中心
文章目录 (十八)SpringCloud Alibaba Nacos服务注册和配置中心 1.Nacos简介 1.1 为什么叫Nacos 1.2 Nacos是什么 1.3 Nacos能干嘛 1.4 Na ...
Spring Cloud中使用Consul作为服务注册中心时如何获得local service id？
微服务是目前非常流行和实用的软件架构设计.Spring Cloud是java开发领域最受欢迎也是常用的微服务框架.Spring Cloud Finchley版本已经发布,与此同时Eureka 2.0的 ...
Consul2-使用consul作为服务注册和发现中心
在windows环境下搭建consul,可以参考我的上一篇博客:https://blog.csdn.net/j903829182/article/details/80960802 在这里进行一个小实战 ...
SpringCloud系列之服务注册中心(Eureka)
文章目录 0.前言 1.搭建第一个Eureka服务 ①.简介 ②.组成 ③.创建Eureka Server模块 ④.编写POM ⑤.YML ⑥.主启动 ⑦.测试 2.注册服务 ①服务提供者 Ⅰ.添加依 ...

SpringCloud Consul自定义服务注册

SpringCloud Consul自定义服务注册相关推荐

最新文章

热门文章