jcache

package module
v1.1.8 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2023 License: MIT Imports: 5 Imported by: 2

README

JCache 实用的Golang多级缓存集成方案

项目由来

我们在开发项目中，少不了需要用到缓存，甚至是分布式缓存。我们用的最多的就是Redis，它是一个非常优秀的分布式缓存数据库。

但是如果在生产环境中，Redis挂了，导致某些业务无法再进行，甚至缓存雪崩，导致所有业务都无法进行。

所以一般情况下，我们是尽量不让redis这个分布式的缓存挂掉的，所以我们很多时候就会把自己服务实例上的内存拿来当缓存用，因为它快速、方便、基本无延迟。所以，我们每开发一个项目就会写上一堆缓存组件，很是麻烦。

现在，一个支持本机内存缓存并支持Redis等分布式缓存服务的集成方案产生了。我们开箱即用，非常方便。

基本架构

现行阶段优先实现功能，未来可能会根据driver的权重指定优先获取顺序。 当前版本的优先顺序按实例化client时指定的driver顺序。

// 实例化一个以redis驱动为优先获取，内存驱动为后取的客户端
client := jcache.NewClient(driver.NewRedis(), driver.NewMemory())


// 实例化一个以内存驱动为优先获取，redis驱动为后取的客户端
client := jcache.NewClient(driver.NewMemory(),driver.NewRedis())

进度

  • Redis支持
  • 本机内存支持
    • 单机模式支持
    • 分布式模式支持

案例

  go get github.com/jerbe/jcache@v1.1.8

import (
    "time"
	
    "github.com/jerbe/jcache"
    "github.com/jerbe/jcache/driver"
)

func main(){
	// driver.NewMemory() 实例化一个以内存作为缓存的驱动
	
	// 支持所有操作的客户端,包括 String,Hash,List 
	client := jcache.NewClient(driver.NewMemory())
	client.Set(context.Background(),"hello","world", time.Hour)
	client.Get(context.Background(),"hello")
	client.MGet(context.Background(),"hello","hi")
	...
		
	// 仅支持 String 操作的客户端 
	stringClient := jcache.NewStringClien(driver.NewMemory()); 
	stringClient.Set(context.Background(),"hello","world", time.Hour)
	stringClient.Get(context.Background(),"hello")
	stringClient.MGet(context.Background(),"hello","hi")
	...
	
	// 仅支持 Hash 操作的客户端
	hashClient := jcache.NewHashClient(driver.NewMemory()); 
	hashClient.HSet(context.Background(),"hello","world","boom")
	hashClient.HGet(context.Background(),"hello","world")
	...
	
	// 仅支持 List 操作的客户端 
	listClient := jcache.NewListClient(driver.NewMemory());
	listClient.Push(context.Background(),"hello","world")
	listClient.Pop(context.Background(),"hello")
	listClient.Shift(context.Background(),"hello")
}

Documentation

Index

Constants

View Source 
const (
	// KeepTTL 保持原先的过期时间(TTL)
	KeepTTL = -1

	// DefaultEmptySetNXDuration 默认空对象设置过期时效
	DefaultEmptySetNXDuration = time.Second * 10

	// DefaultExpirationDuration 默认缓存过期时效
	DefaultExpirationDuration = time.Hour
)

Variables

View Source 
var (
	ErrEmpty         = errors.New("empty")
	ErrNoCacheClient = errors.New("no cache client init")
	ErrNoRecord      = errors.New("no record")
)

Functions

func RandomExpirationDuration 

func RandomExpirationDuration() time.Duration

RandomExpirationDuration 以 DefaultExpirationDuration 为基础,返回一个 DefaultExpirationDuration ± 30m 内的时间长度

Types

type Client added in v1.1.0 

type Client struct {
	StringClient
	HashClient
	ListClient
	// contains filtered or unexported fields
}

func NewClient added in v1.1.0 

func NewClient(drivers ...driver.Cache) *Client

func (*Client) Del added in v1.1.0 

func (cli *Client) Del(ctx context.Context, keys ...string) error

Del 删除键

func (*Client) Exists added in v1.1.0 

func (cli *Client) Exists(ctx context.Context, keys ...string) (int64, error)

Exists 判断某个Key是否存在

func (*Client) Expire added in v1.1.0 

func (cli *Client) Expire(ctx context.Context, key string, expiration time.Duration) error

Expire 设置某个Key的TTL时长

func (*Client) ExpireAt added in v1.1.0 

func (cli *Client) ExpireAt(ctx context.Context, key string, at time.Time) error

ExpireAt 设置某个key在指定时间内到期

type HashClient added in v1.1.0 

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

func NewHashClient added in v1.1.0 

func NewHashClient(drivers ...driver.Hash) *HashClient

func (*HashClient) Del added in v1.1.0 

