两种方式(序列化和json字符串)
一、序列化
public class SerializeUtil {
//序列化
public static byte[] serizlize(Object object){
ObjectOutputStream oos = null;
ByteArrayOutputStream baos = null;
try {
baos = new ByteArrayOutputStream();
oos = new ObjectOutputStream(baos);
oos.writeObject(object);
byte[] bytes = baos.toByteArray();
return bytes;
} catch (Exception e) {
e.printStackTrace();
}finally {
try {
if(baos != null){
baos.close();
}
if (oos != null) {
oos.close();
}
} catch (Exception e2) {
e2.printStackTrace();
}
}
return null;
}
//反序列化
public static Object deserialize(byte[] bytes){
ByteArrayInputStream bais = null;
ObjectInputStream ois = null;
try{
bais = new ByteArrayInputStream(bytes);
ois = new ObjectInputStream(bais);
return ois.readObject();
}catch(Exception e){
e.printStackTrace();
}finally {
try {
} catch (Exception e2) {
e2.printStackTrace();
}
}
return null;
}
}
1
获取jedis实例
public class RedisConnection {
private static String HOST = "127.0.0.1";
private static int PORT = 6379;
private static int MAX_ACTIVE = 1024;
private static int MAX_IDLE = 200;
private static int MAX_WAIT = 10000;
private static JedisPool jedisPool = null;
/*
* 初始化redis连接池
* */
private static void initPool(){
try {
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(MAX_ACTIVE);//最大连接数
config.setMaxIdle(MAX_IDLE);//最大空闲连接数
config.setMaxWaitMillis(MAX_WAIT);//获取可用连接的最大等待时间
jedisPool = new JedisPool(config, HOST, PORT);
} catch (Exception e) {
e.printStackTrace();
}
}
/*
* 获取jedis实例
* */
public synchronized static Jedis getJedis() {
try {
if(jedisPool == null){
initPool();
}
Jedis jedis = jedisPool.getResource();
jedis.auth("redis");//密码
return jedis;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
}
redis操作
public class RedisOps {
public static void set(String key,String value){
Jedis jedis = RedisConnection.getJedis();
jedis.set(key, value);
jedis.close();
}
public static String get(String key){
Jedis jedis = RedisConnection.getJedis();
String value = jedis.get(key);
jedis.close();
return value;
}
public static void setObject(String key,Object object){
Jedis jedis = RedisConnection.getJedis();
jedis.set(key.getBytes(), SerializeUtil.serizlize(object));
jedis.close();
}
public static Object getObject(String key){
Jedis jedis = RedisConnection.getJedis();
byte[] bytes = jedis.get(key.getBytes());
jedis.close();
return SerializeUtil.deserialize(bytes);
}
}
public class User implements Serializable{
private static final long serialVersionUID = -3210884885888888713L;
private int id;
private String name;
public User(){
}
public User(int id,String name){
this.id = id;
this.name = name;
}
//setter和getter方法
}
测试
public class RedisTest {
@Test
public void testString(){
RedisOps.set("user:1", "sisu");
String user = RedisOps.get("user:1");
Assert.assertEquals("sisu", user);
}
@Test
public void testObject(){
RedisOps.setObject("user:2",new User(2,"lumia"));
User user = (User)RedisOps.getObject("user:2");
Assert.assertEquals("lumia", user.getName());
}
}
二：使用fastjson将对象转为json字符串后存储
public class RedisOps {
public static void setJsonString(String key,Object object){
Jedis jedis = RedisConnection.getJedis();
jedis.set(key, JSON.toJSONString(object));
jedis.close();
}
public static Object getJsonObject(String key,Class clazz){
Jedis jedis = RedisConnection.getJedis();
String value = jedis.get(key);
jedis.close();
return JSON.parseObject(value,clazz);
}
}
@Test
public void testObject2(){
RedisOps.setJsonString("user:3", new User(3,"xiaoming"));
User user = (User)RedisOps.getJsonObject("user:3",User.class);
Assert.assertEquals("xiaoming", user.getName());
}
Redis是一个开源的Key-Value数据缓存，和Memcached类似。
Redis多种类型的value，包括string(字符串)、list(链表)、set(集合)、zset(sorted set --有序集合)和hash（哈希类型）。
Jedis 是 Redis 官方首选的 Java 客户端开发包。
//连接redis ，redis的默认端口是6379
Jedis jedis = new Jedis ("localhost",6379);
//验证密码，如果没有设置密码这段代码省略
jedis.auth("password");
jedis.connect();//连接
jedis.disconnect();//断开连接
Set<String> keys = jedis.keys("*"); //列出所有的key
Set<String> keys = jedis.keys("key"); //查找特定的key
//移除给定的一个或多个key,如果key不存在,则忽略该命令.
jedis.del("key1");
jedis.del("key1","key2","key3","key4","key5");
//移除给定key的生存时间(设置这个key永不过期)
jedis.persist("key1");
//检查给定key是否存在
jedis.exists("key1");
//将key改名为newkey,当key和newkey相同或者key不存在时,返回一个错误
jedis.rename("key1", "key2");
//返回key所储存的值的类型。
//none(key不存在),string(字符串),list(列表),set(集合),zset(有序集),hash(哈希表)
jedis.type("key1");
//设置key生存时间，当key过期时，它会被自动删除。
jedis.expire("key1", 5);//5秒过期
//字符串值value关联到key。
jedis.set("key1", "value1");
//将值value关联到key，并将key的生存时间设为seconds(秒)。
jedis.setex("foo", 5, "haha");
//清空所有的key
jedis.flushAll();
//返回key的个数
jedis.dbSize();
//哈希表key中的域field的值设为value。
jedis.hset("key1", "field1", "field1-value");
jedis.hset("key1", "field2", "field2-value");
Map map = new HashMap();
map.put("field1", "field1-value");
map.put("field2", "field2-value");
jedis.hmset("key1", map);
//返回哈希表key中给定域field的值
jedis.hget("key1", "field1");
//返回哈希表key中给定域field的值(多个)
List list = jedis.hmget("key1","field1","field2");
for(int i=0;i<list.size();i++){
System.out.println(list.get(i));
}
//返回哈希表key中所有域和值
Map<String,String> map = jedis.hgetAll("key1");
for(Map.Entry entry: map.entrySet()) {
System.out.print(entry.getKey() + ":" + entry.getValue() + "\t");
}
//删除哈希表key中的一个或多个指定域
jedis.hdel("key1", "field1");
jedis.hdel("key1", "field1","field2");
//查看哈希表key中，给定域field是否存在。
jedis.hexists("key1", "field1");
//返回哈希表key中的所有域
jedis.hkeys("key1");
//返回哈希表key中的所有值
jedis.hvals("key1");
