详解使用Spring Cloud Consul实现服务的注册和发现
首先安装consul环境,参照之前的文章:https://www.nhooo.com/article/141789.htm
项目规划,2个服务端,1个客户端
首先来看服务端,
一:服务端1:
项目依赖
org.springframework.cloud spring-cloud-consul-dependencies 1.0.1.RELEASE pom import org.springframework.boot spring-boot-actuator 1.3.5.RELEASE org.springframework.cloud spring-cloud-starter-consul-discovery
注意,增加spring-boot-actuator是为了项目可以访问/health路径来判断服务是否健康
packagecom.pp.consul1; importorg.springframework.boot.SpringApplication; importorg.springframework.boot.autoconfigure.SpringBootApplication; importorg.springframework.cloud.client.discovery.EnableDiscoveryClient; importorg.springframework.web.bind.annotation.RequestMapping; importorg.springframework.web.bind.annotation.RestController; @SpringBootApplication @EnableDiscoveryClient @RestController publicclassConsulApp{ @RequestMapping("/home") publicObjecthome(){ System.out.println("1111111111111"); return"OK11"; } publicstaticvoidmain(String[]args){ SpringApplication.run(ConsulApp.class,args); } }
application.properties配置内容
server.port=9955 spring.application.name=Consul-Server-1 spring.cloud.consul.host=192.168.1.100 spring.cloud.consul.port=8500 spring.cloud.consul.enabled=true spring.cloud.consul.discovery.enabled=true spring.cloud.consul.discovery.instanceId=tomcat1 spring.cloud.consul.discovery.serviceName=tomcat spring.cloud.consul.discovery.hostname=192.168.2.95 spring.cloud.consul.discovery.port=${server.port} spring.cloud.consul.discovery.healthCheckUrl=http://192.168.2.95:9955/health spring.cloud.consul.discovery.healthCheckInterval=10s spring.cloud.consul.discovery.tags=dev
看过我之前文章的,应该对这些配置很清楚了。这样,一个服务端就配置写好了。
由于我们增加了@EnableDiscoveryClient注解,所以,系统启动的时候,就会向consul注册一个服务,服务的名字为tomcat,ID为tomcat1
访问consul的HTTPAPI/v1/catalog/service/tomcat输出如下:
{ "Node":"192.168.1.100", "Address":"192.168.1.100", "ServiceID":"tomcat1", "ServiceName":"tomcat", "ServiceTags":["dev"], "ServiceAddress":"192.168.2.95", "ServicePort":9955, "ServiceEnableTagOverride":false, "CreateIndex":993, "ModifyIndex":1057 }
二:服务端2
项目依赖和上面一样
packagecom.pp.consul2; importorg.springframework.boot.SpringApplication; importorg.springframework.boot.autoconfigure.SpringBootApplication; importorg.springframework.cloud.client.discovery.EnableDiscoveryClient; importorg.springframework.web.bind.annotation.RequestMapping; importorg.springframework.web.bind.annotation.RestController; @SpringBootApplication @EnableDiscoveryClient @RestController publicclassConsulApp{ @RequestMapping("/home") publicObjecthome(){ System.out.println("2222222222222222"); return"OK22"; } publicstaticvoidmain(String[]args){ SpringApplication.run(ConsulApp.class,args); } }
application.properties配置内容:
server.port=9966 spring.application.name=Consul-Server-2 spring.cloud.consul.host=192.168.1.100 spring.cloud.consul.port=8500 spring.cloud.consul.enabled=true spring.cloud.consul.discovery.enabled=true spring.cloud.consul.discovery.instanceId=tomcat2 spring.cloud.consul.discovery.serviceName=tomcat spring.cloud.consul.discovery.hostname=192.168.2.95 spring.cloud.consul.discovery.port=${server.port} spring.cloud.consul.discovery.healthCheckUrl=http://192.168.2.95:9966/health spring.cloud.consul.discovery.healthCheckInterval=10s spring.cloud.consul.discovery.tags=test
三:客户端
项目依赖,只需要spring-cloud-starter-consul-discovery
application.properties配置内容:
server.port=9977 spring.application.name=Consul-Client spring.cloud.consul.host=192.168.1.100 spring.cloud.consul.port=8500 spring.cloud.consul.discovery.register=false
注意,这里的spring.cloud.consul.discovery.register需要配置成false,否则系统启动的时候,会向consul注册一个服务
packagecom.pp.client; importorg.springframework.beans.factory.annotation.Autowired; importorg.springframework.boot.SpringApplication; importorg.springframework.boot.autoconfigure.SpringBootApplication; importorg.springframework.cloud.client.discovery.DiscoveryClient; importorg.springframework.cloud.client.discovery.EnableDiscoveryClient; importorg.springframework.cloud.client.loadbalancer.LoadBalancerClient; importorg.springframework.web.bind.annotation.RequestMapping; importorg.springframework.web.bind.annotation.RestController; @SpringBootApplication @EnableDiscoveryClient @RestController publicclassConsulClient{ @Autowired privateLoadBalancerClientloadBalancer; @Autowired privateDiscoveryClientdiscoveryClient; /** *从所有服务中选择一个服务(轮询) */ @RequestMapping("/discover") publicObjectdiscover(){ returnloadBalancer.choose("tomcat").getUri().toString(); } /** *获取所有服务 */ @RequestMapping("/services") publicObjectservices(){ returndiscoveryClient.getInstances("tomcat"); } publicstaticvoidmain(String[]args){ SpringApplication.run(ConsulClient.class,args); } }
启动之后,就可以访问/discover,/services查看效果了。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。