定时跑批报表项目（ssm架构）

package com.extjfinal.component.redis; import java.util.HashMap; import java.util.LinkedHashSet; import java.util.List; import java.util.Map; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; import redis.clients.util.SafeEncoder; import com.jfinal.log.Log; import com.sycloud.rptctl.component.util.Config; import com.sycloud.rptctl.component.util.StrUtils; import com.sycloud.rptctl.component.util.serializable.SerializerManage; /** * redis客户端 * * 2016年5月10日 下午2:34:30 flyfox 330627517@qq.com */ public class JedisClient { private static Log logger = Log.getLog(JedisClient.class); private static JedisClient instance = null; public static JedisClient getInstance() { if (instance == null) { synchronized (JedisClient.class) { if (instance == null) { String password = Config.getStr("redis.password"); password = StrUtils.isEmpty(password) ? null : password; instance = new JedisClient(Config.getStr("redis.host"), Config.getToInt("redis.port"), Config.getToInt("redis.maxIdel"), Config.getToInt("redis.maxWait"), Config.getToInt("redis.poolTimeWait"), password); } } } return instance; } public static void resetInstance() { instance = null; } private JedisPoolConfig config; private JedisPool pool; private JedisClient(String host, int port, int maxIdel, int maxWait, int poolTimeWait, String password) { config = new JedisPoolConfig(); config.setMaxIdle(maxIdel); config.setMaxWaitMillis(maxWait); if (null == password) pool = new JedisPool(config, host, port, poolTimeWait); else { pool = new JedisPool(config, host, port, poolTimeWait, password); } } public Long expire(String key, int seconds) { try (Jedis jedis = pool.getResource()) { return jedis.expire(key, seconds); } } public Long ttl(String key) { try (Jedis jedis = pool.getResource()) { return jedis.ttl(key); } } public byte[] get(byte[] key) { try (Jedis jedis = pool.getResource()) { return jedis.get(key); } } public void set(byte[] key, byte[] val) { try (Jedis jedis = pool.getResource()) { jedis.set(key, val); } } public void set(byte[] key, int seconds, byte[] val) { try (Jedis jedis = pool.getResource()) { jedis.setex(key, seconds, val); } } public String get(String key) { try (Jedis jedis = pool.getResource()) { return jedis.get(key); } } public void set(String key, String val) { try (Jedis jedis = pool.getResource()) { jedis.set(key, val); } } public void set(String key, int seconds, String val) { try (Jedis jedis = pool.getResource()) { jedis.setex(key, seconds, val); } } public boolean setnx(String key) { try (Jedis jedis = pool.getResource()) { return jedis.setnx(key, "setnx") == 1; } } public long setnx(String key, String val) { try (Jedis jedis = pool.getResource()) { return jedis.setnx(key, val); } } public Long incr(String key) { try (Jedis jedis = pool.getResource()) { return jedis.incr(key); } } public Long incrBy(String key, long value) { try (Jedis jedis = pool.getResource()) { return jedis.incrBy(key, value); } } public Long decr(String key) { try (Jedis jedis = pool.getResource()) { return jedis.decr(key); } } public Long decrBy(String key, long value) { try (Jedis jedis = pool.getResource()) { return jedis.decrBy(key, value); } } public void append(String key, String str) { try (Jedis jedis = pool.getResource()) { jedis.append(key, str); } } public String setObj(String key, Object data) { byte[] vals = null; try { vals = SerializerManage.serialize(data); } catch (Exception e) { logger.error("SerializerManage error", e); return null; } if (vals == null) { return null; } try (Jedis jedis = pool.getResource()) { return jedis.set(SafeEncoder.encode(key), vals); } } public String setObj(String key, int seconds, Object data) { byte[] vals = null; try { vals = SerializerManage.serialize(data); } catch (Exception e) { logger.error("SerializerManage error", e); return null; } if (vals == null) { return null; } try (Jedis jedis = pool.getResource()) { return jedis.setex(SafeEncoder.encode(key), seconds, vals); } } @SuppressWarnings("unchecked") public <T> T getObj(String key) { byte[] vals = null; try (Jedis jedis = pool.getResource()) { vals = jedis.get(SafeEncoder.encode(key)); } if (vals == null) { return null; } try { return (T) SerializerManage.deserialize(vals); } catch (Exception e) { logger.error("SerializerManage error", e); return null; } } /** * 移除给定的key * * @param key */ public void del(String key) { try (Jedis jedis = pool.getResource()) { jedis.del(key); } } /** * 移除给定的key * * @param key */ public void del(byte[] key) { try (Jedis jedis = pool.getResource()) { jedis.del(key); } } public void flushAll() { try (Jedis jedis = pool.getResource()) { jedis.flushAll(); } } public long dbSize() { try (Jedis jedis = pool.getResource()) { return jedis.dbSize(); } } /** * 移除给定key的生存时间 将这个 key 从『易失的』(带生存时间 key )转换成『持久的』(一个不带生存时间、永不过期的 key ) * * @param key */ public void persist(String key) { try (Jedis jedis = pool.getResource()) { jedis.persist(key); } } /** * 批量将值插入sorted sets中，如果member对应的value不存在，则初始化，否则更新此member对应value * * @param key * jedis中key * @param scoreMembers * 添加(修改的)sets , key:score,value:member */ public void zadd(String key, Map<String, Double> scoreMembers, int validSecond) { try (Jedis jedis = pool.getResource()) { jedis.zadd(key, scoreMembers); jedis.expire(key, validSecond); // jedis.zremrangeByRank(key, rankSize, -1); // jedis.ltrim(key, 0, rankSize); } } public void zremrangeByRank(String key, int limit) { try (Jedis jedis = pool.getResource()) { jedis.zremrangeByRank(key, 0, -limit - 1); } } /** * 将一个或多个member元素及其score值加入到有序集key当中。 * 如果某个member已经是有序集的成员，那么更新这个member的score值 * ，并通过重新插入这个member元素，来保证该member在正确的位置上。 score值可以是整数值或双精度浮点数。 * 如果key不存在，则创建一个空的有序集并执行ZADD操作。 当key存在但不是有序集类型时，返回一个错误。 * * @param key * jedis中对应的key * @param score * 分数，double * @param member * 当前分数对应的对象 */ public void zadd(String key, double score, String member, int validSecond) { try (Jedis jedis = pool.getResource()) { jedis.zadd(key, score, member); jedis.expire(key, validSecond); } } /** * 将一个或多个member元素及其score值加入到有序集key当中。 * 如果某个member已经是有序集的成员，那么更新这个member的score值 * ，并通过重新插入这个member元素，来保证该member在正确的位置上。 score值可以是整数值或双精度浮点数。 * 如果key不存在，则创建一个空的有序集并执行ZADD操作。 当key存在但不是有序集类型时，返回一个错误。 * * @param key * jedis中对应的key * @param score * 分数，double * @param member * 当前分数对应的对象 */ public void zadd(String key, double score, String member) { try (Jedis jedis = pool.getResource()) { jedis.zadd(key, score, member); } } /** * 返回升序排名的用户名和分数的集合,即分数从最低到最高的排列，分数相等的两个member根据字典排序顺序返回。