mirror of
https://github.com/astaxie/beego.git
synced 2024-11-05 15:30:57 +00:00
ec55edfbc4
Adding option for frequency of checking timed out connections as well as an option to specify retries. These changes make redis provider more stable since connection problems are becoming fewer. Since redigo does not have this options and since redis_sentinel and redis_cluster are using go-redis as a client, this commit changes from redigo to go-redis for redis session provider. Added tests for redis session provider as well.
246 lines
6.2 KiB
Go
246 lines
6.2 KiB
Go
// Copyright 2014 beego Author. All Rights Reserved.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
// Package redis for session provider
|
|
//
|
|
// depend on github.com/go-redis/redis
|
|
//
|
|
// go install github.com/go-redis/redis
|
|
//
|
|
// Usage:
|
|
// import(
|
|
// _ "github.com/astaxie/beego/session/redis_cluster"
|
|
// "github.com/astaxie/beego/session"
|
|
// )
|
|
//
|
|
// func init() {
|
|
// globalSessions, _ = session.NewManager("redis_cluster", ``{"cookieName":"gosessionid","gclifetime":3600,"ProviderConfig":"127.0.0.1:7070;127.0.0.1:7071"}``)
|
|
// go globalSessions.GC()
|
|
// }
|
|
//
|
|
// more docs: http://beego.me/docs/module/session.md
|
|
package redis_cluster
|
|
|
|
import (
|
|
"github.com/astaxie/beego/pkg/session"
|
|
rediss "github.com/go-redis/redis/v7"
|
|
"net/http"
|
|
"strconv"
|
|
"strings"
|
|
"sync"
|
|
"time"
|
|
)
|
|
|
|
var redispder = &Provider{}
|
|
|
|
// MaxPoolSize redis_cluster max pool size
|
|
var MaxPoolSize = 1000
|
|
|
|
// SessionStore redis_cluster session store
|
|
type SessionStore struct {
|
|
p *rediss.ClusterClient
|
|
sid string
|
|
lock sync.RWMutex
|
|
values map[interface{}]interface{}
|
|
maxlifetime int64
|
|
}
|
|
|
|
// Set value in redis_cluster session
|
|
func (rs *SessionStore) Set(key, value interface{}) error {
|
|
rs.lock.Lock()
|
|
defer rs.lock.Unlock()
|
|
rs.values[key] = value
|
|
return nil
|
|
}
|
|
|
|
// Get value in redis_cluster session
|
|
func (rs *SessionStore) Get(key interface{}) interface{} {
|
|
rs.lock.RLock()
|
|
defer rs.lock.RUnlock()
|
|
if v, ok := rs.values[key]; ok {
|
|
return v
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Delete value in redis_cluster session
|
|
func (rs *SessionStore) Delete(key interface{}) error {
|
|
rs.lock.Lock()
|
|
defer rs.lock.Unlock()
|
|
delete(rs.values, key)
|
|
return nil
|
|
}
|
|
|
|
// Flush clear all values in redis_cluster session
|
|
func (rs *SessionStore) Flush() error {
|
|
rs.lock.Lock()
|
|
defer rs.lock.Unlock()
|
|
rs.values = make(map[interface{}]interface{})
|
|
return nil
|
|
}
|
|
|
|
// SessionID get redis_cluster session id
|
|
func (rs *SessionStore) SessionID() string {
|
|
return rs.sid
|
|
}
|
|
|
|
// SessionRelease save session values to redis_cluster
|
|
func (rs *SessionStore) SessionRelease(w http.ResponseWriter) {
|
|
b, err := session.EncodeGob(rs.values)
|
|
if err != nil {
|
|
return
|
|
}
|
|
c := rs.p
|
|
c.Set(rs.sid, string(b), time.Duration(rs.maxlifetime)*time.Second)
|
|
}
|
|
|
|
// Provider redis_cluster session provider
|
|
type Provider struct {
|
|
maxlifetime int64
|
|
savePath string
|
|
poolsize int
|
|
password string
|
|
dbNum int
|
|
poollist *rediss.ClusterClient
|
|
}
|
|
|
|
// SessionInit init redis_cluster session
|
|
// savepath like redis server addr,pool size,password,dbnum
|
|
// e.g. 127.0.0.1:6379;127.0.0.1:6380,100,test,0
|
|
func (rp *Provider) SessionInit(maxlifetime int64, savePath string) error {
|
|
rp.maxlifetime = maxlifetime
|
|
configs := strings.Split(savePath, ",")
|
|
if len(configs) > 0 {
|
|
rp.savePath = configs[0]
|
|
}
|
|
if len(configs) > 1 {
|
|
poolsize, err := strconv.Atoi(configs[1])
|
|
if err != nil || poolsize < 0 {
|
|
rp.poolsize = MaxPoolSize
|
|
} else {
|
|
rp.poolsize = poolsize
|
|
}
|
|
} else {
|
|
rp.poolsize = MaxPoolSize
|
|
}
|
|
if len(configs) > 2 {
|
|
rp.password = configs[2]
|
|
}
|
|
if len(configs) > 3 {
|
|
dbnum, err := strconv.Atoi(configs[3])
|
|
if err != nil || dbnum < 0 {
|
|
rp.dbNum = 0
|
|
} else {
|
|
rp.dbNum = dbnum
|
|
}
|
|
} else {
|
|
rp.dbNum = 0
|
|
}
|
|
var idleTimeout time.Duration = 0
|
|
if len(configs) > 4 {
|
|
timeout, err := strconv.Atoi(configs[4])
|
|
if err == nil && timeout > 0 {
|
|
idleTimeout = time.Duration(timeout) * time.Second
|
|
}
|
|
}
|
|
var idleCheckFrequency time.Duration = 0
|
|
if len(configs) > 5 {
|
|
checkFrequency, err := strconv.Atoi(configs[5])
|
|
if err == nil && checkFrequency > 0 {
|
|
idleCheckFrequency = time.Duration(checkFrequency) * time.Second
|
|
}
|
|
}
|
|
var maxRetries = 0
|
|
if len(configs) > 6 {
|
|
retries, err := strconv.Atoi(configs[6])
|
|
if err == nil && retries > 0 {
|
|
maxRetries = retries
|
|
}
|
|
}
|
|
|
|
rp.poollist = rediss.NewClusterClient(&rediss.ClusterOptions{
|
|
Addrs: strings.Split(rp.savePath, ";"),
|
|
Password: rp.password,
|
|
PoolSize: rp.poolsize,
|
|
IdleTimeout: idleTimeout,
|
|
IdleCheckFrequency: idleCheckFrequency,
|
|
MaxRetries: maxRetries,
|
|
})
|
|
return rp.poollist.Ping().Err()
|
|
}
|
|
|
|
// SessionRead read redis_cluster session by sid
|
|
func (rp *Provider) SessionRead(sid string) (session.Store, error) {
|
|
var kv map[interface{}]interface{}
|
|
kvs, err := rp.poollist.Get(sid).Result()
|
|
if err != nil && err != rediss.Nil {
|
|
return nil, err
|
|
}
|
|
if len(kvs) == 0 {
|
|
kv = make(map[interface{}]interface{})
|
|
} else {
|
|
if kv, err = session.DecodeGob([]byte(kvs)); err != nil {
|
|
return nil, err
|
|
}
|
|
}
|
|
|
|
rs := &SessionStore{p: rp.poollist, sid: sid, values: kv, maxlifetime: rp.maxlifetime}
|
|
return rs, nil
|
|
}
|
|
|
|
// SessionExist check redis_cluster session exist by sid
|
|
func (rp *Provider) SessionExist(sid string) (bool, error) {
|
|
c := rp.poollist
|
|
if existed, err := c.Exists(sid).Result(); err != nil || existed == 0 {
|
|
return false, err
|
|
}
|
|
return true, nil
|
|
}
|
|
|
|
// SessionRegenerate generate new sid for redis_cluster session
|
|
func (rp *Provider) SessionRegenerate(oldsid, sid string) (session.Store, error) {
|
|
c := rp.poollist
|
|
|
|
if existed, err := c.Exists(oldsid).Result(); err != nil || existed == 0 {
|
|
// oldsid doesn't exists, set the new sid directly
|
|
// ignore error here, since if it return error
|
|
// the existed value will be 0
|
|
c.Set(sid, "", time.Duration(rp.maxlifetime)*time.Second)
|
|
} else {
|
|
c.Rename(oldsid, sid)
|
|
c.Expire(sid, time.Duration(rp.maxlifetime)*time.Second)
|
|
}
|
|
return rp.SessionRead(sid)
|
|
}
|
|
|
|
// SessionDestroy delete redis session by id
|
|
func (rp *Provider) SessionDestroy(sid string) error {
|
|
c := rp.poollist
|
|
c.Del(sid)
|
|
return nil
|
|
}
|
|
|
|
// SessionGC Impelment method, no used.
|
|
func (rp *Provider) SessionGC() {
|
|
}
|
|
|
|
// SessionAll return all activeSession
|
|
func (rp *Provider) SessionAll() int {
|
|
return 0
|
|
}
|
|
|
|
func init() {
|
|
session.Register("redis_cluster", redispder)
|
|
}
|