Go gRPC网关SSE开发：字符串转ProtoMessage/anypb方案

问题根因 #

anypb.Any 仅支持承载实现了 protoreflect.ProtoMessage 接口的Protobuf消息类型，Go原生字符串未实现该接口，直接强制类型转换必然触发运行时错误。

实现方案 #

方案1：官方wrapperspb包装（无额外proto定义成本，推荐） #

Google Protobuf官方提供基础类型的标准包装器，无需自定义proto即可直接使用。

1. 导入依赖包

import (
    "google.golang.org/protobuf/types/known/anypb"
    "google.golang.org/protobuf/types/known/wrapperspb"
)

2. 转换逻辑

// 业务通道传递的原始字符串
rawStr := "待推送的SSE事件内容"

// 先包装为符合ProtoMessage规范的StringValue类型
strWrapper := wrapperspb.String(rawStr)

// 构造anypb.Any实例
anyData, err := anypb.New(strWrapper)
if err != nil {
    // 标准包装器构造场景下该错误基本不会触发，可按项目规范处理
    panic(err)
}

// 将anyData赋值给EventSource消息的data字段即可正常推送

该方案完全兼容gRPC-Gateway内置的SSE事件序列化逻辑，接收端解包google.protobuf.StringValue类型即可拿到原始字符串。

方案2：自定义Protobuf消息（适合后续扩展字段场景） #

如果后续SSE数据需要附加事件ID、时间戳、标签等扩展字段，可自定义专用消息结构：

1. 在proto文件中定义数据结构

syntax = "proto3";
package your_app;

message SSEEventPayload {
    string content = 1;
    // 可按需扩展其他字段
    int64 event_timestamp = 2;
    string event_id = 3;
}

2. 执行protoc生成对应代码后，转换逻辑如下

import (
    "google.golang.org/protobuf/types/known/anypb"
    pb "项目内proto生成代码的导入路径"
)

rawStr := "待推送的SSE事件内容"
payload := &pb.SSEEventPayload{
    Content:        rawStr,
    EventTimestamp: time.Now().UnixMilli(),
    EventId:        "evt_123456",
}

anyData, err := anypb.New(payload)
if err != nil {
    panic(err)
}

注意事项 #

• 禁止直接将Go原生基础类型（string/int/bool等）强转为protoreflect.ProtoMessage，这类类型未实现Protobuf反射相关方法，强转只会得到nil或运行时panic
• 构造完成后可调用anyData.MessageName()校验承载的消息类型是否符合预期，避免类型错配
• 若使用gRPC-Gateway原生SSE支持，标准wrapperspb类型会被自动序列化为普通文本格式，无需额外编写响应改写中间件

内容的提问来源于stack exchange，提问作者Hasan A Yousef