Redis实战之征服 Redis + Jedis + Spring （二）

接上一篇，
Redis实战之征服 Redis + Jedis + Spring （一）

扩充User属性：

public class User implements Serializable {  
    private static final long serialVersionUID = -1267719235225203410L;  
  
    private String uid;  
  
    private String address;  
  
    private String mobile;  
  
    private String postCode;  
}
复制代码

public class User implements Serializable {  
    private static final long serialVersionUID = -1267719235225203410L;  
  
    private String uid;  
  
    private String address;  
  
    private String mobile;  
  
    private String postCode;  
}  
复制代码

我期望的是：

redis 127.0.0.1:6379> hmget uc.user.info.uid.u123456 address mobile postCode
1) "\xe4\xb8\x8a\xe6\xb5\xb7"
2) "13800138000"
3) "100859"
复制代码

几乎就是一个对象了！
但是，接下来的代码实现，让我彻底崩溃了！



二、代码实现1.保存——HMSET

@Override  
public void save(final User user) {  
    redisTemplate.execute(new RedisCallback<Object>() {  
        @Override  
        public Object doInRedis(RedisConnection connection)  
                throws DataAccessException {  
            byte[] key = redisTemplate.getStringSerializer().serialize(  
                    "uc.user.info.uid." + user.getUid());  
            BoundHashOperations<Serializable, byte[], byte[]> boundHashOperations = redisTemplate  
                    .boundHashOps(key);  
            boundHashOperations.put(redisTemplate.getStringSerializer()  
                    .serialize("mobile"), redisTemplate  
                    .getStringSerializer().serialize(user.getMobile()));  
            boundHashOperations.put(redisTemplate.getStringSerializer()  
                    .serialize("address"), redisTemplate  
                    .getStringSerializer().serialize(user.getAddress()));  
            boundHashOperations.put(redisTemplate.getStringSerializer()  
                    .serialize("postCode"), redisTemplate  
                    .getStringSerializer().serialize(user.getPostCode()));  
            connection.hMSet(key, boundHashOperations.entries());  
            return null;  
        }  
    });  
}
复制代码

@Override  
public void save(final User user) {  
    redisTemplate.execute(new RedisCallback<Object>() {  
        @Override  
        public Object doInRedis(RedisConnection connection)  
                throws DataAccessException {  
            byte[] key = redisTemplate.getStringSerializer().serialize(  
                    "uc.user.info.uid." + user.getUid());  
            BoundHashOperations<Serializable, byte[], byte[]> boundHashOperations = redisTemplate  
                    .boundHashOps(key);  
            boundHashOperations.put(redisTemplate.getStringSerializer()  
                    .serialize("mobile"), redisTemplate  
                    .getStringSerializer().serialize(user.getMobile()));  
            boundHashOperations.put(redisTemplate.getStringSerializer()  
                    .serialize("address"), redisTemplate  
                    .getStringSerializer().serialize(user.getAddress()));  
            boundHashOperations.put(redisTemplate.getStringSerializer()  
                    .serialize("postCode"), redisTemplate  
                    .getStringSerializer().serialize(user.getPostCode()));  
            connection.hMSet(key, boundHashOperations.entries());  
            return null;  
        }  
    });  
}  
复制代码

这里用到：

BoundHashOperations<Serializable, byte[], byte[]> boundHashOperations = redisTemplate.boundHashOps(key);  
boundHashOperations.put(redisTemplate.getStringSerializer().serialize("mobile"), redisTemplate.getStringSerializer().serialize(user.getMobile()));  
复制代码

BoundHashOperations<Serializable, byte[], byte[]> boundHashOperations = redisTemplate.boundHashOps(key);  
boundHashOperations.put(redisTemplate.getStringSerializer().serialize("mobile"), redisTemplate.getStringSerializer().serialize(user.getMobile()));  
复制代码

看着就有点肿。。。Map封装完以后，用HMSET命令：

connection.hMSet(key, boundHashOperations.entries());  
复制代码

connection.hMSet(key, boundHashOperations.entries());  
复制代码

这时候就完成了哈希表的保存操作，可以在控制台看到相应的数据了。

redis 127.0.0.1:6379> hmget uc.user.info.uid.u123456 address mobile postCode
1) "\xe4\xb8\x8a\xe6\xb5\xb7"
2) "13800138000"
3) "100859"
复制代码

