readmtpool.java

采用JAVA开发

/*
 * Created on 2004-11-2
 *
 * To change the template for this generated file go to
 * Window>Preferences>Java>Code Generation>Code and Comments
 */
package com.gctech.sms.tj;

import java.io.File;
import java.io.FileInputStream;
import java.util.Map;

import com.gctech.sms.msg.MTInfo;
import com.gctech.sms.platform.Server;
import com.wutka.jox.JOXBeanInputStream;

/**
 * <p>Title:</p>
 * <p>Description:</p>
 * <p>Copyright: Copyright (c) Gctech 2004-11-2</p>
 * <p>Company: 吉芙德资讯有限公司</p>
 *
 * @version 1.0
 * @author liyi
 *
 */
public class ReadMTPool {
	Map flexwinMap;
	int periods;

	public void runWork() {
		File mtpool = new File("./mtpool");
		mtpool.mkdir();
		File respon = null;
		while (noStopRequested) {
			try {
				String[] filelist = mtpool.list();
				if (filelist.length == 0) {
					Thread.sleep(periods * 1000);
					continue;
				}

				String requestStr;
				for (int i = 0; i < filelist.length; i++) {
					System.out.println(filelist[i]);
					respon = new File("./mtpool/" + filelist[i]);
					FileInputStream in = new FileInputStream(respon);
					JOXBeanInputStream joxIn = new JOXBeanInputStream(in);
					MTBean testBean = (MTBean) joxIn.readObject(MTBean.class);
					MTInfo info = MTBeanToMTInfo.convertor(testBean);
					int ack = Server.getInstance().sentMt(info, Integer.parseInt(testBean.getGateway()));
					if (ack == 0) {
						System.out.println("发送成功！");
					} else {
						System.out.println("发送失败！");
					}

					respon.delete();
				}
			} catch (Exception e) {
				e.printStackTrace();
				if (respon != null)
					respon.delete();
				//stopRequest();
			}
		}
	}
	public ReadMTPool(int periods) {
		this.periods = periods;
		noStopRequested = true;

		Runnable r = new Runnable() {
			public void run() {
				try {
					runWork();
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		};
		internalThread = new Thread(r, "ReadSubmit");
		internalThread.start();
	}
	public Thread internalThread;
	public volatile boolean noStopRequested;
	public void stopRequest() {
		noStopRequested = false;
		internalThread.interrupt();
	}
	public boolean isAlive() {
		return internalThread.isAlive();
	}
	public void startup() {
		noStopRequested = true;
		internalThread.start();
	}
	public void sureStop() {
		internalThread.stop();
	}
	public static void main(String[] args) {
	}
}