redis作为队列解决方案

《redis作为队列解决方案》由会员上传分享，免费在线阅读，更多相关内容在应用文档-天天文库。

1、自从人类进入商品经济社会以来，贸易即已成为人们日常活动的主要部分，并成为一国经济增长的主动力。国际分工的深化、大量国际统一标准规则的建立redis作为队列解决方案　　篇一：javaredis使用之利用jedis实现redis消息队列　　应用场景　　最近在公司做项目，需要对聊天内容进行存储，考虑到数据库查询的IO连接数高、连接频繁的因素，决定利用缓存做。　　从网上了解到redis可以对所有的内容进行二进制的存储，而java是可以对所有对象进行序列化的，序列化的方法会在下面的代码中提供实现。　　序列化　　这里我编写了一个java序列化的工具，主要

2、是对对象转换成byte[]，和根据byte[]数组反序列化成java对象；　　主要是用到了ByteArrayOutputStream和ByteArrayInputStream；　　需要注意的是每个自定义的需要序列化的对象都要实现Serializable接口；　　其代码如下：　　?　　1　　2　　3随着信息化和全球化的发展，国家及地区之间的贸易也已成为拉动一国经济的三驾马车之一，甚至是三驾马车之首，奥巴马政府成立之日起自从人类进入商品经济社会以来，贸易即已成为人们日常活动的主要部分，并成为一国经济增长的主动力。国际分工的深化、大量国际统一标准规

3、则的建立　　4　　5　　6　　7　　8　　9　　10　　11　　12　　13　　14　　15　　16　　17　　18　　19　　20　　21　　22package;import;import;import;import;import;publicclassObjectUtil{/**对象转byte[]*@paramobj*@return*@throwsIOException*/publicstaticbyte[]objectToBytes(Objectobj)throws随着信息化和全球化的发展，国家及地区之间的贸易也已成为拉动一国经济的三驾

4、马车之一，甚至是三驾马车之首，奥巴马政府成立之日起自从人类进入商品经济社会以来，贸易即已成为人们日常活动的主要部分，并成为一国经济增长的主动力。国际分工的深化、大量国际统一标准规则的建立Exception{ByteArrayOutputStreambo=newByteArrayOutputStream();ObjectOutputStreamoo=newObjectOutputStream(bo);(obj);byte[]bytes=();();();returnbytes;}　　23　　24　　25　　26　　27　　28　　29　　30　

5、　31　　3233}/**byte[]转对象*@parambytes*@return*@throwsException*/publicstaticObjectbytesToObject(byte[]bytes)throwsException{ByteArrayInputStreamin=newByteArrayInputStream(bytes);ObjectInputStreamsIn=newObjectInputStream(in);return();}　　定义一个消息类，主要用于接收消息内容和消息下表的设置。　　?随着信息化和全球化的发

6、展，国家及地区之间的贸易也已成为拉动一国经济的三驾马车之一，甚至是三驾马车之首，奥巴马政府成立之日起自从人类进入商品经济社会以来，贸易即已成为人们日常活动的主要部分，并成为一国经济增长的主动力。国际分工的深化、大量国际统一标准规则的建立　　1　　2　　3　　4　　5　　6　　7　　8　　9　　10　　11　　12　　13　　14　　15　　16　　17　　18　　19　　20　　21　　22随着信息化和全球化的发展，国家及地区之间的贸易也已成为拉动一国经济的三驾马车之一，甚至是三驾马车之首，奥巴马政府成立之日起自从人类进入商品经济社会以来，贸

7、易即已成为人们日常活动的主要部分，并成为一国经济增长的主动力。国际分工的深化、大量国际统一标准规则的建立　　23　　2425package;import;/**定义消息类接收消息内容和设置消息的下标*@authorlenovo**/publicclassMessageimplementsSerializable{privatestaticfinallongserialVersionUID=L;privateintid;privateStringcontent;publicintgetId(){returnid;}publicvoidsetId

8、(intid){=id;}publicStringgetContent(){returncontent;}publicvoidsetContent(Stringco