smsqueuehelper.java

短信发送

/**
 * Created at Nov 30, 2008
 */
package com.jdev.app.db;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;

import com.jdev.app.db.queue.SmsAddWorker;
import com.jdev.app.db.queue.SmsQueue;
import com.jdev.app.db.queue.SmsQueueFactory;
import com.jdev.app.db.queue.SmsTakeWorker;
import com.jdev.net.connector.ConnectionFactory;
import com.jdev.net.data.QueueWorker;
import com.jdev.net.data.datatype.StringType;
import com.jdev.util.Debug;

/**
 * <p>Title: SmsQueueHelper</p>
 * <p>Description: </p>
 * @author Lawrence
 * @version 
 */
public class SmsQueueHelper {
	private final static String module = SmsQueueHelper.class.getName();
	private final static SmsQueueFactory queueFactory = SmsQueueFactory
			.getInstance();
	
	protected int CSType;

	/**
	 * @param type
	 */
	public SmsQueueHelper(int type) {
		CSType = type;
	}

	public byte[] getSend() throws Exception {
		byte[] response = null;
		try {
			SmsQueue queue = queueFactory.getQueue();
			if (queue.getSendRecord() <= 0)
				return null;
			
			ByteArrayOutputStream bout = (ByteArrayOutputStream) queue
			.removeSendFirst();
			response = bout.toByteArray();
		} catch (Exception e) {
			Debug.logError("getSend() error:" + e, module);
			throw new Exception(e);
		}
		return response;
	}

	public byte[] getRecv() throws Exception {
		byte[] response = null;
		try {
			SmsQueue queue = queueFactory.getQueue();
			if (queue.getRecvRecord() <= 0)
				return null;
			ByteArrayOutputStream bout = (ByteArrayOutputStream) queue
					.removeRecvFirst();
			response = bout.toByteArray();
		} catch (Exception e) {
			Debug.logError("getRecv() error:" + e, module);
			throw new Exception(e);
		}
		return response;
	}

	public InputStream putSend(byte[] array) throws Exception {
		try {
			SmsQueue queue = queueFactory.getQueue();
			InputStream bin = new ByteArrayInputStream(array);
			queue.pushSend(bin);
			return bin;
		} catch (Exception e) {
			Debug.logError("putSend error:" + e, module);
			throw new Exception(e);
		}

	}

	public InputStream putRecv(byte[] array) throws Exception {
		try {
			SmsQueue queue = queueFactory.getQueue();
			InputStream bin = new ByteArrayInputStream(array);
			queue.pushRecv(bin);
			return bin;
		} catch (Exception e) {
			Debug.logError("putRecv error:" + e, module);
			throw new Exception(e);
		}

	}

	/**
	 * 根据是服务器应用还是客户端应用，设置写入Queue中的信息类型
	 * 是request 还是response
	 * @return
	 */
	public int getWriteMsgType() {
		if (CSType == ConnectionFactory.CLIENT)
			return QueueWorker.REQUEST;
		else
			return QueueWorker.RESPONSE;
	}

	/**
	 * 根据是服务器应用还是客户端应用，设置从Queue中读取的信息类型
	 * 是request 还是response
	 * @return
	 */
	public int getReadMsgType() {
		if (CSType == ConnectionFactory.CLIENT)
			return QueueWorker.REQUEST;
		else
			return QueueWorker.RESPONSE;
	}
	
	/**
	 * 读取字符串
	 * @return String
	 * @throws java.lang.Exception
	 */
	public String readSend() throws Exception {
		try {
			SmsQueue queue = queueFactory.getQueue();
			QueueWorker worker = new SmsTakeWorker(queue);
			StringType st = new StringType(QueueWorker.RESPONSE);
			st.accpet(worker);
			return st.getContent();
		} catch (Exception ex) {
			Debug.logError("readString error:" + ex, module);
			throw new Exception(ex);
		}
	}

	/**
	 * 写入字符串
	 * @param msg
	 * @throws java.lang.Exception
	 */
	public void writeSend(String msg) throws Exception {
		try {
			SmsQueue queue = queueFactory.getQueue();
			QueueWorker worker = new SmsAddWorker(queue);
			StringType st = new StringType(QueueWorker.RESPONSE);
			st.setContent(msg);
			st.accpet(worker);
		} catch (Exception ex) {
			Debug.logError("writeString error:" + ex, module);
			throw new Exception(ex);

		}
	}

	/**
	 * 读取字符串
	 * @return String
	 * @throws java.lang.Exception
	 */
	public String readRecv() throws Exception {
		try {
			SmsQueue queue = queueFactory.getQueue();
			QueueWorker worker = new SmsTakeWorker(queue);
			StringType st = new StringType(QueueWorker.REQUEST);
			st.accpet(worker);
			return st.getContent();
		} catch (Exception ex) {
			Debug.logError("readString error:" + ex, module);
			throw new Exception(ex);
		}
	}

	/**
	 * 写入字符串
	 * @param msg
	 * @throws java.lang.Exception
	 */
	public void writeRecv(String msg) throws Exception {
		try {
			SmsQueue queue = queueFactory.getQueue();
			QueueWorker worker = new SmsAddWorker(queue);
			StringType st = new StringType(QueueWorker.REQUEST);
			st.setContent(msg);
			st.accpet(worker);
		} catch (Exception ex) {
			Debug.logError("writeString error:" + ex, module);
			throw new Exception(ex);

		}
	}
	
}