Tin's Blog

/**
 * 
  */
package  com.goldnet.framework.webwork.result;

import  java.io.Writer;

import  org.apache.log4j.Logger;

import  com.opensymphony.webwork.ServletActionContext;
import  com.opensymphony.xwork.ActionInvocation;
import  com.opensymphony.xwork.Result;
import  com.sun.syndication.feed.synd.SyndFeed;
import  com.sun.syndication.io.SyndFeedOutput;

/**
 * A simple Result to output a Rome SyndFeed object into a newsfeed.
 *  @author  Philip Luppens
 * 
  */
public   class  RomeResult  implements  Result {
  private   static   final   long  serialVersionUID  =   - 6089389751322858939L ;

  private  String feedName;

  private  String feedType;

  private   final   static  Logger logger  =  Logger.getLogger(RomeResult. class );

  /*
  * (non-Javadoc)
  * 
  * @see com.opensymphony.xwork.Result#execute(com.opensymphony.xwork.ActionInvocation)
   */
  public   void  execute(ActionInvocation ai)  throws  Exception {
   if  (feedName  ==   null ) {
    //  ack, we need this to find the feed on the stack
   logger
     .error( " Required parameter 'feedName' not found.  "
        +   " Make sure you have the param tag set and  "
        +   " the static-parameters interceptor enabled in your interceptor stack. " );
    //  no point in continuing ..
    return ;
  }

   //  don't forget to set the content to the correct mimetype
  ServletActionContext.getResponse().setContentType( " text/xml " );
   //  get the feed from the stack that can be found by the feedName
  SyndFeed feed  =  (SyndFeed) ai.getStack().findValue(feedName);

   if  (logger.isDebugEnabled()) {
   logger.debug( " Found object on stack with name ' "   +  feedName  +   " ':  "
      +  feed);
  }
   if  (feed  !=   null ) {

    if  (feedType  !=   null ) {
     //  Accepted types are: rss_0.90 - rss_2.0 and atom_0.3
     //  There is a bug though in the rss 2.0 generator when it checks
     //  for the type attribute in the description element. It's has a
     //  big 'FIXME' next to it (v. 0.7beta).
    feed.setFeedType(feedType);
   }
   SyndFeedOutput output  =   new  SyndFeedOutput();
    // we'll need the writer since Rome doesn't support writing to an outputStream yet
   Writer out  =   null ;
    try  {
    out  =  ServletActionContext.getResponse().getWriter();
    output.output(feed, out);
   }  catch  (Exception e) {
     //  Woops, couldn't write the feed ?
    logger.error( " Could not write the feed " , e);
   }  finally  {
     // close the output writer (will flush automatically)
     if  (out  !=   null ) {
     out.close();
    }
   }

  }  else  {
    //  woops .. no object found on the stack with that name ?
   logger.error( " Did not find object on stack with name ' "   +  feedName
      +   " ' " );
  }
 }

  public   void  setFeedName(String feedName) {
   this .feedName  =  feedName;
 }

  public   void  setFeedType(String feedType) {
   this .feedType  =  feedType;
 }

}

< package  name ="default"  extends ="webwork-default" >
   < result-types >
    < result-type  name ="feed"  class ="com.goldnet.framework.webwork.result.RomeResult" />
   </ result-types >
   < interceptors >
   <!--  然后是你的那些inteceptor配置等  -->

/**
 *
  */
package  com.goldnet.webwork.action.news;

import  com.opensymphony.xwork.ActionSupport;

import  com.sun.syndication.feed.synd.SyndCategory;
import  com.sun.syndication.feed.synd.SyndCategoryImpl;
import  com.sun.syndication.feed.synd.SyndContent;
import  com.sun.syndication.feed.synd.SyndContentImpl;
import  com.sun.syndication.feed.synd.SyndEntry;
import  com.sun.syndication.feed.synd.SyndEntryImpl;
import  com.sun.syndication.feed.synd.SyndFeed;
import  com.sun.syndication.feed.synd.SyndFeedImpl;

import  org.apache.commons.logging.Log;
import  org.apache.commons.logging.LogFactory;

import  java.util.ArrayList;
import  java.util.Date;
import  java.util.List;


/**
 *  @author  Tin
 *
  */
public   class  TestFeedCreateAction  extends  ActionSupport {
     private   static   final   long  serialVersionUID  =   - 2207516408313865979L ;
     private   transient   final  Log log  =  LogFactory.getLog(TestFeedCreateAction. class );
     private   int  maxEntryNumber  =   25 ;
     private  String siteUrl  =   " http://127.0.0.1 " ;
     private  SyndFeed feed  =   null ;

     public  TestFeedCreateAction() {
         super ();
    }

