java Source

:: 管理

14 Posts :: 24 Stories :: 8 Comments :: 0 Trackbacks

該組件實現(xiàn)分為以下幾個部分ChannelEItem,ChannelItem,RssBuildFactory,RssComponentBean

/*
* ChannelEItem.java
* Copyright (C) 2009  <JustinLei@gmail.com>
*
*        This program is free software; you can redistribute it and/or modify
*        it under the terms of the GNU General Public License as published by
*      the Free Software Foundation; either version 2 of the License, or
*     (at your option) any later version.
*
*       This program is distributed in the hope that it will be useful,
*      but WITHOUT ANY WARRANTY; without even the implied warranty of
*     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
*        GNU General Public License for more details.
*
*/
package org.lambdasoft.components.rss.ejb;

/**
* @author lei.tang (justinlei@gmail.com)
* @date
* @version
*/
public class ChannelEItem extends ChannelItem{
    private static final long serialVersionUID = 1L;
    private String enclosure;// 流媒體文件

    public String getEnclosure() {
        return enclosure;
    }

    public void setEnclosure(String enclosure) {
        this.enclosure = enclosure;
    }
}

/*
* ChannelItem.java
* Copyright (C) 2009  <JustinLei@gmail.com>
*
*        This program is free software; you can redistribute it and/or modify
*        it under the terms of the GNU General Public License as published by
*      the Free Software Foundation; either version 2 of the License, or
*     (at your option) any later version.
*
*       This program is distributed in the hope that it will be useful,
*      but WITHOUT ANY WARRANTY; without even the implied warranty of
*     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
*        GNU General Public License for more details.
*
*/
package org.lambdasoft.components.rss.ejb;

import java.io.Serializable;
import java.util.Date;

/**
* @author lei.tang (justinlei@gmail.com)
* @date
* @version
*/
public class ChannelItem implements Serializable{
    private static final long serialVersionUID = 1L;
    private String title;// Rss文件中Item的標題
    private String link;// Rss文件中Item對應的連接
    private String description;// Item的描述
    private Date pubDate;// Item發(fā)布的時間
    private String author;// Item作者
    private String category;// Item所屬的頻道范疇

    public String getTitle() {
        return title;
    }

    public void setTitle(String title) {
        this.title = title;
    }

    public String getLink() {
        return link;
    }

    public void setLink(String link) {
        this.link = link;
    }

    public String getDescription() {
        return description;
    }

    public void setDescription(String description) {
        this.description = description;
    }

    public Date getPubDate() {
        return pubDate;
    }

    public void setPubDate(Date pubDate) {
        this.pubDate = pubDate;
    }

    public String getAuthor() {
        return author;
    }

    public void setAuthor(String author) {
        this.author = author;
    }

    public String getCategory() {
        return category;
    }

    public void setCategory(String category) {
        this.category = category;
    }
}

/*
* RssBuildFactory.java
* Copyright (C) 2009  <JustinLei@gmail.com>
*
*        This program is free software; you can redistribute it and/or modify
*        it under the terms of the GNU General Public License as published by
*      the Free Software Foundation; either version 2 of the License, or
*     (at your option) any later version.
*
*       This program is distributed in the hope that it will be useful,
*      but WITHOUT ANY WARRANTY; without even the implied warranty of
*     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
*        GNU General Public License for more details.
*
*/
package org.lambdasoft.components.rss.ejb;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.io.Writer;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

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.SyndEnclosure;
import com.sun.syndication.feed.synd.SyndEnclosureImpl;
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 com.sun.syndication.io.FeedException;
import com.sun.syndication.io.SyndFeedOutput;

/**
* @author lei.tang (justinlei@gmail.com)
* @date
* @version
*/
public class RssBuildFactory {
    private SyndFeed feed;
    @SuppressWarnings("unchecked")
    private List entries;
    private SyndEntry entry;

    @SuppressWarnings("unchecked")
    public RssBuildFactory() {
        feed = new SyndFeedImpl();
        feed.setFeedType("rss_2.0");
        entries = new ArrayList();
    }

    /**
     * 創(chuàng)建一個頻道
     *
     * @param title 頻道標題
     * @param link 頻道對應的連接
     * @param description 頻道描述
     * @param language 頻道所用語言
     * @param pubDate 頻道發(fā)布時期
     * @param copyright 版權(quán)所有
     * @throws Exception
     */
    public void buildChannel(String title, String link, String description,
            String language, Date pubDate, String copyright)
            throws RuntimeException {
        feed.setTitle(title);
        feed.setLink(link);
        feed.setDescription(description);
        feed.setLanguage(language);
        feed.setPublishedDate(pubDate);
        feed.setCopyright(copyright);
    }

