代码拉取完成,页面将自动刷新
同步操作将从 letsfire/redigo 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
基于 gomodule/redigo 的二次封装,提供 stand-alone
sentinel
cluster
3种部署模式下的统一接口,使得更换 redis
部署模式对业务透明
Mode部署模式 | 代码完成度 | 测试完成度 | 依赖包 |
---|---|---|---|
alone 单例,Twemproxy,Codis | 100% | 100% | |
sentinel 哨兵模式 | 100% | 100% | FZambia/sentinel |
cluster 集群模式 | 100% | 100% | mna/redisc |
订阅连接 type SubFunc func(c redis.PubSubConn) (err error)
普通连接 type ExecFunc func(c redis.Conn) (res interface{}, err error)
var echoStr = "hello world"
var aloneMode = alone.New(
alone.Addr("192.168.0.110:6379"),
alone.PoolOpts(
mode.MaxActive(0), // 最大连接数,默认0无限制
mode.MaxIdle(0), // 最多保持空闲连接数,默认2*runtime.GOMAXPROCS(0)
mode.Wait(false), // 连接耗尽时是否等待,默认false
mode.IdleTimeout(0), // 空闲连接超时时间,默认0不超时
mode.MaxConnLifetime(0), // 连接的生命周期,默认0不失效
mode.TestOnBorrow(nil), // 空间连接取出后检测是否健康,默认nil
),
alone.DialOpts(
redis.DialReadTimeout(time.Second), // 读取超时,默认time.Second
redis.DialWriteTimeout(time.Second), // 写入超时,默认time.Second
redis.DialConnectTimeout(time.Second), // 连接超时,默认500*time.Millisecond
redis.DialPassword(""), // 鉴权密码,默认空
redis.DialDatabase(0), // 数据库号,默认0
redis.DialKeepAlive(time.Minute*5), // 默认5*time.Minute
redis.DialNetDial(nil), // 自定义dial,默认nil
redis.DialUseTLS(false), // 是否用TLS,默认false
redis.DialTLSSkipVerify(false), // 服务器证书校验,默认false
redis.DialTLSConfig(nil), // 默认nil,详见tls.Config
),
)
var instance = redigo.New(aloneMode)
res, err := instance.String(func(c redis.Conn) (res interface{}, err error) {
return c.Do("ECHO", echoStr)
})
if err != nil {
log.Fatal(err)
} else if res != echoStr {
log.Fatalf("unexpected result, expect = %s, but = %s", echoStr, res)
}
var echoStr = "hello world"
var sentinelMode = sentinel.New(
sentinel.Addrs([]string{"192.168.0.110:26379"}),
sentinel.PoolOpts(
mode.MaxActive(0), // 最大连接数,默认0无限制
mode.MaxIdle(0), // 最多保持空闲连接数,默认2*runtime.GOMAXPROCS(0)
mode.Wait(false), // 连接耗尽时是否等待,默认false
mode.IdleTimeout(0), // 空闲连接超时时间,默认0不超时
mode.MaxConnLifetime(0), // 连接的生命周期,默认0不失效
mode.TestOnBorrow(nil), // 空间连接取出后检测是否健康,默认nil
),
sentinel.DialOpts(
redis.DialReadTimeout(time.Second), // 读取超时,默认time.Second
redis.DialWriteTimeout(time.Second), // 写入超时,默认time.Second
redis.DialConnectTimeout(time.Second), // 连接超时,默认500*time.Millisecond
redis.DialPassword(""), // 鉴权密码,默认空
redis.DialDatabase(0), // 数据库号,默认0
redis.DialKeepAlive(time.Minute*5), // 默认5*time.Minute
redis.DialNetDial(nil), // 自定义dial,默认nil
redis.DialUseTLS(false), // 是否用TLS,默认false
redis.DialTLSSkipVerify(false), // 服务器证书校验,默认false
redis.DialTLSConfig(nil), // 默认nil,详见tls.Config
),
// 连接哨兵配置,用法于sentinel.DialOpts()一致
// 默认未配置的情况则直接使用sentinel.DialOpts()的配置
// sentinel.SentinelDialOpts()
)
var instance = redigo.New(sentinelMode)
res, err := instance.String(func(c redis.Conn) (res interface{}, err error) {
return c.Do("ECHO", echoStr)
})
if err != nil {
log.Fatal(err)
} else if res != echoStr {
log.Fatalf("unexpected result, expect = %s, but = %s", echoStr, res)
}
var echoStr = "hello world"
var clusterMode = cluster.New(
cluster.Nodes([]string{
"192.168.0.110:30001", "192.168.0.110:30002", "192.168.0.110:30003",
"192.168.0.110:30004", "192.168.0.110:30005", "192.168.0.110:30006",
}),
cluster.PoolOpts(
mode.MaxActive(0), // 最大连接数,默认0无限制
mode.MaxIdle(0), // 最多保持空闲连接数,默认2*runtime.GOMAXPROCS(0)
mode.Wait(false), // 连接耗尽时是否等待,默认false
mode.IdleTimeout(0), // 空闲连接超时时间,默认0不超时
mode.MaxConnLifetime(0), // 连接的生命周期,默认0不失效
mode.TestOnBorrow(nil), // 空间连接取出后检测是否健康,默认nil
),
cluster.DialOpts(
redis.DialReadTimeout(time.Second), // 读取超时,默认time.Second
redis.DialWriteTimeout(time.Second), // 写入超时,默认time.Second
redis.DialConnectTimeout(time.Second), // 连接超时,默认500*time.Millisecond
redis.DialPassword(""), // 鉴权密码,默认空
redis.DialDatabase(0), // 数据库号,默认0
redis.DialKeepAlive(time.Minute*5), // 默认5*time.Minute
redis.DialNetDial(nil), // 自定义dial,默认nil
redis.DialUseTLS(false), // 是否用TLS,默认false
redis.DialTLSSkipVerify(false), // 服务器证书校验,默认false
redis.DialTLSConfig(nil), // 默认nil,详见tls.Config
),
)
var instance = redigo.New(clusterMode)
res, err := instance.String(func(c redis.Conn) (res interface{}, err error) {
return c.Do("ECHO", echoStr)
})
if err != nil {
log.Fatal(err)
} else if res != echoStr {
log.Fatalf("unexpected result, expect = %s, but = %s", echoStr, res)
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。