(億級流量)分佈式防重複提交token設計【史詩級】

    大型互聯網項目中,不少流量都達到億級。同一時間不少的人在使用,而每一個用戶提交表單的時候均可能會出現重複點擊的狀況,此時若是不作好控制,那麼系統將會產生不少的數據重複的問題。怎樣去設計一個高可用的防重複提交方案呢?博主將在此爲你們詳細分享當前本身負責的一個億級流量項目中如何實現防重複提交。css

    首先,博主在介紹以前,先介紹下這個億級項目的故事。博主在16年入駐公司後,進入了該項目組,此時項目面對大流量訪問的狀況可謂很是糟。客戶每天跟公司搞事情,不信任團隊。具體問題爭論點以下:html

    1.用戶在提交數據後,不少時候總會有重複提交(商城秒搶活動更甚,幾乎不可用)java

    2.系統天天宕機好幾回(後經代碼+服務器數據分析,a各類流沒使用正確的方式去關閉;b.tomcat對應的session redis同步包有io句柄泄露;c.各類代碼不規範寫法如死循環、直接用new Thread()、StringBuffer亂用等;d.編寫的sql性能問題等等)web

    3.不少功能點不可用,如數據量大的報表沒法導出、數據量大的excel沒法導入、pc端和微信端用戶信息等數據同步問題、大數據量的表單下拉選擇沒法使用、微xxxx號裏面圖片沒法多圖片上傳、商城秒搶活動常常出現商品超賣、無界線程(newCachedThreadPool)池亂用ajax

    4.不少時候發版都出現功能漏發(服務器太多、且每臺有多個實例)redis

    ..........spring

    總之,問題多得博主數都數不過來.sql

    固然,上面的這些問題都很重要,必須解決;博主這次就單獨分享在解決防重複提交這個問題上的方案,其它的問題的解決方案如分佈式鎖、pc端單端登陸(微信端非單端)等等在後期講解。apache

    首先說一下防重複提交token的工做流程:數組

    用戶訪問表單添加頁面->spring防重複token攔截器攔截請求url,判斷url對應的controller方法是是否註解有生成防重複token的標識->生成防重複token保存到redis中RedisUtil.getRu().setex("formToken_" + uuid, "1", 60 * 60);同時將本次生成的防重複token放到session中->跳轉到表單頁面時從session中取出token放入表單->用戶填寫完信息提交表單->spring防重複token攔截器攔截請求url,判斷提交的url對應controller方法是否註解有處理防重複提交token的標識->redis中formToken作原子減1操做RedisUtil.getRu().decr("formToken_" + clinetToken);若是redis中formToken值作了減1操做後值不爲0,則爲重複提交,返回false。

防重複提交token生成流程圖:

防重複表單提交處理流程圖:

代碼設計部分(此處因爲非ajax提交表單時只須要兩個註解就能夠實現,故此處不做詳細解讀):

FormToken類,表單類型註解

package com.empire.form;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * 類FormToken.java的實現描述:FormToken註解
 * 
 * @author arron 2017年x月xx日 下午8:51:20
 */
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface FormToken {
    /**
     * 須要防重複功能的表單入口URL對應的controller方法須要添加的註解,用於生成token(默認爲uuid)
     * @return
     */
    boolean save() default false;
    /**
     * 防重複表單提交表單到後臺對應的URL的controller方法須要添加的註解,用於第一次成功提交後remove掉token
     * @return
     */
    boolean remove() default false;
    /**
     * 是否讓token防重複攔截器放過token校驗,爲true時通常用於ajax提交放過到controller中處理,此功能能夠在提交失敗後恢復token
     * @return
     */
    boolean pass() default false;//若是攔截到位表單重複提交是否放過讓controller處理,默認被攔截器處理返回false;
}

TokenInterceptor(自定義token攔截器)

package com.empire.interceptor;

import java.lang.reflect.Method;
import java.util.Date;
import java.util.UUID;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.log4j.Logger;
import org.springframework.web.method.HandlerMethod;
import org.springframework.web.servlet.handler.HandlerInterceptorAdapter;

import com.empire.utils.RedisUtil;

/**
 * 類TokenInterceptor.java的實現描述:攔截器:防止重複提交
 * 
 * @author arron 2017年x月xx日 下午8:51:20
 */
