redis 存储对

如果需要用到Redis存储List对象,而list又不需要进行操作,可以按照MC的方式进行存储,不过Jedis之类的客户端没有提供API,可以有两种思路实现: 1. 分别序列化 elements ,然后 set 存储

2. 序列化List对象,set存储

这两种方法都类似MC的 Object方法存储,运用这种方式意味着放弃Redis对List提供的操作方法。

/**

* Created by IntelliJ IDEA.

* User: taomeng

* Date: 16-10-11

* Time: 上午11:10

* To change this template use File | Settings | File Templates.

*/

public class JedisTest {

private static Logger logger = LoggerFactory.getLogger(JedisTest.class);

public static JedisPool buildJedisPool(){

JedisPoolConfig config = new JedisPoolConfig();

config.setMaxActive(1);

config.setMinIdle(50);

config.setMaxIdle(3000);

config.setMaxWait(5000);

JedisPool jedisPool = new JedisPool(config,

"*****", ****);

return jedisPool;

}

public static List<User> buildTestData(){

User a = new User();

a.setName("a");

User b = new User();

b.setName("b");

List<User> list = new ArrayList<User>();

list.add(a);

list.add(b);

return list;

}

public static void testSetElements(){

List<User> testData = buildTestData();

Jedis jedis = buildJedisPool().getResource();

String key = "testSetElements" + new Random(1000).nextInt();

jedis.set(key.getBytes(), ObjectsTranscoder.serialize(testData));

byte[] in = jedis.get(key.getBytes());

List<User> list = ObjectsTranscoder.deserialize(in);

for(User user : list){

System.out.println("testSetElements user name is:" + user.getName());

}

}

public static void testSetEnsemble(){

List<User> testData = buildTestData();

Jedis jedis = buildJedisPool().getResource();

String key = "testSetEnsemble" + new Random(1000).nextInt();

jedis.set(key.getBytes(), ListTranscoder.serialize(testData));

byte[] in = jedis.get(key.getBytes());

List<User> list = (List<User>)ListTranscoder.deserialize(in);

for(User user : list){

System.out.println("testSetEnsemble user name is:" + user.getName());

}

}

static class User implements Serializable{

String name;

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

}

static class ObjectsTranscoder{

public static byte[] serialize(List<User> value) {

if (value == null) {

throw new NullPointerException("Can't serialize null");

}

byte[] rv=null;

ByteArrayOutputStream bos = null;

ObjectOutputStream os = null;

try {

bos = new ByteArrayOutputStream();

os = new ObjectOutputStream(bos);

for(User user : value){

os.writeObject(user);

}

os.writeObject(null);

os.close();

bos.close();

rv = bos.toByteArray();

} catch (IOException e) {

throw new IllegalArgumentException("Non-serializable object", e);

} finally {

close(os);

close(bos);

}

return rv;

}

public static List<User> deserialize(byte[] in) {

List<User> list = new ArrayList<User>();

ByteArrayInputStream bis = null;

ObjectInputStream is = null;

try {

if(in != null) {

bis=new ByteArrayInputStream(in);

is=new ObjectInputStream(bis);

while (true) {

User user = (User) is.readObject();

if(user == null){

break;

}else{

list.add(user);

}

}

is.close();

bis.close();

}

} catch (IOException e) {

logger.warn("Caught IOException decoding %d bytes of data",

in == null ? 0 : in.length, e);

} catch (ClassNotFoundException e) {

logger.warn("Caught CNFE decoding %d bytes of data",

in == null ? 0 : in.length, e);

} finally {

CloseUtil.close(is);

CloseUtil.close(bis);

}

return list;

}

}

static class ListTranscoder{

public static byte[] serialize(Object value) {

if (value == null) {

throw new NullPointerException("Can't serialize null");

}

byte[] rv=null;

ByteArrayOutputStream bos = null;

ObjectOutputStream os = null;

try {

bos = new ByteArrayOutputStream();

os = new ObjectOutputStream(bos);

os.writeObject(value);

os.close();

bos.close();

rv = bos.toByteArray();

} catch (IOException e) {

throw new IllegalArgumentException("Non-serializable object", e);

} finally {

close(os);

close(bos);

}

return rv;

}

public static Object deserialize(byte[] in) {

Object rv=null;

ByteArrayInputStream bis = null;

ObjectInputStream is = null;

try {

if(in != null) {

bis=new ByteArrayInputStream(in);

is=new ObjectInputStream(bis);

rv=is.readObject();

is.close();

bis.close();

}

} catch (IOException e) {

logger.warn("Caught IOException decoding %d bytes of data"

in == null ? 0 : in.length, e);

} catch (ClassNotFoundException e) {

logger.warn("Caught CNFE decoding %d bytes of data",

in == null ? 0 : in.length, e);

} finally {

CloseUtil.close(is);

CloseUtil.close(bis);

}

return rv;

}

}

} PS:Redsi和memcached有什么区别哪?请看下回分解。

本文分享自微信公众号 - 程序猿那点儿事儿(exportnew),作者:小T

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2018-09-12

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • @Builder注解和@EqualsAndHashCode 注解剖析

    https://projectlombok.org/features/EqualsAndHashCode.html

    半条命专刊
  • spring cloud微服务之间的调用

    在RestTemplate实例化的地方添加了@LoadBalanced注解,我们使用RestTemplate时就该注解就会自动将调用接口的地址替换成真正的服务地...

    半条命专刊
  • mac上安装android studio

    下载并安装Android Studio 官方下载:http://developer.android.com/intl/zh-cn/sdk/index.html

    半条命专刊
  • 线性排序算法(1)

    由于在遍历过程中,当出现前一个元素小于当前元素,提前结束比对,比选择排序算法的比对次数少。

    birdskyws
  • 让 Android 的 WebView 支持 type 为 file 的 input,同时支持拍照

    Android 的 WebView 组件默认是不启用 type 为 file 的 input 的,需要在代码中做一些类似 hack 的编码(因为解决问题的目标对...

    LeoXu
  • 【Jfinal源码】第一章 com.jfinal.core.JFinalFilter(1)

    前言: 首先在gitosc获取到jfinal的源码,本学习笔记使用的是jfinal2.2版本。 ---- 从web.xml开始,我们去学习jfinal是怎么从...

    冷冷
  • python 魔法方法连载四 __new__()

    在学习__new__(cls,[ *args]) 方法之前,我们知道,当实例化一个对象时,首先调用的是 __init__()方法初始化对象,但在我们学习了了__...

    cctester
  • Android 最全 Intent 传递数据姿势

    点击上面蓝色字体关注“IT大飞说” 置顶公众号(**ID:ITBigFly**)第一时间收到推送

    Vance大飞
  • CentOS7中使用shell脚本安装python3.8环境(推荐)

    虚拟机一键安装python3.8环境,只需将网络适配器改为nat模式即可(确保主机能够上网),随后将tar包放入/root目录下,执行脚本。

    砸漏
  • zTree创建quickSearch检索框

    河岸飞流

扫码关注云+社区

领取腾讯云代金券