2.获取——HMGET这一刻，我彻底崩溃了！取出来的值是个List，还得根据取得顺序，逐个反序列化，得到内容。

@Override  
public User read(final String uid) {  
    return redisTemplate.execute(new RedisCallback<User>() {  
        @Override  
        public User doInRedis(RedisConnection connection)  
                throws DataAccessException {  
            byte[] key = redisTemplate.getStringSerializer().serialize(  
                    "uc.user.info.uid." + uid);  
            if (connection.exists(key)) {  
                List<byte[]> value = connection.hMGet(  
                        key,  
                        redisTemplate.getStringSerializer().serialize(  
                                "address"),  
                        redisTemplate.getStringSerializer().serialize(  
                                "mobile"), redisTemplate  
                                .getStringSerializer()  
                                .serialize("postCode"));  
                User user = new User();  
                String address = redisTemplate.getStringSerializer()  
                        .deserialize(value.get(0));  
                user.setAddress(address);  
                String mobile = redisTemplate.getStringSerializer()  
                        .deserialize(value.get(1));  
                user.setMobile(mobile);  
                String postCode = redisTemplate.getStringSerializer()  
                        .deserialize(value.get(2));  
                user.setPostCode(postCode);  
                user.setUid(uid);  
  
                return user;  
            }  
            return null;  
        }  
    });  
}  
复制代码

@Override  
public User read(final String uid) {  
    return redisTemplate.execute(new RedisCallback<User>() {  
        @Override  
        public User doInRedis(RedisConnection connection)  
                throws DataAccessException {  
            byte[] key = redisTemplate.getStringSerializer().serialize(  
                    "uc.user.info.uid." + uid);  
            if (connection.exists(key)) {  
                List<byte[]> value = connection.hMGet(  
                        key,  
                        redisTemplate.getStringSerializer().serialize(  
                                "address"),  
                        redisTemplate.getStringSerializer().serialize(  
                                "mobile"), redisTemplate  
                                .getStringSerializer()  
                                .serialize("postCode"));  
                User user = new User();  
                String address = redisTemplate.getStringSerializer()  
                        .deserialize(value.get(0));  
                user.setAddress(address);  
                String mobile = redisTemplate.getStringSerializer()  
                        .deserialize(value.get(1));  
                user.setMobile(mobile);  
                String postCode = redisTemplate.getStringSerializer()  
                        .deserialize(value.get(2));  
                user.setPostCode(postCode);  
                user.setUid(uid);  
  
                return user;  
            }  
            return null;  
        }  
    });  
}  
复制代码

这个实现，跟Redis的命令几乎一模一样，指定Key，指定field，获取其值。

List<byte[]> value = connection.hMGet(key,redisTemplate.getStringSerializer().serialize("address"),  
redisTemplate.getStringSerializer().serialize("mobile"),   
redisTemplate.getStringSerializer().serialize("postCode"));  
复制代码

List<byte[]> value = connection.hMGet(key,redisTemplate.getStringSerializer().serialize("address"),  
redisTemplate.getStringSerializer().serialize("mobile"),   
redisTemplate.getStringSerializer().serialize("postCode"));  
复制代码

我绝对相信，要么是我用的过于肤浅，低估了Spring的封装能力。或者，我该直接Json！等等，这不是MongoDB干的事情吗？！
PS：这两篇博客里操作的数据类型，只能是String类型，还没搞定除此以外任何类型。吾将上下而求索～～～
上述操作也许你吐了，接下来的代码，就再吐一次吧！
封装对象的时候，一定要记得次序。。。。这绝对不是一个优质代码的实现风格！

User user = new User();  
String address = redisTemplate.getStringSerializer().deserialize(value.get(0));  
user.setAddress(address);  
String mobile = redisTemplate.getStringSerializer().deserialize(value.get(1));  
user.setMobile(mobile);  
String postCode = redisTemplate.getStringSerializer().deserialize(value.get(2));  
user.setPostCode(postCode);  
复制代码

User user = new User();  
String address = redisTemplate.getStringSerializer().deserialize(value.get(0));  
user.setAddress(address);  
String mobile = redisTemplate.getStringSerializer().deserialize(value.get(1));  
user.setMobile(mobile);  
String postCode = redisTemplate.getStringSerializer().deserialize(value.get(2));  
user.setPostCode(postCode);  
复制代码

