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;
	}
}