flatend Context完全指南：Handler、Headers与Body的实战用法

flatend Context完全指南Handler、Headers与Body的实战用法【免费下载链接】flatendQuickly build microservices using p2p networking in NodeJS/Go.项目地址: https://gitcode.com/gh_mirrors/fl/flatendflatend 是一款基于 p2p 网络快速构建微服务的开源框架同时支持 Go 与 NodeJS。本文将以flatend Context为核心带你彻底搞懂三个最关键的概念Handler服务处理函数、Headers请求/响应头与Body请求体。无论你是刚开始接触 p2p 微服务的新手还是想快速上手的普通用户读完这篇实战指南你就能独立写出第一个 flatend 服务。flatend 是什么用 p2p 思想做微服务 传统微服务需要注册中心、网关、负载均衡等一堆基础设施而 flatend 的思路完全不同节点之间直接通过 p2p 网络互连服务按名字暴露其他节点按名字调用不需要中心服务器。✅ 同时支持Go和NodeJS两边可以互调服务✅ 服务注册、发现、路由全部自动完成✅ 基于流式传输天然适合大文件、长连接场景在 flatend 中一个服务的核心就是一个Handler它接收一个Context对象Context 里带着本次调用的全部信息Headers头部、Body请求体以及向调用方写回数据的能力。Handler如何注册一个 flatend 服务处理函数Go 版本一分钟注册服务在 Go 中Handler 是一个函数类型func(ctx *Context)定义在 net.go。把处理函数塞进Node.Services字典即可node : flatend.Node{ Services: map[string]flatend.Handler{ hello_world: func(ctx *flatend.Context) { ctx.Write([]byte(Hello world!)) }, }, } node.Start(127.0.0.1:9000)完整示例可参考 examples/go/hello_world/main.go。NodeJS 版本写法更简洁在 NodeJS 中Context 是一个继承自流Duplex的对象使用ctx.send()一行返回数据const node await Node.start({ addrs: [127.0.0.1:9000], services: { hello_world: (ctx) ctx.send(Hello world!), }, });完整示例见 examples/nodejs/hello_world/index.js。要点服务名就是微服务地址。Go 节点注册的hello_worldNodeJS 节点可以直接调用反之亦然这就是 flatend 跨语言互通的魅力。Headersflatend 中请求头如何传递Context 的Headers字段Go 中为map[string]string保存着调用方传来的头部信息。理解它的最佳方式是看HTTP 网关层是怎么做的——flathttp/service.go 会把 HTTP 请求自动转成 flatend 调用来源转换规则示例HTTP 请求头转为小写 keyAuthorization→authorizationURL 查询参数加query.前缀?id5→query.id路由参数加params.前缀/user/:id→params.id也就是说你可以在业务代码里这样读取func handler(ctx *flatend.Context) { token : ctx.Headers[authorization] userId : ctx.Headers[params.id] }这个设计非常实用HTTP 网关只负责协议转换业务服务完全不用感知 HTTP天然实现协议解耦。路由配置本身也很直观见 flathttp/config.go[[http.routes]] path GET /api/user/:id service user_service如何设置响应头Go在写入数据前调用ctx.WriteHeader(key, val)例如ctx.WriteHeader(content-type, application/json)NodeJS调用ctx.header(key, val)返回的依然是 Context支持链式调用services: { api: (ctx) ctx.header(content-type, application/json).json({ ok: true }), },NodeJS 里还内置了ctx.json()方法自动帮你设置content-type并序列化特别适合写 API见 context.ts。Body读取与发送请求体读取请求体Go 用流NodeJS 用 body()Go 的 Context 中Body是一个io.ReadCloser可以像普通文件一样流式读取func uploadHandler(ctx *flatend.Context) { data, _ : io.ReadAll(ctx.Body) // 一次性读完 defer ctx.Body.Close() }NodeJS 更省心直接await ctx.body()就能拿到完整内容还支持大小限制services: { echo: async (ctx) { const data await ctx.body({ limit: 1024 * 1024 }); // 最大 1MB ctx.send(data); }, },默认限制是 65536 字节64KB超限会抛出异常防止恶意请求撑爆内存。源码见 context.ts。流式写入边读边发flatend 的 Context 本身就是流你可以边接收边转发非常适合做**管道pipe**服务func pipeHandler(ctx *flatend.Context) { _, _ io.Copy(ctx, ctx.Body) // 请求体直接透传为响应 }项目自带的 pipe 示例 就是靠这一行实现的流式管道NodeJS 对应版本在 examples/nodejs/pipe/index.js两者可以互相连通值得亲自跑一遍。实战一个完整的 flatend 计数器服务把上面三个概念串起来写一个调用一次加一的计数器服务参考 examples/go/counter/main.gocounter : uint64(0) node : flatend.Node{ Services: map[string]flatend.Handler{ count: func(ctx *flatend.Context) { current : atomic.AddUint64(counter, 1) - 1 ctx.WriteHeader(x-count, strconv.FormatUint(current, 10)) // 响应头 ctx.Write(strconv.AppendUint(nil, current, 10)) // 响应体 }, }, } node.Start(127.0.0.1:9000)调用方另一个节点通过Push发起请求stream, err : node.Push([]string{count}, headers, body)第一个参数目标服务名列表第二个参数Headers 字典第三个参数请求体返回的stream.Reader就是响应体stream.Header.Headers则是响应头Push的定义可查看 provider.go。小结三件事记住就入门了概念GoNodeJS一句话总结Handlerfunc(ctx *flatend.Context)(ctx) ...注册到node.Services里的服务函数Headersctx.Headers[...]/ctx.WriteHeader(k,v)ctx.headers/ctx.header(k,v)传递元数据HTTP 网关会自动转换Bodyio.ReadAll(ctx.Body)await ctx.body({limit})读取请求体也可ctx.Write/send回写flatend 的 Context 设计兼顾了 Go 的严谨与 NodeJS 的简洁Handler 决定干什么Headers 传递上下文Body 承载数据。理解了这三者的协作方式再去看 flathttp 网关层、nodejs/src/ 的源码实现你会发现整个 p2p 微服务架构瞬间变得清晰起来。下一步不妨打开 examples/go/hello_world/main.go 或 examples/nodejs/hello_world/index.js跑通第一个 flatend 服务再试着把 HTTP 网关接进来感受一下 p2p 微服务的开发效率。【免费下载链接】flatendQuickly build microservices using p2p networking in NodeJS/Go.项目地址: https://gitcode.com/gh_mirrors/fl/flatend创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考