Pangkalan data MySQL dan bahasa Go: Bagaimana untuk melakukan caching data?

Dalam beberapa tahun kebelakangan ini, bahasa Go telah menjadi semakin popular di kalangan pembangun dan telah menjadi salah satu bahasa pilihan untuk membangunkan aplikasi web berprestasi tinggi. MySQL juga merupakan pangkalan data popular yang digunakan secara meluas. Dalam proses menggabungkan kedua-dua teknologi ini, caching adalah bahagian yang sangat penting.

Yang berikut akan memperkenalkan cara menggunakan bahasa Go untuk mengendalikan cache pangkalan data MySQL.

1. Konsep cache

Dalam aplikasi web, cache ialah lapisan tengah yang dicipta untuk mempercepatkan akses data. Ia digunakan terutamanya untuk menyimpan data yang kerap diminta supaya ia boleh diperolehi dengan lebih cepat pada permintaan seterusnya. Caching biasanya dibahagikan kepada dua kaedah: cache memori dan cache cakera.

Caching memori secara amnya merujuk kepada menyimpan data dalam memori aplikasi, dengan itu mempercepatkan akses kepada data. Cache cakera menyimpan data pada cakera, dan apabila cache memori tidak dapat menyimpan lebih banyak data, data boleh dibaca daripada cakera.

2. Bahasa Go dan pangkalan data MySQL

Dalam bahasa Go, kami boleh menggunakan pakej pihak ketiga untuk mengendalikan pangkalan data MySQL. Yang paling biasa digunakan ialah Go-MySQL-Driver. Go-MySQL-Driver ialah pemacu MySQL yang ditulis dalam bahasa Go tulen dan menyokong antara muka pangkalan data/sql standard. Ia menggunakan protokol binari MySQL yang berasal dari protokol, jadi pelaksanaannya sangat pantas.

Pertama, kita perlu memasang Go-MySQL-Driver dalam persekitaran Go. Kemudian, kita boleh menggunakan kod berikut untuk menyambung ke pangkalan data MySQL:

dsn := "user:password@tcp(127.0.0.1:3306)/dbname"
db, err := sql.Open("mysql", dsn)
if err != nil {
    log.Fatal(err)
}

Dalam kod di atas, dsn ialah nama sumber data yang disambungkan ke MySQL, pengguna ialah nama pengguna, kata laluan ialah kata laluan, 127.0.0.1 ialah alamat pelayan MySQL, 3306 ialah nombor port pelayan MySQL, dan nama db ialah nama pangkalan data yang akan disambungkan.

3. Pelaksanaan cache data

Dalam bahasa Go, kita boleh menggunakan peta untuk melaksanakan cache memori. Berikut ialah contoh mudah:

type Cache struct {
    data map[string]interface{}
    sync.RWMutex
}

func NewCache() *Cache {
    return &Cache{
        data: make(map[string]interface{}),
    }
}

func (c *Cache) Get(key string) interface{} {
    c.RLock()
    defer c.RUnlock()
    if value, ok := c.data[key]; ok {
        return value
    }
    return nil
}

func (c *Cache) Set(key string, value interface{}) {
    c.Lock()
    defer c.Unlock()
    c.data[key] = value
}

func main() {
    cache := NewCache()

    // 缓存数据
    cache.Set("key", "value")

    // 获取数据
    if value := cache.Get("key"); value != nil {
        fmt.Println(value)
    }
}

Dalam kod di atas, kami mentakrifkan struktur Cache, yang mengandungi ahli data untuk menyimpan data cache. Dalam kaedah Dapatkan, kami menggunakan kunci baca-tulis untuk memastikan keselamatan benang. Dalam kaedah Set, kami juga menggunakan kunci baca-tulis untuk memastikan keselamatan benang. Dengan cara ini, kami telah mencipta cache dalam memori yang mudah.

Kini kami boleh menambah caching pada aplikasi pangkalan data MySQL kami. Berikut ialah contoh aplikasi pangkalan data MySQL menggunakan cache dalam memori:

const cacheTTL = 5 * time.Minute

func main() {
    // 创建缓存
    cache := NewCache()

    // 连接到MySQL数据库
    dsn := "user:password@tcp(127.0.0.1:3306)/dbname"
    db, err := sql.Open("mysql", dsn)
    if err != nil {
        log.Fatal(err)
    }

    // 查询数据
    rows, err := db.Query("SELECT * FROM table")
    if err != nil {
        log.Fatal(err)
    }
    defer rows.Close()

    // 遍历查询结果
    for rows.Next() {
        var name string
        var age int
        err := rows.Scan(&name, &age)
        if err != nil {
            log.Fatal(err)
        }

        // 查询数据是否已经被缓存
        cacheKey := fmt.Sprintf("name:%s", name)
        if data := cache.Get(cacheKey); data != nil {
            fmt.Println("cache hit")
            continue
        }

        // 数据未被缓存，从MySQL数据库中获取数据
        fmt.Println("cache miss")
        // ...

        // 存储缓存数据
        cache.Set(cacheKey, data)
    }
}

Dalam kod di atas, kami mentakrifkan pemalar cacheTTL untuk menyimpan masa sah data cache. Dalam aplikasi, kami mula-mula membuat contoh cache. Kemudian, kami menyambung ke pangkalan data MySQL dan menanyakan data tersebut. Apabila melintasi hasil pertanyaan, kami terlebih dahulu bertanya sama ada data telah dicache Jika data telah dicache, tidak perlu menanyakan pangkalan data MySQL. Jika data tidak dicache, data diambil daripada pangkalan data MySQL dan disimpan dalam cache.

Akhir sekali, kami perlu menambah mekanisme untuk mengosongkan cache dengan kerap untuk memastikan kesahihan data cache. Kami boleh menggunakan kod berikut untuk mengosongkan cache dengan kerap:

func (c *Cache) expire() {
    for {
        time.Sleep(cacheTTL)
        c.Lock()
        for key, value := range c.data {
            if time.Now().Sub(value.(time.Time)) >= cacheTTL {
                delete(c.data, key)
            }
        }
        c.Unlock()
    }
}

func main() {
    cache := NewCache()

    // 启动清除缓存的协程
    go cache.expire()

    // ...
}

Dalam kod di atas, kami mentakrifkan kaedah tamat tempoh untuk mengosongkan cache dengan kerap. Dalam fungsi utama, kami memulakan goroutine untuk menjalankan kaedah tamat tempoh.

4. Kesimpulan

Dalam bahasa Go, sangat mudah untuk menggunakan cache memori dan pangkalan data MySQL. Kita boleh menggunakan peta untuk melaksanakan cache memori dan menggunakan Go-MySQL-Driver untuk menyambung ke pangkalan data MySQL. Apabila data ditanya dari pangkalan data MySQL, kita boleh mencari data dalam cache terlebih dahulu Jika data telah di-cache, tidak perlu menanyakan pangkalan data MySQL lagi, jika tidak, kita perlu mendapatkan data dari pangkalan data MySQL. dan simpan dalam cache. Akhir sekali, kita perlu menambah mekanisme untuk mengosongkan cache secara berkala untuk memastikan kesahihan data cache.

Atas ialah kandungan terperinci Pangkalan data MySQL dan bahasa Go: Bagaimana untuk melakukan caching data?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!