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 ;  
   }