groupcache分布式缓存的Peer通信与HTTPPool使用指南

package main

import (
    "fmt"
    "log"
    "net/http"
    "time"

    "github.com/golang/groupcache"
)

func main() {
    // 1. 初始化当前Peer的HTTPPool
    // 参数 "http://localhost:8080" 是当前Peer对外提供服务的HTTP地址。
    // 其他Peer将通过此地址访问本Peer以获取数据。
    // 注意：在生产环境中，这应该是可被其他Peer访问的实际IP或域名。
    selfURL := "http://localhost:8080"
    pool := groupcache.NewHTTPPool(selfURL)
    log.Printf("Current groupcache peer listening on: %s", selfURL)

    // 2. 启动HTTP服务器来处理来自其他Peer的请求
    // HTTPPool本身实现了http.Handler接口，可以作为HTTP服务器的处理器。
    // 通常，我们会将HTTPPool挂载到一个特定的路径下，例如 "/_groupcache/"。
    http.Handle("/_groupcache/", pool)

    // 模拟启动一个HTTP服务器
    go func() {
        log.Fatal(http.ListenAndServe(":8080", nil))
    }()

    // 3. 定义一个groupcache Group
    // 这是一个简单的示例GetterFunc，模拟从数据源获取数据
    var myGroup *groupcache.Group
    myGroup = groupcache.NewGroup("my-cache", 64<<20, groupcache.GetterFunc(
        func(ctx groupcache.Context, key string, dest groupcache.Sink) error {
            log.Printf("Fetching data for key: %s from origin (local source)", key)
            // 模拟从数据库或其他服务获取数据
            data := fmt.Sprintf("value_for_%s_from_origin", key)
            return dest.SetString(data)
        }))

    // 稍作等待，确保HTTP服务器启动
    time.Sleep(100 * time.Millisecond)

    // 示例：从本地groupcache获取数据
    var value string
    err := myGroup.Get(nil, "key1", groupcache.StringSink(&value))
    if err != nil {
        log.Fatalf("Error getting key1: %v", err)
    }
    log.Printf("Retrieved key1: %s", value)

    // 为了演示目的，程序不会退出
    select {}
}

package main

import (
    "fmt"
    "log"
    "net/http"
    "time"

    "github.com/golang/groupcache"
)

func main() {
    // ... (同上，初始化当前Peer的HTTPPool和启动HTTP服务器) ...
    selfURL := "http://localhost:8080"
    pool := groupcache.NewHTTPPool(selfURL)
    http.Handle("/_groupcache/", pool)
    go func() {
        log.Fatal(http.ListenAndServe(":8080", nil))
    }()
    time.Sleep(100 * time.Millisecond) // 等待服务器启动

    // 4. 注册集群中其他Peer的地址
    // 这些地址是其他Peer对外提供服务的HTTP地址。
    // groupcache会根据这些地址向其他Peer请求数据。
    // 在实际应用中，这些地址通常从配置服务（如etcd, Consul）或配置文件中获取。
    peerAddresses := []string{
        "http://localhost:8001", // 假设有另一个Peer在8001端口
        "http://localhost:8002", // 假设有第三个Peer在8002端口
    }
    pool.Set(peerAddresses...)
    log.Printf("Registered peers: %v", peerAddresses)

    // ... (同上，定义groupcache Group) ...
    var myGroup *groupcache.Group
    myGroup = groupcache.NewGroup("my-cache", 64<<20, groupcache.GetterFunc(
        func(ctx groupcache.Context, key string, dest groupcache.Sink) error {
            log.Printf("Fetching data for key: %s from origin (local source)", key)
            data := fmt.Sprintf("value_for_%s_from_origin", key)
            return dest.SetString(data)
        }))

    // 示例：获取数据。如果key不在本地，groupcache会尝试从注册的Peer获取。
    var value string
    err := myGroup.Get(nil, "key_distributed", groupcache.StringSink(&value))
    if err != nil {
        log.Fatalf("Error getting key_distributed: %v", err)
    }
    log.Printf("Retrieved key_distributed: %s", value)

    select {}
}