redis

package
v1.3.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 19, 2024 License: MIT Imports: 4 Imported by: 0

README

redis 使用

此库已弃用，不再维护建议使用：

github.com/zituocn/gow/lib/goredis

初始化链接

比如放在 init()方法中，初始化一次

    
func init(){
	conf := RDSConfig{
		Host:      "192.168.0.197",
		Port:      6379,
		Password:  "123456",
		MaxIdle:   50,
		MaxActive: 10000,
		DB:        1,
	}

	err := InitRDSClient(&conf)
	if err != nil {
		fmt.Println("连接失败:", err)
	}
}

操作redis


	//get rds common
	redis := GetRDSCommon()
	key := "token:1"
        
    // SetString
	_, err = redis.SetString(key, "abcdef1xd0r1jdkf")
	if err != nil {
		t.Fatal(err)
	}

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitRDSClient 

func InitRDSClient(rdc *RDSConfig) (err error)

InitRDSClient use RDSConfig init redis pool

Types

type RDSCommon 

type RDSCommon struct {
	// contains filtered or unexported fields
}

RDSCommon redis 操作类

func GetRDSCommon 

func GetRDSCommon() *RDSCommon

GetRDSCommon return *RDSCommon

func (*RDSCommon) AddSet 

func (m *RDSCommon) AddSet(key string, values []string) error

AddSet COMMAND:"SADD"

func (*RDSCommon) AddZSet 

func (m *RDSCommon) AddZSet(key string, score float64, value []byte) (err error)

AddZSet 添加单个ZST

func (*RDSCommon) DEL 

func (m *RDSCommon) DEL(key string) (int64, error)

DEL 删除某个Key

func (*RDSCommon) DelZSetMember 

func (m *RDSCommon) DelZSetMember(key string, member interface{}) error

DelZSetMember 删除zset成员

func (*RDSCommon) Exists 

func (m *RDSCommon) Exists(key string) (bool, error)

Exists key 是否存在

func (*RDSCommon) GetBit 

func (m *RDSCommon) GetBit(key string, offset int64) (int, error)

GetBit COMMAND:"GETBIT"

func (*RDSCommon) GetConn added in v1.0.7 

func (m *RDSCommon) GetConn() redis.Conn

GetConn GetConn

func (*RDSCommon) GetHashAll 

func (m *RDSCommon) GetHashAll(key string, obj interface{}) (err error)

GetHashAll get hash all to obj

func (*RDSCommon) GetHashAll2Map 

func (m *RDSCommon) GetHashAll2Map(key string) (map[string]string, error)

GetHashAll2Map get hash all to map

func (*RDSCommon) GetHashFields 

func (m *RDSCommon) GetHashFields(key string, fields []string) ([]string, error)

GetHashFields HMGET key field [field ...] 返回哈希表 key 中，一个或多个给定域的值。 如果给定的域不存在于哈希表，那么返回一个 nil 值。

func (*RDSCommon) GetHashInt 

func (m *RDSCommon) GetHashInt(key string, v interface{}) (int64, error)

GetHashInt 获取hash里某个int值

func (*RDSCommon) GetHashString 

func (m *RDSCommon) GetHashString(key string, v interface{}) (string, error)

GetHashString 获取hash里某个int值

func (*RDSCommon) GetHashValue 

func (m *RDSCommon) GetHashValue(key string) (data []string, err error)

GetHashValue get hash all

func (*RDSCommon) GetInt64 

func (m *RDSCommon) GetInt64(key string) (v int64, err error)

GetInt64 取 int64

func (*RDSCommon) GetKeys added in v1.1.7 

func (m *RDSCommon) GetKeys(key string) (slice []string, err error)

获得所有的key

func (*RDSCommon) GetList 

func (m *RDSCommon) GetList(key string) (data []string, err error)

GetList cmd "LRANGE"

func (*RDSCommon) GetSet 

func (m *RDSCommon) GetSet(key string, v interface{}) (interface{}, error)

GetSet 设置指定 key 的值，并返回 key 的旧值。

func (*RDSCommon) GetSetData 

func (m *RDSCommon) GetSetData(key string) (data []string, err error)

GetSetData COMMAND:"SMEMBERS"

func (*RDSCommon) GetString 

func (m *RDSCommon) GetString(key string) (v string, err error)

GetString 取 string

func (*RDSCommon) GetTTL 

func (m *RDSCommon) GetTTL(key string) (ttl int64, err error)

GetTTL GetTTL

func (*RDSCommon) GetZSetCount 

func (m *RDSCommon) GetZSetCount(key string) (count int64, err error)

GetZSetCount 获取指定区间min-max之间成员的数量

func (*RDSCommon) GetZSetCountByArea 

func (m *RDSCommon) GetZSetCountByArea(key string, min, max int64) (count int64, err error)

GetZSetCountByArea 获取指定区间min-max 之间成员的数量

