go gomemcache包源码分析

因为beego中的cache模块中的子模块memcached引用了这个包，所以也对这包的源码进行分析了下。花了一定的时间编写整理这篇博客，这个包一共两个文件，源码文件。
关于memcache学习，可以到http://www.runoob.com/memcached/memcached-tutorial.html这边教程学习

1）func New(server ...string) *Client
用法：
mc := memcache.New("127.0.0.1:11211")

主要可以分为以下步骤：
1、传入一个合法的memcached服务器地址信息
2、定义变量和赋值

New方法流程图如下，点击下载

image.png

2）func (c *Client) Add(item *Item) error
作用：
mc := memcache.New("127.0.0.1:11211")
mc.Add(&memcache.Item{Key:"data",Value:[]byte("你好！")})

主要可以分为以下步骤：
1、选择一个memcache服务器并获取连接
2、发送数据到memcached服务器
3、接收memcached信息和处理连接
Add方法流程图如下，点击下载

image.png

3）func (c *Client) Set(item *Item) error
用法：
mc := memcache.New("127.0.0.1:11211")
mc.Set(&memcache.Item{Key:"data",Value:[]byte("你好！")})

主要分为以下步骤：
1、选择一个memcached服务器并进行连接
2、向连接的那个memcached服务器发送数据并处理相关内容
3、连接处理（回收或释放）
Set方法流程图如下，点击下载

image.png

4）func (c *Client) Get(key string) (item *Item, err error)
用法：
mc := memcache.New("127.0.0.1:11211")
i, err := mc.Get("data")
fmt.Println(i, err)

主要可分为三个步骤
1：获取tcp连接
2：发送数据到memcached
3：处理memcached返回消息和tcp连接处理（放入回收池或释放）
Get方法流程图如下，点击下载

image.png

5）func (c Client) GetMulti(keys []string) (map[string]Item, error)
用法：
mc := memcache.New("127.0.0.1:11211")
items, err := mc.GetMulti([]string{"data1","data2","data3"})

主要可分为三个步骤
1：获取tcp连接
2：发送数据到memcached
3：处理memcached返回消息和tcp连接处理（放入回收池或释放）
GetMulti方法流程图如下，点击下载

image.png

6）func (c *Client) Increment(key string, delta uint64) (newValue uint64, err error)
用法：
mc := memcache.New("127.0.0.1:11211")
newVal, err := mc.Increment("test", 2)
fmt.Println(newVal, err)

作用：将原来键的值加上指定数，可分为以下两种情况：
1、如果原来的是一个数字，则加上指定数，返回修改后的值和nil
2、如果原来的不是一个数，则返回0和报错信息

内部执行步骤：
1、连接memcached服务器
2、发送数据到memcached服务器
3、断开连接，对连接进行回收或释放
Delete方法流程图如下，点击下载

image.png

7）func (c *Client) Decrement(key string, delta uint64) (newValue uint64, err error)
用法：
mc := memcache.New("127.0.0.1:11211")
newVal, err := mc.Decrement("test", 2)
fmt.Println(newVal, err)

作用：将原来键的值减去指定数，可分为以下两种情况：
1、如果原来的是一个数字，则减去指定数，返回修改后的值和nil
2、如果原来的不是一个数，则返回0和报错信息
Decrement方法流程图如下，点击下载

image.png

8）func (c *Client) CompareAndSwap(item *Item) error
用法：
mc := memcache.New("127.0.0.1:11211")
mc.CompareAndSwap(&memcache.Item{Key:"data",
Value:[]byte("你好！")})

封装发给memcached服务器的命令是：cas data 0 0 9 0
主要分为以下步骤：
1、选择一个memcached服务器地址并进行连接
2、向memcached服务器发送数据和处理服务器返回的信息
3、连接结束处理（回收或释放）
CompareAndSwap方法流程图如下，[点击下载]
(https://github.com/laijinhang/go-gomemcache-study/blob/master/CompareAndSwap方法.odg)

image.png

9）func (c *Client) FlushAll() error
用法：
mc := memcache.New("127.0.0.1:11211")
err := mc.FlushAll()

用于清理缓存中的所有 key=>value(键=>值) 对

主要可以分为以下步骤：
1、往每个memcached服务器发送数据和接收处理memcached信息
2、和处理连接
FlushAll方法流程图如下，点击下载

image.png

10）func (c *Client) Replace() error
用法：
mc := memcache.New("127.0.0.1:11211")
err := mc.Replace()
发送replace命令到mecmached服务器，该命令用于替换已存在的
key(键)的value(数据值)。
如果 key 不存在，则替换失败，并且您将获得响应 NOT_STORED。

主要可以分为以下步骤：
1、往每个memcached服务器发送数据和接收处理memcached信息
2、和处理连接
Replace方法流程图如下，点击下载

image.png

11）func (c *Client) Touch(key string, seconds int32) (err error)
用法：
mc := memcache.New("127.0.0.1:11211")
err := mc.Touch("data", 120)
发送touch命令到mecmached服务器，如果key不存在，则会返回错误，
如果key存在，则会在设置的时间后自动删除。

主要可以分为以下步骤：
1、获取服务器地址操作
2、往每个memcached服务器发送数据和接收处理memcached信息
3、连接处理（回收或释放）
Touch方法流程图如下，点击下载

image.png

12）func (c *Client) Delete(key string) error
用法：
mc := memcache.New("127.0.0.1:11211")
err := mc.Delete("test")

将原有key对应的内容删除

主要可以分为以下步骤：
1、获取连接
2、发送数据到memcached服务器
3、接收memcached信息和处理连接
Delete方法流程图如下，点击下载

image.png

13）func (c *Client) DeleteAll() error

用法：
mc := memcache.New("127.0.0.1:11211")
err := mc.DeleteAll()
将内容删除
（和Delete共用一套实现代码）

主要可以分为以下步骤：
1、获取连接
2、发送数据到memcached服务器
3、接收memcached信息和处理连接
DeleteAll方法流程图如下，点击下载

image.png

相关链接：
源码链接：https://github.com/laijinhang/gomemcache
笔记链接：https://github.com/laijinhang/go-gomemcache-study