Boltdb-键值数据存储纯粹在Go中

Question

Bolt获得数据文件的文件锁，因此多个进程不能同时打开同一个数据库。打开已经打开的Bolt数据库将导致它挂起，直到其他进程关闭它为止。

在这种情况下，是否存在连接池的概念，就像各种客户端同时连接和访问数据库一样。这在boltdb中是可能的吗?就像在同一个time.How上的数据库中有各种各样的连接一样，它可以实现吗？

Answer 1

博尔特数据库通常嵌入到更大的程序中，不像共享数据库那样在网络上使用(比如SQLite和MySQL)。如果可能的话，使用Bolt有点像一个持久的map[[]byte][]byte。根据您正在做的事情，您可能只想使用类似Redis之类的东西。

也就是说，如果您需要以这种方式使用Bolt，那么使用简单的服务器就不难了。下面是一个通过HTTP从Bolt写入/读取键的示例。您可以使用Keep-Alive进行连接池。

代码：https://github.com/skyec/boltdb-server

package main

import (
    "flag"
    "fmt"
    "io/ioutil"
    "log"
    "net/http"
    "time"

    "github.com/boltdb/bolt"
    "github.com/gorilla/mux"
)

type server struct {
    db *bolt.DB
}

func newServer(filename string) (s *server, err error) {
    s = &server{}
    s.db, err = bolt.Open(filename, 0600, &bolt.Options{Timeout: 1 * time.Second})
    return
}

func (s *server) Put(bucket, key, contentType string, val []byte) error {
    return s.db.Update(func(tx *bolt.Tx) error {
        b, err := tx.CreateBucketIfNotExists([]byte(bucket))
        if err != nil {
            return err
        }
        if err = b.Put([]byte(key), val); err != nil {
            return err
        }
        return b.Put([]byte(fmt.Sprintf("%s-ContentType", key)), []byte(contentType))
    })
}

func (s *server) Get(bucket, key string) (ct string, data []byte, err error) {
    s.db.View(func(tx *bolt.Tx) error {
        b := tx.Bucket([]byte(bucket))
        r := b.Get([]byte(key))
        if r != nil {
            data = make([]byte, len(r))
            copy(data, r)
        }

        r = b.Get([]byte(fmt.Sprintf("%s-ContentType", key)))
        ct = string(r)
        return nil
    })
    return
}

func (s *server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
    vars := mux.Vars(r)

    if vars["bucket"] == "" || vars["key"] == "" {
        http.Error(w, "Missing bucket or key", http.StatusBadRequest)
        return
    }

    switch r.Method {
    case "POST", "PUT":
        data, err := ioutil.ReadAll(r.Body)
        if err != nil {
            http.Error(w, err.Error(), http.StatusInternalServerError)
            return
        }
        err = s.Put(vars["bucket"], vars["key"], r.Header.Get("Content-Type"), data)
        w.WriteHeader(http.StatusOK)
    case "GET":
        ct, data, err := s.Get(vars["bucket"], vars["key"])
        if err != nil {
            http.Error(w, err.Error(), http.StatusInternalServerError)
            return
        }
        w.Header().Add("Content-Type", ct)
        w.Write(data)
    }
}

func main() {
    var (
        addr   string
        dbfile string
    )

    flag.StringVar(&addr, "l", ":9988", "Address to listen on")
    flag.StringVar(&dbfile, "db", "/var/data/bolt.db", "Bolt DB file")
    flag.Parse()

    log.Println("Using Bolt DB file:", dbfile)
    log.Println("Listening on:", addr)

    server, err := newServer(dbfile)
    if err != nil {
        log.Fatalf("Error: %s", err)
    }

    router := mux.NewRouter()
    router.Handle("/v1/buckets/{bucket}/keys/{key}", server)
    http.Handle("/", router)

    log.Fatal(http.ListenAndServe(addr, nil))
}

Answer 2

在boltdb中没有连接池的概念，因为没有连接。它不是一个客户机/服务器数据库，它是一个嵌入式数据库(像sqlite或Berkeley-DB)。

Boltdb的设计使得同一进程的多个对象可以同时访问数据库(使用不同的事务)。模型是单一的作者，多个读者。Boltdb不用于支持来自多个进程的访问。

如果需要一个Go程序同时使用支持从多个进程访问的嵌入式数据库，则可能需要查看LMDB的包装器，例如：

• https://github.com/szferi/gomdb
• https://github.com/armon/gomdb