Solon2 接口开发: 分布式 Api Gateway 开发预览

原创
2023/03/22 11:54
阅读数 138

建议使用专业的分布式网关产品,比如:

  • nginx
  • apisix [推荐]
  • k8s ingress controller
  • 等...

对 Solon 来讲,只有 Gateway:它调用本地接口时,则为本地网关;调用远程接口时,则为分布式网关。

1、一个简单的分布式接口网关效果预览

基于上一节的 ApiGateway3x,微做调整:将注册的处理,由本地改为远程调用。主要原理演示:

  • 拦截或过滤
  • 路由
  • 转发
@Mapping("/sev/**")
@Component
public class SevGateway extends ApiGatewayBase {
    @Override
    protected void register() {
        filter(new BreakerFilter()); //融断

        before(new StartHandler()); //开始计时
        before(new ParamsParseHandler()); //参数解析
        before(new ParamsSignCheckHandler(new Md5Encoder())); //参数签名较验
        before(new ParamsRebuildHandler(new AesDecoder())); //参数重构

        after(new OutputBuildHandler(new AesEncoder())); //输出构建
        after(new OutputSignHandler(new Md5Encoder())); //输出签名
        after(new OutputHandler()); //输出
        after(new EndBeforeLogHandler()); //日志
        after(new EndHandler("sev")); //结束计时

        //添加一个处理类(带 @Mapping 的函数会注册进来)
        add(Nav.class); 
    }

    public static class Nav {
        //没有加印射值时,将做为默认处理 //当只有默认处理时,将接收所有请求
        @Mapping
        public Object def(Context ctx) throws Throwable {
            //检测请求,并尝试获取二级接口服务名
            String sevName = ctx.pathMap("/sev/{name}/**").get("name");
            if (sevName == null) {
                throw ApiCodes.CODE_4001011;
            }

            //转发请求(分布式的特点:转发到别处去)//使用服务名转发,即是用“负载均衡”了
            String rstJson = HttpUtils.http(sevName, ctx.path()).data(ctx.paramMap()).post();

            //返回 json //如有需求,也可先转换为对象
            return rstJson; //return ONode.load(rstJson).toData();
        }
    }
}
展开阅读全文
加载中
点击引领话题📣 发布并加入讨论🔥
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部