Spring Cloud自己体系中的注册中心为Eureka,同时也支持其它服务来进行服务注册与发现。本文介绍使用Consul来实现服务注册与发现,并整合进Spring Cloud项目中进行使用。

本文项目依赖环境版本为:

  • Consul → 1.5.0
  • Spring Cloud → Edgware.SR5
  • Spring 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: 8081
spring: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: 8082
spring:application:name: leon-providercloud:consul:host: localhostport: 8500
复制代码

添加监控依赖:

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId>
</dependency>复制代码

创建LoginService类,提供login方法供Consumer端调用

@RestController
public 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服务方法:

@RestController
public 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
@EnableFeignClients
public 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: 8083
spring: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秒后如果服务停掉,检测界面会立即更新为非正常状态
复制代码

转载于:https://juejin.im/post/5d00c19be51d454f723024e3

Spring Cloud 基于Consul 实现服务注册与发现相关推荐

  1. 【夯实Spring Cloud】Spring Cloud中的Eureka服务注册与发现详解

    本文属于[夯实Spring Cloud]系列文章,该系列旨在用通俗易懂的语言,带大家了解和学习Spring Cloud技术,希望能给读者带来一些干货.系列目录如下: [夯实Spring Cloud]D ...

  2. Spring Cloud第一篇:服务注册与发现Eureka

    一.spring cloud简介 spring cloud 为开发人员提供了快速构建分布式系统的一些工具,包括配置管理.服务发现.断路器.路由.微代理.事件总线.全局锁.决策竞选.分布式会话等等.它运 ...

  3. 从源码底层聊聊Spring Cloud是如何一统服务注册、发现编程模型

    文章目录 背景 源码版本 核心抽象接口 DiscoveryClient EnableDiscoveryClient ReactiveDiscoveryClient ServiceInstance Re ...

  4. Spring Cloud | 第一篇:服务注册与发现(Eureka)

    写在前面:本文参考spring cloud官方文档 http://projects.spring.io/spring-cloud/spring-cloud.html#_service_discover ...

  5. 一个故事,一段代码告诉你如何使用不同语言(GolangC#)提供相同的能力基于Consul做服务注册与发现

    文章目录 引言 什么是微服务 传统服务 微服务 什么是服务注册与服务发现 为什么要使用不同的语言提供相同的服务能力 服务协调器 服务注册 Golang C#(.NetCore3.1) 服务发现 通过H ...

  6. Consul微服务注册与发现

    Consul微服务注册与发现 概念 安装与运行 服务提供者 服务消费者 总结:Eureka.Zookeeper.Consul 的异同 概念 1.什么是Consul? Consul是一套开源的分布式服务 ...

  7. Web Api 基于Zookeeper的服务注册与发现

    差异 基于Nginx的服务提供和消费 基于zookeeper的服务注册和发现 zk的负载均衡是可以调控,nginx只是能调权重,其他需要可控的都需要自己写插件:但是nginx的吞吐量比zk大很多,可以 ...

  8. (三)Alian 的 Spring Cloud Eureka Server(服务注册中心)

    目录 一.创建Eureka服务工程 1.1.第一步(创建工程) 1.2.第二步(springboot工程) 1.3.第三步(工程设置) 1.4.第四步(依赖选择) 二.配置 2.1.pom文件 2.2 ...

  9. Spring Cloud (4)---Eureka(服务注册与消费详解)

    Spring Cloud (一)Eureka(服务注册与消费详解) Spring Cloud Eureka(服务注册与消费详解) 1.Spring Cloud Eureka 服务注册中心 Eureka ...

最新文章

  1. 缓存用不好,Bug改到老
  2. html拖放数据库字段,HTML5 拖放(Drag 和 Drop)
  3. centos mount 用法_linux screen的用法 - mouseleo
  4. webso员ket php,客戶端和PHP後端通信:Sokets,Stream,TCP/UDP?
  5. 【转】企业网站建设方法论
  6. B9.流行的框架与新技术
  7. 论文阅读02:基于深度学习的图像细粒度分类算法
  8. 【es】client通信流程与负载均衡
  9. Win11打不开Windows安全程序如何修复?
  10. java .net 图形界面_Aspose.Words for .NET是一个无图形用户界面的.NET和JAVA Word文档的报告控件...
  11. c语言程序设计50例(经典收藏),C语言程序设计50例(经典收藏)
  12. 《网上订餐系统》开发全程回忆
  13. sqlmap注入之tamper绕过WAF防火墙过滤
  14. 遥感图像处理之计算植被覆盖度公式
  15. 和平精英服务器响应超时什么意思,和平精英服务器无响应,和平精英服务器超时...
  16. 关于偶的专业-信息工程
  17. [Asp.Net Core]鉴权授权
  18. 使用树莓派连接笔记本热点
  19. 字符编码的常用种类介绍
  20. 用Excel做排列图

热门文章

  1. JSON 之 SuperObject(6): 方法
  2. Tyvj-TOM的无穷序列
  3. Arcgis for JS扩展GraphicLayer实现区域对象的聚类统计与展示
  4. 初学SSH 配置+错误总结
  5. 得到Raster的一些基本信息(高程值,列数,列数)
  6. [转] Ghost自动安装
  7. 多域名下Mvc的Http缓存冲突的问题
  8. 设计过程中常见的 10 个小问题
  9. Python -- 循环技巧(Looping Techniques)
  10. 算法分类整理+模板②:字符串处理