func (cli *HashClient) Del(ctx context.Context, keys ...string) error

Del 删除键

func (*HashClient) Exists added in v1.1.0 

func (cli *HashClient) Exists(ctx context.Context, keys ...string) (int64, error)

Exists 判断某个Key是否存在

func (*HashClient) Expire added in v1.1.0 

func (cli *HashClient) Expire(ctx context.Context, key string, expiration time.Duration) error

Expire 设置某个Key的TTL时长

func (*HashClient) ExpireAt added in v1.1.0 

func (cli *HashClient) ExpireAt(ctx context.Context, key string, at time.Time) error

ExpireAt 设置某个key在指定时间内到期

func (*HashClient) HDel added in v1.1.0 

func (cli *HashClient) HDel(ctx context.Context, key string, fields ...string) error

HDel 删除hash数据

func (*HashClient) HExists added in v1.1.7 

func (cli *HashClient) HExists(ctx context.Context, key, field string) (bool, error)

HExists 判断哈希表周公某个字段是否存在

func (*HashClient) HGet added in v1.1.0 

func (cli *HashClient) HGet(ctx context.Context, key, field string) (string, error)

HGet 获取Hash表指定字段的值

func (*HashClient) HGetAll added in v1.1.7 

func (cli *HashClient) HGetAll(ctx context.Context, key string) (map[string]string, error)

HGetAll 获取哈希表中所有的值,包括键/值

func (*HashClient) HGetAndScan added in v1.1.0 

func (cli *HashClient) HGetAndScan(ctx context.Context, dst interface{}, key, field string) error

HGetAndScan 获取Hash表指定字段的值

func (*HashClient) HKeys added in v1.1.0 

func (cli *HashClient) HKeys(ctx context.Context, key string) ([]string, error)

HKeys 获取Hash表的所有键

func (*HashClient) HKeysAndScan added in v1.1.0 

func (cli *HashClient) HKeysAndScan(ctx context.Context, dst interface{}, key string) error

HKeysAndScan 获取Hash表的所有键并扫描到dst中

func (*HashClient) HLen added in v1.1.0 

func (cli *HashClient) HLen(ctx context.Context, key string) (int64, error)

HLen 获取Hash表的所有键个数

func (*HashClient) HMGet added in v1.1.0 

func (cli *HashClient) HMGet(ctx context.Context, key string, fields ...string) ([]interface{}, error)

HMGet 获取Hash表指定字段的值

func (*HashClient) HMGetAndScan added in v1.1.0 

func (cli *HashClient) HMGetAndScan(ctx context.Context, dst interface{}, key string, fields ...string) error

HMGetAndScan 获取Hash表指定字段的值并扫描进入到dst中

func (*HashClient) HSet added in v1.1.0 

func (cli *HashClient) HSet(ctx context.Context, key string, values ...interface{}) error

HSet 写入hash数据 接受以下格式的值： HSet("myhash", "key1", "value1", "key2", "value2")

HSet("myhash", []string{"key1", "value1", "key2", "value2"})

HSet("myhash", map[string]interface{}{"key1": "value1", "key2": "value2"}) 使用“redis”标签播放结构。 type MyHash struct { Key1 string `redis:"key1"`; Key2 int `redis:"key2"` }

HSet("myhash", MyHash{"value1", "value2"}) 警告：redis-server >= 4.0 对于struct，可以是结构体指针类型，我们只解析标签为redis的字段。如果你不想读取该字段，可以使用 `redis:"-"` 标志来忽略它，或者不需要设置 redis 标签。对于结构体字段的类型，我们只支持简单的数据类型：string、int/uint(8,16,32,64)、float(32,64)、time.Time(to RFC3339Nano)、time.Duration(to Nanoseconds) ），如果是其他更复杂或者自定义的数据类型，请实现encoding.BinaryMarshaler接口。

func (*HashClient) HSetNX added in v1.1.7 

func (cli *HashClient) HSetNX(ctx context.Context, key, field string, value interface{}) (bool, error)

HSetNX 哈希表设置某个字段的值,如果存在的话返回true

func (*HashClient) HVals added in v1.1.0 

func (cli *HashClient) HVals(ctx context.Context, key string) ([]string, error)

HVals 获取Hash表的所有值

func (*HashClient) HValsAndScan added in v1.1.0 

func (cli *HashClient) HValsAndScan(ctx context.Context, dst interface{}, key string) error

HValsAndScan 获取Hash表的所有值并扫如dst中

type ListClient added in v1.1.0 

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

func NewListClient added in v1.1.0 

func NewListClient(drivers ...driver.List) *ListClient

func (*ListClient) Del added in v1.1.0 

func (cli *ListClient) Del(ctx context.Context, keys ...string) error

Del 删除键

func (*ListClient) Exists added in v1.1.0 

