凡科可以做淘宝客网站吗/电商培训

一、Redis支持的数据类型

Redis中存储数据是通过key-value存储的，对于value的类型有以下几种:

(1)字符串。

(2)Map

(3)List

(4)Set

 

public class RedisPoolManager{// Redis服务器IPprivate static String HOST = "192.168.109.157";// Redis的端口号private static int PORT = 6379;// 可用连接实例的最大数目，默认值为8；// 如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。private static int MAX_ACTIVE = 1024;// 控制一个pool最多有多少个状态为idle(空闲的)的jedis实例，默认值也是8。private static int MAX_IDLE = 200;// 等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出JedisConnectionException；private static int MAX_WAIT = 10000;private static int TIMEOUT = 10000;// 在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；private static boolean TEST_ON_BORROW = true;private static JedisPool jedisPool = null;/** 初始化Redis连接池*/static{try{JedisPoolConfig config = new JedisPoolConfig();config.setMaxIdle(MAX_IDLE);config.setMaxWaitMillis(MAX_WAIT);config.setMaxTotal(MAX_ACTIVE);config.setTestOnBorrow(TEST_ON_BORROW);jedisPool = new JedisPool(config,HOST,PORT,TIMEOUT);}catch(Exception e){e.printStackTrace();}}/** 获取Jedis实例*/public synchronized static Jedis getJedis(){try{if(jedisPool != null){Jedis resource = jedisPool.getResource();return resource;}else{return null;}}catch(Exception e){e.printStackTrace();return null;}}/** 释放jedis资源*/public static void returnResource(final Jedis jedis) {if (jedis != null) {jedisPool.returnResourceObject(jedis);}}}

1.String类型

set: 设置key值。
get: 获取key值。
del: 删除key。
append: 追加key值。
incr: key值自增1。
incrBy: key值自增，指定步长。
decr: key值自减1。
decrBy: key值自减，指定步长。
expire: 为key设置过期时间（秒数）。
setex: 设置key值，可指定存活时间（秒数）。
setnx: 设置key值。key不存在才会设置，如果key存在则回滚操作，结果返回0，表示没有设置成功。
ttl: time to live，获取key的存活时间（秒），-1表示永不过期。
persist: 去掉key的expire设置，不再有失效时间。

