Redisオブジェクトインスタンスの小さな例

Redis           ，  Redis      ，                         

package com.comtop;

 

import java.io.ByteArrayInputStream;

import java.io.ByteArrayOutputStream;

import java.io.ObjectInputStream;

import java.io.ObjectOutputStream;

import java.io.Serializable;

 

import org.junit.Before;

import org.junit.Test;

 

import redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisPool;

import redis.clients.jedis.JedisPoolConfig;

 

/**

* @ProjectName:Skeleton

* @PackageName:com.comtop

* @Verson :0.1

* @CreateUser :Test

* @CreateDate :2014-7-19 10:47:11

* @UseFor :

*/

public class JedisTest {

JedisPool pool;

Jedis jedis;

 

@Before

public void setUp() {

JedisPoolConfig config = new JedisPoolConfig();

pool = new JedisPool(config, "127.0.0.1");

jedis = pool.getResource();

//

jedis.auth("password");

}

 

@Test

public void test() throws InterruptedException {

Person person = new Person("123", "alan");

jedis.set("person:123".getBytes(), SerializeUtil.ObjTOSerialize(person));

person = new Person("234", "bruce");

jedis.set("person:234".getBytes(), SerializeUtil.ObjTOSerialize(person));

 

Person per = getObject("234");

System.out.println(per);

}

 

private Person getObject(String id) {

byte[] person = jedis.get(("person:" + id).getBytes());

return (Person) SerializeUtil.unSerialize(person);

}

}

 

class Person implements Serializable {

private static final long serialVersionUID = 1L;

private String id;

private String name;

 

/**

* @param id

* @param name

*/

Person(String id, String name) {

super();

this.id = id;

this.name = name;

}

 

public String getId() {

return id;

}

 

public void setId(String id) {

this.id = id;

}

 

public String getName() {

return name;

}

 

public void setName(String name) {

this.name = name;

}

 

@Override

public String toString()

{

return this.id +" "+this.name ;

}

}

 

class SerializeUtil {

 

/**

*

* @CreateUser:

* @ReturnType:byte[]

* @param obj

* @return

* @CreateDate:2014-7-19 11:38:19

* @SerializeUtilUseFor :

*/

public static byte[] ObjTOSerialize(Object obj) {

ObjectOutputStream oos = null;

ByteArrayOutputStream byteOut = null;

try {

byteOut = new ByteArrayOutputStream();

oos = new ObjectOutputStream(byteOut);

oos.writeObject(obj);

byte[] bytes = byteOut.toByteArray();

return bytes;

} catch (Exception e) {

}

return null;

}

 

/**

*

* @CreateUser:Test

* @ReturnType:Object

* @param bytes

* @return

* @CreateDate:2014-7-19 11:38:29

* @SerializeUtilUseFor :

*/

public static Object unSerialize(byte[] bytes) {

ByteArrayInputStream in = null;

try {

in = new ByteArrayInputStream(bytes);

ObjectInputStream objIn = new ObjectInputStream(in);

return objIn.readObject();

} catch (Exception e) {

}

return null;

}

}