redis数据库--操作对象

import java.io.Serializable;

/**
* @ClassName: User
* @Description: TODO()
* @author liang
* @date 2016年4月22日 下午3:17:39
*
*/
public class User implements Serializable{

/**
*
*/
private static final long serialVersionUID = -7291711270391262346L;

private Integer id;

private String name;

private String password;

private Integer age;

private String sex;

public Integer getId() {
return id;
}

public void setId(Integer id) {
this.id = id;
}

public String getName() {
return name;
}

public void setName(String name) {
this.name = name;
}

public String getPassword() {
return password;
}

public void setPassword(String password) {
this.password = password;
}

public Integer getAge() {
return age;
}

public void setAge(Integer age) {
this.age = age;
}

public String getSex() {
return sex;
}

public void setSex(String sex) {
this.sex = sex;
}

}

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import org.junit.Before;
import org.junit.Test;
import com.yingze.entity.User;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

/**
*
*/

/**
* @ClassName: RedisTest02
* @Description: TODO(redis 操作对象)
* @author liang
* @date 2016年4月22日 下午3:19:52
*
*/
public class RedisTest02 {

JedisPool pool=null;
Jedis jedis=null;

@Before
public void init(){
String ip="127.0.0.1";
pool=new JedisPool(new JedisPoolConfig(), ip);
jedis=pool.getResource();
}

@Test
public void addUser(){
User user=new User();
user.setId(1);
user.setName("liang");
user.setPassword("123456");
user.setAge(24);
user.setSex("男");
jedis.set("user1".getBytes(), objectToByte(user));
}

@Test
public void showUser(){
byte[] bytes=jedis.get("user1".getBytes());
User user=(User) byteToObject(bytes);
System.out.println("id:"+user.getId());
System.out.println("name:"+user.getName());
}

/*序列号对象*/
public byte[] objectToByte(Object obj){
byte[] bytes=null;
try {
ByteArrayOutputStream bos=new ByteArrayOutputStream();
ObjectOutputStream oos=new ObjectOutputStream(bos);
oos.writeObject(obj);
bytes=bos.toByteArray();
bos.close();
oos.close();
} catch (IOException e) {
e.printStackTrace();
}
return bytes;
}

/*反序列化对象*/
public Object byteToObject(byte[] bytes){
Object obj=null;
try {
ByteArrayInputStream bis=new ByteArrayInputStream(bytes);
ObjectInputStream ois=new ObjectInputStream(bis);
obj=ois.readObject();
ois.close();
bis.close();
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
return obj;
}

}