好吧！苦逼的事情，就此结束。目标Json支持！

继续补充：


为了简便操作，我使用了StringRedisTemplate。用字符串操作做展示。当然，你可以继续使用RedisTemplate。
闲言少叙，上代码，一目了然：

/** 
 * Mar 5, 2013 
 */  
package org.zlex.redis.support;  
  
import java.util.List;  
  
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.data.redis.core.StringRedisTemplate;  
import org.springframework.stereotype.Component;  
  
/** 
 *  
 * @author snowolf 
 * @version 1.0 
 * @since 1.0 
 */  
@Component("listOps")  
public class ListOps {  
  
    @Autowired  
    private StringRedisTemplate stringRedisTemplate;  
  
    /** 
     * 压栈 
     *  
     * @param key 
     * @param value 
     * @return 
     */  
    public Long push(String key, String value) {  
        return stringRedisTemplate.opsForList().leftPush(key, value);  
    }  
  
    /** 
     * 出栈 
     *  
     * @param key 
     * @return 
     */  
    public String pop(String key) {  
        return stringRedisTemplate.opsForList().leftPop(key);  
    }  
  
    /** 
     * 入队 
     *  
     * @param key 
     * @param value 
     * @return 
     */  
    public Long in(String key, String value) {  
        return stringRedisTemplate.opsForList().rightPush(key, value);  
    }  
  
    /** 
     * 出队 
     *  
     * @param key 
     * @return 
     */  
    public String out(String key) {  
        return stringRedisTemplate.opsForList().leftPop(key);  
    }  
  
    /** 
     * 栈/队列长 
     *  
     * @param key 
     * @return 
     */  
    public Long length(String key) {  
        return stringRedisTemplate.opsForList().size(key);  
    }  
  
    /** 
     * 范围检索 
     *  
     * @param key 
     * @param start 
     * @param end 
     * @return 
     */  
    public List<String> range(String key, int start, int end) {  
        return stringRedisTemplate.opsForList().range(key, start, end);  
    }  
  
    /** 
     * 移除 
     *  
     * @param key 
     * @param i 
     * @param value 
     */  
    public void remove(String key, long i, String value) {  
        stringRedisTemplate.opsForList().remove(key, i, value);  
    }  
  
    /** 
     * 检索 
     *  
     * @param key 
     * @param index 
     * @return 
     */  
    public String index(String key, long index) {  
        return stringRedisTemplate.opsForList().index(key, index);  
    }  
  
    /** 
     * 置值 
     *  
     * @param key 
     * @param index 
     * @param value 
     */  
    public void set(String key, long index, String value) {  
        stringRedisTemplate.opsForList().set(key, index, value);  
    }  
  
    /** 
     * 裁剪 
     *  
     * @param key 
     * @param start 
     * @param end 
     */  
    public void trim(String key, long start, int end) {  
        stringRedisTemplate.opsForList().trim(key, start, end);  
    }  
}  
复制代码

/** 
 * Mar 5, 2013 
 */  
package org.zlex.redis.support;  
  
import java.util.List;  
  
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.data.redis.core.StringRedisTemplate;  
import org.springframework.stereotype.Component;  
  
/** 
 *  
 * @author snowolf 
 * @version 1.0 
 * @since 1.0 
 */  
@Component("listOps")  
public class ListOps {  
  
    @Autowired  
    private StringRedisTemplate stringRedisTemplate;  
  
    /** 
     * 压栈 
     *  
     * @param key 
     * @param value 
     * @return 
     */  
    public Long push(String key, String value) {  
        return stringRedisTemplate.opsForList().leftPush(key, value);  
    }  
  
    /** 
     * 出栈 
     *  
     * @param key 
     * @return 
     */  
    public String pop(String key) {  
        return stringRedisTemplate.opsForList().leftPop(key);  
    }  
  
    /** 
     * 入队 
     *  
     * @param key 
     * @param value 
     * @return 
     */  
    public Long in(String key, String value) {  
        return stringRedisTemplate.opsForList().rightPush(key, value);  
    }  
  
    /** 
     * 出队 
     *  
     * @param key 
     * @return 
     */  
    public String out(String key) {  
        return stringRedisTemplate.opsForList().leftPop(key);  
    }  
  
