Spring Cloud Gateway 应用概述

下面的示例启动两个服务:gataway-server 和 user-service 都注册到注册中心 Eureka上,客户端请求后端服务【user-service】,网关提供后端服务的统一入口。网关通过负载均衡将客户端请求转发到具体的后端服务。

序号 服务名称 端口号 备注
1 gateway-server 9000 网关服务
2 user-service 8001 用户服务
3 eureka-server 8888 注册中心

用户服务搭建

用户服务比较简单,只需要注册到注册中心并提供一个测试接口 /user

Maven 依赖

<!--注册中心客户端-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency> <dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency> <!--actuator 监控-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency> <!--配置中心客户端-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-config</artifactId>
</dependency>

配置文件

#服务暴露顿口号
server.port=8001
#服务名称
spring.application.name=user-service #注册中心地址
eureka.client.serviceUrl.defaultZone=${EUREKA_SERVICE_URL:http://localhost:8888}/lb/eureka/ management.endpoint.conditions.enabled=true
#优先使用IP地址注册
eureka.instance.prefer-ip-address=true
##服务所属分组名称
#eureka.instance.app-group-name=lkf_group
#服务实例id
eureka.instance.instanceId=${spring.application.name}@${spring.cloud.client.ip-address}@${server.port} #开放所有页面节点 默认只开启了health、info两个节点
management.endpoints.web.exposure.include=*

暴露服务接口

对外暴露 /user 接口,返回字符串 I’m ok

@SpringBootApplication
@EnableDiscoveryClient
@RestController
public class UserApplication {
public static void main(String[] args) {
SpringApplication.run(UserApplication.class, args);
} @GetMapping("/user")
public String getUser() {
return "I'm ok";
}
}

网关服务搭建

网关服务提供路由配置、路由断言和过滤器等功能。下面将会分别实现这些功能

Maven 引用

        <dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-gateway</artifactId>
</dependency> <dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!--注册中心客户端-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

配置文件

注册到注册中心并读取服务列表,支持向注册中心服务列表中的服务路由,这里需要注意,如果 spring.cloud.gateway.discovery.locator.lowerCaseServiceId 不为true,则只能根据服务实例id的大写进行转发,不支持小写的serviceId

#服务暴露顿口号
server.port=9000
#服务名称
spring.application.name=gateway-server #注册中心地址
eureka.client.serviceUrl.defaultZone=${EUREKA_SERVICE_URL:http://localhost:8888}/eureka/ management.endpoint.conditions.enabled=true
#优先使用IP地址注册
eureka.instance.prefer-ip-address=true
##服务所属分组名称
#eureka.instance.app-group-name=lkf_group
#服务实例id
eureka.instance.instanceId=${spring.application.name}@${spring.cloud.client.ip-address}@${server.port} #开放所有页面节点 默认只开启了health、info两个节点
management.endpoints.web.exposure.include=*
#启用基于服务发现的路由定位
spring.cloud.gateway.discovery.locator.enabled=true
#启用服务实例id名称小写支持
spring.cloud.gateway.discovery.locator.lowerCaseServiceId=true

路由断言

路由断言有很多种,根据请求时间、Host地址、请求路径和请求方法等,这里实现一个基于路径的路由断言匹配

 @Bean
public RouterFunction<ServerResponse> testFunRouterFunction() {
RouterFunction<ServerResponse> route = RouterFunctions.route(
RequestPredicates.path("/test"), request -> ServerResponse.ok()
.body(BodyInserters.fromObject("I am testing")));
return route;
}

当请求路径为 /test 时,直接返回结果为 I am testing

过滤器

网关经常需要对路由请求进行过滤,对符合条件的请求进行一些操作,例如:增加请求头、增加请求参数、增加响应头和断路器等功能。

 @Bean
public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
return builder.routes().route(r -> r.path("/test/custom").uri("http://ww.baidu.com"))
.route(r -> r.path("/user/**").uri("lb://user-service"))
.build(); }

当请求路径为 /test/custom 时,网关将请求转发到 http://ww.baidu.com;

当请求路径为 /user 时,网关将请求转发到用户服务的/user 接口 ,/user-service/user

客户端访问

向网关发送请求:http://127.0.0.1:9000/user ,

被网关转发到 http://127.0.0.1:9000/user-service/user,得到结果为:I’m ok

最新文章

  1. JQ中的方法、事件及动画
  2. Could not parse mapping document from input stream hibernate配置异常
  3. 【转载】java版打字练习软件
  4. Hibernate SQL优化技巧dynamic-insert=&quot;true&quot; dynamic-update=&quot;true&quot;
  5. VPS -Digital Ocean -搭建一个最简单的web服务器
  6. svn学习笔记(2)操作----还原,重命名,冲突处理,权限配置等
  7. JSBinding / Memory Management (GC)
  8. if条件里比较浮点数
  9. [CSS3 Animation] TweenMax.staggerTo()
  10. (转)C#之玩转反射
  11. VS代码清理批处理
  12. Xcode中插件的安装以及Xcode升级后插件实效的解决方法
  13. Singleton模式(Singleton创建类型)c#简单的例子
  14. hdu4597 Play Game 区间DP
  15. 大家一起来找茬(BUG)
  16. Quartz.NET 入门,带C#实例
  17. 启动apache 提示Starting httpd: AH00558
  18. PreparedStatement setDate setTimestamp ,util.date sql.date区别
  19. python 全栈开发,Day76(Django组件-cookie,session)
  20. Javascript面向

热门文章

  1. 写给Web开发人员看的Nginx介绍
  2. 九、小程序 Redux详解与在小程序中怎么使用(action和reducers)
  3. ubuntu14.04
  4. Win10安装PyQt5与Qt Designer
  5. 前端:table、thead、th、tr、td
  6. 使用HTML CSS制作简易三角形和旗帜
  7. 什么是DDOS
  8. JS 百度地图 地图线路描绘
  9. 去“BAT”这样面试,拿到offer的几率是80%
  10. 阿里P7告诉你什么是java并发包、线程池、锁