public class TokenInterceptor extends HandlerInterceptorAdapter {
    private static final Logger logger = Logger.getLogger(FormToken.class);

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        if (handler instanceof HandlerMethod) {
            HandlerMethod handlerMethod = (HandlerMethod) handler;
            Method method = handlerMethod.getMethod();
            FormToken annotation = method.getAnnotation(FormToken.class);
            if (annotation != null) {
                boolean needSaveSession = annotation.save();
                if (needSaveSession) {
                    Date d = new Date();
                    String uuid = UUID.randomUUID().toString();
                    RedisUtil.getRu().setex("formToken_" + uuid, "1", 60 * 60);
                    request.getSession(true).setAttribute("formToken", uuid);
                    logger.warn(request.getServletPath() + "---->formToken:" + uuid);
                }
                boolean needRemoveSession = annotation.remove();

                if (needRemoveSession) {
                    if (isRepeatSubmit(request)) {
                        logger.warn("please don't repeat submit,url:" + request.getServletPath());
                        boolean pass = annotation.pass();
                        request.setAttribute("formToken_pass_repeat", "true");
                        return pass;
                    }
                    //request.getSession(true).removeAttribute("token");  
                }
            }
            return true;
        } else {
            return super.preHandle(request, response, handler);
        }
    }

    private boolean isRepeatSubmit(HttpServletRequest request) {
        String clinetToken = request.getParameter("formToken");
        if (clinetToken == null) {
            return true;
        }
        boolean r = RedisUtil.getRu().exists("formToken_" + clinetToken);
        if (r) {
            Long upCount = RedisUtil.getRu().decr("formToken_" + clinetToken);
            //若是對更新標記作減減操做後不等0,表示是重複提交
            if (upCount != 0) {
                RedisUtil.getRu().del("formToken_" + clinetToken);
                return true;
            } else {
                RedisUtil.getRu().del("formToken_" + clinetToken);
                return false;
            }
        } else {
            return true;
        }
    }
}

controller表單入口方法:

@FormToken(save = true)
@RequestMapping(value = "addAppointPage", produces = "text/html")
public String addAppointPage(HttpServletRequest request, HttpServletResponse response, Model uiModel) {
     //業務代碼
     ......

     return "pcpageAppoint/add";
}

jsp(例子爲ajax方式狀況)

<jsp:directive.page contentType="text/html;charset=UTF-8"/>
<%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core"%>
<%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c"%>
<%@taglib prefix="fmt" uri="http://java.sun.com/jsp/jstl/fmt" %>
//script、css import
.......
<script>
        function addAppoint(){
        	var formToken = $("#formToken").val();
        	var flag=true;
    		var mileage=$('#mileage').val();
    		if(mileage==""){
    			alert("請輸入行駛里程");
    			 flag=false;
        		  return;
    		}else{
    				var reg=/^[0-9]*$/;
    				if (!reg.test(mileage)){
    					alert("行駛里程只能是數字");
    				flag=false;
    				return;
    			}
    		}
        	$(".btn").removeAttr("onclick");
    	 if(flag){ 
    		$.ajax({
    		    url:"/ump/xxxxpc/pageAppoint/addAppointment",
    			data : {
					//業務字段
    				"memberId":'${member.id}',
    				 ...................
    				 "mileage":mileage,
    			    'formToken' : formToken
    			},
    			type: "POST",
    			error: function(msg){},
    			success:function(s){
    				var res = eval('([{'+s+'}])');
    				if(res[0].state){
    					alert(res[0].msg);
    					window.location.href ="/ump/xxxxpc/pageAppoint/showAppointmentList";
    				}else{
    					alert(res[0].msg);
    					return;
    				}
    			},
    			complete: comAjaxComplete  //----此處爲pc端ajax統一鑑權,暫時不用管
    		})
    	}
        }
</script>
<div class="personal_right clearfix">
    <div class="appointment">
        <div class="appointment_form">
        	<input type="hidden" id="formToken"  name="formToken" value="${formToken}"/>
            <div class="form_item">
                <div class="item_left">行駛里程<sup class="important_ts">*</sup>:</div>
                <div class="item_right"><input id="mileage" placeholder="請輸入行駛里程"/></div>
            </div>
            <div class="submit_re">
                <input type="button" value="提交" class="submit_sub theme_c" onclick="addAppoint();"/>
                <input type="button" value="返回" class="submit_sub other_c" onclick="history.back();"/>
            </div>
        </div>
    </div>
</div>

controller表單提交方法:

@RequestMapping(value = "addAppointment", produces = "text/html;charset=utf-8")
@ResponseBody
@FormToken(remove = true, pass = true)
public String addAppointment(HttpServletRequest request, HttpServletResponse response, Model 
        uiModel,@RequestParam(value = "memberId", required = false) Long memberId,
        @RequestParam(value = "mileage", required = false) String mileage) {
        String str = "";
        //判斷是否爲重複提交,若是是直接跳轉
        String passRepeat = (String) request.getAttribute("formToken_pass_repeat");
        if ("true".equals(passRepeat)) {
            str = "state:false,msg:\"請勿重複提交!\"";
            return str;
        }
        String clinetToken= request.getParameter("formToken");
        //從新生成一個uuid,預定失敗的時候生成新的uuid
        String uuid =clinetToken;
        if (memberId == null || memberId.longValue() == 0l) {
            CommonInterceptorUtil.recoveryFormToken(uuid);
            str = "state:false,msg:\"參數錯誤,請刷新後重試\"";
        } else if (StringUtils.isEmpty(mileage)) {
            CommonInterceptorUtil.recoveryFormToken(uuid);
            str = "state:false,msg:\"行駛里程不能爲空\"";
        } else {
           //業務代碼
           ......
           str = "state:true,msg:\"預定成功\"";
        }
        return str;
}