func (*RDSCommon) GetZSetWithScore 

func (m *RDSCommon) GetZSetWithScore(key string, offset, limit int) (values []interface{}, err error)

GetZSetWithScore

func (*RDSCommon) GetZSetWithScoreToInt64s 

func (m *RDSCommon) GetZSetWithScoreToInt64s(key string, offset, limit int) (ii []int64, err error)

GetZSetWithScoreToInt64s ZSET to []int64

func (*RDSCommon) GetZSetWithScoreToInts 

func (m *RDSCommon) GetZSetWithScoreToInts(key string, offset, limit int) (ii []int, err error)

GetZSetWithScoreToInts ZSET to []int

func (*RDSCommon) GetZSetWithScoreToStrings 

func (m *RDSCommon) GetZSetWithScoreToStrings(key string, offset, limit int) (ss []string, err error)

GetZSetWithScoreToStrings ZSET to []string

func (*RDSCommon) GetZSetWithZrevRange added in v1.0.7 

func (m *RDSCommon) GetZSetWithZrevRange(key string, offset, limit int) (values []interface{}, err error)

GetZSetWithZrevRange ZSET - ZREVRANGE

func (*RDSCommon) GetZSetWithZrevRangeToStrings added in v1.0.7 

func (m *RDSCommon) GetZSetWithZrevRangeToStrings(key string, offset, limit int) (ss []string, err error)

GetZSetWithZrevRangeToStrings ZSET to []string

func (*RDSCommon) HashFieldExists 

func (m *RDSCommon) HashFieldExists(key, field string) (bool, error)

HashFieldExists hash某个field是否存在

func (*RDSCommon) Hdel added in v1.1.6 

func (m *RDSCommon) Hdel(key, field string) (bool, error)

Hdel 用于删除哈希表 key 中的一个或多个指定字段，不存在的字段将被忽略。

func (*RDSCommon) Incr 

func (m *RDSCommon) Incr(key string) (num int64, err error)

Incr 自增

func (*RDSCommon) NewClient 

func (m *RDSCommon) NewClient(p *redis.Pool)

NewClient 创建 redis client

func (*RDSCommon) ReName 

func (m *RDSCommon) ReName(dist, newKey string) (err error)

ReName rename key:dist to newKey

func (*RDSCommon) SetBit 

func (m *RDSCommon) SetBit(key string, offset int64, v int) (err error)

SetBit COMMAND:"SETBIT"

func (*RDSCommon) SetEX 

func (m *RDSCommon) SetEX(key string, v interface{}, ex int64) (ok bool, err error)

SetEX 写入string，同时设置过期时间 

SetEx(key,"value",24*time.Hour)

func (*RDSCommon) SetEXPIRE 

func (m *RDSCommon) SetEXPIRE(key string, seconds int64) (bool, error)

SetEXPIRE 设置过期时间

func (*RDSCommon) SetEXPIREAT 

func (m *RDSCommon) SetEXPIREAT(key string, timestamp int64) (bool, error)

SetEXPIREAT 设置过期时间(以时间戳的方式)

func (*RDSCommon) SetHash 

func (m *RDSCommon) SetHash(key string, v interface{}) (err error)

SetHash 设置hash值

func (*RDSCommon) SetHashField 

func (m *RDSCommon) SetHashField(key string, field, v interface{}) (int64, error)

SetHashField 设置某个field值

func (*RDSCommon) SetList 

func (m *RDSCommon) SetList(key string, values []string) error

SetList 添加list

func (*RDSCommon) SetNX 

func (m *RDSCommon) SetNX(key string, v interface{}) (bool, error)

SetNX key不存时，设置key的值为v

func (*RDSCommon) SetString 

func (m *RDSCommon) SetString(key string, v interface{}) (ok bool, err error)

SetString 设置key的值为v

func (*RDSCommon) SetZSet 

func (m *RDSCommon) SetZSet(key string, mp map[float64]interface{}) (err error)

SetZSet 添加一个新的ZSet 

ZADD

func (*RDSCommon) Zincrby added in v1.1.6 

func (m *RDSCommon) Zincrby(key string, score int64, value interface{}) error

Zincrby 增加元素的score

func (*RDSCommon) Zpopmax added in v1.1.6 

func (m *RDSCommon) Zpopmax(key string) (ss []string, err error)

Zpopmax 命令删除并返回有序集合 key 中的最多 count 个具有最高得分的成员。

func (*RDSCommon) Zscore added in v1.1.6 

func (m *RDSCommon) Zscore(key string, value interface{}) (int64, error)

Zscore 获取元素的score

type RDSConfig 

type RDSConfig struct {

	// Host 主机
	Host string

	// Port 端口
	Port int

	// Password 密码，无密码传""
	Password  string
	MaxIdle   int
	MaxActive int

	// DB 使用的DB
	DB int
}

RDSConfig redis 配置结构

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.