首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > 开发语言 > 编程 >

Servlet 3.0札记之Redis操作示范Retwis JAVA版

2012-10-27 
Servlet 3.0笔记之Redis操作示范Retwis JAVA版最近学习Redis,一个目前风头正劲的KEY-VALUE NOSQL,支持LIST

Servlet 3.0笔记之Redis操作示范Retwis JAVA版

最近学习Redis,一个目前风头正劲的KEY-VALUE NOSQL,支持LIST、SET、MAP等格式存储,某些操作竟然是原子级别,比如incr命令,相当惊艳。官方提供的一个Retwis(simple clone of Twitter)示范,证明了完全可以使用redis替代SQL数据库存储数据,真是一大开创性创新,挑战人们的传统思维模式,为之惊叹!

不过那是一个PHP版本,我下载到本地PHP但无法部署成功;还好有一个Retwis-RB示范,还提供一个在线版,试用之后,再下载源代码,RUBY + Sinatra MVC结构,看的流口水,代码那般简洁。

为体验Redis,同时也为对比Ruby代码,因此诞生了Retwis-JAVA,Retwis-RB的山寨版,因此其逻辑和HTML资源一致,再次表示对原作者Dan Lucraft的感谢。

Retwis-JAVA,基于Servlet 3.0 + UrlRewrite + Freemarker + Jedis。示范运行在Tomcat 7中,redis为最新的2.22版本,jedis为redis的java客户端操作框架。在Servlet 3.0规范中,对Url映射处理依然没有进步,因此只能使用UrlRewrite框架让部分url看起来友好一些。另外,项目没有使用IOC容器框架,没有使用MVC框架,代码量稍微多些,代码相对耦合一些。若使用Struts2 + Spring 代码量会少一些。

对涉及到的redis存储结构,大致如下:


涉及到的两个对象很简单:


序列化后以二进制数据保存到redis中:

????private?byte[]?object2Bytes(V?value)?{
????????if?(value?==?null)
????????????return?null;

????????ByteArrayOutputStream?arrayOutputStream?=?new?ByteArrayOutputStream();
????????ObjectOutputStream?outputStream;
????????try?{
????????????outputStream?=?new?ObjectOutputStream(arrayOutputStream);

????????????outputStream.writeObject(value);
????????}?catch?(IOException?e)?{
????????????e.printStackTrace();
????????}?finally?{
????????????try?{
????????????????arrayOutputStream.close();
????????????}?catch?(IOException?e)?{
????????????????e.printStackTrace();
????????????}
????????}

????????return?arrayOutputStream.toByteArray();
????}


????public?void?save(String?key,?V?value)?{
????????jedis.set(getKey(key),?object2Bytes(value));
????}

获取用户的timeline时,redis的LRANGE命令提供对list类型数据提供分页操作:

????private?List<Status>?timeline(String?targetId,?int?page)?{
????????if?(page?<?1)
????????????page?=?1;

????????int?startIndex?=?(page?-?1)?*?10;
????????int?endIndex?=?page?*?10;

????????List<String>?idList?=?super.jedis
????????????????.lrange(targetId,?startIndex,?endIndex);

????????if?(idList.isEmpty())
????????????return?new?ArrayList<Status>(0);

????????List<Status>?statusList?=?new?ArrayList<Status>(idList.size());
????????for?(String?id?:?idList)?{
????????????Status?status?=?load(Long.valueOf(id));

????????????if?(status?==?null)
????????????????continue;

????????????status.setUser(userService.load(status.getUid()));

????????????statusList.add(status);
????????}

????????return?statusList;
????}

很显然,LRANGE取出了Status对象的ID,然后我们需要再次根据ID获取对应的Status对象二进制数据,然后反序列化:

????public?Status?load(long?id)?{
????????return?super.get(getFormatId(id));
????}

????private?String?getFormatId(long?id)?{
????????return?String.format(STATUS_ID_FORMAT,?id);
????}

????private?static?final?String?STATUS_ID_FORMAT?=?"status:id:%d";

????public?V?get(String?key)?{
????????return?byte2Object(jedis.get(getKey(key)));
????}

????@SuppressWarnings("unchecked")
????private?V?byte2Object(byte[]?bytes)?{
????????if?(bytes?==?null?||?bytes.length?==?0)
????????????return?null;

????????try?{
????????????ObjectInputStream?inputStream;
????????????inputStream?=?new?ObjectInputStream(new?ByteArrayInputStream(bytes));
????????????Object?obj?=?inputStream.readObject();

????????????return?(V)?obj;
????????}?catch?(IOException?e)?{
????????????e.printStackTrace();
????????}?catch?(ClassNotFoundException?e)?{
????????????e.printStackTrace();
????????}

????????return?null;
????}

以上使用JDK内置的序列化支持;更多序列化,可参考hessian、google protobuf等序列化框架,后者提供业界更为成熟的跨平台、更为高效的序列化方案。更多代码请参见附件。

一些总结和思考:

    不仅仅是缓存,替代SQL数据库已完全成为可能,更高效,更经济;虽然只是打开了一扇小的窗户,但说不准以后人们会把大门打开。实际环境中,可能最佳方式为SQL + NOSQL配合使用,互相弥补不足;还好,redis指令不算多,可速查,简单易记。JAVA和RUBY代码相比,有些重

另:

在线版,请参考 http://retwisrb.danlucraft.com/。那个谁谁,要运行范例,保证redis运行才行。

Retwis-JAVA下载

热点排行