    @Override
     public  String execute() {
        List < News >  newsList  =  getNewsList();

         if  (log.isDebugEnabled()) {
            log.debug( " Geting feed! and got news  "   +  newsList.size()  +
                 "  pieces. " );
        }

        feed  =   new  SyndFeedImpl();

        feed.setTitle(converttoISO( " 测试中的新闻系统 " ));
        feed.setDescription(converttoISO( " 测试中的新闻系统：测试Rome Result " ));
        feed.setAuthor(converttoISO( " 测试Tin " ));
        feed.setLink( " http://www.justatest.cn " );

        List < SyndEntry >  entries  =   new  ArrayList < SyndEntry > ();
        feed.setEntries(entries);

         for  (News news : newsList) {
            SyndEntry entry  =   new  SyndEntryImpl();
            entry.setAuthor(converttoISO(news.getAuthor()));

            SyndCategory cat  =   new  SyndCategoryImpl();
            cat.setName(converttoISO(news.getCategory()));

            List < SyndCategory >  cats  =   new  ArrayList < SyndCategory > ();
            cats.add(cat);
            entry.setCategories(cats);

            SyndContent content  =   new  SyndContentImpl();
            content.setValue(converttoISO(news.getContent()));

            List < SyndContent >  contents  =   new  ArrayList < SyndContent > ();
            contents.add(content);
            entry.setContents(contents);
            entry.setDescription(content);
            entry.setLink(siteUrl  +   " /common/news/displayNews.action?id= "   +
                news.getId());
            entry.setTitle(converttoISO(news.getTitle()));
            entry.setPublishedDate(news.getPublishDate());
            entries.add(entry);
        }

         return  SUCCESS;
    }

     private   static  String converttoISO(String s) {
         try  {
             byte [] abyte0  =  s.getBytes( " UTF-8 " );

             return   new  String(abyte0,  " ISO-8859-1 " );
        }  catch  (Exception exception) {
             return  s;
        }
    }

     private  List < News >  getNewsList() {
        List < News >  newsList  =   new  ArrayList < News > ();

         for  ( int  i  =   0 ; i  <  maxEntryNumber; i ++ ) {
            News news  =   new  News();
            news.setTitle( " 测试标题 "   +  i);
            news.setContent(
                 " <p>测试内容测试内容<span style=\ " color:red\ " >测试内容</span></p> " );
            news.setPublishDate( new  Date());
            news.setId( new  Long(i));
            news.setAuthor( " Tin " );
            newsList.add(news);
        }

         return  newsList;
    }

     /**
     *  @return  Returns the maxEntryNumber.
      */
     public   long  getMaxEntryNumber() {
         return  maxEntryNumber;
    }

     /**
     *  @param  maxEntryNumber The maxEntryNumber to set.
      */
     public   void  setMaxEntryNumber( int  maxEntryNumber) {
         this .maxEntryNumber  =  maxEntryNumber;
    }

     /**
     *  @param  siteUrl The siteUrl to set.
      */
     public   void  setSiteUrl(String siteUrl) {
         this .siteUrl  =  siteUrl;
    }

     /**
     *  @return  Returns the feed.
      */
     public  SyndFeed getFeed() {
         return  feed;
    }

     private   class  News {
         private  Long id;
         private  String title;
         private  String content;
         private  Date publishDate;
         private  String author;
         private  String category;

         /**
  * Getter/Setter都省略了，使用了内部类，就是图个方便
  * 本意是模仿我们常常使用的Pojo，大家的实现都不一样，我突简单，里面其实可以有复杂类型的
   */
    }
}

< package  name ="news"  extends ="default"  namespace ="/news" >
   < action  name ="feed"  class ="com.goldnet.webwork.action.news.TestFeedCreateAction" >
    <!--  每次生成15条rss feed  -->
    < param  name ="maxEntryNumber" > 15 </ param >
    <!--  链接的前缀，我们使用Weblogic是7001，也许你的是8080  -->
    < param  name ="siteUrl" > http://127.0.0.1:7001 </ param >
    <!--  result是feed  -->
    < result  name ="success"  type ="feed" >
     <!--  feed名字是feed，对应我们这个Action中的那个SyndFeed的实例的名字feed，别忘记写getter  -->
     < param  name ="feedName" > feed </ param >
     <!--  制定生成的feed的类型，我这里选择rss_2.0  -->
     <!--  rome 0.8支持atom_0.3、atom_1.0、rss_1.0、rss_2.0、rss_0.90、rss_0.91、rss_0.91、rss_0.91U、rss_0.92、rss_0.93、rss_0.94  -->
     < param  name ="feedType" > rss_2.0 </ param >
    </ result >
   </ action >
</ package >