Solon Cloud —— 服务网关

说明

Solon Cloud Gateway 是一个可 Java 编程的分布式网关，提供了服务路由的能力和各种拦截的支持，只要是 http 服务（不需要关心实现的语言）都可以通过 Solon Cloud Gateway 进行代理转发，代理转发的服务也不一定要注册到服务注册中心。

虽然 Solon Cloud 提供了网关的实现，但在其官网出于性能及资源等原因的考虑，推荐优先使用专业网关（ngix，apisix，kong， k8s ingress controller），其次才是 Java 实现的网关 Spring Cloud Gateway 和 Solon Cloud Gateway。因此，在实际的项目中需要结合自己的项目情况来选择。

以下是微服务框架配合网关的架构图，图片来自 Solon 官网。https://solon.noear.org/article/328 。

在这里插入图片描述

依赖

dependencies {implementation platform(project(":demo-parent"))implementation("org.noear:nacos2-solon-cloud-plugin")implementation("org.noear:solon.cloud.gateway")annotationProcessor("org.mapstruct:mapstruct-processor:${mapstructVersion}")testImplementation("org.noear:solon-test-junit5")
}

实现

响应式

Solon Cloud Gateway 使用响应式接口，由 Solon-Rx 来实现，是基于 reactive-streams 封装的 RxJava 极简版。目前仅一个接口 Completable，意为：可完成的发布者。

接口	说明
Completable	作为返回类型
Completable::complete()	构建完成发布者
Completable::error(cause)	构建异常发布者
Completable::create(（emitter)->{…})	构建发射器发布者

路由检测器

内置路由检测器

匹配检测器工厂	本置前缀	说明与示例
AfterPredicateFactory	After=	After 时间检测器，ZonedDateTime 格式 (After=2017-01-20T17:42:47.789-07:00[America/Denver])
BeforePredicateFactory	Before=	After 时间检测器，ZonedDateTime 格式 (Before=2017-01-20T17:42:47.789-07:00[America/Denver])
CookiePredicateFactory	Cookie=	Cookie 检测器 (Cookie=token)(Cookie=token, ^user.)
HeaderPredicateFactory	Header=	Header 检测器 (Header=token)(Header=token, ^user.)
MethodPredicateFactory	Method=	Method 检测器 (Method=GET,POST)
PathPredicateFactory	Path=	Path 检测器（支持多路径匹配，以","号隔开） (Path=/demo/) ，(Path=/demo/,/hello/**)

通常情况下，我们使用 PathPredicateFactory 就够用，不需要额外的配置。

路由过滤器

内置过滤器

Solon 提供了一些内置的路由过滤器，可以通过直接的配置就可以使用。

过滤器工厂	本置前缀	说明与示例
AddRequestHeaderFilterFactory	AddRequestHeader=	添加请求头 (AddRequestHeader=Demo-Ver,1.0)
AddResponseHeaderFilterFactory	AddResponseHeader=	添加响应头 (AddResponseHeader=Demo-Ver,1.0)
PrefixPathFilterFactory	PrefixPath=	附加路径前缀 (PrefixPath=/app)
RedirectToFilterFactory	RedirectTo=	跳转到 (RedirectTo=302,http://demo.org/a,true)
RemoveRequestHeaderFilterFactory	RemoveRequestHeader=	移除请求头 (RemoveRequestHeader=Demo-Ver,1.0)
RemoveResponseHeaderFilterFactory	RemoveResponseHeader=	移除响应头 (RemoveResponseHeader=Demo-Ver,1.0)
StripPrefixFilterFactory	StripPrefix=	移除路径前缀段数 (StripPrefix=1)

定制

通过RouteFilterFactory定制路由过滤规则，实现不同类型的接口过滤。

package com.example.demo.solon.filter;import io.vertx.core.buffer.Buffer;
import lombok.extern.slf4j.Slf4j;
import org.dromara.hutool.core.text.StrUtil;
import org.noear.solon.annotation.Component;
import org.noear.solon.cloud.gateway.exchange.ExContext;
import org.noear.solon.cloud.gateway.exchange.ExFilter;
import org.noear.solon.cloud.gateway.exchange.ExFilterChain;
import org.noear.solon.cloud.gateway.route.RouteFilterFactory;
import org.noear.solon.rx.Completable;/*** @author airhead*/
@Component
@Slf4j
public class AuthFilterFactory implements RouteFilterFactory {public static final String TOKEN = "token";public static final String EMPTY = "empty";@Overridepublic String prefix() {return "Auth";}@Overridepublic ExFilter create(String config) {if (TOKEN.equals(config)) {return new TokenFilter();} else {return new EmptyAuthFilter();}}/** 默认的空鉴权 */public static class EmptyAuthFilter implements ExFilter {public EmptyAuthFilter() {}@Overridepublic Completable doFilter(ExContext ctx, ExFilterChain chain) {log.info("empty filter, do nothing");return chain.doFilter(ctx);}}/** token 鉴权 ，如果鉴权逻辑比较复杂的，用独立类 */public static class TokenFilter implements ExFilter {@Overridepublic Completable doFilter(ExContext ctx, ExFilterChain chain) {String token = ctx.rawHeader("token");if (StrUtil.isBlank(token)) {ctx.newResponse().status(401);ctx.newResponse().body(Buffer.buffer("token is empty"));return Completable.complete();}return chain.doFilter(ctx);}}
}

其中 EmptyFilter 只是简单的记录日志，而 TokenFilter 会从头中获取 token 信息判断是否为空，为空是返回错误信息，不为空时正常情况。

配置

server.port: 8000solon.app:name: 'demo-cloud-gateway'# group: "DEFAULT_GROUP" # 默认值为 DEFAULT_GROUP# namespace: "public" # 默认值为 publicknife4j.enable: true# 运行样例时，屏蔽，或者配置app-local.yml
solon.env: localsolon.cloud.nacos:server: "localhost:8848"           #nacos2 服务地址config:load: "demo-cloud-gateway.yml"solon.cloud.gateway:discover:enabled: falseexcludedServices:- "self-service"httpClient:responseTimeout: 1800 #单位：秒routes:- id: demoindex: 0 #默认为0target: "http://127.0.0.1:8081"predicates:- "Path=/demo/**"filters:- "Auth=empty"- "StripPrefix=1"timeout:responseTimeout: 1800 #单位：秒- id: service01index: 0 #默认为0target: lb://demo-cloud-service01predicates:- "Path=/service01/**"filters:- "Auth=token"- "StripPrefix=1"timeout:responseTimeout: 1800 #单位：秒

这里使用 service01 作为上游服务，配置直接地址和使用服务注册的地址来分别测试。

使用直接地址时，使用了一个空的鉴权逻辑，然后利用 Solon 内置的StripPrefix 来移除url 中的第一段，然后请求实际的服务。

使用注册服务时，使用了一个简单的Token鉴权逻辑，然后利用 Solon 内置的StripPrefix 来移除url 中的第一段，然后请求实际的服务。