Fiber v3 如何用 SharedState 与 SharedStorage 在 prefork 多进程间共享状态-育师

Fiber v3 如何用 SharedState 与 SharedStorage 在 prefork 多进程间共享状态

【免费下载链接】fiber⚡️ Express inspired web framework written in Go项目地址: https://gitcode.com/GitHub_Trending/fi/fiber

在 Fiber v3 中开启 prefork 后，每个 worker 进程都拥有独立的app.State()存储，文档明确指出："When prefork is enabled, each worker process has an independent state store, meaning state is not shared between them."。如果你的应用需要在多个 prefork worker 之间共享计数器、会话快照、限流状态等运行时数据，就不能再依赖app.State()，而要使用 v3 新增的app.SharedState()：它由fiber.Storage实现作为后端，通过Config.SharedStorage配置，专用于 prefork-safe / 多进程协调（见 What's New in v3）。

本文完成的任务是：开启 prefork，配置共享存储，用SharedState在多个 worker 进程间读写同一份数据，并验证跨进程可见性。

前提条件

Fiber v3。v3 要求 Go1.26或更高版本，升级前先更新工具链。
一个实现fiber.Storage接口的存储后端。该接口定义在 storage_interface.go，方法包括Get/Set/Delete/Reset/Close及对应的WithContext变体；Set的过期参数中0表示永不过期。
关键约束：后端必须是多个 worker 进程都指向的同一实例。State Management 文档中的警告写得很直接：使用内存型后端（in-memory）时，数据仍然是进程本地的，prefork 模式下每个 worker 各自拥有一份独立的内存存储。所以真正要实现跨进程共享，后端应该是 Redis 之类的外部存储；内存实现只适合单进程验证逻辑。

第一步：开启 prefork

v3 中EnablePrefork已从fiber.Config移到监听配置中。按 Fiber API 文档的写法，在Listen时传入ListenConfig：

app.Listen(":8080", fiber.ListenConfig{EnablePrefork: true})

EnablePrefork默认false；设为true后 Fiber 会派生多个 Go 进程监听同一端口。这一步是后文"状态不共享"问题的来源，也是使用SharedState的触发条件。

第二步：配置 SharedStorage 与前缀

在创建 app 时把存储后端注入fiber.Config，文档给出的配置方式如下（redisStorage处替换为你自己的任意fiber.Storage实现，文档原注释即 "any implementation of fiber.Storage"）：

app := fiber.New(fiber.Config{ AppName: "billing-api", SharedStorage: redisStorage, // any implementation of fiber.Storage SharedStatePrefix: "billing-shared-", // optional })

三个字段的作用：

SharedStorage：SharedState的数据后端。未配置时，调用任何SharedState方法都会返回ErrSharedStorageNotConfigured（错误信息为 "fiber: shared storage is not configured"，见 shared_state.go）。
SharedStatePrefix：可选的命名空间前缀。留空时 Fiber 会派生一个默认前缀，并在AppName非空时把AppName包含进去，用于降低多个 app/服务之间的键冲突。
AppName：如示例中的"billing-api"，参与默认前缀的生成。

在共享存储后端中，实际存储的键是"前缀 + 十六进制编码后的 key"（storageKey逻辑，见 shared_state.go）。这一点在排查后端数据时可以直接用上：按前缀过滤即可找到本应用写入的键。

第三步：在处理器中使用 SharedState 读写

SharedState提供字节读写和一组带编解码的辅助方法（完整签名见 State Management 文档）：

Set/Get：原始[]byte读写，Set接受 TTL（0表示不过期）；
SetJSON/GetJSON、SetXML/GetXML：默认使用标准库json.Marshal/Unmarshal、xml.Marshal/Unmarshal；
SetMsgPack/GetMsgPack、SetCBOR/GetCBOR：需要你在Config中配置对应的MsgPackEncoder/MsgPackDecoder、CBOREncoder/CBORDecoder。未配置时这些辅助方法返回 error 而不是 panic；
Delete、Has、Reset、Close：删除单键、存在性检查、清空与关闭（Reset/Close会透传给底层存储）；
每个方法都有WithContext变体，可传入带超时/取消的context.Context；
空 key 的操作是 no-op，直接返回，不报错。

文档中的完整示例是一个会话快照场景：POST 写入、GET 读取，TTL 设为 30 分钟：

type SessionSnapshot struct { UserID string `json:"user_id"` UpdatedAt time.Time `json:"updated_at"` } app.Post("/sessions/:id", func(c fiber.Ctx) error { key := "session:" + c.Params("id") value := SessionSnapshot{ UserID: c.Params("id"), UpdatedAt: time.Now().UTC(), } if err := app.SharedState().SetJSON(key, value, 30*time.Minute); err != nil { return err } return c.SendStatus(fiber.StatusAccepted) }) app.Get("/sessions/:id", func(c fiber.Ctx) error { key := "session:" + c.Params("id") var snapshot SessionSnapshot _, found, err := app.SharedState().GetJSON(key, &snapshot) if err != nil { return err } if !found { return c.SendStatus(fiber.StatusNotFound) } return c.JSON(snapshot) })

验证跨进程可见性

把Listen配置为EnablePrefork: true后启动应用，按上面的示例用 HTTP 请求验证：

向POST /sessions/<id>发一次请求，期望状态码202（示例中fiber.StatusAccepted）。
再连续向GET /sessions/<id>发多次请求。prefork 下请求会落到不同 worker 进程，若SharedStorage后端是共享的，任意 worker 都应返回该快照的 JSON（示例中为{"user_id":"...","updated_at":"..."}结构）；
对从未写入的 id 发起GET /sessions/<id>，示例逻辑返回404（fiber.StatusNotFound）。

如果同样的请求有时能读到、有时返回404，优先检查SharedStorage是否为内存型后端——文档警告的"每个 worker 独立内存存储"正是这一现象的直接原因。也可以在存储后端侧按SharedStatePrefix前缀核对键是否确实写入。

单元测试场景可以不真正Listen，使用 v3 的app.Test(req, fiber.TestConfig{...})发起请求（Timeout设为0表示不限时，见 What's New in v3 的 Test Config 一节）来验证读写逻辑。

可选：带超时的 WithContext 变体

对存储 I/O 需要超时控制时，用WithContext方法传入受控 context。文档示例中SetJSONWithContext返回的 error 可能来自：超时、取消、存储错误或 JSON 序列化错误：

ctx, cancel := context.WithTimeout(context.Background(), 500*time.Millisecond) defer cancel() err := app.SharedState().SetJSONWithContext(ctx, "job:42", fiber.Map{ "status": "queued", }, 2*time.Minute) if err != nil { // timeout, cancellation, storage error, or JSON serialization error }

限制与排查清单

内存后端不跨进程：SharedState只有在SharedStorage后端本身共享时才是跨 worker / 跨进程的（State Management 文档的 Memory storage caveat）。
MsgPack/CBOR 缺少编解码器：未配置对应Config编码器/解码器时，辅助方法返回错误而非 panic；JSON 与 XML 有标准库默认实现，无需额外配置。
未配置 SharedStorage：所有SharedState调用返回 "fiber: shared storage is not configured"。
不要混用app.State()：app.State()基于sync.Map，只保证单进程内的并发安全，prefork 下每份都是独立副本；跨进程数据一律走SharedState。
Reset的影响：SharedState().Reset()会透传给底层存储并删除其全部键，不要对多个服务共用、且前缀相同的后端随意调用。