Skip to content

R
redis-client-sdk
Commit fdb5b467 by yemin
Options

no message

parents
Showing with 265 additions and 0 deletions
build.bat 0 → 100644
go get -u git.168cad.top/go/logger/log
go get -u github.com/go-redis/redis
\ No newline at end of file
go.mod 0 → 100644
module git.168cad.top/go/redisSDK
go 1.17
require (
git.168cad.top/go/logger v1.0.3 // indirect
github.com/go-redis/redis v6.15.9+incompatible // indirect
)
go.sum 0 → 100644
git.168cad.top/go/logger v1.0.3 h1:r0w3p+4h7fHZ3xxEZcWHePP7zv9OwKJgOGN5hZ/2f6U=
git.168cad.top/go/logger v1.0.3/go.mod h1:HlxzmTuqONGC5xGiuBVQ1qAEoby29AaWYMDhBBSi8c4=
github.com/go-redis/redis v6.15.9+incompatible h1:K0pv1D7EQUjfyoMql+r/jZqCLizCGKFlFgcHWWmHQjg=
github.com/go-redis/redis v6.15.9+incompatible/go.mod h1:NAIEuMOZ/fxfXJIrKDQDz8wamY7mA7PouImQ2Jvg6kA=
main.go 0 → 100644
package main
func main() {
}
redis/RedisClient.go 0 → 100644
package redis
import (
"fmt"
"git.168cad.top/go/logger/log"
"github.com/go-redis/redis"
"time"
)
const (
Y string = "1"
N string = "0"
)
func TestLog() {
log.Info("Redis 测试")
}
var redisClient *redis.Client
func Init() {
redisClient = redis.NewClient(&redis.Options{
Addr: fmt.Sprintf("%s:%d", Conf.RedisHost, Conf.RedisPort),
Password: Conf.RedisPwd,
DB: Conf.RedisDb, // redis一共16个库，指定其中一个库即可
PoolSize: Conf.PoolSize, //最大连接数 默认cpu数*10
MinIdleConns: Conf.MinIdleConns, //最小空闲连接数
ReadTimeout: time.Duration(Conf.ReadTimeout) * time.Second, //取超时间 单位秒 默认值为3秒
WriteTimeout: time.Duration(Conf.WriteTimeout) * time.Second, // 写入超时时间 单位秒 默认与读超时时间一致
})
_, err := redisClient.Ping().Result()
if err != nil {
log.Error(fmt.Sprintf("Redis connect error ：%s", err.Error()))
} else {
log.Info("Redis connect success")
}
return
}
func getDb() *redis.Client {
return redisClient
}
func Incr(key string) int64 {
r := getDb().Incr(key)
return r.Val()
}
func IncrBy(key string, n int64) int64 {
r := getDb().IncrBy(key, n)
return r.Val()
}
func DecrBy(key string, n int64) int64 {
r := getDb().DecrBy(key, n)
return r.Val()
}
func Exists(key string) bool {
r := getDb().Exists(key)
return r.Val() > 0
}
//SwitchOpen 在redis中存0或1,1代表OK
func SwitchOpen(key string) bool {
r := GetString(key)
log.Debug(fmt.Sprintf("缓存[%s]数据为：%s", key, r))
return r == Y
}
func GetString(key string) string {
r := getDb().Get(key)
return r.Val()
}
func Get(key string) []byte {
r := getDb().Get(key)
rByte, err := r.Bytes()
if err != nil {
log.Warn(fmt.Sprintf("获取缓存错误：%s", err.Error()))
}
return rByte
}
func Set(k, v string) error {
e := getDb().Set(k, v, 0).Err()
if e == nil {
log.Debug(fmt.Sprintf("设置缓存成功：%s %s", k, v))
} else {
log.Debug(fmt.Sprintf("设置缓存失败：%s %s %s", k, v, e))
}
return e
}
func SetNx(k, v string, timeoutSecond int) error {
e := getDb().Set(k, v, time.Duration(timeoutSecond)*time.Second).Err()
if e == nil {
log.Debug(fmt.Sprintf("设置缓存成功：%s %s", k, v))
} else {
log.Debug(fmt.Sprintf("设置缓存失败：%s %s %s", k, v, e))
}
return e
}
func Del(ks ...string) (int64, error) {
return getDb().Del(ks...).Result()
}
func Expire(k string, t int64) bool {
b := getDb().Expire(k, time.Duration(t*1000000000))
if b.Val() {
log.Debug(fmt.Sprintf("设置缓存过期成功：%s %d", k, t))
} else {
log.Warn(fmt.Sprintf("设置缓存过期失败：%s %d", k, t))
}
return b.Val()
}
var lockScript string = `if redis.call("exists",KEYS[1]) == 0 then
local lockSrc = redis.call("setex",KEYS[1],unpack(ARGV))
if lockSrc then
return "1"
end
return "0"
end`
var unlockScript string = `if redis.call('get', KEYS[1]) == ARGV[1] then
local lockSrc = redis.call('del', KEYS[1])
if lockSrc then
return "1"
end
return "0"
end`
// Lock 抢锁。抢到锁返回true，否则false。只抢一次
// 所有参数必传，超时时间单位秒
func Lock(k, uniqueValue string, timeoutSecond int) bool {
r, _ := getDb().Eval(lockScript, []string{k}, timeoutSecond, uniqueValue).String()
if r == "1" {
return true
}
return false
}
// Unlock 解锁
// 所有参数必传
func Unlock(k, uniqueValue string) bool {
r, _ := getDb().Eval(unlockScript, []string{k}, uniqueValue).String()
if r == "1" {
return true
}
return false
}
// Hset 向一张hash表中放入数据,如果不存在将创建
func Hset(k, i, v string, timeoutSecond int) error {
e := getDb().HSet(k, i, v).Err()
if e == nil {
log.Debug(fmt.Sprintf("设置缓存成功：%s %s %s", k, i, v))
if timeoutSecond > 0 {
Expire(k, int64(timeoutSecond))
}
} else {
log.Debug(fmt.Sprintf("设置缓存失败：%s %s %s %s", k, i, v, e))
}
return e
}
// HGet 从hash中获取值
func HGet(k, i string) (string, error) {
r, e := getDb().HGet(k, i).Result()
return r, e
}
// HGetAll 从hash中获key所有的取值
func HGetAll(k string) (map[string]string, error) {
return getDb().HGetAll(k).Result()
}
// Hdel 从hash中删除
func Hdel(k string, is ...string) (int64, error) {
r, e := getDb().HDel(k, is...).Result()
return r, e
}
// HMSet 向一张hash表中放入数据,如果不存在将创建
func HMSet(k string, fields map[string]interface{}, timeoutSecond int) error {
e := getDb().HMSet(k, fields).Err()
if e == nil {
log.Debug(fmt.Sprintf("设置缓存成功：%s %s", k, fields))
if timeoutSecond > 0 {
Expire(k, int64(timeoutSecond))
}
} else {
log.Debug(fmt.Sprintf("设置缓存失败：%s %s %s", k, fields, e))
}
return e
}
func HMget(k string, is ...string) ([]interface{}, error) {
return getDb().HMGet(k, is...).Result()
}
redis/RedisClient_test.go 0 → 100644
package redis
import (
"git.168cad.top/go/logger/log"
"testing"
)
func init() {
Conf = RedisConf{
RedisHost: "to-chengdu-office.168cad.top",
RedisPort: 50001,
RedisPwd: "testPassevnsoo567",
RedisDb: 0,
}
}
func TestExpire(t *testing.T) {
Init()
//Expire("ZQY123", 1000)
for i := 0; i < 10; i++ {
log.Infof("%v", Lock("yemin", "yemin", 20))
}
log.Info("--------------------------------------------------------")
for i := 0; i < 10; i++ {
log.Debugf("%v", Unlock("yemin", "yemin"))
}
}
redis/RedisConf.go 0 → 100644
package redis
//Redis conf
type RedisConf struct {
RedisHost string
RedisPort int
RedisPwd string
RedisDb int
ReadTimeout int //取超时间 单位秒 默认值为3秒
WriteTimeout int // 写入超时时间 单位秒 默认与读超时时间一致
PoolSize int //最大连接数 默认cpu数*10
MinIdleConns int //最小空闲连接数
}
var Conf = RedisConf{}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment