Groupcache对等节点通信：HTTPPool详解与实践

package main

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

    "github.com/golang/groupcache"
)

func main() {
    // 定义当前节点对外服务的URL
    // 这是其他groupcache节点访问本节点的地址。例如，在容器化部署中，这通常是容器的内部IP和端口，或者外部可访问的域名。
    selfURL := "http://localhost:8080" // 假设当前节点在8080端口提供服务

    // 创建一个Groupcache HTTPPool实例
    // HTTPPool是groupcache对等节点之间进行数据通信的实现
    pool := groupcache.NewHTTPPool(selfURL)

    // ... 后续配置和启动代码
}

    // ... (接上面的代码)

    // 设置对等节点列表
    // 这些是对等集群中其他groupcache节点对外服务的URL。
    // 在生产环境中，应包含所有其他节点的地址。
    // 注意：selfURL 不应包含在 peerURLs 中，因为 groupcache 会自动处理本地请求。
    peerURLs := []string{
        "http://example.net:8000",   // 假设一个对等节点在example.net的8000端口
        "http://another.net:8000", // 假设另一个对等节点在another.net的8000端口
        // ... 更多对等节点
    }
    pool.Set(peerURLs...)

    // ... 后续配置和启动代码

    // ... (接上面的代码)

    // 创建一个Group
    // groupcache.GetterFunc 是当缓存中不存在数据时，用于从源头获取数据的回调函数
    // 64MB 是这个group在本地缓存中可以存储的最大字节数
    myGroup := groupcache.NewGroup("my-data-cache", 64<<20, groupcache.GetterFunc(
        func(ctx context.Context, key string, dest groupcache.Sink) error {
            log.Printf("DEBUG: 从源头加载数据 for key: %s", key)
            // 模拟从数据库、API或其他存储系统获取数据
            time.Sleep(50 * time.Millisecond) // 模拟网络延迟或计算开销
            data := fmt.Sprintf("Value for %s (fetched at %s)", key, time.Now().Format("15:04:05"))
            return dest.SetString(data)
        }))

    // 启动HTTP服务器
    // 此服务器将处理来自其他groupcache对等节点的请求，以及可能的客户端请求
    log.Printf("Groupcache HTTPPool 在 %s 上启动服务...", selfURL)
    go func() {
        // http.ListenAndServe 的第二个参数是实现了 http.Handler 接口的对象
        // groupcache.HTTPPool 也实现了这个接口，因此可以直接作为处理器
        log.Fatal(http.ListenAndServe(":8080", pool)) // 监听8080端口，并使用pool处理请求
    }()

    // 模拟从缓存中获取数据
    // 在分布式环境中，如果key不在本地，groupcache会自动通过HTTPPool向其他对等节点请求
    time.Sleep(1 * time.Second) // 确保HTTP服务器有时间启动

    var result string
    ctx := context.Background()

    fmt.Println("\n--- 第一次尝试获取 'item-1' ---")
    err := myGroup.Get(ctx, "item-1", groupcache.StringSink(&result))
    if err != nil {
        log.Fatalf("获取数据失败: %v", err)
    }
    fmt.Printf("获取到数据: %s\n", result) // 预期会从源头加载

    fmt.Println("\n--- 第二次尝试获取 'item-1' (应从本地缓存获取) ---")
    err = myGroup.Get(ctx, "item-1", groupcache.StringSink(&result))
    if err != nil {
        log.Fatalf("获取数据失败: %v", err)
    }
    fmt.Printf("获取到数据: %s\n", result) // 预期从本地缓存获取

    // 保持主goroutine运行，以便HTTP服务器持续服务
    select {}
}