CommonInterceptorUtil (提交失敗時token恢復類)

package com.empire.interceptor;

import java.util.Date;

import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.empire.utils.RedisUtil;

/**
 * 類CommonInterceptorUtil.java的實現描述:數據同步工具類
 * 
 * @author arron 2017年x月xx日 下午8:51:20
 */
public class CommonInterceptorUtil {
    private static final Logger log = LoggerFactory.getLogger(CommonInterceptorUtil .class);

    /**
     * 恢復formToken,用於ajax防止重複提交,在controller中執行業務失敗後調用
     * 
     * @param clinetToken
     */
    public static void recoveryFormToken(String clinetToken) {
        if (StringUtils.isNotBlank(clinetToken)) {
            RedisUtil.getRu().setex("formToken_" + clinetToken, "1", 60 * 60);
            log.warn("防重複提交業務失敗_恢復成功formToken:" + clinetToken);
        }
    }

}

RedisUtil(此處不是重點,可自行實現)

package com.empire.utils;

import java.util.List;
import java.util.Map;
import java.util.Set;

import org.apache.log4j.Logger;

import redis.clients.jedis.BinaryClient.LIST_POSITION;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

/**
 * jredis工具類
 * 
 * @author Aaron
 */

public class RedisUtil {
    private static final Logger LOGGER = Logger.getLogger(RedisUtil.class);
    private static JedisPool    pool   = null;

    private static RedisUtil    ru     = new RedisUtil();

    private RedisUtil() {
        if (pool == null) {
            String ip = "";
            int port = 6379;
            String redisIpPort = Global.REDIS_STRING;
            String[] str = redisIpPort.split(";");
            if (null != str) {
                for (String ipAddress : str) {
                    if (null != ipAddress && !"".equals(ipAddress)) {
                        ip = ipAddress.split(":")[0];
                        port = Integer.parseInt(ipAddress.split(":")[1]);
                    }
                }
            }
            JedisPoolConfig config = new JedisPoolConfig();
            // 控制一個pool可分配多少個jedis實例,經過pool.getResource()來獲取;  
            // 若是賦值爲-1,則表示不限制;若是pool已經分配了maxActive個jedis實例,則此時pool的狀態爲exhausted(耗盡)。  
            config.setMaxTotal(10000);
            // 控制一個pool最多有多少個狀態爲idle(空閒的)的jedis實例。  
            config.setMaxIdle(2000);
            // 表示當borrow(引入)一個jedis實例時,最大的等待時間,若是超過等待時間,則直接拋出JedisConnectionException;  
            config.setMaxWaitMillis(1000 * 100);
            config.setTestOnBorrow(true);
            pool = new JedisPool(config, ip, port, 100000);
        }
    }

    /**
     * <p>
     * 設置key value,若是key已經存在則返回0,nx==> not exist
     * </p>
     * 
     * @param key
     * @param value
     * @return 成功返回1 若是存在 和 發生異常 返回 0
     */
    public Long setnx(byte[] key, byte[] value) {
        Jedis jedis = null;
        try {
            jedis = pool.getResource();
            return jedis.setnx(key, value);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
            return 0L;
        } finally {
            returnResource(pool, jedis);
        }
    }

    /**
     * 設置有效時間
     * 
     * @param key
     * @param seconds單位:秒
     * @return
     */
    public Long expire(byte[] key, int seconds) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.expire(key, seconds);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 向redis存入key和value,並釋放鏈接資源
     * </p>
     * <p>
     * 若是key已經存在 則覆蓋
     * </p>
     * 
     * @param key
     * @param value
     * @return 成功 返回OK 失敗返回 0
     */

    public String set(byte[] key, byte[] value) {
        Jedis jedis = null;
        try {
            jedis = pool.getResource();
            return jedis.set(key, value);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
            return "0";
        } finally {
            returnResource(pool, jedis);
        }
    }

