在Go语言开发的后端服务中，对接MongoDB数据库时，常需要将查询到的文档返回给前端，而前端通常要求数据格式为JSON。MongoDB默认存储和查询返回的是BSON格式数据，直接处理容易出现格式不匹配或者性能浪费的问题，需要选择合适的转换方式来实现高效返回。
为什么需要专门处理BSON到JSON的转换
MongoDB的官方Go驱动返回的数据结构通常是bson.M或者自定义的BSON标签结构体，BSON格式支持的数据类型比如ObjectID、时间类型等，和JSON的默认序列化规则不一致。如果直接使用encoding/json序列化BSON数据，可能会出现ObjectID被序列化为对象、时间格式不符合预期等问题，而且默认的转换逻辑会多做一次不必要的序列化操作，增加性能开销。
常见的转换方案对比
目前主流的转换方式有三种，各自的适用场景和性能表现不同，我们可以通过简单的测试来对比：
| 转换方案 | 优点 | 缺点 | 适用场景 |
|---|---|---|---|
| 先序列化为BSON字节，再反序列化为JSON | 实现简单，无需额外依赖 | 多一次序列化开销，性能较差 | 数据量小、对性能要求不高的简单场景 |
| 使用自定义结构体加JSON标签 | 格式可控，性能较好 | 需要提前定义结构体，灵活性不足 | 数据结构固定、字段明确的业务场景 |
| 使用驱动的BSON转JSON工具方法 | 无需额外序列化步骤，性能好 | 需要了解驱动提供的转换接口 | 数据结构灵活、对性能要求高的场景 |
高效转换的实现示例
方案一：使用自定义结构体返回
提前定义好对应的结构体，给字段加上BSON和JSON标签，查询时直接映射到结构体，再序列化返回，这种方式性能最优。
package main
import (
"context"
"encoding/json"
"fmt"
"net/http"
"time"
"go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/mongo/options"
)
// 定义用户结构体，同时指定BSON字段名和JSON字段名
type User struct {
ID string `bson:"_id,omitempty" json:"id"`
Name string `bson:"name" json:"name"`
Age int `bson:"age" json:"age"`
CreateAt time.Time `bson:"create_at" json:"create_at"`
}
var userCollection *mongo.Collection
func initMongoDB() {
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
client, err := mongo.Connect(ctx, options.Client().ApplyURI("mongodb://127.0.0.1:27017"))
if err != nil {
panic(err)
}
userCollection = client.Database("test_db").Collection("users")
}
func getUserHandler(w http.ResponseWriter, r *http.Request) {
ctx := context.Background()
// 查询单个用户
var user User
err := userCollection.FindOne(ctx, bson.M{"name": "张三"}).Decode(&user)
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
// 直接序列化结构体返回JSON
w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(user)
}
func main() {
initMongoDB()
http.HandleFunc("/user", getUserHandler)
fmt.Println("服务启动在 :8080")
http.ListenAndServe(":8080", nil)
}
方案二：灵活转换BSON数据为JSON
如果查询的字段不固定，无法提前定义结构体，可以使用驱动提供的bson.Marshal和自定义的JSON编码逻辑，或者直接使用bson.M配合转换方法，减少不必要的开销。
package main
import (
"context"
"fmt"
"net/http"
"time"
"go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/bson/primitive"
"go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/mongo/options"
)
var userCollection *mongo.Collection
func initMongoDB() {
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
client, err := mongo.Connect(ctx, options.Client().ApplyURI("mongodb://127.0.0.1:27017"))
if err != nil {
panic(err)
}
userCollection = client.Database("test_db").Collection("users")
}
func getFlexibleUserHandler(w http.ResponseWriter, r *http.Request) {
ctx := context.Background()
// 查询返回bson.M类型
var result bson.M
err := userCollection.FindOne(ctx, bson.M{"name": "张三"}).Decode(&result)
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
// 处理ObjectID类型，转为字符串
if id, ok := result["_id"].(primitive.ObjectID); ok {
result["_id"] = id.Hex()
}
// 处理时间类型，转为常用格式
if createAt, ok := result["create_at"].(primitive.DateTime); ok {
result["create_at"] = time.Unix(int64(createAt)/1000, 0).Format("2006-01-02 15:04:05")
}
// 删除不需要返回的BSON字段，比如内部状态字段
delete(result, "internal_status")
// 序列化返回
w.Header().Set("Content-Type", "application/json")
// 这里使用json迭代编码，避免额外的缓冲区开销
enc := json.NewEncoder(w)
enc.SetEscapeHTML(false)
enc.Encode(result)
}
func main() {
initMongoDB()
http.HandleFunc("/flexible_user", getFlexibleUserHandler)
fmt.Println("服务启动在 :8080")
http.ListenAndServe(":8080", nil)
}
优化建议
- 尽量使用自定义结构体返回数据，提前明确字段的JSON名称，避免运行时的反射和转换开销。
- 如果必须使用灵活的
bson.M返回，提前处理好ObjectID、时间等BSON特有类型，不要依赖默认的序列化逻辑。 - 关闭JSON编码器的HTML转义，减少不必要的字符处理，提升序列化速度。
- 对于批量查询的场景，可以使用缓冲区批量处理，减少多次序列化带来的开销。
- 避免在返回前做过多的数据拷贝操作，直接处理查询到的原始数据结构，减少内存分配。
注意：如果需要返回的数据中包含MongoDB的ObjectID，一定要提前转换为字符串格式，否则默认的序列化会把ObjectID转成一个包含时间戳、机器标识等字段的对象，不符合前端的使用习惯。
MongoDBGoJSONbson_to_json修改时间：2026-06-30 01:36:42