基于Payload的Spring Cloud路由

Question

我正在尝试实现以下模式。

API网关：

http://apigateway/serve-this-request

服务-A：

http://service-a/v1/type1

http://service-a/v1/type2

服务-B：

http://service-b/v1/type2

http://service-b/v1/type5

服务-C：

http://service-c/v1/type3

场景是：

我只会从 APIgateway 公开一个端点，并且根据 APIGateway 收到的有效负载，我需要将请求路由到特定服务。如果我的有效负载包含与 service-a 和 type1 端点相关的有效负载，则需要将请求路由到 http://service-a/v1/type1 端点。如果有效负载包含与 service-b 和 type5 相关的数据，则需要路由到 http://service-b/v1/type5

我尝试过但未能找到解决方案。请帮忙。

Answer 1

解决方法如下

创建自定义路由谓词或过滤器： 以下是如何创建自定义路由谓词或过滤器的高级想法：

a. 创建一个扩展 AbstractRoutePredicateFactory 的自定义类或实现 GlobalFilter 接口来定义自定义路由逻辑。

b. 在自定义类中，解析传入请求的有效负载（通常来自请求正文）以提取路由所需的信息。

c. 根据提取的信息，决定将请求路由到哪个服务。

d. 相应地修改请求的 URI 或路由 ID，以将请求转发到适当的服务。

以下是如何创建自定义路由谓词或过滤器的简化示例：

@Component
public class PayloadBasedRoutePredicateFactory extends AbstractRoutePredicateFactory<PayloadBasedRoutePredicateFactory.Config> {
    public PayloadBasedRoutePredicateFactory() {
        super(Config.class);
    }

    @Override
    public Predicate<ServerWebExchange> apply(Config config) {
        return exchange -> {
            // Extract payload from the request
            String requestBody = extractRequestBody(exchange.getRequest());

            // Logic to determine the route based on the payload
            if (requestBody.contains("service-a") && requestBody.contains("type1")) {
                exchange.getAttributes().put(ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR, "http://service-a/v1/type1");
                return true;
            } else if (requestBody.contains("service-b") && requestBody.contains("type5")) {
                exchange.getAttributes().put(ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR, "http://service-b/v1/type5");
                return true;
            }
            return false;
        };
    }

    private String extractRequestBody(ServerHttpRequest request) {
        // Implement code to extract the request body here
        // This will depend on the request format (e.g., JSON, XML)
    }

    public static class Config {
        // Configuration properties can be added here if needed
    }
}

希望能帮助您解决问题。