在网上查了挺多groupcache的相关信息,但是搜出来大部分都是copy,实际的例子也没有,所以就看了下源码,也在golang-nuts上问了,github上搜索了一些groupcache的使用例子,在此作个总结,目前对这个缓存库还仅处于了解状态

大概介绍

    其实关于groupcache的介绍网上非常的多,搜索出来清一色都是说的介绍,当然也有配图如何部署,但是文字与配图完全不在一个时空,图也是copy国外的一篇博客,

。它不像其它的一些缓存数据库有个服务端,需要客户端去连接,文档中明确说明了它就是一个程序库,所以没有服务端与客户端这么一说,换句话说,它本没有服务端,又或者是人人都是服务端,食神的感觉油然而生。

主要代码结构

consistenthashlrusingleflightbyteview.gohttp.gopeers.gosinks.gogroupcache.go

一个测试例子

    在使用这个缓存的时候比较重要的几方面也是我之前犯错的几个地方

需要监听两个地方,一个是监听节点,一个是监听请求

http://

启动的节点地址要与设置的节点地址一致:数量和地址值。因为我每次少一个就无法在节点间交互。

    以上的一些信息可能也有不对的地方,只是我个人的一个测试后的结果。

代码部分

<code class="language-go" data-lang="go">package main        import (            "flag"            "fmt"            "github.com/golang/groupcache"            "io/ioutil"            "log"            "net/http"            "os"            "strconv"            "strings"        )                var (            // peers_addrs = []string{"127.0.0.1:8001", "127.0.0.1:8002", "127.0.0.1:8003"}            //rpc_addrs = []string{"127.0.0.1:9001", "127.0.0.1:9002", "127.0.0.1:9003"}            index = flag.Int("index", 0, "peer index")        )                func main() {            flag.Parse()            peers_addrs := make([]string, 3)            rpc_addrs := make([]string, 3)            if len(os.Args) > 0 {                for i := 1; i < 4; i++ {                    peers_addrs[i-1] = os.Args[i]                    rpcaddr := strings.Split(os.Args[i], ":")[1]                    port, _ := strconv.Atoi(rpcaddr)                    rpc_addrs[i-1] = ":" + strconv.Itoa(port+1000)                }            }            if *index < 0 || *index >= len(peers_addrs) {                fmt.Printf("peer_index %d not invalid\n", *index)                os.Exit(1)            }            peers := groupcache.NewHTTPPool(addrToURL(peers_addrs[*index]))            var stringcache = groupcache.NewGroup("SlowDBCache", 64<<20, groupcache.GetterFunc(                func(ctx groupcache.Context, key string, dest groupcache.Sink) error {                    result, err := ioutil.ReadFile(key)                    if err != nil {                        log.Fatal(err)                        return err                    }                    fmt.Printf("asking for %s from dbserver\n", key)                    dest.SetBytes([]byte(result))                    return nil                }))                    peers.Set(addrsToURLs(peers_addrs)...)                    http.HandleFunc("/zk", func(rw http.ResponseWriter, r *http.Request) {                log.Println(r.URL.Query().Get("key"))                var data []byte                k := r.URL.Query().Get("key")                fmt.Printf("cli asked for %s from groupcache\n", k)                stringcache.Get(nil, k, groupcache.AllocatingByteSliceSink(&data))                rw.Write([]byte(data))            })            go http.ListenAndServe(rpc_addrs[*index], nil)            rpcaddr := strings.Split(os.Args[1], ":")[1]            log.Fatal(http.ListenAndServe(":"+rpcaddr, peers))        }                func addrToURL(addr string) string {            return "http://" + addr        }                func addrsToURLs(addrs []string) []string {            result := make([]string, 0)            for _, addr := range addrs {                result = append(result, addrToURL(addr))            }            return result        }</code>
./demo 127.0.0.1:8001 127.0.0.1:8002 127.0.0.1:8003

    在上面的命令中我们就启动了一个节点,并且设置节点地址个数为3个,这里由于我是默认的index为0,所以在启动其它节点的时候变换下地址的顺序,使第一个地址三次都不一样就好了,

《[Golang] groupcache的简单例子》(https://www.unjs.com)。(抱歉,这里实现的不是很好),这样同样方法启动三个节点。
127.0.0.1:9001?key=1.txt

    运行结果:

:9001

   

   

   

:8001key:8003
:9002

   

   

   

:8002

    我在本地开启了两个虚拟机,在同一个局域网中,测试也能得出相同的结果。这里结果就不再贴上了,当然运行的时候节点地址要做相应的变动,根据每个机子的局域网中的地址。

    这篇博客关于groupcache的介绍和源代码的说明部分比较少,主要就是贴出了一个测试的例子,因为我看到网上很少,并且压根就没有给出如何运行或者运行结果(不包括刚才提到的老外的一个博客,他写的还是很好的,我就是看了他的博客才着手自己编写的)。