在服务启动后向 consul 注册 spring boot 应用程序

Question

我有一个遗留代码，其中一个Spring Boot应用程序在服务启动后向consul注册。该应用程序自动装配ConsulLifesycle Spring bean，通过它使用其内建方法ConsulLifecycle.start（）和ConsulLifecycle.stop（）向consul注册/取消注册服务。

现在我们把spring升级到了5.1.5，spring-cloud-starter-consul-discovery升级到了2.1.1，spring-cloud-dependencies升级到了格林威治。删除了同椭圆bean的版本。因此，为了实现相同的行为，我尝试自动连接ConsulAutoServiceRegistration spring bean，并使用它的start和stop方法向consul注册和注销服务。

现在的问题是，当我试图启动spring boot应用程序时，我在应用程序启动时遇到一些错误(错误在帖子的最后一部分提到)。

注意：我有一份申请。我在其中定义此属性的属性文件

spring.cloud.consul.host=127.0.0.1
spring.cloud.consul.port=8500     
##Embedded Tomcat 
server.port = 8091
server.address = 0.0.0.0

我在应用程序启动时遇到的错误，即在向consul注册服务时

2:25 - Unknown error occured.
java.lang.IllegalArgumentException: service.port has not been set
    at org.springframework.util.Assert.notNull(Assert.java:198)
    at org.springframework.cloud.consul.serviceregistry.ConsulAutoServiceRegistration.getRegistration(ConsulAutoServiceRegistration.java:56)
    at org.springframework.cloud.consul.serviceregistry.ConsulAutoServiceRegistration.getRegistration(ConsulAutoServiceRegistration.java:32)
    at org.springframework.cloud.client.serviceregistry.AbstractAutoServiceRegistration.start(AbstractAutoServiceRegistration.java:117)
    at org.springframework.cloud.consul.serviceregistry.ConsulAutoServiceRegistration.start(ConsulAutoServiceRegistration.java:68)
at com.bmc.agent.data.refresh.manager.core.ConsulLeaderElectionHelper.checkAndGetLocalService(ConsulLeaderElectionHelper.java:201)
at com.bmc.agent.data.refresh.manager.core.ConsulLeaderElectionHelper.run(ConsulLeaderElectionHelper.java:152)

Answer 1

您的< code > application . properties 还应该具有以下属性:

spring.cloud.consul.discovery.healthCheckPath=${spring.application.name}/ManagementEndPoints/health
spring.cloud.consul.discovery.healthCheckInterval=5s
spring.cloud.consul.discovery.instance-id=${spring.application.name}
spring.cloud.consul.discovery.scheme=http or https
spring.cloud.consul.discovery.hostname=${spring.application.name}
spring.cloud.consul.discovery.port=${server.port}