    /**
     * 添加頻道的子內(nèi)容
     *
     * @param item
     *            [email={@link]{@link[/email] ChannelItem}
     * @throws Exception
     */
    @SuppressWarnings("unchecked")
    public void buildItems(ChannelItem item) throws RuntimeException {
        entry = new SyndEntryImpl();
        // 設(shè)置新聞標題
        entry.setTitle(item.getTitle());
        // 設(shè)置新聞的連接地址
        entry.setLink(item.getLink());
        // 設(shè)置新聞簡介
        SyndContent content = new SyndContentImpl();
        content.setType("text/plain");
        content.setValue(item.getDescription());
        entry.setDescription(content);
        // 設(shè)置發(fā)布時間
        entry.setPublishedDate(item.getPubDate());
        // 設(shè)置頻道所屬的范圍
        SyndCategory cate = new SyndCategoryImpl();
        cate.setName(item.getCategory());
        List cateList = new ArrayList();
        cateList.add(cate);
        entry.setCategories(cateList);
        // 設(shè)置作者
        entry.setAuthor(item.getAuthor());
        // 將新聞項添加至數(shù)組中
        entries.add(entry);
    }

    /**
     * 添加頻道的內(nèi)容項
     *
     * @param item
     *            [email={@link]{@link[/email] ChannelEItem}此類繼承自ChannelItem類
     * @throws Exception
     */
    @SuppressWarnings("unchecked")
    public void buildItems(ChannelEItem item) throws RuntimeException {
        entry = new SyndEntryImpl();
        // 設(shè)置新聞標題
        entry.setTitle(item.getTitle());
        // 設(shè)置新聞的連接地址
        entry.setLink(item.getLink());
        // 設(shè)置新聞簡介
        SyndContent content = new SyndContentImpl();
        content.setValue(item.getDescription());
        entry.setDescription(content);
        // 設(shè)置發(fā)布時間
        entry.setPublishedDate(item.getPubDate());
        // 設(shè)置頻道所屬的范圍
        SyndCategory cate = new SyndCategoryImpl();
        cate.setName(item.getCategory());
        List cateList = new ArrayList();
        cateList.add(cate);
        entry.setCategories(cateList);
        // 設(shè)置作者
        entry.setAuthor(item.getAuthor());
        // 設(shè)置流媒體播放文件
        SyndEnclosure en = new SyndEnclosureImpl();
        en.setUrl(item.getEnclosure());
        List enList = new ArrayList();
        enList.add(en);
        entry.setEnclosures(enList);
        // 將新聞項添加至數(shù)組中
        entries.add(entry);
    }

    /**
     * 生成XML文件
     *
     * @param outputStream
     * @throws Exception
     */
    public String buildChannel() throws IOException {
        feed.setEntries(entries);
        SyndFeedOutput output = new SyndFeedOutput();
        Writer writer;
        ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
        writer = new OutputStreamWriter(outputStream, "UTF-8");
        try {
            output.output(feed, writer);
            return new String(outputStream.toByteArray());
        } catch (FeedException e) {
            throw new IOException();
        }
    }
}

/*
* RssComponentBean.java
* Copyright (C) 2009  <JustinLei@gmail.com>
*
*        This program is free software; you can redistribute it and/or modify
*        it under the terms of the GNU General Public License as published by
*      the Free Software Foundation; either version 2 of the License, or
*     (at your option) any later version.
*
*       This program is distributed in the hope that it will be useful,
*      but WITHOUT ANY WARRANTY; without even the implied warranty of
*     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
*        GNU General Public License for more details.
*
*/
package org.lambdasoft.components.rss.ejb;

import javax.ejb.Remote;
import javax.ejb.Stateless;
import javax.interceptor.Interceptors;

import org.lambdasoft.components.application.RssComponent;
import org.lambdasoft.components.application.param.RssBuildParam;
import org.lambdasoft.ejb.interceptors.EjbCheckParamInterceptor;

/**
* @author lei.tang (justinlei@gmail.com)
* @date
* @version
*/
@Stateless
@Remote
@Interceptors({EjbCheckParamInterceptor.class})
public class RssComponentBean implements RssComponent{
    public String buildChannel(RssBuildParam rssBuildParam) throws Exception{
        if(rssBuildParam.getChannelEItems() == null)
            return null;
        RssBuildFactory builder = new RssBuildFactory();
        for (ChannelEItem channelEItem : rssBuildParam.getChannelEItems()) {
            builder.buildItems(channelEItem);
        }
        builder.buildChannel(rssBuildParam.getTitle(),rssBuildParam.getLink(), rssBuildParam.getDescription(),
                rssBuildParam.getLanguage(), rssBuildParam.getPubDate(), rssBuildParam.getCopyright());
        return builder.buildChannel();
    }
}

posted @ 2009-12-18 15:24 JustinLei 閱讀(1081) | 評論 (0) | 編輯收藏

EJB3.0 MDB 異步日志實現(xiàn)

