From 76877a0625c5936222e001bce6a28cecfb8b06b2 Mon Sep 17 00:00:00 2001 From: RenKaiGe-Office Date: Wed, 18 Jul 2018 10:26:42 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B0=86fdfs=E7=9A=84=E8=B7=AF=E5=BE=84?= =?UTF-8?q?=E6=8F=90=E5=8F=96=E5=88=B0=E9=85=8D=E7=BD=AE=E6=96=87=E4=BB=B6?= =?UTF-8?q?=E4=B8=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/nis/util/Configurations.java | 2 +- src/main/java/com/nis/util/JedisUtils.java | 6 - src/main/java/com/nis/util/JedisUtils2.java | 1422 ----------------- .../web/service/fdfs/FileManagerConfig.java | 6 +- src/main/resources/fastdfs-client.properties | 4 + src/main/resources/fdfs_client.conf | 1 + src/main/resources/jdbc.properties | 4 +- 7 files changed, 14 insertions(+), 1431 deletions(-) delete mode 100644 src/main/java/com/nis/util/JedisUtils2.java diff --git a/src/main/java/com/nis/util/Configurations.java b/src/main/java/com/nis/util/Configurations.java index 04c26f1..1338387 100644 --- a/src/main/java/com/nis/util/Configurations.java +++ b/src/main/java/com/nis/util/Configurations.java @@ -2,7 +2,6 @@ package com.nis.util; import java.io.File; import java.util.Map; import java.util.Properties; -import com.nis.util.StringUtil; @@ -16,6 +15,7 @@ public final class Configurations { prop.load(Configurations.class.getResourceAsStream("/applicationLog-hive.properties")); prop.load(Configurations.class.getResourceAsStream("/applicationConfig-maatOracle.properties")); prop.load(Configurations.class.getResourceAsStream("/applicationConfig-rule.properties")); + prop.load(Configurations.class.getResourceAsStream("/fastdfs-client.properties")); } catch (Exception e) { prop = null; diff --git a/src/main/java/com/nis/util/JedisUtils.java b/src/main/java/com/nis/util/JedisUtils.java index c7ebcd4..2baf23e 100644 --- a/src/main/java/com/nis/util/JedisUtils.java +++ b/src/main/java/com/nis/util/JedisUtils.java @@ -1,15 +1,11 @@ package com.nis.util; import java.util.List; -import java.util.Map; -import java.util.Set; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.google.common.collect.Lists; -import com.google.common.collect.Maps; -import com.google.common.collect.Sets; import com.nis.web.service.SpringContextHolder; import redis.clients.jedis.Jedis; @@ -18,7 +14,6 @@ import redis.clients.jedis.exceptions.JedisException; public class JedisUtils { private static Logger logger = LoggerFactory.getLogger(JedisUtils.class); - private static JedisPool jedisPool = SpringContextHolder.getBean(JedisPool.class); /** @@ -31,7 +26,6 @@ public class JedisUtils { Jedis jedis = null; try { jedis = getResource(redisDb); - if (jedis.exists(key)) { value = jedis.get(key); value = StringUtils.isNotBlank(value) && !"nil".equalsIgnoreCase(value) ? value : null; diff --git a/src/main/java/com/nis/util/JedisUtils2.java b/src/main/java/com/nis/util/JedisUtils2.java deleted file mode 100644 index bba7725..0000000 --- a/src/main/java/com/nis/util/JedisUtils2.java +++ /dev/null @@ -1,1422 +0,0 @@ -package com.nis.util; - -import java.util.List; -import java.util.Map; -import java.util.Set; - -import redis.clients.jedis.BinaryClient.LIST_POSITION; -import redis.clients.jedis.Jedis; -import redis.clients.jedis.JedisPool; -import redis.clients.jedis.JedisPoolConfig; -import redis.clients.jedis.JedisSentinelPool; -import redis.clients.jedis.Response; -import redis.clients.jedis.SortingParams; -import redis.clients.jedis.Transaction; -import redis.clients.util.SafeEncoder; - -public class JedisUtils2 { - - /* 缓存生存时间 */ - private int expire = 60000; - - /* 对key的操作方法 */ - private static JedisPool jedisPool = null; - - public static void main(String[] args) { - - JedisPoolConfig config = new JedisPoolConfig(); - config.setMaxTotal(25); - config.setMaxIdle(5); - config.setMaxWaitMillis(100000); - // 在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的 - config.setTestOnBorrow(true); - jedisPool = new JedisPool(config, "10.0.6.249", 6381); - - Jedis resource = jedisPool.getResource(); - resource.watch("version"); - Transaction multi = resource.multi(); - - multi.incrBy("version", 1); - multi.set("cgh", "任凯歌"); - String version = new JedisUtils2().get("version"); - multi.select(2); - multi.set("rkg", "陈桂华"); - List exec = multi.exec(); - for (Object object : exec) { - System.out.println(object); - } - System.out.println("ok"); - } - - public JedisPool getPool() { - return jedisPool; - } - - /* 从jedispool中获取jedis对象 */ - public Jedis getJedis() { - if (jedisPool == null) { - throw new NullPointerException(); - } - return jedisPool.getResource(); - } - - public static JedisPool getJedisPool() { - return jedisPool; - } - - public static void setJedisPool(JedisPool jedisPool) { - JedisUtils2.jedisPool = jedisPool; - } - - /* - * 在finaally中回收jedis - */ - public void returnJedis(Jedis jedis) { - if (null != jedis && null != jedisPool) { - // jedisPool.returnResource(jedis); - jedis.close(); - } - } - - /* - * 销毁链接(放入catch - */ - public static void returnBrokenResource(Jedis jedis) { - if (null != jedis && null != jedisPool) { - // jedisPool.returnResource(jedis); - jedis.close(); - } - } - - /* - * 设置过期时间 - */ - public void expire(String key, int seconds) { - if (seconds < 0) { - return; - } - Jedis jedis = getJedis(); - jedis.expire(key, seconds); - returnJedis(jedis); - } - - /* - * 设置默认过期时间 - */ - public void expire(String key) { - expire(key, expire); - } - - /* - * 清空所有key - */ - public String flushAll() { - Jedis jedis = getJedis(); - String stata = jedis.flushAll(); - returnJedis(jedis); - return stata; - } - - /* - * 更改key 返回值是状态吗 - */ - - public String rename(String oldkey, String newkey) { - return rename(SafeEncoder.encode(oldkey), SafeEncoder.encode(newkey)); - } - - /* - * 更改key，仅当新key不存在时才执行 - */ - public long renamenx(String oldkey, String newkey) { - Jedis jedis = getJedis(); - long status = jedis.renamenx(oldkey, newkey); - returnJedis(jedis); - return status; - - } - - /* - * 更改key - */ - public String rename(byte[] oldkey, byte[] newkey) { - Jedis jedis = getJedis(); - String status = jedis.rename(oldkey, newkey); - returnJedis(jedis); - return status; - } - - /* - * 设置key的过期时间，以秒为单位 返回值是影响的记录数 - */ - public long expired(String key, int seconds) { - Jedis jedis = getJedis(); - long count = jedis.expire(key, seconds); - returnJedis(jedis); - return count; - } - - /* - * 设置key的过期时间，它是距历元（即格林威治标准时间 1970年1月1日的00:00:00,格里高利历)的偏移量 - */ - public long expireAt(String key, long timestamp) { - Jedis jedis = getJedis(); - long count = jedis.expireAt(key, timestamp); - returnJedis(jedis); - return count; - } - - /* - * 查询key的过期时间 以秒为单位的时间表示返回的是指定key的剩余的生存时间 - */ - public long ttl(String key) { - Jedis sjedis = getJedis(); - long len = sjedis.ttl(key); - returnJedis(sjedis); - return len; - - } - - /* - * 取消对key过期时间的设置 将带生存时间的转换成一个永不过期的key - * - * 当移除成功时返回1，key不存在或者移除不成功时返回0 - */ - public long persist(String key) { - Jedis jedis = getJedis(); - long count = jedis.persist(key); - returnJedis(jedis); - return count; - } - - /* - * 删除keys对应的记录，可以是多个key - * - * 返回值是被删除的数量 - */ - public long del(String... keys) { - Jedis jedis = getJedis(); - long count = jedis.del(keys); - returnJedis(jedis); - return count; - } - - /* - * 删除keys对应的记录，可以是多个key - */ - public long del(byte[]... keys) { - Jedis jedis = getJedis(); - long count = jedis.del(keys); - returnJedis(jedis); - return count; - } - - /* - * 判断key是否存在 - */ - public boolean exists(String key) { - Jedis jedis = getJedis(); - boolean exists = jedis.exists(key); - returnJedis(jedis); - return exists; - } - - /* - * 对List，set，SortSet 进行排序，如果集合数据较大应避免使用这个方法 - * - * 返回排序后的结果，默认升序 sort key Desc为降序 - */ - public List sort(String key) { - Jedis jedis = getJedis(); - List list = jedis.sort(key); - - returnJedis(jedis); - return list; - } - - /* - * 对List，set，SortSet 进行排序，如果集合数据较大应避免使用这个方法 - * - * 返回排序后的结果，默认升序 sort key Desc为降序 - */ - public List sort(String key, SortingParams parame) { - Jedis jedis = getJedis(); - List list = jedis.sort(key, parame); - returnJedis(jedis); - return list; - } - /* - * 返回指定key的存储类型 - */ - - public String type(String key) { - Jedis jedis = getJedis(); - String type = jedis.type(key); - returnJedis(jedis); - return type; - } - - /* - * 查找所有匹配模式的键 - * - * key的查询表达式 *代表任意多个 ？代表一个 - */ - public Set Keys(String pattern) { - Jedis jedis = getJedis(); - Set set = jedis.keys(pattern); - - returnJedis(jedis); - return set; - } - - /*************************set部分*******************************/ - /* - * 向set添加一条记录，如果member已经存在则返回0，否则返回1 - */ - public long sadd(String key, String member) { - Jedis jedis = getJedis(); - - Long s = jedis.sadd(key, member); - returnJedis(jedis); - return s; - } - - public long sadd(byte[] key, byte[] member) { - Jedis jedis = getJedis(); - Long s = jedis.sadd(key, member); - returnJedis(jedis); - return s; - } - - /* - * 获取给定key中元素个数 - * - * @return 元素个数 - */ - public long scard(String key) { - Jedis jedis = getJedis(); - Long count = jedis.scard(key); - returnJedis(jedis); - return count; - } - - /* - * 返回从第一组和所有的给定集合之间的有差异的成员 - * - * @return 有差异成员的集合 - */ - public Set sdiff(String... keys) { - Jedis jedis = getJedis(); - Set set = jedis.sdiff(keys); - returnJedis(jedis); - return set; - } - - /* - * 这个命令的作用和 SDIFF 类似，但它将结果保存到 destination 集合，而不是简单地返回结果集,如果目标已存在，则覆盖 - * - * @return 新集合的记录数 - */ - public long sdiffstore(String newkey, String... keys) { - Jedis jedis = getJedis(); - Long count = jedis.sdiffstore(newkey, keys); - returnJedis(jedis); - return count; - } - - /* - * sinter 返回给定集合交集成员，如果其中一个集合为不存在或为空，则返回空set - * - * @return 交集成员的集合 - */ - public Set sinter(String... keys) { - Jedis jedis = getJedis(); - Set set = jedis.sinter(keys); - returnJedis(jedis); - return set; - } - - /* - * sinterstore 这个命令类似于 SINTER 命令，但它将结果保存到 destination 集合，而不是简单地返回结果集。 如果 - * destination 集合已经存在，则将其覆盖。destination 可以是 key 本身 - * - * @return 新集合的记录数 - */ - public long sinterstore(String dstkey, String... keys) { - Jedis jedis = getJedis(); - long count = jedis.sinterstore(dstkey, keys); - returnJedis(jedis); - return count; - } - - /* - * sismember 确定一个给定的值是否存在 - * - * @param String member 要判断的值 - * - * @return 存在返回1，不存在返回0 - */ - public boolean sismember(String key, String member) { - Jedis jedis = getJedis(); - Boolean s = jedis.sismember(key, member); - returnJedis(jedis); - return s; - } - /* - * smembers 返回集合中的所有成员 - * - * @return 成员集合 - */ - - public Set smembers(String key) { - Jedis jedis = getJedis(); - Set set = jedis.smembers(key); - returnJedis(jedis); - return set; - } - - public Set smembers(byte[] key) { - Jedis jedis = getJedis(); - Set set = jedis.smembers(key); - returnJedis(jedis); - return set; - } - - /* - * smove 将成员从源集合移除放入目标集合
如果源集合不存在或不包含指定成员，不进行任何操作，返回0
- * 否则该成员从源集合上删除，并添加到目标集合，如果目标集合成员以存在，则只在源集合进行删除 - * - * @param srckey 源集合 dstkey目标集合 member源集合中的成员 - * - * @return 状态码 1成功 0失败 - */ - public long smove(String srckey, String dstkey, String member) { - Jedis jedis = getJedis(); - Long s = jedis.smove(srckey, dstkey, member); - returnJedis(jedis); - return s; - } - - /* - * spop 从集合中删除成员 移除并返回集合中的一个随机元素。 - * - * @return 被删除的随机成员 - */ - public String spop(String key) { - Jedis jedis = getJedis(); - String s = jedis.spop(key); // s 被移除的随机成员 - returnJedis(jedis); - return s; - } - - /* - * 从集合中删除指定成员 移除集合 key 中的一个或多个 member 元素，不存在的 member 元素会被忽略。当 key 不是集合类型，返回一个错误。 - * - * @param key member要删除的成员 - * - * @return 状态码 成功返回1，成员不存在返回0 - */ - public long srem(String key, String member) { - Jedis jedis = getJedis(); - Long s = jedis.srem(key, member); - returnJedis(jedis); - return s; - } - - /* - * sunion 合并多个集合并将合并后的结果集保存在指定的新集合中，如果新集合已经存在则覆盖 - */ - public Set sunion(String... keys) { - Jedis jedis = getJedis(); - Set set = jedis.sunion(keys); - returnJedis(jedis); - return set; - } - - /* - * 这个命令类似于 SUNION 命令，但它将结果保存到 destination 集合，而不是简单地返回结果集。 如果 destination - * 已经存在，则将其覆盖。 destination 可以是 key 本身 - */ - public long sunionstore(String dstkey, String... keys) { - Jedis jedis = getJedis(); - Long s = jedis.sunionstore(dstkey, keys); - returnJedis(jedis); - return s; - } - - /******************************SortSet******************************/ - - /* - * zadd 向集合中增加一条记录，如果这个值已经存在，这个值对应的权重将被置为新的权重 - * - * @param double score 权重 member要加入的值 - * - * @return 状态码 1成功 0已经存在member值 - */ - - public long zadd(String key, double score, String member) { - Jedis jedis = getJedis(); - long s = jedis.zadd(key, score, member); - returnJedis(jedis); - return s; - } - - /* - * 获取集合中元素的数量 - * - * @param String key - * - * @return 当 key 存在且是有序集类型时，返回有序集的基数。 当 key 不存在时，返回 0 。 - */ - public long zcard(String key) { - Jedis jedis = getJedis(); - long count = jedis.zcard(key); - returnJedis(jedis); - return count; - } - - /* - * zcount 获取指定权重区间内的集合数量 - * - * @param double min最小排序位置 max最大排序位置 - */ - public long zcount(String key, double min, double max) { - Jedis jedis = getJedis(); - long count = jedis.zcount(key, min, max); - returnJedis(jedis); - return count; - } - - /* - * zrange 返回有序集合key中，指定区间的成员0，-1指的是整个区间的成员 - */ - public Set zrange(String key, int start, int end) { - - Jedis jedis = getJedis(); - Set set = jedis.zrange(key, 0, -1); - returnJedis(jedis); - return set; - } - - /* - * zrevrange 返回有序集 key 中，指定区间内的成员。其中成员的位置按 score 值递减(从大到小)来排列 - */ - public Set zrevrange(String key, int start, int end) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - Set set = sjedis.zrevrange(key, start, end); - returnJedis(sjedis); - return set; - } - - /* - * zrangeByScore 根据上下权重查询集合 - */ - public Set zrangeByScore(String key, double min, double max) { - Jedis jedis = getJedis(); - Set set = jedis.zrangeByScore(key, min, max); - returnJedis(jedis); - return set; - } - - /* - * 接上面方法，获取有序集合长度 - */ - public long zlength(String key) { - long len = 0; - Set set = zrange(key, 0, -1); - len = set.size(); - return len; - } - - /* - * zincrby 为有序集 key 的成员 member 的 score 值加上增量 increment - * - * @return member 成员的新 score 值，以字符串形式表示 - */ - - public double zincrby(String key, double score, String member) { - Jedis jedis = getJedis(); - double s = jedis.zincrby(key, score, member); - returnJedis(jedis); - return s; - } - /* - * zrank 返回有序集 key 中成员 member 的排名。其中有序集成员按 score 值递增(从小到大)顺序排列 - */ - - public long zrank(String key, String member) { - Jedis jedis = getJedis(); - long index = jedis.zrank(key, member); - returnJedis(jedis); - return index; - } - - /* - * zrevrank 返回有序集 key 中成员 member 的排名。其中有序集成员按 score 值递减(从大到小)排序。 - */ - public long zrevrank(String key, String member) { - Jedis jedis = getJedis(); - long index = jedis.zrevrank(key, member); - returnJedis(jedis); - return index; - } - - /* - * zrem 移除有序集 key 中的一个或多个成员，不存在的成员将被忽略。当 key 存在但不是有序集类型时，返回一个错误。在 Redis 2.4 - * 版本以前， ZREM 每次只能删除一个元素。 - * - * @return 被成功移除的成员的数量，不包括被忽略的成员 - */ - public long zrem(String key, String member) { - Jedis jedis = getJedis(); - long count = jedis.zrem(key, member); - returnJedis(jedis); - return count; - - } - - /* - * zremrangebyrank 移除有序集 key 中，指定排名(rank)区间内的所有成员。 - * - * @return 被移除成员的数量 - */ - public long zremrangeByRank(String key, int start, int end) { - Jedis jedis = getJedis(); - long count = jedis.zremrangeByRank(key, start, end); - returnJedis(jedis); - return count; - - } - - /* - * zremrangeByScore 删除指定权重区间的元素 - */ - public long zremrangeByScore(String key, double min, double max) { - Jedis jedis = getJedis(); - long count = jedis.zremrangeByScore(key, min, max); - returnJedis(jedis); - return count; - } - - /* - * 获取给定值在集合中的权重 - */ - public double zscore(String key, String member) { - Jedis jedis = getJedis(); - Double score = jedis.zscore(key, member); - returnJedis(jedis); - if (score != null) { - return score; - } - return 0; - } - - /*******************************hash***********************************/ - /** - * 从hash中删除指定的存储 - * - * @param String - * key - * @param String - * fieid 存储的名字 - * @return 状态码，1成功，0失败 - * */ - public long hdel(String key, String fieid) { - Jedis jedis = getJedis(); - long s = jedis.hdel(key, fieid); - returnJedis(jedis); - return s; - } - - public long hdel(String key) { - Jedis jedis = getJedis(); - long s = jedis.del(key); - returnJedis(jedis); - return s; - } - - /** - * 测试hash中指定的存储是否存在 - * - * @param String - * key - * @param String - * fieid 存储的名字 - * @return 1存在，0不存在 - * */ - public boolean hexists(String key, String fieid) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - boolean s = sjedis.hexists(key, fieid); - returnJedis(sjedis); - return s; - } - - /** - * 返回hash中指定存储位置的值 - * - * @param String - * key - * @param String - * fieid 存储的名字 - * @return 存储对应的值 - * */ - public String hget(String key, String fieid) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - String s = sjedis.hget(key, fieid); - returnJedis(sjedis); - return s; - } - - public byte[] hget(byte[] key, byte[] fieid) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - byte[] s = sjedis.hget(key, fieid); - returnJedis(sjedis); - return s; - } - - /** - * 以Map的形式返回hash中的存储和值 - * - * @param String - * key - * @return Map - * */ - public Map hgetAll(String key) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - Map map = sjedis.hgetAll(key); - returnJedis(sjedis); - return map; - } - - /** - * 添加一个对应关系 - * - * @param String - * key - * @param String - * fieid - * @param String - * value - * @return 状态码 1成功，0失败，fieid已存在将更新，也返回0 - * **/ - public long hset(String key, String fieid, String value) { - Jedis jedis = getJedis(); - long s = jedis.hset(key, fieid, value); - returnJedis(jedis); - return s; - } - - public long hset(String key, String fieid, byte[] value) { - Jedis jedis = getJedis(); - long s = jedis.hset(key.getBytes(), fieid.getBytes(), value); - returnJedis(jedis); - return s; - } - - /** - * 添加对应关系，只有在fieid不存在时才执行 - * - * @param String - * key - * @param String - * fieid - * @param String - * value - * @return 状态码 1成功，0失败fieid已存 - * **/ - public long hsetnx(String key, String fieid, String value) { - Jedis jedis = getJedis(); - long s = jedis.hsetnx(key, fieid, value); - returnJedis(jedis); - return s; - } - - /** - * 获取hash中value的集合 - * - * @param String - * key - * @return List - * */ - public List hvals(String key) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - List list = sjedis.hvals(key); - returnJedis(sjedis); - return list; - } - - /** - * 在指定的存储位置加上指定的数字，存储位置的值必须可转为数字类型 - * - * @param String - * key - * @param String - * fieid 存储位置 - * @param String - * long value 要增加的值,可以是负数 - * @return 增加指定数字后，存储位置的值 - * */ - public long hincrby(String key, String fieid, long value) { - Jedis jedis = getJedis(); - long s = jedis.hincrBy(key, fieid, value); - returnJedis(jedis); - return s; - } - - /** - * 返回指定hash中的所有存储名字,类似Map中的keySet方法 - * - * @param String - * key - * @return Set 存储名称的集合 - * */ - public Set hkeys(String key) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - Set set = sjedis.hkeys(key); - returnJedis(sjedis); - return set; - } - - /** - * 获取hash中存储的个数，类似Map中size方法 - * - * @param String - * key - * @return long 存储的个数 - * */ - public long hlen(String key) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - long len = sjedis.hlen(key); - returnJedis(sjedis); - return len; - } - - /** - * 根据多个key，获取对应的value，返回List,如果指定的key不存在,List对应位置为null - * - * @param String - * key - * @param String - * ... fieids 存储位置 - * @return List - * */ - public List hmget(String key, String... fieids) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - List list = sjedis.hmget(key, fieids); - returnJedis(sjedis); - return list; - } - - public List hmget(byte[] key, byte[]... fieids) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - List list = sjedis.hmget(key, fieids); - returnJedis(sjedis); - return list; - } - - /** - * 添加对应关系，如果对应关系已存在，则覆盖 - * - * @param Strin - * key - * @param Map - * 对应关系 - * @return 状态，成功返回OK - * */ - public String hmset(String key, Map map) { - Jedis jedis = getJedis(); - String s = jedis.hmset(key, map); - returnJedis(jedis); - return s; - } - - /** - * 添加对应关系，如果对应关系已存在，则覆盖 - * - * @param Strin - * key - * @param Map - * 对应关系 - * @return 状态，成功返回OK - * */ - public String hmset(byte[] key, Map map) { - Jedis jedis = getJedis(); - String s = jedis.hmset(key, map); - returnJedis(jedis); - return s; - } - - // *******************************************Strings*******************************************// - /** - * 根据key获取记录 - * - * @param String - * key - * @return 值 - * */ - public String get(String key) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - String value = sjedis.get(key); - returnJedis(sjedis); - return value; - } - - /** - * 根据key获取记录 - * - * @param byte[] key - * @return 值 - * */ - public byte[] get(byte[] key) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - byte[] value = sjedis.get(key); - returnJedis(sjedis); - return value; - } - - /** - * 添加有过期时间的记录 - * - * @param String - * key - * @param int seconds 过期时间，以秒为单位 - * @param String - * value - * @return String 操作状态 - * */ - public String setEx(String key, int seconds, String value) { - Jedis jedis = getJedis(); - String str = jedis.setex(key, seconds, value); - returnJedis(jedis); - return str; - } - - /** - * 添加有过期时间的记录 - * - * @param String - * key - * @param int seconds 过期时间，以秒为单位 - * @param String - * value - * @return String 操作状态 - * */ - public String setEx(byte[] key, int seconds, byte[] value) { - Jedis jedis = getJedis(); - String str = jedis.setex(key, seconds, value); - returnJedis(jedis); - return str; - } - - /** - * 添加一条记录，仅当给定的key不存在时才插入 - * - * @param String - * key - * @param String - * value - * @return long 状态码，1插入成功且key不存在，0未插入，key存在 - * */ - public long setnx(String key, String value) { - Jedis jedis = getJedis(); - long str = jedis.setnx(key, value); - returnJedis(jedis); - return str; - } - - /** - * 添加记录,如果记录已存在将覆盖原有的value - * - * @param String - * key - * @param String - * value - * @return 状态码 - * */ - public String set(String key, String value) { - return set(SafeEncoder.encode(key), SafeEncoder.encode(value)); - } - - /** - * 添加记录,如果记录已存在将覆盖原有的value - * - * @param String - * key - * @param String - * value - * @return 状态码 - * */ - public String set(String key, byte[] value) { - return set(SafeEncoder.encode(key), value); - } - - /** - * 添加记录,如果记录已存在将覆盖原有的value - * - * @param byte[] key - * @param byte[] value - * @return 状态码 - * */ - public String set(byte[] key, byte[] value) { - Jedis jedis = getJedis(); - String status = jedis.set(key, value); - returnJedis(jedis); - return status; - } - - /** - * 从指定位置开始插入数据，插入的数据会覆盖指定位置以后的数据
- * 例:String str1="123456789";
- * 对str1操作后setRange(key,4,0000)，str1="123400009"; - * - * @param String - * key - * @param long offset - * @param String - * value - * @return long value的长度 - * */ - public long setRange(String key, long offset, String value) { - Jedis jedis = getJedis(); - long len = jedis.setrange(key, offset, value); - returnJedis(jedis); - return len; - } - - /** - * 在指定的key中追加value - * - * @param String - * key - * @param String - * value - * @return long 追加后value的长度 - * **/ - public long append(String key, String value) { - Jedis jedis = getJedis(); - long len = jedis.append(key, value); - returnJedis(jedis); - return len; - } - - /** - * 将key对应的value减去指定的值，只有value可以转为数字时该方法才可用 - * - * @param String - * key - * @param long number 要减去的值 - * @return long 减指定值后的值 - * */ - public long decrBy(String key, long number) { - Jedis jedis = getJedis(); - long len = jedis.decrBy(key, number); - returnJedis(jedis); - return len; - } - - /** - * 可以作为获取唯一id的方法
- * 将key对应的value加上指定的值，只有value可以转为数字时该方法才可用 - * - * @param String - * key - * @param long number 要减去的值 - * @return long 相加后的值 - * */ - public long incrBy(String key, long number) { - Jedis jedis = getJedis(); - long len = jedis.incrBy(key, number); - returnJedis(jedis); - return len; - } - - /** - * 对指定key对应的value进行截取 - * - * @param String - * key - * @param long startOffset 开始位置(包含) - * @param long endOffset 结束位置(包含) - * @return String 截取的值 - * */ - public String getrange(String key, long startOffset, long endOffset) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - String value = sjedis.getrange(key, startOffset, endOffset); - returnJedis(sjedis); - return value; - } - - /** - * 获取并设置指定key对应的value
- * 如果key存在返回之前的value,否则返回null - * - * @param String - * key - * @param String - * value - * @return String 原始value或null - * */ - public String getSet(String key, String value) { - Jedis jedis = getJedis(); - String str = jedis.getSet(key, value); - returnJedis(jedis); - return str; - } - - /** - * 批量获取记录,如果指定的key不存在返回List的对应位置将是null - * - * @param String - * keys - * @return List 值得集合 - * */ - public List mget(String... keys) { - Jedis jedis = getJedis(); - List str = jedis.mget(keys); - returnJedis(jedis); - return str; - } - - /** - * 批量存储记录 - * - * @param String - * keysvalues 例:keysvalues="key1","value1","key2","value2"; - * @return String 状态码 - * */ - public String mset(String... keysvalues) { - Jedis jedis = getJedis(); - String str = jedis.mset(keysvalues); - returnJedis(jedis); - return str; - } - - /** - * 获取key对应的值的长度 - * - * @param String - * key - * @return value值得长度 - * */ - public long strlen(String key) { - Jedis jedis = getJedis(); - long len = jedis.strlen(key); - returnJedis(jedis); - return len; - } - - // *******************************************Lists*******************************************// - /** - * List长度 - * - * @param String - * key - * @return 长度 - * */ - public long llen(String key) { - return llen(SafeEncoder.encode(key)); - } - - /** - * List长度 - * - * @param byte[] key - * @return 长度 - * */ - public long llen(byte[] key) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - long count = sjedis.llen(key); - returnJedis(sjedis); - return count; - } - - /** - * 覆盖操作,将覆盖List中指定位置的值 - * - * @param byte[] key - * @param int index 位置 - * @param byte[] value 值 - * @return 状态码 - * */ - public String lset(byte[] key, int index, byte[] value) { - Jedis jedis = getJedis(); - String status = jedis.lset(key, index, value); - returnJedis(jedis); - return status; - } - - /** - * 覆盖操作,将覆盖List中指定位置的值 - * - * @param key - * @param int index 位置 - * @param String - * value 值 - * @return 状态码 - * */ - public String lset(String key, int index, String value) { - return lset(SafeEncoder.encode(key), index, SafeEncoder.encode(value)); - } - - /** - * 在value的相对位置插入记录 - * - * @param key - * @param LIST_POSITION - * 前面插入或后面插入 - * @param String - * pivot 相对位置的内容 - * @param String - * value 插入的内容 - * @return 记录总数 - * */ - public long linsert(String key, LIST_POSITION where, String pivot, String value) { - return linsert(SafeEncoder.encode(key), where, SafeEncoder.encode(pivot), SafeEncoder.encode(value)); - } - - /** - * 在指定位置插入记录 - * - * @param String - * key - * @param LIST_POSITION - * 前面插入或后面插入 - * @param byte[] pivot 相对位置的内容 - * @param byte[] value 插入的内容 - * @return 记录总数 - * */ - public long linsert(byte[] key, LIST_POSITION where, byte[] pivot, byte[] value) { - Jedis jedis = getJedis(); - long count = jedis.linsert(key, where, pivot, value); - returnJedis(jedis); - return count; - } - - /** - * 获取List中指定位置的值 - * - * @param String - * key - * @param int index 位置 - * @return 值 - * **/ - public String lindex(String key, int index) { - return SafeEncoder.encode(lindex(SafeEncoder.encode(key), index)); - } - - /** - * 获取List中指定位置的值 - * - * @param byte[] key - * @param int index 位置 - * @return 值 - * **/ - public byte[] lindex(byte[] key, int index) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - byte[] value = sjedis.lindex(key, index); - returnJedis(sjedis); - return value; - } - - /** - * 将List中的第一条记录移出List - * - * @param String - * key - * @return 移出的记录 - * */ - public String lpop(String key) { - return SafeEncoder.encode(lpop(SafeEncoder.encode(key))); - } - - /** - * 将List中的第一条记录移出List - * - * @param byte[] key - * @return 移出的记录 - * */ - public byte[] lpop(byte[] key) { - Jedis jedis = getJedis(); - byte[] value = jedis.lpop(key); - returnJedis(jedis); - return value; - } - - /** - * 将List中最后第一条记录移出List - * - * @param byte[] key - * @return 移出的记录 - * */ - public String rpop(String key) { - Jedis jedis = getJedis(); - String value = jedis.rpop(key); - returnJedis(jedis); - return value; - } - - /** - * 向List尾部追加记录 - * - * @param String - * key - * @param String - * value - * @return 记录总数 - * */ - public long lpush(String key, String value) { - return lpush(SafeEncoder.encode(key), SafeEncoder.encode(value)); - } - - /** - * 向List头部追加记录 - * - * @param String - * key - * @param String - * value - * @return 记录总数 - * */ - public long rpush(String key, String value) { - Jedis jedis = getJedis(); - long count = jedis.rpush(key, value); - returnJedis(jedis); - return count; - } - - /** - * 向List头部追加记录 - * - * @param String - * key - * @param String - * value - * @return 记录总数 - * */ - public long rpush(byte[] key, byte[] value) { - Jedis jedis = getJedis(); - long count = jedis.rpush(key, value); - returnJedis(jedis); - return count; - } - - /** - * 向List中追加记录 - * - * @param byte[] key - * @param byte[] value - * @return 记录总数 - * */ - public long lpush(byte[] key, byte[] value) { - Jedis jedis = getJedis(); - long count = jedis.lpush(key, value); - returnJedis(jedis); - return count; - } - - /** - * 获取指定范围的记录，可以做为分页使用 - * - * @param String - * key - * @param long start - * @param long end - * @return List - * */ - public List lrange(String key, long start, long end) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - List list = sjedis.lrange(key, start, end); - returnJedis(sjedis); - return list; - } - - /** - * 获取指定范围的记录，可以做为分页使用 - * - * @param byte[] key - * @param int start - * @param int end 如果为负数，则尾部开始计算 - * @return List - * */ - public List lrange(byte[] key, int start, int end) { - // ShardedJedis sjedis = getShardedJedis(); - Jedis sjedis = getJedis(); - List list = sjedis.lrange(key, start, end); - returnJedis(sjedis); - return list; - } - - /** - * 删除List中c条记录，被删除的记录值为value - * - * @param byte[] key - * @param int c 要删除的数量，如果为负数则从List的尾部检查并删除符合的记录 - * @param byte[] value 要匹配的值 - * @return 删除后的List中的记录数 - * */ - public long lrem(byte[] key, int c, byte[] value) { - Jedis jedis = getJedis(); - long count = jedis.lrem(key, c, value); - returnJedis(jedis); - return count; - } - - /** - * 删除List中c条记录，被删除的记录值为value - * - * @param String - * key - * @param int c 要删除的数量，如果为负数则从List的尾部检查并删除符合的记录 - * @param String - * value 要匹配的值 - * @return 删除后的List中的记录数 - * */ - public long lrem(String key, int c, String value) { - return lrem(SafeEncoder.encode(key), c, SafeEncoder.encode(value)); - } - - /** - * 算是删除吧，只保留start与end之间的记录 - * - * @param byte[] key - * @param int start 记录的开始位置(0表示第一条记录) - * @param int end 记录的结束位置（如果为-1则表示最后一个，-2，-3以此类推） - * @return 执行状态码 - * */ - public String ltrim(byte[] key, int start, int end) { - Jedis jedis = getJedis(); - String str = jedis.ltrim(key, start, end); - returnJedis(jedis); - return str; - } - - /** - * 算是删除吧，只保留start与end之间的记录 - * - * @param String - * key - * @param int start 记录的开始位置(0表示第一条记录) - * @param int end 记录的结束位置（如果为-1则表示最后一个，-2，-3以此类推） - * @return 执行状态码 - * */ - public String ltrim(String key, int start, int end) { - return ltrim(SafeEncoder.encode(key), start, end); - } - -} diff --git a/src/main/java/com/nis/web/service/fdfs/FileManagerConfig.java b/src/main/java/com/nis/web/service/fdfs/FileManagerConfig.java index bf609ae..660700e 100644 --- a/src/main/java/com/nis/web/service/fdfs/FileManagerConfig.java +++ b/src/main/java/com/nis/web/service/fdfs/FileManagerConfig.java @@ -2,6 +2,8 @@ package com.nis.web.service.fdfs; import java.io.Serializable; +import com.nis.util.Configurations; + /** *

Title: FileManagerConfig.java

*

Description:

@@ -21,7 +23,9 @@ public class FileManagerConfig implements Serializable { public static final String SEPARATOR = "/"; // fdfs-tracker-nginx服务器 - public static final String TRACKER_NGNIX_ADDR = "10.0.6.249"; + public static final String TRACKER_NGNIX_ADDR = Configurations.getStringProperty("fastDfsHttpAddr", + "192.168.10.205"); + // public static final String TRACKER_NGNIX_ADDR = "10.0.6.249"; public static final String TRACKER_NGNIX_PORT = ""; diff --git a/src/main/resources/fastdfs-client.properties b/src/main/resources/fastdfs-client.properties index 4f71258..93ae6af 100644 --- a/src/main/resources/fastdfs-client.properties +++ b/src/main/resources/fastdfs-client.properties @@ -12,3 +12,7 @@ fastdfs.http_tracker_http_port = 80 #fastdfs.tracker_servers = 10.0.11.201:22122,10.0.11.202:22122,10.0.11.203:22122 #fastdfs.tracker_servers = 10.0.6.192:22122 fastdfs.tracker_servers = 10.0.6.249:22122 +#fastdfs.tracker_servers = 192.168.10.205:22122 + +fastDfsHttpAddr= 10.0.6.249 +#fastDfsHttpAddr=192.168.10.205 \ No newline at end of file diff --git a/src/main/resources/fdfs_client.conf b/src/main/resources/fdfs_client.conf index 530d0f9..7d7efcd 100644 --- a/src/main/resources/fdfs_client.conf +++ b/src/main/resources/fdfs_client.conf @@ -6,5 +6,6 @@ http.anti_steal_token = no http.secret_key = FastDFS1234567890 tracker_server = 10.0.6.249:22122 +#tracker_server = 192.168.10.204:22122 #tracker_server = 10.0.11.248:22122 #tracker_server = 10.0.11.249:22122 diff --git a/src/main/resources/jdbc.properties b/src/main/resources/jdbc.properties index a098d1f..03c3127 100644 --- a/src/main/resources/jdbc.properties +++ b/src/main/resources/jdbc.properties @@ -2,6 +2,7 @@ #jdbc.driver=oracle.jdbc.driver.OracleDriver jdbc.devlop.driver=com.mysql.jdbc.Driver jdbc.devlop.url=jdbc:mysql://10.0.6.100:3306/web_frame?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull +#jdbc.devlop.url=jdbc:mysql://192.168.10.204:3306/web_frame?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull jdbc.devlop.username=dfh jdbc.devlop.key=xLtQB+Bp6joOYrVIfBdrRA== jdbc.devlop.password=/+7+DgxK++ZaD1nIcRRmDg== @@ -9,6 +10,7 @@ jdbc.devlop.password=/+7+DgxK++ZaD1nIcRRmDg== #==========日志库 Mysql======================= jdbc.log.driver=com.mysql.jdbc.Driver jdbc.log.url=jdbc:mysql://10.0.6.249:3306/galaxy?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull +#jdbc.log.url=jdbc:mysql://192.168.10.204:3306/galaxy?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull jdbc.log.username=root jdbc.log.key=9Pjh5K20Sho0lnWMClUXYA== jdbc.log.password=D3ptWYX8vx/GoEXaSrJycQ== @@ -60,8 +62,8 @@ bonecp.hive.statementsCacheSize=100 ##################################################################################################################################### ##redis连接 ##################################################################################################################################### -#redis.host=10.0.6.228 redis.host=10.0.6.249 +#redis.host=192.168.10.205 redis.port=6379 redis.pass= redis.maxIdle=5