func (cli *ListClient) Exists(ctx context.Context, keys ...string) (int64, error)

Exists 判断某个Key是否存在

func (*ListClient) Expire added in v1.1.0 

func (cli *ListClient) Expire(ctx context.Context, key string, expiration time.Duration) error

Expire 设置某个Key的TTL时长

func (*ListClient) ExpireAt added in v1.1.0 

func (cli *ListClient) ExpireAt(ctx context.Context, key string, at time.Time) error

ExpireAt 设置某个key在指定时间内到期

func (*ListClient) LLen added in v1.1.6 

func (cli *ListClient) LLen(ctx context.Context, key string) (int64, error)

LLen 返回列表长度

func (*ListClient) LPop added in v1.1.6 

func (cli *ListClient) LPop(ctx context.Context, key string) (string, error)

LPop 移除并取出列表内的最后一个元素

func (*ListClient) LPopAndScan added in v1.1.6 

func (cli *ListClient) LPopAndScan(ctx context.Context, dst interface{}, key string) error

LPopAndScan 通过扫描方式移除并取出列表内的最后一个元素

func (*ListClient) LPush added in v1.1.6 

func (cli *ListClient) LPush(ctx context.Context, key string, data ...interface{}) error

LPush 推送数据

func (*ListClient) LRang added in v1.1.6 

func (cli *ListClient) LRang(ctx context.Context, key string, start, stop int64) ([]string, error)

LRang 获取列表内的范围数据

func (*ListClient) LRangAndScan added in v1.1.6 

func (cli *ListClient) LRangAndScan(ctx context.Context, dst interface{}, key string, start, stop int64) error

LRangAndScan 通过扫描方式获取列表内的范围内数据

func (*ListClient) LShift added in v1.1.7 

func (cli *ListClient) LShift(ctx context.Context, key string) (string, error)

LShift 移除并取出列表内的第一个元素

func (*ListClient) LShiftAndScan added in v1.1.7 

func (cli *ListClient) LShiftAndScan(ctx context.Context, dst interface{}, key string) error

LShiftAndScan 通过扫描方式移除并取出列表内的第一个元素

func (*ListClient) LTrim added in v1.1.6 

func (cli *ListClient) LTrim(ctx context.Context, key string, start, stop int64) error

LTrim 获取列表内的范围数据

type StringClient added in v1.1.0 

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

func NewStringClient added in v1.1.0 

func NewStringClient(drivers ...driver.String) *StringClient

func (*StringClient) CheckAndGet added in v1.1.0 

func (cli *StringClient) CheckAndGet(ctx context.Context, key string) (string, error)

CheckAndGet 检测并获取数据

func (*StringClient) CheckAndScan added in v1.1.0 

func (cli *StringClient) CheckAndScan(ctx context.Context, dst interface{}, key string) error

CheckAndScan 获取数据

func (*StringClient) Del added in v1.1.0 

func (cli *StringClient) Del(ctx context.Context, keys ...string) error

Del 删除键

func (*StringClient) Exists added in v1.1.0 

func (cli *StringClient) Exists(ctx context.Context, keys ...string) (int64, error)

Exists 判断某个Key是否存在

func (*StringClient) Expire added in v1.1.0 

func (cli *StringClient) Expire(ctx context.Context, key string, expiration time.Duration) error

Expire 设置某个Key的TTL时长

func (*StringClient) ExpireAt added in v1.1.0 

func (cli *StringClient) ExpireAt(ctx context.Context, key string, at time.Time) error

ExpireAt 设置某个key在指定时间内到期

func (*StringClient) Get added in v1.1.0 

func (cli *StringClient) Get(ctx context.Context, key string) (string, error)

Get 获取数据

func (*StringClient) GetAndScan added in v1.1.0 

func (cli *StringClient) GetAndScan(ctx context.Context, dst interface{}, key string) error

GetAndScan 获取并扫描

func (*StringClient) MGet added in v1.1.0 

func (cli *StringClient) MGet(ctx context.Context, keys ...string) ([]interface{}, error)

MGet 获取多个Keys的值

func (*StringClient) MGetAndScan added in v1.1.0 

func (cli *StringClient) MGetAndScan(ctx context.Context, dst interface{}, keys ...string) error

MGetAndScan 获取多个Keys的值并扫描进dst中

func (*StringClient) Set added in v1.1.0 

func (cli *StringClient) Set(ctx context.Context, key string, data interface{}, expiration time.Duration) error

Set 设置数据

func (*StringClient) SetNX added in v1.1.0 

func (cli *StringClient) SetNX(ctx context.Context, key string, data interface{}, expiration time.Duration) error

SetNX 设置数据,如果key不存在的话

Source Files

View all Source files

Directories

Path Synopsis
internal
hscan

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.