	/** set：设置key值 * get：获取key值 * del：删除key * append：追加key值 * incr：key值自增1 * incrBy：key值自增，指定步长 * decr：key值自减1 * decrBy：key值自减，指定步长 * expire：为key设置过期时间（秒数） * setex：设置key值，可指定存活时间（秒数） * setnx：设置key值。key不存在才会设置，如果key存在则回滚操作，结果返回0，表示没有设置成功 * ttl：time to live，获取key的存活时间（秒），-1表示永不过期 * persist：去掉key的expire设置，不再有失效时间 */  @Testpublic void testString(){Jedis jedis = RedisPoolManager.getJedis();//设置key值jedis.set("Tom","22");//获取key值String result = jedis.get("Tom");System.out.println("Tom : " + result);//删除keyjedis.del("Tom");result = jedis.get("Tom");System.out.println("Tom : " + result);jedis.set("num","1");//key值自增，并指定步长jedis.incrBy("num",5);jedis.incrBy("num",5);System.out.println("nun : " + jedis.get("num"));//key值自减，并指定步长jedis.decrBy("num",5);System.out.println("nun : " + jedis.get("num"));//设置key值，可指定存活时间（秒数）jedis.setex("AAA",5,"22");System.out.println("5秒前---AAA : " + jedis.get("AAA"));try{TimeUnit.SECONDS.sleep(5);}catch(InterruptedException e){e.printStackTrace();}System.out.println("5秒后---AAA : " + jedis.get("AAA"));}

结果:

    

 

2.Map类型

hmset: 设置key值，值类型为map对象。 
type: 返回key值的类型，可能值有none, string, hash, set, list, zset。 
hkeys: 获取所有key。 
hvals: 获取所有key对应的值。
hmget: 一次性获取多个field的值。 
hexists: 判断field是否存在。 
hset: 设置field的值。 
hgetAll: 获取全部内容。 
hget: 获取field的值。 
hdel: 删除field。 
hincrBy: field值自增1。 
hlen: 计算field的数目。 
hsetnx: 设置key值。field不存在才会设置，如果field存在则回滚操作，结果返回0，表示没有设置成功。可以用来实现分布式锁。

 

	/** hmset：设置key值，值类型为map对象 * type：返回key值的类型，可能值有none, string, hash, set, list, zset * hkeys：获取所有key * hvals：获取所有key对应的值 * hmget：一次性获取多个field的值 * hexists：判断field是否存在 * hset：设置field的值 * hgetAll：获取全部内容 * hget：获取field的值 * hdel：删除field * hincrBy：field值自增1 * hlen：计算field的数目 * hsetnx：设置key值。field不存在才会设置，如果field存在则回滚操作，结果返回0，表示没有设置成功。可以用来实现分布式锁 */@Testpublic void testMap(){Jedis jedis = RedisPoolManager.getJedis();Map<String,String> map = new HashMap<String,String>();map.put("username","AAA");map.put("address","北京市昌平区");map.put("age","22");//设置key值，值类型为map对象jedis.hmset("user",map);//返回key值的类型，可能值有none, string, hash, set, list, zset System.out.println("type: " + jedis.type("user"));//获取所有keySystem.out.println("hkeys: " + jedis.hkeys("user"));//获取所有key对应的值System.out.println("hvals: " + jedis.hvals("user"));//一次性获取多个field的值 System.out.println("hmget: " + jedis.hmget("user","username","address"));//判断field是否存在System.out.println("hexists: " + jedis.hexists("user","username"));//设置field的值 jedis.hset("user","username","AAA001");//获取field的值System.out.println("hget: " + jedis.hget("user","username"));System.out.println("hgetAll: " + jedis.hgetAll("user"));}

结果:

     

 

3.Set类型

sadd: 往set对象中添加一个值。
smembers: 取得set中所有的值。
sismember: 判断一个值是否在set中存在。
srandmember: 从set中随机取得一个值。
srem: 从set中删除一个值。
scard: 返回set的item个数。

	/** sadd：往set对象中添加一个值 * smembers：取得set中所有的值 * sismember：判断一个值是否在set中存在 * srandmember：从set中随机取得一个值 * srem：从set中删除一个值 * scard：返回set的item个数 */@Testpublic void testSet(){Jedis jedis = RedisPoolManager.getJedis();//往set对象中添加一个值jedis.sadd("uid","u001");jedis.sadd("uid","u002");jedis.sadd("uid","u003");System.out.println("type : " + jedis.type("uid"));//取得set中所有的值 System.out.println(jedis.smembers("uid"));//判断一个值是否在set中存在System.out.println(jedis.sismember("uid","u003"));//从set中随机取得一个值 System.out.println(jedis.srandmember("uid"));//从set中删除一个值jedis.srem("uid","u003");System.out.println(jedis.smembers("uid"));//返回set的item个数 System.out.println(jedis.scard("uid"));}

结果:

     

 

4.List类型

rpush: 从列表尾部插入多个元素。
llen: 返回列表中的元素的数量。
lpop: 从列表头部移除并返回list的第一个元素。
lrem: 从头部开始找，删除n个值。
lrange: 从列表中获取指定范围的子集。

 

	/** rpush：从列表尾部插入多个元素 * llen：返回列表中的元素的数量 * lpop：从列表头部移除并返回list的第一个元素 * lrem：从头部开始找，删除n个值 * lrange：从列表中获取指定范围的子集 */ @Testpublic void testList(){Jedis jedis = RedisPoolManager.getJedis();//从列表尾部插入多个元素jedis.rpush("list","AAA","BBB","CCC","DDD");//返回列表中的元素的数量System.out.println("llen: " + jedis.llen("list"));//从列表头部移除并返回list的第一个元素String item = jedis.lpop("list");System.out.println("lpop: " + item);System.out.println("llen: " + jedis.llen("list"));jedis.rpush("list","111","222","333","444","AAA");//从头部开始找，删除n个值jedis.lrem("list",1,"AAA");System.out.println("llen: " + jedis.llen("list"));}

结果:

    

 

5.工具类

public class RedisUtil {private static String HOST = "192.168.109.157";private static int PORT = 6379;private static JedisPool pool = null;static {JedisPoolConfig config = new JedisPoolConfig();config.setMaxTotal(128);config.setMaxIdle(80);config.setMaxWaitMillis(2001);pool = new JedisPool(config, HOST, PORT, 2000);}/*** 把key存入redis中** @param key     k* @param value   v* @param seconds 过期时间（秒）* @return boolean*/public static boolean set(byte[] key, byte[] value, int seconds) {Jedis jedis = null;try {jedis = pool.getResource();String result = jedis.set(key, value);if (seconds > 0) {Long r = jedis.expire(key, seconds);}} catch (Exception e) {return false;} finally {if (null != jedis) {jedis.close();}}return true;}public static byte[] get(byte[] key) {byte[] value = null;Jedis jedis = null;try {jedis = pool.getResource();value = jedis.get(key);} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return value;}/*** 向缓存中设置对象** @param key key* @param obj value* @return boolean*/public static boolean set(String key, Object obj, Integer seconds) {Jedis jedis = null;try {jedis = pool.getResource();ObjectMapper mapper = new ObjectMapper();String value = mapper.writeValueAsString(obj);jedis.set(SafeEncoder.encode(key), SafeEncoder.encode(value));if (seconds != null) {jedis.expire(key, seconds);}return true;} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return false;}/*** 向缓存中设置对象** @param key   key* @param value value* @return boolean*/public static boolean set(String key, String value, Integer seconds) {Jedis jedis = null;try {jedis = pool.getResource();jedis.set(SafeEncoder.encode(key), SafeEncoder.encode(value));if (seconds != null) {jedis.expire(key, seconds);}return true;} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return false;}/*** 移除缓存中设置对象** @param keys 被删除的KEYS* @return Long 被删除个数*/public static Long del(String... keys) {Jedis jedis = null;try {jedis = pool.getResource();return jedis.del(keys);} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return null;}/*** 根据key 获取对象** @param key key* @return T*/public static <T> T get(String key, Class<T> clazz) {Jedis jedis = null;try {jedis = pool.getResource();String v = jedis.get(key);if (StringUtils.isNotEmpty(v)) {ObjectMapper mapper = new ObjectMapper();return mapper.readValue(v, clazz);}} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return null;}/*** 根据key值得到String类型的返回值** @param key key* @return String*/public static String get(String key) {Jedis jedis = null;try {jedis = pool.getResource();String v = jedis.get(key);if (StringUtils.isNotEmpty(v)) {return v;}} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return null;}public static Boolean exists(String key) {Jedis jedis = null;try {jedis = pool.getResource();return jedis.exists(key);} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return null;}/*** redis的list操作：* 把元素插入到列表的尾部** @param key     KEY* @param strings 要插入的值，变参* @return 返回插入后list的大小*/public static Long rpush(String key, String... strings) {Jedis jedis = null;try {jedis = pool.getResource();return jedis.rpush(key, strings);} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return null;}/*** redis的list操作：* 根据开始与结束下标取list中的值** @param key   KEY* @param start 开始下标* @param end   结束下标* @return List<String>*/public static List<String> lrange(String key, int start, int end) {Jedis jedis = null;try {jedis = pool.getResource();return jedis.lrange(key, start, end);} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return null;}/*** redis的list操作：* 取列表的长度** @param key key* @return Long*/public static Long llen(String key) {Jedis jedis = null;try {jedis = pool.getResource();return jedis.llen(key);} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return null;}/*** redis的list操作：* 根据值移除list中的元素** @param key   KEY* @param count ：*              count > 0 : 从表头开始向表尾搜索，移除与 value 相等的元素，数量为 count 。*              count < 0 : 从表尾开始向表头搜索，移除与 value 相等的元素，数量为 count 的绝对值。*              count = 0 : 移除表中所有与 value 相等的值。* @param value 要删除的值* @return 返回被移除的个数*/public static Long lrem(String key, long count, String value) {Jedis jedis = null;try {jedis = pool.getResource();return jedis.lrem(key, count, value);} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return null;}public static boolean setLong(String key, Long value) {Jedis jedis = null;try {jedis = pool.getResource();return "OK".equals(jedis.set(key, String.valueOf(value)));} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return false;}public static Long getLong(String key) {String result = get(key);return result == null ? null : Long.valueOf(result);}public static Long incrBy(String key, Long increment) {Jedis jedis = null;try {jedis = pool.getResource();return jedis.incrBy(key, increment);} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return null;}public static Long hashSet(String key, String field, String value) {Jedis jedis = null;try {jedis = pool.getResource();return jedis.hset(key, field, value);} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return -1L;}public static Long hashSetLong(String key, String field, Long value) {Jedis jedis = null;try {jedis = pool.getResource();return jedis.hset(key, field, String.valueOf(value));} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return -1L;}public static Long hashIncrBy(String key, String field, Long increment) {Jedis jedis = null;try {jedis = pool.getResource();return jedis.hincrBy(key, field, increment);} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return -1L;}public static Map<String, String> hashGetAll(String key) {Jedis jedis = null;try {jedis = pool.getResource();return jedis.hgetAll(key);} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return null;}public static Set<String> hashKeys(String key) {Jedis jedis = null;try {jedis = pool.getResource();return jedis.hkeys(key);} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return null;}public static Long hashDelAll(String key, String... fields) {Jedis jedis = null;try {jedis = pool.getResource();return jedis.hdel(key, fields);} catch (Exception e) {} finally {if (null != jedis) {jedis.close();}}return null;}}

 

测试:

	@Testpublic void testObj(){User user = new User("001","张三","朝阳区");RedisUtil.set("user",user,3600000);User user2 = RedisUtil.get("user",User.class);System.out.println(user2);}

 

结果:

      User [id=001, username=张三, address=朝阳区]