Go语言如何将Protobuff字节数组入队到Azure存储队列？

可以实现，核心思路是将Protobuf序列化得到的二进制字节数组编码为Base64安全字符串，即可适配Enqueue方法的字符串参数要求。

Protobuf序列化后的字节数组包含大量非UTF-8字符，直接强制转换为Go字符串会导致入队失败、数据损坏，而Base64编码会将任意二进制数据转换为纯ASCII的可打印字符，完全符合Azure存储队列的消息格式要求。

入队实现示例 #

import (
    "context"
    "encoding/base64"
    "time"
    "github.com/golang/protobuf/proto"
    "github.com/Azure/azure-storage-queue-go/azqueue"
)

func enqueueProto(ctx context.Context, msgURL azqueue.MessagesURL, protoMsg proto.Message, visibilityTimeout, ttl time.Duration) error {
    // 序列化Protobuf为字节数组
    pbBytes, err := proto.Marshal(protoMsg)
    if err != nil {
        return err
    }
    // 编码为Base64字符串
    msgContent := base64.StdEncoding.EncodeToString(pbBytes)
    // 调用入队方法
    _, err = msgURL.Enqueue(ctx, msgContent, visibilityTimeout, ttl)
    return err
}

出队解析实现示例 #

func dequeueProto(ctx context.Context, msgURL azqueue.MessagesURL, visibilityTimeout time.Duration, target proto.Message) error {
    // 出队拉取1条消息
    resp, err := msgURL.Dequeue(ctx, 1, visibilityTimeout)
    if err != nil {
        return err
    }
    if len(resp.Messages) == 0 {
        return nil // 队列无消息
    }
    // Base64解码回Protobuf字节数组
    pbBytes, err := base64.StdEncoding.DecodeString(resp.Messages[0].Text)
    if err != nil {
        return err
    }
    // 反序列化为目标Protobuf结构体
    return proto.Unmarshal(pbBytes, target)
}

注意事项 #

• Azure存储队列单条消息最大容量为64KB，如果Protobuf序列化后的数据超过该限制，建议将数据存入Azure Blob存储，再将Blob访问地址作为消息内容入队。
• 直接使用标准Base64编码即可，无需使用URL安全编码，Azure存储队列对标准Base64字符集无兼容性问题。

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