
leveldb 本身仅支持字节切片(`[]byte`)作为键和值,因此需将 go 结构体序列化为字节流后存入;推荐使用 `encoding/gob`(go 原生高效)、`encoding/json`(跨语言兼容)或 `gogoprotobuf`/`msgpack` 等方案。
LevelDB 是一个高性能、可嵌入的键值存储系统,其 Go 实现 github.com/syndtr/goleveldb 严格要求 key 和 value 均为 []byte 类型。这意味着你不能直接传入结构体(如 Thm),而必须先将其序列化为字节序列。
以下是以 encoding/gob 为例的完整实践方案(适用于纯 Go 环境,性能好、无额外依赖):
package main
import (
"bytes"
"encoding/gob"
"log"
"github.com/syndtr/goleveldb/leveldb"
)
type Thm struct {
Name string
Age int
}
// 必须为字段导出(首字母大写),否则 gob 无法序列化
func main() {
db, err := leveldb.OpenFile("/tmp/ldb-test", nil)
if err != nil {
log.Fatal(err)
}
defer db.Close()
// 序列化结构体
t := Thm{Name: "Gon", Age: 33}
var buf bytes.Buffer
enc := gob.NewEncoder(&buf)
if err := enc.Encode(t); err != nil {
log.Fatal("encode failed:", err)
}
// 写入 LevelDB
if err := db.Put([]byte("test3"), buf.Bytes(), nil); err != nil {
log.Fatal("put failed:", err)
}
// 读取并反序列化
data, err := db.Get([]byte("test3"), nil)
if err != nil {
log.Fatal("get failed:", err)
}
var t2 Thm
dec := gob.NewDecoder(bytes.NewReader(data))
if err := dec.Decode(&t2); err != nil {
log.Fatal("decode failed:", err)
}
log.Printf("Retrieved: %+v", t2) // 输出: Retrieved: {Name:"Gon" Age:33}
}✅ 关键注意事项:
- 所有需序列化的字段必须是导出字段(大写字母开头),gob 不处理未导出字段;
- 使用 gob 时,写入与读取端的结构体定义必须完全一致(包括字段名、类型、顺序),否则解码失败;
- 若需跨语言访问(如 Python/Java 客户端读取),请改用 encoding/json 或 Protocol Buffers:
b, _ := json.Marshal(t) // 序列化 var t2 Thm; _ = json.Unmarshal(b, &t2) // 反序列化
- 对于高频写入场景,可封装通用的 PutStruct / GetStruct 辅助函数,避免重复 boilerplate 代码。
总之,LevelDB 的“纯字节”设计并非限制,而是将序列化策略交由应用层决策——这赋予了你灵活性:可根据性能、兼容性、可读性需求自由选择编码方式。










