Servlet3.0笔记之Redis操作示范Retwis Java版

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代码相比，有些重