Spring Cloud自己体系中的注册中心为Eureka,同时也支持其它服务来进行服务注册与发现。本文介绍使用Consul来实现服务注册与发现,并整合进Spring Cloud项目中进行使用。
本文项目依赖环境版本为:
Consul → 1.5.0Spring Cloud → Edgware.SR5Spring Boot → 1.5.21操作系统 → Win10 (PowerShell)
启动Consul服务
首先启动Consul服务,使用以下命令:
.\consul.exe agent -server -ui -bootstrap -client 0.0.0.0 -data-dir="d:\consul\data" -bind 127.0.0.1复制代码
也可以使用开发模式(更加简单,自动开启UI服务,但是不能保存数据状态)
.\consul.exe agent -dev复制代码
服务启动成功后访问地址:http://localhost:8500 ,看到如下界面说明服务启动成功
创建Consumer项目
新建Spring Boot项目,指定名称为:leon-consumer,在依赖中选择Web、Consul Discovery,版本选择为1.5.21
修改配置文件application.yml,指定服务端口、名称、Consul服务地址
server:port: 8081spring:application:name: leon-consumercloud:consul:host: localhostport: 8500复制代码
启动程序,查看Consul web界面:
此时可以看到服务已经注册到Consul上,但是发现后红色X提醒,点击进入可查看详细提示信息:
可以看到错误提示是健康检查方面的提示,这是因为Consul进行健康检查需要依赖 Actuator 模块,在pom.xml中添加依赖
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency>复制代码
然后重启程序,刷新浏览器再次观察,此时发现就已经全是正常状态
点击后可以看到当前服务的具体的名称、IP、端口等信息。
创建Provider程序
新建Spring Boot项目,指定名称为:leon-provider-1,在依赖中选择Web、Consul Discovery,版本选择为1.5.21 修改配置文件application.yml,指定服务端口、名称、Consul服务地址
server:port: 8082spring:application:name: leon-providercloud:consul:host: localhostport: 8500复制代码
添加监控依赖:
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency>复制代码
创建LoginService类,提供login方法供Consumer端调用
@RestControllerpublic class LoginService {@RequestMapping("/login")public String login(@RequestParam("userName") String userName, @RequestParam("passWord") String passWord) {if (userName.equals("leon") && passWord.equals("888")) {return "login success";}return "login fail";}}复制代码
改造Consumer服务
为leon-consumer添加Feign相关依赖,然后调用Provider提供的接口 在leon-consumer项目的pom.xml中添加依赖:
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-feign</artifactId></dependency>复制代码
创建一个接口:UserFeignClient,在里面定义好需要调用的接口方法(和Provider提供的方法一致),同时添加@FeignClient注解,并通过name指定需要调用的服务名称:
@FeignClient(name = "leon-provider")public interface UserFeignClient {@RequestMapping(value = "/login", method = RequestMethod.GET)public String login(@RequestParam("userName") String userName, @RequestParam("passWord") String passWord);}复制代码
创建Controller类调用Provider服务方法:
@RestControllerpublic class UserController {@Autowiredprivate UserFeignClient userFeignClient;/*** 用户账号名和密码登录** @param userName* @param passWord* @return*/@RequestMapping("/login")public String login(@RequestParam("userName") String userName, @RequestParam("passWord") String passWord) {return userFeignClient.login(userName, passWord);}}复制代码
在启动类上添加注解:@EnableFeignClients
@SpringBootApplication@EnableFeignClientspublic class LeonConsumerApplication {public static void main(String[] args) {SpringApplication.run(LeonConsumerApplication.class, args);}}复制代码
运行测试
分别运行leon-provider、leon-consumer,然后访问leon-consumer提供的login方法,分别传入正确、错误参数查看效果:
说明服务已经能够通过注册中心找到对应的服务调用。
服务集群
复制leon-provider-1项目为leon-provider-2,然后打开项目,更改项目端口为8083
server:port: 8083spring:application:name: leon-providercloud:consul:host: localhostport: 8500复制代码
修改leon-provider-1、leon-provider-2的方法,添加识别信息:
@RequestMapping("/login")public String login(@RequestParam("userName") String userName, @RequestParam("passWord") String passWord) {if (userName.equals("leon") && passWord.equals("888")) {return "leon-provider-1: login success";}return "leon-provider-1: login fail";}复制代码
@RequestMapping("/login")public String login(@RequestParam("userName") String userName, @RequestParam("passWord") String passWord) {if (userName.equals("leon") && passWord.equals("888")) {return "leon-provider-2: login success";}return "leon-provider-2: login fail";}复制代码
分别重启服务,可以看到新增了同名的服务
然后刷新调用登录方法,可以看到会按照Spring Cloud体系中Ribbon的默认负载均衡策略轮询调用不同的服务。
其它配置
服务检测间隔
cloud:consul:host: localhostport: 8500discovery:health-check-interval: 3s //3秒后如果服务停掉,检测界面会立即更新为非正常状态复制代码
如果觉得《Spring Cloud 基于Consul 实现服务注册与发现》对你有帮助,请点赞、收藏,并留下你的观点哦!