标签：缓存 return err nil UserId func 简单 GO query

ICacheQueryBase

type ICacheQueryBase  interface {
    GetCacheKey() string
}

CacheMiddleware

package entity_cache

import (
    "encoding/json"
    "errors"
    "github.com/coocood/freecache"
    "reflect"
)

type CacheCore   struct {
}

func (c *CacheCore) OnHit(key string) ([]byte, bool) {
    resp, err := LocalCache.Get([]byte(key))
    if err == freecache.ErrNotFound {
        return nil, false
    }
    if err != nil {
        //log
        return nil, false
    }

    return resp, true
}

func (c *CacheCore) Set(key string, data []byte, expireSeconds int) {
    err := LocalCache.Set([]byte(key), []byte(data), expireSeconds)
    if err != nil {
        //log
    }
}

type CacheMiddleware   struct {
}

func (c *CacheMiddleware) Query(query ICacheQueryBase, reload   func (query ICacheQueryBase) (  interface {}, error), refV   interface {}) error {
    cacheCore := CacheCore{}

    if cacheBytes, isHit := cacheCore.OnHit(query.GetCacheKey()); isHit {
        err := json.Unmarshal(cacheBytes, &refV)
        if err == nil {
            return nil
        }   else {
            //log
        }
    }

    resp, err := reload(query)
    if err != nil {
        return err
    }

    va := reflect.ValueOf(refV).Elem()
    if va.IsValid() {
        va.Set(reflect.ValueOf(resp))
    }   else {
        return errors.New(  "err type,refV must be pointer" )
    }

    respByte, err := json.Marshal(resp)
    if err != nil {
        //log
    }
    cacheCore.Set(query.GetCacheKey(), respByte, 60)

    return nil
}

Cache_test

type UserEntity struct {
	UserId   int64
	UserName string
}

type UserQuery struct {
	UserId int64
}

func (c UserQuery) GetCacheKey() string {
	idStr := strconv.FormatInt(c.UserId, 10)
	return "User" + idStr
}

func TestCache(t *testing.T) {
	Init()

	var userId int64 = 99
	query := UserQuery{
		UserId: userId,
	}

	var respV UserEntity

	medware := CacheMiddleware{}
	err := medware.Query(query, func(query ICacheQueryBase) (interface{}, error) {
		q := query.(UserQuery)
		return UserEntity{
			UserId:   q.UserId,
			UserName: "UUUUUUUUUUUUU",
		}, nil
	}, &respV)
	if err != nil {
		//
	}

	var respV2 UserEntity
	err = medware.Query(query, func(query ICacheQueryBase) (interface{}, error) {
		q := query.(UserQuery)
		return UserEntity{
			UserId:   q.UserId,
			UserName: "UUUUUUUUUUUUU",
		}, nil
	}, &respV2)
	if err != nil {
		//
	}

	fmt.Println(respV2)
}

标签：缓存,return,err,nil,UserId,func,简单,GO,query
来源： https://www.cnblogs.com/FCmmmmmm/p/16638928.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。