/*
* LogMessageBean.java
* Copyright (C) 2009  <JustinLei@gmail.com>
*
*        This program is free software; you can redistribute it and/or modify
*        it under the terms of the GNU General Public License as published by
*      the Free Software Foundation; either version 2 of the License, or
*     (at your option) any later version.
*
*       This program is distributed in the hope that it will be useful,
*      but WITHOUT ANY WARRANTY; without even the implied warranty of
*     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
*        GNU General Public License for more details.
*
*/
package org.lambdasoft.mdb;

import java.util.Map;

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
import javax.naming.InitialContext;

import org.lambdasoft.components.log.BaseLogSendInterface;
import org.lambdasoft.components.log.OperateType;
import org.lambdasoft.components.log.param.LogParam;
import org.lambdasoft.utils.FileUtil;

/**
* 日志添加消息
*
* @author lei.tang (justinlei@gmail.com)
* @date 2009-9-17
* @version 1.0
*/
@MessageDriven(activationConfig = {
        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = MessageConstant.DESTINATIONTYPE_QUEUE),
        @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = MessageConstant.ACKNOWLEDGEMODE_AUTO),
        @ActivationConfigProperty(propertyName = "destination", propertyValue = MessageConstant.DESTINATION_LOG) })
public class LogMessageBean implements MessageListener{
    public static final String LOG_PREFIX = "LOG.TYPE.BEAN.";
    private Map<String, String> logConfigure;
    public void onMessage(Message message) {
        if(!(message instanceof ObjectMessage))
            return;
        ObjectMessage objectMessage = (ObjectMessage)message;
        try {
            if(!(objectMessage.getObject() instanceof LogParam))
                return;
            LogParam logParam = (LogParam)objectMessage.getObject();
            InitialContext context = new InitialContext();
            for (Object level : logParam.getOperateTypes()) {
                OperateType operateType = (OperateType)level;
                String ejbName = getConfigure().get(LOG_PREFIX + (operateType.toString()));
                Object sendComponent = context.lookup(ejbName);
                if (sendComponent != null
                        && (sendComponent instanceof BaseLogSendInterface)) {
                    ((BaseLogSendInterface) sendComponent).log(logParam);
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
            return;
        }
    }

    private Map<String, String> getConfigure() {
        String propertiesName = "/org/lambdasoft/components/log/ejb/logConfigure.properties";
        try {
            logConfigure = FileUtil.getPropertiesMap(LogMessageBean.class,propertiesName);
            return logConfigure;
        } catch (Exception e) {
            return null;
        }
    }
}

/*
* MessageConstant.java
* Copyright (C) 2009  <JustinLei@gmail.com>
*
*        This program is free software; you can redistribute it and/or modify
*        it under the terms of the GNU General Public License as published by
*      the Free Software Foundation; either version 2 of the License, or
*     (at your option) any later version.
*
*       This program is distributed in the hope that it will be useful,
*      but WITHOUT ANY WARRANTY; without even the implied warranty of
*     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
*        GNU General Public License for more details.
*
*/
package org.lambdasoft.mdb;

/**
* 消息驅(qū)動bean定義
*
* @author lei.tang (justinlei@gmail.com)
* @date 2009-9-18
* @version 1.0
*/
public class MessageConstant {
    public static final String DESTINATIONTYPE_QUEUE = "javax.jms.Queue";
    public static final String ACKNOWLEDGEMODE_AUTO = "Auto-acknowledge";//會話確認模式

    public static final String DESTINATION_CACHE = "queue/AO_CACHE";
    public static final String DESTINATION_LOG = "queue/AO_LOG";
    public static final String DESTINATION_MAIL = "queue/AO_MAIL";
    public static final String DESTINATION_CACHE_REFLASH = "queue/AO_CACHE_REFLASH";

    private MessageConstant() {}

}

* LogMessage.java

* This program is free software; you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation; either version 2 of the License, or

* (at your option) any later version.

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

package org.lambdasoft.mdb;

import java.io.Serializable;

/**

* @author lei.tang (justinlei@gmail.com)

* @date 2009-9-17

* @version 1.0

public interface LogMessage extends Serializable{

String getType();

String getLevel();

String getLog();

}

posted @ 2009-12-18 15:17 JustinLei 閱讀(1078) | 評論 (0) | 編輯收藏

字符串處理工具 StringUtils

posted @ 2009-12-18 14:28 JustinLei 閱讀(1370) | 評論 (0) | 編輯收藏

Java安全工具,生成MD5,Base64,UUID

摘要: span { font-family: 'Courier New'; font-size: 10pt; color: #000000; } .sc0 { } .sc1 { color: #008000; } .sc2 { color: #008000; } .sc3 { color: #008080; } .sc4 { color: #FF8000; } .s... 閱讀全文

posted @ 2009-12-18 14:25 JustinLei 閱讀(1990) | 評論 (0) | 編輯收藏

僅列出標題

java Source

常用鏈接

留言簿(12)

我參與的團隊

隨筆檔案

文章分類

文章檔案

搜索

最新隨筆

最新評論

閱讀排行榜

評論排行榜