Go服务通信无银弹:HTTP/JSON易用但有性能损耗,gRPC适合强契约场景,消息队列解耦异步任务,自定义TCP/UDP仅适用于超低延迟场景。
Go 语言中服务间通信没有“银弹”,选型取决于延迟容忍、一致性要求、运维复杂度和团队熟悉度——HTTP/JSON 最易上手但性能有损耗,gRPC 适合强契约场景,消息队列(如 Kafka/RabbitMQ)解耦异步任务,而直接 TCP 或 UDP 自定义协议仅在极低延迟或嵌入式网关场景下值得考虑。
net/http 实现 RESTful 同步调用:简单但要注意超时与重试这是最常见起点,http.Client 默认不设超时,生产环境极易因下游卡顿拖垮上游。必须显式配置 Timeout、KeepAlive 和连接池。
client := &http.Client{
Timeout: 5 * time.Second,
Transport: &http.Transport{
MaxIdleConns: 100,
MaxIdleConnsPerHost: 100,
IdleConnTimeout: 30 * time.Second,
},
}http.Get 或 http.Post 会阻塞直到响应头到达,不是整个 body;大响应体仍需手动 resp.Body.Close() 防止连接泄漏url.Error(网络层)、http.StatusCode >= 400(业务层),不能只看 err != nil
json.Unmarshal 直接解析未知结构体字段,建议用 map[string]interface{} 或定义精确 struct + json.RawMessage 延迟解析gRPC-Go 实现强类型 RPC:需要 Protocol Buffers 编译链gRPC 不是“HTTP+JSON 的升级版”,它是基于 HTTP/2 的二进制协议,天然支持流式、拦截器、截止时间传递。但代价是必须维护 .proto 文件并生成 Go 代码。
RegisterXxxServer,客户端用 grpc.Dial 连接,地址格式为 "127.0.0.1:8080"(不带 http://)context.WithTimeout 控制,服务端可通过 ctx.Deadline() 感知并提前退出status.Errorf 构造,否则客户端收到的是 rpc error: code = Unknown,无法提取原始错误码grpc-gateway 自动生成 REST 网关,但它会把 gRPC 错误转成 HTTP 状态码,需注意映射规则go-stan(NATS Streaming)或 segmentio/kafka-go 做异步解耦:消息可靠性是关键分歧点同步调用失败即失败,消息队列则引入“至少一次”或“恰好一次”语义。Kafka 依赖 offset 提交策略,NATS Streaming 默认 at-least-once,且不支

RequiredAcks: kafka.RequireAllIsr 和 MaxRetries: 3 防止丢消息;消费者要控制 CommitInterval,太短影响吞吐,太长导致重复消费ClusterID 和 ClientID,后者需全局唯一(例如用 Pod ID),否则旧连接会被踢出Protobuf 序列化而非 JSON,减少网络体积和反序列化开销;同时保留 schema version 字段,便于后续兼容升级当你的服务部署在边缘设备、实时音视频网关或高频交易路径上,且对 P99 延迟要求低于 100μs,或者需要绕过 TLS 握手开销时,net 包直连 TCP 或 golang.org/x/net/quic(实验性)才值得投入。但你要自己实现连接复用、心跳保活、帧解析、背压控制——这些在 http 或 grpc 里已封装好。
多数微服务项目卡点不在通信协议本身,而在服务发现(Consul/Etcd)、配置中心(Viper+Remote)和链路追踪(OpenTelemetry SDK 注入)的落地质量。先跑通一个可观察、可降级的 HTTP 服务,比强行上 gRPC 却没配好指标监控更务实。