Grpc-gateway流式HTTP响应解码失败:排查与解决方案
本文针对使用grpc-gateway处理流式HTTP响应时,runtime.jsonpb.decode解码失败(返回nil值)的问题,提供详细的排查和解决方法。 假设HTTP响应体本身数据正确,但解码却出错。
问题描述: 在使用grpc-gateway将gRPC服务暴露为HTTP服务时,流式响应解码失败。 gRPC服务端已正确发送多个响应对象,但客户端使用runtime.jsonpb.decode无法获取有效数据。
原因分析: grpc-gateway生成的HTTP响应并非直接返回原始protobuf消息,而是包含了一个额外的包装字段。
解决方案: 通过升级grpc-gateway版本并调整protobuf定义和解码逻辑,即可解决此问题。
升级grpc-gateway: 将github.com/grpc-ecosystem/grpc-gateway升级到v2.4.0或更高版本。旧版本可能存在兼容性问题。
修改protobuf定义: 在protobuf文件中,添加一个新的message来包裹原始响应消息。例如:
message Resp { int32 code = 1; string msg = 2;}message HttpResp { Resp result = 1;}
登录后复制修改解码代码: 修改解码代码,使用新的HttpResp message进行解码,并使用取地址符&:
var result *pb.HttpResp // 使用新的HttpResp messageerr := decoder.Decode(&result) // 使用取地址符 &
登录后复制
修正后的单元测试示例:
package mainimport ( "bytes" "context" "net/http" "test/pb" "testing" "github.com/grpc-ecosystem/grpc-gateway/v2/runtime" "google.golang.org/grpc")// ... (其余代码不变) for { var result *pb.HttpResp err := decoder.Decode(&result) if err == nil { t.Logf("resp: %+v", result) } else { t.Logf("%+v", err) break } }}
登录后复制
通过以上步骤,runtime.jsonpb.decode应该能够正确解码流式响应数据。 问题根源在于grpc-gateway的HTTP响应结构与客户端解码预期不一致,通过升级版本和调整protobuf结构及解码代码,解决了这种不匹配。
以上就是使用grpc-gateway流式HTTP请求解码失败,如何排查和解决?的详细内容,更多请关注【创想鸟】其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至253000106@qq.com举报,一经查实,本站将立刻删除。
发布者:PHP中文网,转转请注明出处:https://www.chuangxiangniao.com/p/3047805.html