我们项目中最常用的的就是增、删、改、查的API,今天我们详解几种常用的操作类型:
1、最常用的增、删、改、查接口
/** * 添加key * * @param key * @param value */ public void set(String key, String value) { redisTemplate.opsForValue().set(key, value); } public Object getV(String key, String value) { return redisTemplate.opsForValue().get(key); } public Object get(final String key) { return this.redisTemplate.execute(new RedisCallback<Object>() { @Override public Object doInRedis(RedisConnection conn) { byte[] bvalue = conn.get(key.getBytes()); if (null == bvalue) { return null; } else { return redisTemplate.getStringSerializer().deserialize(bvalue); } } }); } //删除接口 public void del(final String key) { this.redisTemplate.execute(new RedisCallback<Object>() { @Override public Object doInRedis(RedisConnection conn) { return conn.del(key.getBytes()); } }); }
解析:
redisUtils.set("user_keys", JSON.toJSONString(users));//存数据 List<UserInfo> users = JSON.parseArray(JSON.parse(o.toString()).toString(), UserInfo.class);//批量取数据 UserInfo user= JSON.parseObject(JSON.parse(o.toString()).toString(),UserInfo.class);//单个取数据
注意参与的业务对象,必须序列化,才能进行网络传输:
UserInfo implements Serializable
2、带有超时时间的API
/** * 存储时加了60秒的超时时间,查、删接口同上 */ redisUtils.set("user_body",JSON.toJSONString(userInfo),600,TimeUnit.SECONDS);
3、带有hash索引的API接口:
//查询接口 public Object hGet(final String key, final String field) { return this.redisTemplate.execute(new RedisCallback<Object>() { @Override public Object doInRedis(RedisConnection conn) { byte[] bvalue = conn.hGet(key.getBytes(), field.getBytes()); if (null == bvalue) { return null; } else { return redisTemplate.getStringSerializer().deserialize(bvalue); } } }); } //删除接口 public void hDel(final String key, final String field) { this.redisTemplate.execute(new RedisCallback<Object>() { @Override public Object doInRedis(RedisConnection conn) { return conn.hDel(key.getBytes(), field.getBytes()); } }); } //添加接口 public void hSet(final String key, final String field, final String value) { this.redisTemplate.execute(new RedisCallback<Object>() { @Override public Object doInRedis(RedisConnection conn) throws DataAccessException { conn.hSet(key.getBytes(), field.getBytes(), value.getBytes()); return null; } }); }
解析数据类似上面:
UserInfo user = JSON.parseObject(hStr.toString(), UserInfo.class);
hset 则存储结构化数据,一个 hash 存储一条数据,一个 filed 则存储 一条数据中的一个属性,value 则是属性对应的值。Redis hash 是一个 string 类型的 field 和 value 的映射表,hash 特别适合用于存储对象。