    /** 
     * 栈/队列长 
     *  
     * @param key 
     * @return 
     */  
    public Long length(String key) {  
        return stringRedisTemplate.opsForList().size(key);  
    }  
  
    /** 
     * 范围检索 
     *  
     * @param key 
     * @param start 
     * @param end 
     * @return 
     */  
    public List<String> range(String key, int start, int end) {  
        return stringRedisTemplate.opsForList().range(key, start, end);  
    }  
  
    /** 
     * 移除 
     *  
     * @param key 
     * @param i 
     * @param value 
     */  
    public void remove(String key, long i, String value) {  
        stringRedisTemplate.opsForList().remove(key, i, value);  
    }  
  
    /** 
     * 检索 
     *  
     * @param key 
     * @param index 
     * @return 
     */  
    public String index(String key, long index) {  
        return stringRedisTemplate.opsForList().index(key, index);  
    }  
  
    /** 
     * 置值 
     *  
     * @param key 
     * @param index 
     * @param value 
     */  
    public void set(String key, long index, String value) {  
        stringRedisTemplate.opsForList().set(key, index, value);  
    }  
  
    /** 
     * 裁剪 
     *  
     * @param key 
     * @param start 
     * @param end 
     */  
    public void trim(String key, long start, int end) {  
        stringRedisTemplate.opsForList().trim(key, start, end);  
    }  
}  
复制代码

这里说明下，例如LPUSH，RPUSH，其实就是从左边压栈，还是从右边压栈的不同命令。可以把堆栈看作是一个从左至右的数组。如果左边压栈，右边出栈，那就是队列的入队/出队操作；如果左边压栈，左边出栈，那就是堆栈操作。

举个具体的例子：
队列操作：LPUSH入队，RPOP出队，同理，可把L|R替换。
堆栈操作：LPUSH压栈，LPOP出栈，同理，可把L|R替换。

下面进行测试用例，初始、结束时，分别做入队、出队操作，期间进行堆栈，队列操作。不用我细说了，看测试用例，很简单！

/** 
 * Mar 5, 2013 
 */  
package org.zlex.redis;  
  
import static org.junit.Assert.*;  
  
import java.util.List;  
  
import org.junit.Before;  
import org.junit.After;  
import org.junit.Test;  
import org.springframework.context.ApplicationContext;  
import org.springframework.context.support.ClassPathXmlApplicationContext;  
import org.zlex.redis.support.ListOps;  
  
/** 
 *  
 * @author snowolf 
 * @version 1.0 
 * @since 1.0 
 */  
public class ListOpsTest {  
    private ApplicationContext app;  
    private ListOps listOps;  
    private String key = "queue";  
  
    @Before  
    public void before() throws Exception {  
        app = new ClassPathXmlApplicationContext("applicationContext.xml");  
        listOps = (ListOps) app.getBean("listOps");  
  
        System.out.println("------------IN---------------");  
        for (int i = 0; i < 5; i++) {  
            String uid = "u" + i;  
            System.out.println(uid);  
            listOps.in(key, uid);  
        }  
    }  
  
    @After  
    public void after() {  
        // ------------OUT---------------  
        System.out.println("------------OUT---------------");  
        long length = listOps.length(key);  
        for (long i = 0; i < length; i++) {  
            String uid = listOps.out(key);  
            System.out.println(uid);  
        }  
    }  
  
    @Test  
    public void stack() {  
        // ------------PUSH---------------  
        String key = "stack";  
        int len = 5;  
        System.out.println("------------PUSH---------------");  
        for (int i = 0; i < len; i++) {  
            String uid = "u" + System.currentTimeMillis();  
            System.out.println(uid);  
            listOps.push(key, uid);  
        }  
  
        long length = listOps.length(key);  
        assertEquals(len, length);  
  
        // ------------POP---------------  
        System.out.println("------------POP---------------");  
        for (long i = 0; i < length; i++) {  
            String uid = listOps.pop(key);  
            System.out.println(uid);  
        }  
    }  
  
    @Test  
    public void index() {  
  
        // -------------INDEX-------------  
        String value = listOps.index(key, 3);  
        assertEquals("u3", value);  
    }  
  
