nginx+redis缓存微信的token数据
package wonyen.mall.dao;import java.io.IOException;
import java.io.InputStream;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Properties;
import java.util.Set;
import org.springframework.dao.DataAccessException;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.serializer.RedisSerializer;
import redis.clients.jedis.Jedis;
import wonyen.mall.constant.SystemConstant;
public>AbstractBaseRedisDao<String, HashMap<String, Object>> {/** * 新增键值对
*
*
@param key *
@param value *
@return */
public boolean addString(final String key, final String value) {
boolean result = redisTemplate.execute(new RedisCallback<Boolean>() {public Boolean doInRedis(RedisConnection connection)throws DataAccessException { RedisSerializer
<String> serializer = getRedisSerializer();byte[] jkey = serializer.serialize(key);byte[] jvalue = serializer.serialize(value);return connection.setNX(jkey, jvalue); }
});
return result; }
/** * 新增(拼接字符串)
*
*
@param key *
@param value *
@return */
public boolean appendString(final String key, final String value) {
boolean result = redisTemplate.execute(new RedisCallback<Boolean>() {
public Boolean doInRedis(RedisConnection connection)
throws DataAccessException {
RedisSerializer<String> serializer = getRedisSerializer();
byte[] jkey = serializer.serialize(key);
byte[] jvalue = serializer.serialize(value);
if (connection.exists(jkey)) {
connection.append(jkey, jvalue);
return true;
} else {
return false;
}
}
});
return result;
}
/**
* 新增(存储Map)
*
* @param key
* @param value
* @return
*/
public String addMap(String key, Map<String, String> map) {
Jedis jedis = getJedis();
String result = jedis.hmset(key, map);
jedis.close();
return result;
}
/**
* 获取map
*
* @param key
* @return
*/
public Map<String, String> getMap(String key) {
Jedis jedis = getJedis();
Map<String, String> map = new HashMap<String, String>();
Iterator<String> iter = jedis.hkeys(key).iterator();
while (iter.hasNext()) {
String ikey = iter.next();
map.put(ikey, jedis.hmget(key, ikey).get(0));
}
jedis.close();
return map;
}
/**
* 新增(存储List)
*
* @param key
* @param pd
* @return
*/
public void addList(String key, List<String> list) {
Jedis jedis = getJedis();
jedis.del(key); // 开始前，先移除所有的内容
for (String value : list) {
jedis.rpush(key, value);
}
jedis.close();
}
/**
* 获取List
*
* @param key
* @return
*/
public List<String> getList(String key) {
Jedis jedis = getJedis();
List<String> list = jedis.lrange(key, 0, -1);
jedis.close();
return list;
}
/**
* 新增(存储set)
*
* @param key
* @param set
*/
public void addSet(String key, Set<String> set) {
Jedis jedis = getJedis();
jedis.del(key);
for (String value : set) {
jedis.sadd(key, value);
}
jedis.close();
}
/**
* 获取Set
*
* @param key
* @return
*/
public Set<String> getSet(String key) {
Jedis jedis = getJedis();
Set<String> set = jedis.smembers(key);
jedis.close();
return set;
}
/**
* 删除 (non-Javadoc)
*
* @see com.fh.dao.redis.RedisDao#delete(java.lang.String)
*/
public boolean delete(final String key) {
boolean result = redisTemplate.execute(new RedisCallback<Boolean>() {
public Boolean doInRedis(RedisConnection connection)
throws DataAccessException {
RedisSerializer<String> serializer = getRedisSerializer();
byte[] jkey = serializer.serialize(key);
if (connection.exists(jkey)) {
connection.del(jkey);
return true;
} else {
return false;
}
}
});
return result;
}
/**
* 删除多个 (non-Javadoc)
*
* @see com.fh.dao.redis.RedisDao#delete(java.util.List)
*/
public void delete(List<String> keys) {
redisTemplate.delete(keys);
}
/**
* 修改 (non-Javadoc)
*
* @see com.fh.dao.redis.RedisDao#eidt(java.lang.String, java.lang.String)
*/
public boolean eidt(String key, String value) {
if (delete(key)) {
addString(key, value);
return true;
}
return false;
}
/**
* 先删除后添加
* @param key
* @param value
*/
public void del_add(String key, String value){
delete(key);
addString(key, value);
}
/**
* 通过key获取值 (non-Javadoc)
*
*
*/
public String get(final String keyId) {
String result = redisTemplate.execute(new RedisCallback<String>() {
public String doInRedis(RedisConnection connection)
throws DataAccessException {
RedisSerializer<String> serializer = getRedisSerializer();
byte[] jkey = serializer.serialize(keyId);
byte[] jvalue = connection.get(jkey);
if (jvalue == null) {
return null;
}
return serializer.deserialize(jvalue);
}
});
return result;
}
/**
* 获取Jedis
*
* @return
*/
public Jedis getJedis() {
Properties pros = getPprVue();
String isopen = pros.getProperty("redis_isopen"); // 地址
String host = pros.getProperty("redis_hostName"); // 地址
String port = pros.getProperty("redis_port"); // 端口
String pass = pros.getProperty("redis_password"); // 密码
if ("yes".equals(isopen)) {
Jedis jedis = new Jedis(host, Integer.parseInt(port));
jedis.auth(pass);
return jedis;
} else {
return null;
}
}
/**
* 读取redis.properties 配置文件
*
* @return
* @throws IOException
*/
public Properties getPprVue() {
InputStream inputStream = SystemConstant.class.getClassLoader()
.getResourceAsStream("redis.properties");
Properties p = new Properties();
try {
p.load(inputStream);
inputStream.close();
} catch (IOException e) {
// 读取配置文件出错
e.printStackTrace();
}
return p;
}
}
页:
[1]