    /**
     * <p>
     * 經過key獲取儲存在redis中的value
     * </p>
     * <p>
     * 並釋放鏈接
     * </p>
     * 
     * @param key
     * @return 成功返回value 失敗返回null
     */
    public byte[] get(byte[] key) {
        Jedis jedis = null;
        byte[] value = null;
        try {
            jedis = pool.getResource();
            value = jedis.get(key);
        } catch (Exception e) {
            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return value;
    }

    /**
     * <p>
     * 經過key獲取儲存在redis中的value
     * </p>
     * <p>
     * 並釋放鏈接
     * </p>
     * 
     * @param key
     * @return 成功返回value 失敗返回null
     */
    public String get(String key) {
        Jedis jedis = null;
        String value = null;
        try {
            jedis = pool.getResource();
            value = jedis.get(key);
        } catch (Exception e) {
            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return value;
    }

    /**
     * <p>
     * 向redis存入key和value,並釋放鏈接資源
     * </p>
     * <p>
     * 若是key已經存在 則覆蓋
     * </p>
     * 
     * @param key
     * @param value
     * @return 成功 返回OK 失敗返回 0
     */
    public String set(String key, String value) {
        Jedis jedis = null;
        try {
            jedis = pool.getResource();
            return jedis.set(key, value);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
            return "0";
        } finally {
            returnResource(pool, jedis);
        }
    }

    /**
     * <p>
     * 刪除指定的key,也能夠傳入一個包含key的數組
     * </p>
     * 
     * @param keys 一個key 也可使 string 數組
     * @return 返回刪除成功的個數
     */
    public Long del(byte[]... keys) {
        Jedis jedis = null;
        try {
            jedis = pool.getResource();
            return jedis.del(keys);
        } catch (Exception e) {
            LOGGER.error(e.getMessage());
            return 0L;
        } finally {
            returnResource(pool, jedis);
        }
    }

    /**
     * <p>
     * 刪除指定的key,也能夠傳入一個包含key的數組
     * </p>
     * 
     * @param keys 一個key 也可使 string 數組
     * @return 返回刪除成功的個數
     */
    public Long del(String... keys) {
        Jedis jedis = null;
        try {
            jedis = pool.getResource();
            return jedis.del(keys);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
            return 0L;
        } finally {
            returnResource(pool, jedis);
        }
    }

    /**
     * <p>
     * 經過key向指定的value值追加值
     * </p>
     * 
     * @param key
     * @param str
     * @return 成功返回 添加後value的長度 失敗 返回 添加的 value 的長度 異常返回0L
     */
    public Long append(String key, String str) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.append(key, str);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
            return 0L;
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 判斷key是否存在
     * </p>
     * 
     * @param key
     * @return true OR false
     */
    public Boolean exists(String key) {
        Jedis jedis = null;
        try {
            jedis = pool.getResource();
            return jedis.exists(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
            return false;
        } finally {
            returnResource(pool, jedis);
        }
    }

    /**
     * <p>
     * 設置key value,若是key已經存在則返回0,nx==> not exist
     * </p>
     * 
     * @param key
     * @param value
     * @return 成功返回1 若是存在 和 發生異常 返回 0
     */
    public Long setnx(String key, String value) {
        Jedis jedis = null;
        try {
            jedis = pool.getResource();
            return jedis.setnx(key, value);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
            return 0L;
        } finally {
            returnResource(pool, jedis);
        }
    }

    /**
     * <p>
     * 設置key value並制定這個鍵值的有效期
     * </p>
     * 
     * @param key
     * @param value
     * @param seconds 單位:秒
     * @return 成功返回OK 失敗和異常返回null
     */
    public String setex(String key, String value, int seconds) {
        Jedis jedis = null;
        String res = null;
        try {
            jedis = pool.getResource();
            res = jedis.setex(key, seconds, value);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * 設置有效時間
     * 
     * @param key
     * @param seconds單位:秒
     * @return
     */
    public Long expire(String key, int seconds) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.expire(key, seconds);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key 和offset 從指定的位置開始將原先value替換
     * </p>
     * <p>
     * 下標從0開始,offset表示從offset下標開始替換
     * </p>
     * <p>
     * 若是替換的字符串長度太小則會這樣
     * </p>
     * <p>
     * example:
     * </p>
     * <p>
     * value : bigsea@zto.cn
     * </p>
     * <p>
     * str : abc
     * </p>
     * <P>
     * 從下標7開始替換 則結果爲
     * </p>
     * <p>
     * RES : bigsea.abc.cn
     * </p>
     * 
     * @param key
     * @param str
     * @param offset 下標位置
     * @return 返回替換後 value 的長度
     */
    public Long setrange(String key, String str, int offset) {
        Jedis jedis = null;
        try {
            jedis = pool.getResource();
            return jedis.setrange(key, offset, str);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
            return 0L;
        } finally {
            returnResource(pool, jedis);
        }
    }

    /**
     * <p>
     * 經過批量的key獲取批量的value
     * </p>
     * 
     * @param keys string數組 也能夠是一個key
     * @return 成功返回value的集合, 失敗返回null的集合 ,異常返回空
     */
    public List<String> mget(String... keys) {
        Jedis jedis = null;
        List<String> values = null;
        try {
            jedis = pool.getResource();
            values = jedis.mget(keys);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return values;
    }

    /**
     * <p>
     * 批量的設置key:value,能夠一個
     * </p>
     * <p>
     * example:
     * </p>
     * <p>
     * obj.mset(new String[]{"key2","value1","key2","value2"})
     * </p>
     * 
     * @param keysvalues
     * @return 成功返回OK 失敗 異常 返回 null
     */
    public String mset(String... keysvalues) {
        Jedis jedis = null;
        String res = null;
        try {
            jedis = pool.getResource();
            res = jedis.mset(keysvalues);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 批量的設置key:value,能夠一個,若是key已經存在則會失敗,操做會回滾
     * </p>
     * <p>
     * example:
     * </p>
     * <p>
     * obj.msetnx(new String[]{"key2","value1","key2","value2"})
     * </p>
     * 
     * @param keysvalues
     * @return 成功返回1 失敗返回0
     */
    public Long msetnx(String... keysvalues) {
        Jedis jedis = null;
        Long res = 0L;
        try {
            jedis = pool.getResource();
            res = jedis.msetnx(keysvalues);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 設置key的值,並返回一箇舊值
     * </p>
     * 
     * @param key
     * @param value
     * @return 舊值 若是key不存在 則返回null
     */
    public String getset(String key, String value) {
        Jedis jedis = null;
        String res = null;
        try {
            jedis = pool.getResource();
            res = jedis.getSet(key, value);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過下標 和key 獲取指定下標位置的 value
     * </p>
     * 
     * @param key
     * @param startOffset 開始位置 從0 開始 負數表示從右邊開始截取
     * @param endOffset
     * @return 若是沒有返回null
     */
    public String getrange(String key, int startOffset, int endOffset) {
        Jedis jedis = null;
        String res = null;
        try {
            jedis = pool.getResource();
            res = jedis.getrange(key, startOffset, endOffset);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key 對value進行加值+1操做,當value不是int類型時會返回錯誤,當key不存在是則value爲1
     * </p>
     * 
     * @param key
     * @return 加值後的結果
     */
    public Long incr(String key) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.incr(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key給指定的value加值,若是key不存在,則這是value爲該值
     * </p>
     * 
     * @param key
     * @param integer
     * @return
     */
    public Long incrBy(String key, Long integer) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.incrBy(key, integer);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 對key的值作減減操做,若是key不存在,則設置key爲-1
     * </p>
     * 
     * @param key
     * @return
     */
    public Long decr(String key) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.decr(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 減去指定的值
     * </p>
     * 
     * @param key
     * @param integer
     * @return
     */
    public Long decrBy(String key, Long integer) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.decrBy(key, integer);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key獲取value值的長度
     * </p>
     * 
     * @param key
     * @return 失敗返回null
     */
    public Long serlen(String key) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.strlen(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key給field設置指定的值,若是key不存在,則先建立
     * </p>
     * 
     * @param key
     * @param field 字段
     * @param value
     * @return 若是存在返回0 異常返回null
     */
    public Long hset(String key, String field, String value) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.hset(key, field, value);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key給field設置指定的值,若是key不存在則先建立,若是field已經存在,返回0
     * </p>
     * 
     * @param key
     * @param field
     * @param value
     * @return
     */
    public Long hsetnx(String key, String field, String value) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.hsetnx(key, field, value);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key同時設置 hash的多個field
     * </p>
     * 
     * @param key
     * @param hash
     * @return 返回OK 異常返回null
     */
    public String hmset(String key, Map<String, String> hash) {
        Jedis jedis = null;
        String res = null;
        try {
            jedis = pool.getResource();
            res = jedis.hmset(key, hash);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key 和 field 獲取指定的 value
     * </p>
     * 
     * @param key
     * @param field
     * @return 沒有返回null
     */
    public String hget(String key, String field) {
        Jedis jedis = null;
        String res = null;
        try {
            jedis = pool.getResource();
            res = jedis.hget(key, field);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key 和 fields 獲取指定的value 若是沒有對應的value則返回null
     * </p>
     * 
     * @param key
     * @param fields 可使 一個String 也能夠是 String數組
     * @return
     */
    public List<String> hmget(String key, String... fields) {
        Jedis jedis = null;
        List<String> res = null;
        try {
            jedis = pool.getResource();
            res = jedis.hmget(key, fields);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key給指定的field的value加上給定的值
     * </p>
     * 
     * @param key
     * @param field
     * @param value
     * @return
     */
    public Long hincrby(String key, String field, Long value) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.hincrBy(key, field, value);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key和field判斷是否有指定的value存在
     * </p>
     * 
     * @param key
     * @param field
     * @return
     */
    public Boolean hexists(String key, String field) {
        Jedis jedis = null;
        Boolean res = false;
        try {
            jedis = pool.getResource();
            res = jedis.hexists(key, field);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key返回field的數量
     * </p>
     * 
     * @param key
     * @return
     */
    public Long hlen(String key) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.hlen(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;

    }

    /**
     * <p>
     * 經過key 刪除指定的 field
     * </p>
     * 
     * @param key
     * @param fields 能夠是 一個 field 也能夠是 一個數組
     * @return
     */
    public Long hdel(String key, String... fields) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.hdel(key, fields);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key返回全部的field
     * </p>
     * 
     * @param key
     * @return
     */
    public Set<String> hkeys(String key) {
        Jedis jedis = null;
        Set<String> res = null;
        try {
            jedis = pool.getResource();
            res = jedis.hkeys(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key返回全部和key有關的value
     * </p>
     * 
     * @param key
     * @return
     */
    public List<String> hvals(String key) {
        Jedis jedis = null;
        List<String> res = null;
        try {
            jedis = pool.getResource();
            res = jedis.hvals(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key獲取全部的field和value
     * </p>
     * 
     * @param key
     * @return
     */
    public Map<String, String> hgetall(String key) {
        Jedis jedis = null;
        Map<String, String> res = null;
        try {
            jedis = pool.getResource();
            res = jedis.hgetAll(key);
        } catch (Exception e) {
            // TODO  
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key向list頭部添加字符串
     * </p>
     * 
     * @param key
     * @param strs 可使一個string 也可使string數組
     * @return 返回list的value個數
     */
    public Long lpush(String key, String... strs) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.lpush(key, strs);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key向list尾部添加字符串
     * </p>
     * 
     * @param key
     * @param strs 可使一個string 也可使string數組
     * @return 返回list的value個數
     */
    public Long rpush(String key, String... strs) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.rpush(key, strs);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key在list指定的位置以前或者以後 添加字符串元素
     * </p>
     * 
     * @param key
     * @param where LIST_POSITION枚舉類型
     * @param pivot list裏面的value
     * @param value 添加的value
     * @return
     */
    public Long linsert(String key, LIST_POSITION where, String pivot, String value) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.linsert(key, where, pivot, value);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key設置list指定下標位置的value
     * </p>
     * <p>
     * 若是下標超過list裏面value的個數則報錯
     * </p>
     * 
     * @param key
     * @param index 從0開始
     * @param value
     * @return 成功返回OK
     */
    public String lset(String key, Long index, String value) {
        Jedis jedis = null;
        String res = null;
        try {
            jedis = pool.getResource();
            res = jedis.lset(key, index, value);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key從對應的list中刪除指定的count個 和 value相同的元素
     * </p>
     * 
     * @param key
     * @param count 當count爲0時刪除所有
     * @param value
     * @return 返回被刪除的個數
     */
    public Long lrem(String key, long count, String value) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.lrem(key, count, value);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key保留list中從strat下標開始到end下標結束的value值
     * </p>
     * 
     * @param key
     * @param start
     * @param end
     * @return 成功返回OK
     */
    public String ltrim(String key, long start, long end) {
        Jedis jedis = null;
        String res = null;
        try {
            jedis = pool.getResource();
            res = jedis.ltrim(key, start, end);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key從list的頭部刪除一個value,並返回該value
     * </p>
     * 
     * @param key
     * @return
     */
    synchronized public String lpop(String key) {
        Jedis jedis = null;
        String res = null;
        try {
            jedis = pool.getResource();
            res = jedis.lpop(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key從list尾部刪除一個value,並返回該元素
     * </p>
     * 
     * @param key
     * @return
     */
    synchronized public String rpop(String key) {
        Jedis jedis = null;
        String res = null;
        try {
            jedis = pool.getResource();
            res = jedis.rpop(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key從一個list的尾部刪除一個value並添加到另外一個list的頭部,並返回該value
     * </p>
     * <p>
     * 若是第一個list爲空或者不存在則返回null
     * </p>
     * 
     * @param srckey
     * @param dstkey
     * @return
     */
    public String rpoplpush(String srckey, String dstkey) {
        Jedis jedis = null;
        String res = null;
        try {
            jedis = pool.getResource();
            res = jedis.rpoplpush(srckey, dstkey);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key獲取list中指定下標位置的value
     * </p>
     * 
     * @param key
     * @param index
     * @return 若是沒有返回null
     */
    public String lindex(String key, long index) {
        Jedis jedis = null;
        String res = null;
        try {
            jedis = pool.getResource();
            res = jedis.lindex(key, index);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key返回list的長度
     * </p>
     * 
     * @param key
     * @return
     */
    public Long llen(String key) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.llen(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key獲取list指定下標位置的value
     * </p>
     * <p>
     * 若是start 爲 0 end 爲 -1 則返回所有的list中的value
     * </p>
     * 
     * @param key
     * @param start
     * @param end
     * @return
     */
    public List<String> lrange(String key, long start, long end) {
        Jedis jedis = null;
        List<String> res = null;
        try {
            jedis = pool.getResource();
            res = jedis.lrange(key, start, end);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key向指定的set中添加value
     * </p>
     * 
     * @param key
     * @param members 能夠是一個String 也能夠是一個String數組
     * @return 添加成功的個數
     */
    public Long sadd(String key, String... members) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.sadd(key, members);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key刪除set中對應的value值
     * </p>
     * 
     * @param key
     * @param members 能夠是一個String 也能夠是一個String數組
     * @return 刪除的個數
     */
    public Long srem(String key, String... members) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.srem(key, members);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key隨機刪除一個set中的value並返回該值
     * </p>
     * 
     * @param key
     * @return
     */
    public String spop(String key) {
        Jedis jedis = null;
        String res = null;
        try {
            jedis = pool.getResource();
            res = jedis.spop(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key獲取set中的差集
     * </p>
     * <p>
     * 以第一個set爲標準
     * </p>
     * 
     * @param keys 可使一個string 則返回set中全部的value 也能夠是string數組
     * @return
     */
    public Set<String> sdiff(String... keys) {
        Jedis jedis = null;
        Set<String> res = null;
        try {
            jedis = pool.getResource();
            res = jedis.sdiff(keys);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key獲取set中的差集並存入到另外一個key中
     * </p>
     * <p>
     * 以第一個set爲標準
     * </p>
     * 
     * @param dstkey 差集存入的key
     * @param keys 可使一個string 則返回set中全部的value 也能夠是string數組
     * @return
     */
    public Long sdiffstore(String dstkey, String... keys) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.sdiffstore(dstkey, keys);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key獲取指定set中的交集
     * </p>
     * 
     * @param keys 可使一個string 也能夠是一個string數組
     * @return
     */
    public Set<String> sinter(String... keys) {
        Jedis jedis = null;
        Set<String> res = null;
        try {
            jedis = pool.getResource();
            res = jedis.sinter(keys);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key獲取指定set中的交集 並將結果存入新的set中
     * </p>
     * 
     * @param dstkey
     * @param keys 可使一個string 也能夠是一個string數組
     * @return
     */
    public Long sinterstore(String dstkey, String... keys) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.sinterstore(dstkey, keys);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key返回全部set的並集
     * </p>
     * 
     * @param keys 可使一個string 也能夠是一個string數組
     * @return
     */
    public Set<String> sunion(String... keys) {
        Jedis jedis = null;
        Set<String> res = null;
        try {
            jedis = pool.getResource();
            res = jedis.sunion(keys);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key返回全部set的並集,並存入到新的set中
     * </p>
     * 
     * @param dstkey
     * @param keys 可使一個string 也能夠是一個string數組
     * @return
     */
    public Long sunionstore(String dstkey, String... keys) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.sunionstore(dstkey, keys);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key將set中的value移除並添加到第二個set中
     * </p>
     * 
     * @param srckey 須要移除的
     * @param dstkey 添加的
     * @param member set中的value
     * @return
     */
    public Long smove(String srckey, String dstkey, String member) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.smove(srckey, dstkey, member);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key獲取set中value的個數
     * </p>
     * 
     * @param key
     * @return
     */
    public Long scard(String key) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.scard(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key判斷value是不是set中的元素
     * </p>
     * 
     * @param key
     * @param member
     * @return
     */
    public Boolean sismember(String key, String member) {
        Jedis jedis = null;
        Boolean res = null;
        try {
            jedis = pool.getResource();
            res = jedis.sismember(key, member);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key獲取set中隨機的value,不刪除元素
     * </p>
     * 
     * @param key
     * @return
     */
    public String srandmember(String key) {
        Jedis jedis = null;
        String res = null;
        try {
            jedis = pool.getResource();
            res = jedis.srandmember(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key獲取set中全部的value
     * </p>
     * 
     * @param key
     * @return
     */
    public Set<String> smembers(String key) {
        Jedis jedis = null;
        Set<String> res = null;
        try {
            jedis = pool.getResource();
            res = jedis.smembers(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key向zset中添加value,score,其中score就是用來排序的
     * </p>
     * <p>
     * 若是該value已經存在則根據score更新元素
     * </p>
     * 
     * @param key
     * @param score
     * @param member
     * @return
     */
    public Long zadd(String key, double score, String member) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.zadd(key, score, member);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key刪除在zset中指定的value
     * </p>
     * 
     * @param key
     * @param members 可使一個string 也能夠是一個string數組
     * @return
     */
    public Long zrem(String key, String... members) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.zrem(key, members);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key增長該zset中value的score的值
     * </p>
     * 
     * @param key
     * @param score
     * @param member
     * @return
     */
    public Double zincrby(String key, double score, String member) {
        Jedis jedis = null;
        Double res = null;
        try {
            jedis = pool.getResource();
            res = jedis.zincrby(key, score, member);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key返回zset中value的排名
     * </p>
     * <p>
     * 下標從小到大排序
     * </p>
     * 
     * @param key
     * @param member
     * @return
     */
    public Long zrank(String key, String member) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.zrank(key, member);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key返回zset中value的排名
     * </p>
     * <p>
     * 下標從大到小排序
     * </p>
     * 
     * @param key
     * @param member
     * @return
     */
    public Long zrevrank(String key, String member) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.zrevrank(key, member);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key將獲取score從start到end中zset的value
     * </p>
     * <p>
     * socre從大到小排序
     * </p>
     * <p>
     * 當start爲0 end爲-1時返回所有
     * </p>
     * 
     * @param key
     * @param start
     * @param end
     * @return
     */
    public Set<String> zrevrange(String key, long start, long end) {
        Jedis jedis = null;
        Set<String> res = null;
        try {
            jedis = pool.getResource();
            res = jedis.zrevrange(key, start, end);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key返回指定score內zset中的value
     * </p>
     * 
     * @param key
     * @param max
     * @param min
     * @return
     */
    public Set<String> zrangebyscore(String key, String max, String min) {
        Jedis jedis = null;
        Set<String> res = null;
        try {
            jedis = pool.getResource();
            res = jedis.zrevrangeByScore(key, max, min);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key返回指定score內zset中的value
     * </p>
     * 
     * @param key
     * @param max
     * @param min
     * @return
     */
    public Set<String> zrangeByScore(String key, double max, double min) {
        Jedis jedis = null;
        Set<String> res = null;
        try {
            jedis = pool.getResource();
            res = jedis.zrevrangeByScore(key, max, min);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 返回指定區間內zset中value的數量
     * </p>
     * 
     * @param key
     * @param min
     * @param max
     * @return
     */
    public Long zcount(String key, String min, String max) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.zcount(key, min, max);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key返回zset中的value個數
     * </p>
     * 
     * @param key
     * @return
     */
    public Long zcard(String key) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.zcard(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key獲取zset中value的score值
     * </p>
     * 
     * @param key
     * @param member
     * @return
     */
    public Double zscore(String key, String member) {
        Jedis jedis = null;
        Double res = null;
        try {
            jedis = pool.getResource();
            res = jedis.zscore(key, member);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key刪除給定區間內的元素
     * </p>
     * 
     * @param key
     * @param start
     * @param end
     * @return
     */
    public Long zremrangeByRank(String key, long start, long end) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.zremrangeByRank(key, start, end);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key刪除指定score內的元素
     * </p>
     * 
     * @param key
     * @param start
     * @param end
     * @return
     */
    public Long zremrangeByScore(String key, double start, double end) {
        Jedis jedis = null;
        Long res = null;
        try {
            jedis = pool.getResource();
            res = jedis.zremrangeByScore(key, start, end);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 返回知足pattern表達式的全部key
     * </p>
     * <p>
     * keys(*)
     * </p>
     * <p>
     * 返回全部的key
     * </p>
     * 
     * @param pattern
     * @return
     */
    public Set<String> keys(String pattern) {
        Jedis jedis = null;
        Set<String> res = null;
        try {
            jedis = pool.getResource();
            res = jedis.keys(pattern);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * <p>
     * 經過key判斷值得類型
     * </p>
     * 
     * @param key
     * @return
     */
    public String type(String key) {
        Jedis jedis = null;
        String res = null;
        try {
            jedis = pool.getResource();
            res = jedis.type(key);
        } catch (Exception e) {

            LOGGER.error(e.getMessage());
        } finally {
            returnResource(pool, jedis);
        }
        return res;
    }

    /**
     * 返還到鏈接池
     * 
     * @param pool
     * @param jedis
     */
    public static void returnResource(JedisPool pool, Jedis jedis) {
        if (jedis != null) {
            pool.returnResource(jedis);
        }
    }

    public static RedisUtil getRu() {
        return ru;
    }

    public static void setRu(RedisUtil ru) {
        RedisUtil.ru = ru;
    }
}

 

    注:以上列子也能夠從新生成個token用於恢復到redis中,而後將新token傳遞到前臺替換舊token,用於實現單頁面能夠點擊多個提交按鈕的狀況;本設計以用於千萬級大型項目真實使用,無端障/bug;讀者可直接在項目中使用。

    最後總結:因爲非ajax表單提交是,只須要在controller表單入口處和表單提交方法上各添加一個註解就能夠實現所有功能,故沒貼出代碼。若是你們不會,能夠在下方留言,或者聯繫博主交流。

@FormToken(save = true)
//表單入口方法
@FormToken(remove = true, pass = false)
//表單提交方法

    以上是博主本次文章的所有內容,若是你們以爲博主的文章還不錯,請點贊;若是您對博主其它服務器技術或者博主本人感興趣,請關注博主博客,而且歡迎隨時跟博主溝通交流。

相關文章
相關標籤/搜索