hotime/cache/cache_redis.go

package cache

import (
	. "../common"
	"github.com/garyburd/redigo/redis"
	"strings"
	"time"
)

type CacheRedis struct {
	TimeOut    int64
	DbSet      bool
	SessionSet bool
	Host       string
	Pwd        string
	Port       int64
	conn       redis.Conn
	tag        int64
	ContextBase
	*Error
}

func (this *CacheRedis) GetError() *Error {

	return this.Error

}

func (this *CacheRedis) SetError(err *Error) {
	this.Error = err
}

//唯一标志
func (this *CacheRedis) GetTag() int64 {

	if this.tag == int64(0) {
		this.tag = time.Now().UnixNano()
	}
	return this.tag
}

func (this *CacheRedis) reCon() bool {
	var err error
	this.conn, err = redis.Dial("tcp", this.Host+":"+ObjToStr(this.Port))
	if err != nil {
		this.conn = nil
		this.Error.SetError(err)
		return false
	}

	if this.Pwd != "" {
		_, err = this.conn.Do("AUTH", this.Pwd)
		if err != nil {
			this.conn = nil
			this.Error.SetError(err)
			return false
		}
	}

	return true
}
func (this *CacheRedis) del(key string) {
	del := strings.Index(key, "*")
	if del != -1 {
		val, err := redis.Strings(this.conn.Do("KEYS", key))
		if err != nil {
			return
		}
		this.conn.Send("MULTI")
		for i, _ := range val {
			this.conn.Send("DEL", val[i])
		}
		this.conn.Do("EXEC")
	} else {
		_, err := this.conn.Do("DEL", key)
		if err != nil {
			this.Error.SetError(err)
			_, err = this.conn.Do("PING")
			if err != nil {
				if this.reCon() {
					_, err = this.conn.Do("DEL", key)
				}
			}
		}
	}
}

//key value ,时间为时间戳
func (this *CacheRedis) set(key string, value string, time int64) {
	_, err := this.conn.Do("SET", key, value, "EX", ObjToStr(time))
	if err != nil {

		this.Error.SetError(err)
		_, err = this.conn.Do("PING")
		if err != nil {
			if this.reCon() {
				_, err = this.conn.Do("SET", key, value, "EX", ObjToStr(time))
			}
		}
	}
}

func (this *CacheRedis) get(key string) *Obj {
	reData := &Obj{}
	var err error
	reData.Data, err = redis.String(this.conn.Do("GET", key))
	if err != nil {
		reData.Data = nil
		if !strings.Contains(err.Error(), "nil returned") {
			this.Error.SetError(err)
			_, err = this.conn.Do("PING")
			if err != nil {
				if this.reCon() {
					reData.Data, err = redis.String(this.conn.Do("GET", key))
				}
			}

			return reData
		}
	}
	return reData
}

func (this *CacheRedis) Cache(key string, data ...interface{}) *Obj {
	reData := &Obj{}
	if this.conn == nil {
		re := this.reCon()
		if !re {
			return reData
		}
	}
	//查询缓存
	if len(data) == 0 {

		reData = this.get(key)
		return reData

	}
	tim := int64(0)
	//删除缓存
	if len(data) == 1 && data[0] == nil {
		this.del(key)
		return reData
	}
	//添加缓存
	if len(data) == 1 {

		if this.TimeOut == 0 {
			//this.Time = Config.GetInt64("cacheShortTime")
		}

		tim += this.TimeOut
	}
	if len(data) == 2 {
		this.Error.SetError(nil)
		tempt := ObjToInt64(data[1], this.Error)
		if tempt > tim {

			tim = tempt
		} else if this.GetError() == nil {

			tim = tim + tempt
		}
	}

	this.set(key, ObjToStr(data[0]), tim)

	return reData

}