|
|
@@ -367,25 +367,23 @@ func PutLoginSess(mongodb MongodbSim, apppushRpc, key, userid string, limit, max
|
|
|
value = append(value, key)
|
|
|
}
|
|
|
ttlmap := []TtlMap{}
|
|
|
- //大于临界点 清理无用sessionid
|
|
|
// if len(value) >= int(limit*max/100) {
|
|
|
- // new_value := []string{}
|
|
|
- // //如果已存的session大于限制 则清除三天后到期的session
|
|
|
- // for _, vv := range value {
|
|
|
- // ttl := redis.GetTTL("session", vv)
|
|
|
- // log.Println("ttl:", ttl)
|
|
|
- // // if ttl <= 86400*3 && ttl != -1 {
|
|
|
- // if ttl <= 600 && ttl != -1 {
|
|
|
- // if ok := redis.Del("session", vv); ok {
|
|
|
- // LoginOutPush(mongodb, userid, vv, apppushRpc)
|
|
|
- // log.Println(fmt.Sprintf("%s用户的sessionid 到期时间还有%v 小于三天 清除 %s", userid, ttl, vv))
|
|
|
- // }
|
|
|
- // continue
|
|
|
- // }
|
|
|
- // new_value = append(new_value, vv)
|
|
|
- // ttlmap = append(ttlmap, TtlMap{vv, int(ttl)})
|
|
|
- // }
|
|
|
- // value = new_value
|
|
|
+ // new_value := []string{}
|
|
|
+ //如果已存的session大于限制 则清除三天后到期的session
|
|
|
+ for _, vv := range value {
|
|
|
+ ttl := redis.GetTTL("session", vv)
|
|
|
+ // if ttl <= 86400*3 && ttl != -1 {
|
|
|
+ // if ttl <= 600 && ttl != -1 {
|
|
|
+ // if ok := redis.Del("session", vv); ok {
|
|
|
+ // LoginOutPush(mongodb, userid, vv, apppushRpc)
|
|
|
+ // log.Println(fmt.Sprintf("%s用户的sessionid 到期时间还有%v 小于三天 清除 %s", userid, ttl, vv))
|
|
|
+ // }
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // new_value = append(new_value, vv)
|
|
|
+ ttlmap = append(ttlmap, TtlMap{vv, int(ttl)})
|
|
|
+ }
|
|
|
+ // value = new_value
|
|
|
// }
|
|
|
//清除并发最大限制的某个sessionid
|
|
|
if len(value) > max {
|
