consul注册报错 connectex: No connection could be made because the target machine actively refused it.

consul注册报错 connectex: No connection could be made because the target machine actively refused it.

Get http://localhost:2000/actuator/health: dial tcp [::1]:2000: connectex: No connection could be made because the target machine actively refused it.

Copy Output

项目springboot 注册向consul时,健康检查失败,可以看到上面的连接地址是 localhost:2000/actuator/health ,consul与微服务在不同主机上,就会出现以上错误.

原因是配置properties有问题,

配置如下

spring.application.name=XXX
server.port=9114
spring.cloud.consul.host=192.168.0.17
spring.cloud.consul.port=8500
spring.cloud.consul.discovery.serviceName=service-XXX

解决方式:

1.配置hostname

spring.cloud.consul.discovery.hostname=192.168.0.240

2.配置健康检查地址

spring.cloud.consul.discovery.healthCheckUrl=http://192.168.0.240:9113/actuator/health

以下是向consul注册服务的spring源码,

下面也附上具体的类的名称方便找到方法进行查看

1.注册所有class

//类名
org.springframework.context.annotation.ConfigurationClassEnhancer//方法static {CALLBACKS = new Callback[]{new ConfigurationClassEnhancer.BeanMethodInterceptor(), new ConfigurationClassEnhancer.BeanFactoryAwareMethodInterceptor(), NoOp.INSTANCE};CALLBACK_FILTER = new ConfigurationClassEnhancer.ConditionalCallbackFilter(CALLBACKS); //遍历logger = LogFactory.getLog(ConfigurationClassEnhancer.class);objenesis = new SpringObjenesis();}

2.通过properies写入hostname

//类名
org.springframework.cloud.consul.discovery.ConsulDiscoveryProperties//方法public void setHostname(String hostname) {this.hostname = hostname;this.hostInfo.override = true;}

3.开始注册,传入参数

//类名
org.springframework.cloud.consul.serviceregistry.ConsulAutoServiceRegistrationAutoConfiguration//方法@Bean@ConditionalOnMissingBeanpublic ConsulAutoRegistration consulRegistration(AutoServiceRegistrationProperties autoServiceRegistrationProperties, ConsulDiscoveryProperties properties, ApplicationContext applicationContext, ObjectProvider<List<ConsulRegistrationCustomizer>> registrationCustomizers, HeartbeatProperties heartbeatProperties) {return ConsulAutoRegistration.registration(autoServiceRegistrationProperties, properties, applicationContext, (List)registrationCustomizers.getIfAvailable(), heartbeatProperties);}

4.写入参数

//类名
org.springframework.cloud.consul.serviceregistry.ConsulAutoRegistration//方法
public static ConsulAutoRegistration registration(AutoServiceRegistrationProperties autoServiceRegistrationProperties, ConsulDiscoveryProperties properties, ApplicationContext context, List<ConsulRegistrationCustomizer> registrationCustomizers, HeartbeatProperties heartbeatProperties) {NewService service = new NewService();String appName = getAppName(properties, context.getEnvironment());service.setId(getInstanceId(properties, context));if (!properties.isPreferAgentAddress()) {service.setAddress(properties.getHostname());}service.setName(normalizeForDns(appName));service.setTags(createTags(properties));if (properties.getPort() != null) {service.setPort(properties.getPort());setCheck(service, autoServiceRegistrationProperties, properties, context, heartbeatProperties);}ConsulAutoRegistration registration = new ConsulAutoRegistration(service, autoServiceRegistrationProperties, properties, context, heartbeatProperties);customize(registrationCustomizers, registration);return registration;}

5.请求注册

//类名
org.springframework.cloud.client.serviceregistry.AbstractAutoServiceRegistration//方法public void start() {if (!this.isEnabled()) {if (logger.isDebugEnabled()) {logger.debug("Discovery Lifecycle disabled. Not starting");}} else {if (!this.running.get()) {this.register();  //注册if (this.shouldRegisterManagement()) {this.registerManagement();}this.context.publishEvent(new InstanceRegisteredEvent(this, this.getConfiguration()));this.running.compareAndSet(false, true);}}}

package com.ecwid.consul.v1.agent.modelpublic class NewService {@SerializedName("ID") private String id;  //XXX-9114@SerializedName("Name")private String name;  //service-XXX@SerializedName("Tags")private List<String> tags;@SerializedName("Address")private String address;        //properties.getHostname()@SerializedName("Port")private Integer port;@SerializedName("EnableTagOverride")private Boolean enableTagOverride;@SerializedName("Check")private NewService.Check check;@SerializedName("Checks")private List<NewService.Check> checks;....省略GetSet
}

6.发送请求,到consul注册

//类名com.ecwid.consul.v1.agent.AgentConsulClient;//方法public Response<Void> agentServiceRegister(NewService newService, String token) {UrlParameters tokenParam = token != null ? new SingleUrlParameters("token", token) : null;String json = GsonFactory.getGson().toJson(newService); /*{"ID":"oms-xt-plan-9114","Name":"service-oms-xt-plan","Tags":["secure\u003dfalse"],"Address":"localhost","Port":9114,"Check":{"Interval":"10s","HTTP":"http://192.168.0.240:9114/actuator/health"}}*/RawResponse rawResponse = this.rawClient.makePutRequest("/v1/agent/service/register", json, new UrlParameters[]{tokenParam});if (rawResponse.getStatusCode() == 200) {return new Response((Object)null, rawResponse);} else {throw new OperationException(rawResponse);}}

7.发送put 请求

//类名
com.ecwid.consul.transport.AbstractHttpTransport;//方法
public RawResponse makePutRequest(String url, String content) { /*content =  {"ID":"oms-xt-plan-9114","Name":"service-oms-xt-plan","Tags":["secure\u003dfalse"],"Address":"localhost","Port":9114,"Check":{"Interval":"10s","HTTP":"http://192.168.0.240:9114/actuator/health"}} */HttpPut httpPut = new HttpPut(url);         //PUT http://192.168.0.17:8500/v1/agent/service/register?token= HTTP/1.1httpPut.setEntity(new StringEntity(content, UTF_8));return this.executeRequest(httpPut);}

//类名
com.ecwid.consul.v1.ConsulRawClient;//方法public RawResponse makePutRequest(String endpoint, String content, UrlParameters... urlParams) {String url = this.prepareUrl(this.agentAddress + endpoint);
//  http://192.168.0.17:8500/v1/agent/service/registerurl = Utils.generateUrl(url, urlParams);                //http://192.168.0.17:8500/v1/agent/service/register?token=return this.httpTransport.makePutRequest(url, content);}

consul注册报错 connectex: No connection could be made because the target machine actively refused it.相关推荐

解决grpc连接报错connectex: No connection could be made because the target machine actively refused it
如有帮助,欢迎留下足迹哦! 详情如下 code = Unavailable desc = connection error: desc = "transport: Error while d ...
关于docker报错：No connection could be made because the target machine actively refused it.
我是在win10下跑的docker 事情是这样的,今天安装好douker跑起来后报了一个很奇怪的错误` C:\Users\Administrator>docker ps error during ...
connectex: No connection could be made because the target machine actively refused it.
关于阿里云服务器出现以下错误的原因: connectex: No connection could be made because the target machine actively refuse ...
【TDengine】解决 connectex: No connection could be made because the target machine actively refused it.
目录 1.遇到问题 2.问题描述 3.问题解决 1.遇到问题 .connectex: No conne ction could be made because the target machine a ...
Redis错误：No connection could be made because the target machine actively refused it
问题: 利用go连接远程阿里云centos主机的redis,代码如下: redisCli := redis.NewClient(&redis.Options{Addr: url,Passwor ...
nginx connect()错误(10061: No connection could be made because the target machine actively refused it)
nginx偶尔会报下面这个错误: 2019/05/20 10:54:56 [error] 717920#661892: *16943633 connect() failed (10061: No co ...
connect() failed (10061: No connection could be made because the target machine actively refused it
nginx运行web前端项目的时候出现了以下错误项目在加载保存的图片的过程中,报错了,看了一下Nginx的错误日志日志出现了connect() failed (10061: No connecti ...
No connection could be made because the target machine actively refused it 127.0.0.1:8888
No connection could be made because the target machine actively refused it 127.0.0.1:8888 你妹的微软用的Wi ...
No connection could be made because the target machine actively refused it [::1]:808
No connection could be made because the target machine actively refused it [::1]:808 1.首先查看端口占用情况, 在 ...