SpringMVC+Mybatis+WebSocket+Task定时任务

package com.acl.utils; import org.apache.commons.codec.binary.Hex; import org.apache.commons.lang.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import javax.servlet.http.HttpServletRequest; import java.security.MessageDigest; import java.text.DateFormat; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.*; import java.util.Map.Entry; import java.util.concurrent.TimeUnit; /** * @Filename DigestUtil.java * @Description 签名工具类 * @Version 1.0 * @Author bohr * @Email qzhanbo@yiji.com * @History <li>Author: bohr.qiu</li> <li>Date: 2012-10-15</li> <li>Version: 1.0 * </li> <li>Content: create</li> */ public class DigestUtil { private static final Logger logger = LoggerFactory.getLogger(DigestUtil.class.getName()); private static final String TIME_ZONE = "UTC"; private static final String UTC_TIME_FORMAT = "yyyy-MM-dd'T'HH:mm:ss.SSS Z"; /** * 签名编码 */ public static final String UTF8 = "utf-8"; /** * 签名key */ public static final String SIGN_KEY = "sign"; /** * 渠道id key */ public static final String CHANNEL_ID_KEY = "channelId"; /** * 签名类型key，支持DigestALGEnum */ public static final String SIGN_TYPE_KEY = "signType"; /** * utc时间key */ public static final String TIMESTAMP_KEY = "utc_time_stamp"; /** * 签名算法 * * @Filename DigestUtil.java * @Description * @Version 1.0 * @Author bohr.qiu * @Email qzhanbo@yiji.com * @History <li>Author: bohr.qiu</li> <li>Date: 2013-1-5</li> <li>Version: * 1.0</li> <li>Content: create</li> */ public static enum DigestALGEnum { SHA256("SHA-256"), MD5("MD5"); private String name; DigestALGEnum(String name) { this.name = name; } public static DigestALGEnum getByName(String name) { for (DigestALGEnum _enum : values()) { if (_enum.getName().equals(name)) { return _enum; } } return null; } public String getName() { return name; } } /** * 以Map中key的字符顺序排序后签名，如果secretKey不为空，排在最后面签名。<br/> * 比如：Map中值如下：<br/> * keyA=valueA<br/> * keyB=valueB<br/> * keyA1=valueA1<br/> * <br/> * security_check_code为yjf<br/> * <p/> * 待签名字符串为：<br/> * keyA=valueA&keyA1=valueA1&keyB=valueByjf<br/> * <b>注意:</b>SIGN_KEY不会被签名 * * @param dataMap * @param securityCheckKey 密钥 * @param de 摘要算法 * @return */ public static <T> String digest(Map<String, T> dataMap, String securityCheckKey, DigestALGEnum de) { return digest(dataMap, securityCheckKey, de, UTF8); } /** * 签名并带上时间戳 * * @param dataMap * @param securityCheckKey * @param de * @param charset * @return */ public static String digestWithTimeStamp(Map<String, Object> dataMap, String securityCheckKey, DigestALGEnum de, String charset) { dataMap.put(TIMESTAMP_KEY, getUTCTime()); return digest(dataMap, securityCheckKey, de, charset); } /** * 签名并带上时间戳，使用utf-8编码 * * @param dataMap * @param securityCheckKey * @param de * @return */ public static String digestWithTimeStamp(Map<String, Object> dataMap, String securityCheckKey, DigestALGEnum de) { return digestWithTimeStamp(dataMap, securityCheckKey, de, UTF8); } /** * 以Map中key的字符顺序排序后签名，如果secretKey不为空，排在最后面签名。<br/> * 比如：Map中值如下：<br/> * keyA=valueA<br/> * keyB=valueB<br/> * keyA1=valueA1<br/> * <br/> * security_check_code为yjf<br/> * <p/> * 待签名字符串为：<br/> * keyA=valueA&keyA1=valueA1&keyB=valueByjf<br/> * <b>注意:</b>SIGN_KEY不会被签名 * * @param dataMap * @param securityCheckKey 密钥 * @param de 摘要算法 * @return */ public static <T> String digest(Map<String, T> dataMap, String securityCheckKey, DigestALGEnum de, String encoding) { if (dataMap == null) { throw new IllegalArgumentException("数据不能为空"); } if (dataMap.isEmpty()) { return null; } if (securityCheckKey == null) { throw new IllegalArgumentException("安全校验码数据不能为空"); } if (de == null) { throw new IllegalArgumentException("摘要算法不能为空"); } if (StringUtils.isBlank(encoding)) { throw new IllegalArgumentException("字符集不能为空"); } TreeMap<String, T> treeMap = new TreeMap<String, T>(dataMap); StringBuilder sb = new StringBuilder(); for (Entry<String, T> entry : treeMap.entrySet()) { if (entry.getValue() == null) { throw new IllegalArgumentException(entry.getKey() + " 待签名值不能为空"); } if (entry.getKey().equals(SIGN_KEY)) { continue; } sb.append(entry.getKey()).append("=").append(entry.getValue().toString()).append("&"); } sb.deleteCharAt(sb.length() - 1); sb.append(securityCheckKey); byte[] toDigest; try { String str = sb.toString(); toDigest = str.getBytes(encoding); if (logger.isDebugEnabled()) { logger.debug("待签名url:" + str); } MessageDigest md = MessageDigest.getInstance(de.getName()); md.update(toDigest); return new String(Hex.encodeHex(md.digest())); } catch (Exception e) { throw new RuntimeException("签名失败", e); } } private static String getSign(Map<String, ?> params) { Object para = params.get(SIGN_KEY); if (para == null) { throw new IllegalArgumentException(SIGN_KEY + "不能为空"); } return StringUtils.trimToEmpty(para.toString()); } private static String getParameter(HttpServletRequest request, String parameter) { String para = request.getParameter(parameter); if (para == null) { throw new IllegalArgumentException(parameter + "不能为空"); } return StringUtils.trimToEmpty(para); } /** * 从request中获取待签名数据，校验签名是否正确 * * @param request * @param securityCheckKey * @param de 签名算法,如果request中有SIGN_TYPE_KEY，则以SIGN_TYPE_KEY指定的摘要算法摘要 * @param charset 字符集 * @param expireTime 过期时间 * @param timeUnit 过期时间单位 */ public static void checkWithTimestamp(HttpServletRequest request, String securityCheckKey, DigestALGEnum de, String charset, long expireTime, TimeUnit timeUnit) { String timestamp = getParameter(request, TIMESTAMP_KEY); checkTimeout(timestamp, expireTime, timeUnit); check(request, securityCheckKey, de, charset); } /** * 从request中获取待签名数据，校验签名是否正确 * * @param request * @param securityCheckKey * @param de 签名算法,如果request中有SIGN_TYPE_KEY，则以SIGN_TYPE_KEY指定的摘要算法摘要 * @param charset 编码 * @return */ public static void check(HttpServletRequest request, String securityCheckKey, DigestALGEnum de, String charset) { if (securityCheckKey == null) { throw new IllegalArgumentException("安全校验码不能为空"); } if (request == null) { throw new IllegalArgumentException("request对象不能为空"); } String signType = request.getParameter(SIGN_TYPE_KEY); signType = (signType == null) ? de.getName() : signType; if (DigestALGEnum.getByName(signType) == null) { throw new IllegalArgumentException("不支持的摘要算法类型:" + signType); } String sign = getParameter(request, SIGN_KEY); @SuppressWarnings("unchecked") TreeMap<String, String[]> treeMap = new TreeMap<String, String[]>(request.getParameterMap()); StringBuilder sb = new StringBuilder(); for (Entry<String, String[]> entry : treeMap.entrySet()) { if