将字节切片转换为context.Context是否可行？beanstalkd消息上下文传递问题

结论 #

该操作完全不可行，你现在的实现思路从原理上就走不通，理由如下：

• Go标准库的context.Context是接口类型，所有内置的context实现（比如emptyCtx、cancelCtx、timerCtx等）都没有导出可序列化的成员字段，你用JSON序列化得到的只有空结构体{}，完全不包含原context的任何有效信息，也不可能反序列化回可用的context.Context实例
• context携带的核心能力：取消信号、超时计时、动态设置的value，要么是进程内的runtime状态，要么是任意类型的未导出值，本身就不支持跨进程序列化/反序列化，不可能通过消息队列传递完整的context实例
• 你现在贴的代码实际运行后打印的string(body)就是空JSON对象，不存在任何可用的上下文信息

正确实现方案 #

你不需要传递完整的context实例，只需要传递上下文里的有效业务信息，配合消费端本地生成context即可：

1. 定义专门的消息结构体，把你需要跨进程传递的上下文字段抽出来单独序列化：

// 定义可序列化的消息结构
type MQMessage struct {
    RequestID string `json:"request_id"` // 你存在context里的请求ID
    Uid       int64  `json:"uid"` // 你存在context里的用户ID
    // 其他需要传递的业务上下文字段
    Content []byte `json:"content"` // 实际业务消息体
}

// 发送端代码
ctx := context.Background()
// 从原context里取出你需要的业务值
reqID, _ := ctx.Value("request_id").(string)
uid, _ := ctx.Value("uid").(int64)

msg := MQMessage{
    RequestID: reqID,
    Uid: uid,
    Content: 你的业务消息字节,
}
// 序列化消息投递到beanstalkd
reqBodyBytes := new(bytes.Buffer)
if err := json.NewEncoder(reqBodyBytes).Encode(msg); err != nil {
    // 处理错误
}
_, err = conn.Put(reqBodyBytes.Bytes(), 1, 0, 120*time.Second)

2. 消费端拿到消息后，本地生成context，把取到的业务值塞进去即可：

_, body, err := conn.Reserve(120 * time.Second)
if err != nil {
    // 处理错误
}
var msg MQMessage
if err := json.Unmarshal(body, &msg); err != nil {
    // 处理错误
}
// 生成本地context，剩余超时时间可以用beanstalkd的TTR减去已过时间计算
ctx, cancel := context.WithTimeout(context.Background(), 120 * time.Second)
defer cancel()
// 把拿到的业务值塞到context里
ctx = context.WithValue(ctx, "request_id", msg.RequestID)
ctx = context.WithValue(ctx, "uid", msg.Uid)
// 后续业务逻辑直接用这个ctx即可

内容的提问来源于stack exchange，提问作者oldBear