newMonitoringSystem_order
所属分类：手机短信编程
开发工具：Java
文件大小：13054KB
下载次数：14
上传日期：2008-03-18 14:06:05
上 传 者：
75876997
说明： 监控整个SP系统的SMS信息通道的发送情况并且生成日志。 支持权限判断。
(Monitoring of the entire SP system to send SMS information channel situation and generate a log. Support the competence to judge.)
文件列表:
newMonitoringSystem_order (0, 2008-01-19)
newMonitoringSystem_order\.classpath (1648, 2008-01-19)
newMonitoringSystem_order\.myeclipse (0, 2008-01-19)
newMonitoringSystem_order\.mymetadata (336, 2008-01-29)
newMonitoringSystem_order\.project (1024, 2008-01-19)
newMonitoringSystem_order\.project.bak (1018, 2008-01-19)
newMonitoringSystem_order\.settings (0, 2008-01-19)
newMonitoringSystem_order\.settings\org.eclipse.core.resources.prefs (669, 2008-01-19)
newMonitoringSystem_order\.settings\org.eclipse.jdt.core.prefs (629, 2008-01-19)
newMonitoringSystem_order\.settings\org.eclipse.jdt.ui.prefs (99, 2008-01-19)
newMonitoringSystem_order\monitoring.log (0, 2008-01-19)
newMonitoringSystem_order\resource (0, 2008-01-19)
newMonitoringSystem_order\resource\classpath.sh (2899, 2008-01-19)
newMonitoringSystem_order\resource\classpath.sh~ (3544, 2008-01-19)
newMonitoringSystem_order\resource\DatabaseCacheDaemonConfig.properties (1188, 2008-01-19)
newMonitoringSystem_order\resource\DatabaseCacheDaemonConfig.xml (148, 2008-01-19)
newMonitoringSystem_order\resource\run.conf (1359, 2008-01-19)
newMonitoringSystem_order\resource\run.conf~ (1362, 2008-01-19)
newMonitoringSystem_order\resource\run.sh (6856, 2008-01-19)
newMonitoringSystem_order\resource\run.sh~ (6350, 2008-01-19)
newMonitoringSystem_order\resource\shutdown.sh (1903, 2008-01-19)
newMonitoringSystem_order\resource\start.sh (377, 2008-01-19)
newMonitoringSystem_order\resource\start.sh~ (377, 2008-01-19)
newMonitoringSystem_order\root (0, 2008-01-19)
newMonitoringSystem_order\root\images (0, 2008-01-19)
newMonitoringSystem_order\root\images\basic-dialog (0, 2008-01-19)
newMonitoringSystem_order\root\images\basic-dialog\btn-sprite.gif (1186, 2008-01-19)
newMonitoringSystem_order\root\images\basic-dialog\close.gif (893, 2008-01-19)
newMonitoringSystem_order\root\images\basic-dialog\e-handle.gif (995, 2008-01-19)
newMonitoringSystem_order\root\images\basic-dialog\gray (0, 2008-01-19)
newMonitoringSystem_order\root\images\basic-dialog\gray\close.gif (893, 2008-01-19)
newMonitoringSystem_order\root\images\basic-dialog\gray\dlg-bg.gif (27857, 2008-01-19)
newMonitoringSystem_order\root\images\basic-dialog\gray\e-handle.gif (995, 2008-01-19)
newMonitoringSystem_order\root\images\basic-dialog\gray\hd-sprite.gif (1060, 2008-01-19)
newMonitoringSystem_order\root\images\basic-dialog\gray\s-handle.gif (992, 2008-01-19)
newMonitoringSystem_order\root\images\basic-dialog\gray\se-handle.gif (833, 2008-01-19)
newMonitoringSystem_order\root\images\basic-dialog\gray\Thumbs.db (12800, 2008-01-19)
newMonitoringSystem_order\root\images\basic-dialog\hd-sprite.gif (1099, 2008-01-19)
newMonitoringSystem_order\root\images\basic-dialog\s-handle.gif (992, 2008-01-19)
newMonitoringSystem_order\root\images\basic-dialog\se-handle.gif (833, 2008-01-19)
... ...
package com.infobank.superchannel.daemon.databasecache;
import java.util.Queue;
import org.apache.commons.configuration.Configuration;
import com.infobank.superchannel.database.DAO;
import com.infobank.superchannel.database.DAOListener;
import com.infobank.superchannel.pojo.TextMessage;
import com.infobank.superchannel.pojo.TextMessageResultSetting;
import com.infobank.superchannel.pojo.TextMessageStatusSetting;
import com.infobank.superchannel.util.DaemonConfiguration;
import com.infobank.superchannel.util.DatabaseConnectionPool;
/**
* @author Xiaoguang Sun
* @version 类说明: 读取新信息任务
*/
public class ReadMessageTask implements Runnable,DAOListener{
// 应扫描的表名
private String tableName=null;
// 数据库缓冲服务器对象
private DatabaseCacheDaemon daemon=null;
// 每次扫描扫描间隔时间(单位毫秒:1000毫秒=1秒)
private int interval=5000;
// 每次扫描最多读取信息条数
private int maxRecordNumber=0;
// 特服号约束条件
private String callbackPattern=null;
// datasource name
private String dataSource=null;
// status setting
private TextMessageStatusSetting statusSetting=null;
// result setting
private TextMessageResultSetting resultSetting=null;
private String tag=null;
/**
* 构造函数
* @param daemon 数据库缓冲服务器对象
* @param tableName 此任务应扫描的数据库表名
* @param dataSource Datasource for this task
* @param callbackPattern callback pattern
* @param maxRecordNumber maximum record number in one read
* @param interval interval of each reading
* @param statusSetting status setting
* @param resultSetting result setting
* @param tag tag
*/
public ReadMessageTask(DatabaseCacheDaemon daemon, String tableName,
String dataSource,String callbackPattern,int maxRecordNumber,int interval,
TextMessageStatusSetting statusSetting, TextMessageResultSetting resultSetting,
String tag){
this.daemon=daemon;
this.tableName=tableName;
this.dataSource=dataSource;
this.callbackPattern=callbackPattern;
this.maxRecordNumber=maxRecordNumber;
this.interval=interval;
this.statusSetting=statusSetting;
this.resultSetting=resultSetting;
this.tag=tag;
}
/**
* 新信息读取任务执行体
*/
public void run() {
DAO dao=DAO.getInstance();
DatabaseConnectionPool dbcp=DatabaseConnectionPool.getInstance();
while(daemon.isRunnable()){
try{
if(daemon.isPaused()){
Thread.sleep(interval);
continue;
}
}
catch (InterruptedException ex){
// interrupted. probably want to exit
if(!daemon.isRunnable()){
System.out.println("正在停止数据读取任务");
return;
}
}
// 获取待发信息
dao.getPendingMessage(dataSource,tableName,callbackPattern,maxRecordNumber,statusSetting, resultSetting, tag, this);
try {
Thread.sleep(interval); //查询表的间隔
} catch (Exception e) {
return;
}
}
}
public void onMessages(Queue messages) {
while(daemon.isMessageQueueFull()){
try{
Thread.sleep(interval);
}
catch(Exception ex){
return;
}
}
while(!daemon.addNewMessage(messages, tag)){
// message can not be added into message queue
if(!daemon.isRunnable()){
// server is exiting.
// the new message does not get delivered however the status are not changed
// these message will be delivered next time
return;
}
}
}
}
近期下载者：
相关文件：
收藏者：