Go HashMap緩存與數據庫熱點數據同步

在Go語言中，使用sync.Map可以實現一個簡單的HashMap緩存。然而，sync.Map并不支持過期數據的處理。為了實現緩存與數據庫熱點數據的同步，我們可以使用第三方庫，如groupcache或bigcache。這些庫提供了過期數據處理和分布式緩存的功能。

下面是一個使用groupcache庫實現緩存與數據庫熱點數據同步的示例：

1. 首先，安裝groupcache庫：

go get github.com/golang/groupcache/v2

2. 創建一個簡單的Go程序，實現緩存與數據庫熱點數據同步：

package main

import (
	"fmt"
	"github.com/golang/groupcache/v2"
	"github.com/golang/groupcache/v2/singleflight"
	"sync"
	"time"
)

// 模擬數據庫熱點數據
var hotData = map[string]string{
	"key1": "value1",
	"key2": "value2",
	"key3": "value3",
}

// 緩存獲取函數
func getFromCacheOrDB(key string, dbFunc func() (string, error)) (string, error) {
	// 使用singleflight確保并發安全
	sg := singleflight.NewGroup()
	value, err, _ := sg.Do(key, func() (interface{}, error) {
		// 嘗試從緩存中獲取數據
		if val, ok := hotData[key]; ok {
			return val, nil
		}

		// 如果緩存中沒有數據，從數據庫中獲取
		val, err := dbFunc()
		if err != nil {
			return "", err
		}

		// 將數據存入緩存，設置過期時間為10秒
		go func() {
			time.Sleep(10 * time.Second)
			delete(hotData, key)
		}()

		return val, nil
	})

	return value.(string), err
}

func main() {
	// 模擬數據庫查詢函數
	dbFunc := func() (string, error) {
		fmt.Println("Querying database...")
		return "valueFromDB", nil
	}

	// 從緩存或數據庫中獲取數據
	value, err := getFromCacheOrDB("key1", dbFunc)
	if err != nil {
		fmt.Println("Error:", err)
	} else {
		fmt.Println("Value:", value)
	}

	// 再次從緩存或數據庫中獲取數據，應該從緩存中獲取
	value, err = getFromCacheOrDB("key1", dbFunc)
	if err != nil {
		fmt.Println("Error:", err)
	} else {
		fmt.Println("Value:", value)
	}
}

在這個示例中，我們使用groupcache庫實現了一個簡單的緩存系統。getFromCacheOrDB函數首先嘗試從hotData緩存中獲取數據，如果緩存中沒有數據，則從數據庫中獲取。獲取到的數據會被存入緩存，并設置一個過期時間（例如10秒）。在過期時間到達后，緩存中的數據將被自動刪除。

注意：這個示例僅用于演示目的，實際應用中可能需要根據具體需求進行調整。例如，可以使用更復雜的緩存策略，如LRU（最近最少使用）或LFU（最不經常使用），以及使用分布式緩存系統，如Redis。