golang版本的memcached客户端，使用二进制协议，支持分布式，支持连接池，支持多种数据格式
- 支持多server集群
- 与memcached使用二进制协议通信
- 支持连接池
- 存储value支持golang基本数据类型：string、[]byte、int、int8、int16、int32、int64、bool、uint8、uint16、uint32、uint64、float32、float64、map、结构体，不需要单独转为string存储
- Replace、Increment/Decrement、Delete、Append/Prepend命令支持cas原子操作
默认开启分布式集群，key按照一致性哈希算法分配到各server，当server无法连接时如果设置了SetRemoveBadServer(true)则自动被剔除server列表，等到恢复正常时再重新加入server列表
与github.com/bradfitz/gomemcache项目(beego cache用的这个)比较，测试方式：启动一个http服务，每次请求调用一次memcached的Get操作。测试脚本example/pangudashu-Vs-bradfitz.go
用ab分别测试请求:
ab -c 200 -n 10000 http://127.0.0.1:9955/bradfitz_foo
ab -c 200 -n 10000 http://127.0.0.1:9955/pangudashu_foo
github.com/bradfitz/gomemcache结果：
Document Path: /bradfitz_foo
Document Length: 295 bytes
Concurrency Level: 200
Time taken for tests: 1.982 seconds
Complete requests: 10000
Failed requests: 0
Write errors: 0
Total transferred: 4135782 bytes
HTML transferred: 2954130 bytes
Requests per second: 5046.27 [#/sec] (mean)
Time per request: 39.633 [ms] (mean)
Time per request: 0.198 [ms] (mean, across all concurrent requests)
Transfer rate: 2038.11 [Kbytes/sec] received
Connection Times (ms)
min mean[+/-sd] median max
Connect: 0 4 40.2 1 1006
Processing: 0 33 16.6 31 251
Waiting: 0 31 16.2 29 251
Total: 0 36 43.4 33 1039
Percentage of the requests served within a certain time (ms)
50% 33
66% 40
75% 45
80% 48
90% 56
95% 64
98% 73
99% 79
100% 1039 (longest request)
github.com/pangudashu/memcache结果：
Document Path: /pangudashu_foo
Document Length: 295 bytes
Concurrency Level: 200
Time taken for tests: 1.140 seconds
Complete requests: 10000
Failed requests: 0
Write errors: 0
Total transferred: 4144455 bytes
HTML transferred: 2960325 bytes
Requests per second: 8771.33 [#/sec] (mean)
Time per request: 22.802 [ms] (mean)
Time per request: 0.114 [ms] (mean, across all concurrent requests)
Transfer rate: 3550.04 [Kbytes/sec] received
Connection Times (ms)
min mean[+/-sd] median max
Connect: 0 4 41.3 2 1003
Processing: 0 15 9.9 13 218
Waiting: 0 13 9.5 11 211
Total: 0 19 42.5 16 1024
Percentage of the requests served within a certain time (ms)
50% 16
66% 19
75% 22
80% 24
90% 29
95% 34
98% 40
99% 46
100% 1024 (longest request)
go get github.com/pangudashu/memcache
package main
import(
"fmt"
"github.com/pangudashu/memcache"
)
func main(){
/**
* server配置
* Address string //host:port
* Weight int //权重
* InitConn int: //初始化连接数 < MaxCnt
* MaxConn int: //最大连接数
* IdleTime time.Duration: //空闲连接有效期
*/
s1 := &memcache.Server{Address: "127.0.0.1:12000", Weight: 50}
s2 := &memcache.Server{Address: "127.0.0.1:12001", Weight: 20}
s3 := &memcache.Server{Address: "127.0.0.1:12002", Weight: 20}
s4 := &memcache.Server{Address: "127.0.0.1:12003", Weight: 10}
//初始化连接池
mc, err := memcache.NewMemcache([]*memcache.Server{s1, s2, s3, s4})
if err != nil {
fmt.Println(err)
return
}
//设置是否自动剔除无法连接的server，默认不开启(建议开启)
//如果开启此选项被踢除的server如果恢复正常将会再次被加入server列表
mc.SetRemoveBadServer(true)
//设置连接、读写超时
mc.SetTimeout(time.Second*2, time.Second, time.Second)
mc.Set("test_key",true)
fmt.Println(mc.Get("test_key"))
//...
mc.Close()
}
根据key检索一个元素
【说明】
Get(key string [, format_struct interface{} ])(value interface{}, cas uint64, err error)
【参数】
key 要检索的元素的key
format 用于存储的value为map、结构体时，返回值将直接反序列化到format
【返回值】
value为interface，取具体存储的值需要断言
存储的value为map、结构体时,value将返回nil
type User struct {
//...
}
var user User
if _, _, e := mc.Get("pangudashu_struct", &user); e != nil {
fmt.Println(e)
} else {
fmt.Println(user)
}
向一个新的key下面增加一个元素
【说明】
Set(key string, value interface{} [, expire ...uint32 ]) (res bool, err error)
【参数】
key 用于存储值的键名
value 存储的值，可以为string、[]byte、int、int8、int16、int32、int64、bool、uint8、uint16、uint32、uint64、float32、float64、map、struct等类型
expire 过期时间，默认0
【返回值】
设置成功res返回true，err返回nil，否则res返回false，err返回memcache.ErrNotStord
【注意】
int类型长度与系统位数相关，所以实际存储转为string，建议尽量使用具体长度的类型：int8、int16、int32、int64替换
//demo
var value uint32 = 360000000000
mc.Set("test_value", value, 1800)
向一个新的key下面增加一个元素,与Set类似，但是如果 key已经在服务端存在，此操作会失败
【说明】
Add(key string, value interface{} [, expire uint32 ]) (res bool, err error)
【参数】
同Set
【返回值】
同Set。
如果key已经存在，res返回false，err返回memcache.ErrKeyExists
替换已存在key下的元素,类似Set，但是如果服务端不存在key，操作将失败
【说明】
Replace(key string, value interface{} [, expire uint64 [, cas uint64 ]]) (res bool, err error)
【参数】
key 用于存储值的键名
value 存储的值
expire 过期时间
cas 数据版本号，原子替换，如果数据在此操作前已被其它客户端更新，则替换失败
_,cas,_ := mc.Get("test_key")
res, er := mc.Replace("test_key", "new value~", 0, cas) //每次更新操作数据的cas都会变，所以如果这个值在Get后被其它client更新了则返回false，err返回memcache.ErrKeyExists
删除一个元素
【说明】
Delete(key string [, cas uint64 ]) (res bool, err error)
【参数】
key 要删除的key
cas 数据版本号，如果数据在此操作前已被其它客户端更新，则删除失败
【返回值】
成功时返回 true，或者在失败时返回 false，如果key不存在err返回 memcache.ErrNotFound
增加数值元素的值,如果key不存在则操作失败
【说明】
Increment(key string [, delta int [, cas int ]]) (res bool, err error)
【参数】
key 要增加值的元素的key
delta 要将元素的值增加的大小,默认1
cas 数据版本号，只有当服务端cas没有变化时此操作才成功
【返回值】
成功时返回 true，或者在失败时返回 false，如果key不存在则初始化为0，如果cas版本号已变err返回memcache.ErrKeyExists
【注意】
Increment/Decrement只能操作value类型为int的值，其它任何类型均无法操作。(原因是memcached中在Incr/Decr处理时首先使用strtoull将value转为unsigned long long再进行加减操作，所以只有将数值存为字符串strtoull才能将其转为合法的数值)
减小数值元素的值
【说明】
Decrement(key string [, delta int [, cas int ]]) (res bool, err error)
【参数】
同Increment
删除缓存中的所有元素
【说明】
Flush([ delay uint32 ]) (res bool, err error)
【参数】
delay 在flush所有元素之前等待的时间（单位秒）
【返回值】
成功时返回 true， 或者在失败时返回 false
向已存在string元素后追加数据
【说明】
Append(key string, value string [, cas uint64 ]) (res bool, err error)
【参数】
key 用于存储值的键名
value 将要追加的值
【返回值】
成功时返回 false， 或者在失败时返回 false。 如果key不存在err返回memcache.ErrNotFound
【注意】
Append/Prepend只能操作string类型，尽管操作其它类型时也能转化为string，但是将导致数据原来的类型失效，也就是说Append/Prement能够成功，但是Get时将出错
向已存在string元素前追加数据
【说明】
Prepend(key string, value string [, cas uint64 ]) (res bool, err error)
同Append
获取memcached服务端版本
【说明】
Version(server *memcache.Server) (v string, err error)
【参数】
server server配置结构
【返回值】
memcached version
- ErrNotConn : Can't connect to server
- ErrNotFound : Key not found
- ErrKeyExists : Key exists
- ErrInval : Invalid arguments
- ErrNotStord : Item not stored
- ErrDeltaBadVal : Increment/Decrement on non-numberic value
- ErrMem : Out of memery
- ErrInvalValue : Unkown value type
- ErrInvalFormat : Invalid format struct
- ErrNoFormat : Format struct empty
- ErrUnkown : Unkown error