    @Test  
    public void range() {  
        // -------------RANGE-------------  
        List<String> list = listOps.range(key, 3, 5);  
        boolean result1 = list.contains("u3");  
        assertEquals(true, result1);  
  
        boolean result2 = list.contains("u1");  
        assertEquals(false, result2);  
    }  
  
    @Test  
    public void trim() {  
        // ------------TRIM---------------  
        List<String> list = listOps.range(key, 3, 5);  
        listOps.trim(key, 3, 5);  
        boolean result3 = list.contains("u1");  
        assertEquals(false, result3);  
    }  
  
    @Test  
    public void set() {  
        // ------------SET-----------------  
        List<String> list = listOps.range(key, 3, 5);  
        listOps.set(key, 4, "ux4");  
        boolean result4 = list.contains("u4");  
        assertEquals(true, result4);  
  
    }  
  
    @Test  
    public void remove() {  
        // ------------REMOVE-----------------  
        listOps.remove(key, 4, "u4");  
        String value = listOps.index(key, 4);  
        assertEquals(null, value);  
  
    }  
}  
复制代码

/** 
 * Mar 5, 2013 
 */  
package org.zlex.redis;  
  
import static org.junit.Assert.*;  
  
import java.util.List;  
  
import org.junit.Before;  
import org.junit.After;  
import org.junit.Test;  
import org.springframework.context.ApplicationContext;  
import org.springframework.context.support.ClassPathXmlApplicationContext;  
import org.zlex.redis.support.ListOps;  
  
/** 
 *  
 * @author snowolf 
 * @version 1.0 
 * @since 1.0 
 */  
public class ListOpsTest {  
    private ApplicationContext app;  
    private ListOps listOps;  
    private String key = "queue";  
  
    @Before  
    public void before() throws Exception {  
        app = new ClassPathXmlApplicationContext("applicationContext.xml");  
        listOps = (ListOps) app.getBean("listOps");  
  
        System.out.println("------------IN---------------");  
        for (int i = 0; i < 5; i++) {  
            String uid = "u" + i;  
            System.out.println(uid);  
            listOps.in(key, uid);  
        }  
    }  
  
    @After  
    public void after() {  
        // ------------OUT---------------  
        System.out.println("------------OUT---------------");  
        long length = listOps.length(key);  
        for (long i = 0; i < length; i++) {  
            String uid = listOps.out(key);  
            System.out.println(uid);  
        }  
    }  
  
    @Test  
    public void stack() {  
        // ------------PUSH---------------  
        String key = "stack";  
        int len = 5;  
        System.out.println("------------PUSH---------------");  
        for (int i = 0; i < len; i++) {  
            String uid = "u" + System.currentTimeMillis();  
            System.out.println(uid);  
            listOps.push(key, uid);  
        }  
  
        long length = listOps.length(key);  
        assertEquals(len, length);  
  
        // ------------POP---------------  
        System.out.println("------------POP---------------");  
        for (long i = 0; i < length; i++) {  
            String uid = listOps.pop(key);  
            System.out.println(uid);  
        }  
    }  
  
    @Test  
    public void index() {  
  
        // -------------INDEX-------------  
        String value = listOps.index(key, 3);  
        assertEquals("u3", value);  
    }  
  
    @Test  
    public void range() {  
        // -------------RANGE-------------  
        List<String> list = listOps.range(key, 3, 5);  
        boolean result1 = list.contains("u3");  
        assertEquals(true, result1);  
  
        boolean result2 = list.contains("u1");  
        assertEquals(false, result2);  
    }  
  
    @Test  
    public void trim() {  
        // ------------TRIM---------------  
        List<String> list = listOps.range(key, 3, 5);  
        listOps.trim(key, 3, 5);  
        boolean result3 = list.contains("u1");  
        assertEquals(false, result3);  
    }  
  
    @Test  
    public void set() {  
        // ------------SET-----------------  
        List<String> list = listOps.range(key, 3, 5);  
        listOps.set(key, 4, "ux4");  
        boolean result4 = list.contains("u4");  
        assertEquals(true, result4);  
  
    }  
  
    @Test  
    public void remove() {  
        // ------------REMOVE-----------------  
        listOps.remove(key, 4, "u4");  
        String value = listOps.index(key, 4);  
        assertEquals(null, value);  
  
    }  
}  
复制代码

回头继续整理，这个套路没错！

感谢楼主分享。

感谢楼主分享。

感谢楼主分享。