cmppoutputstream.java

短信网关发送接受平台。

import java.lang.*;
import java.net.*;
import java.io.*;

import CMPPThread;
import CMPPPacketCircle;

import CMPPSynchronizedIO;

public class CMPPOutputStream extends CMPPThread
{
	boolean m_bBlocking = false;

	CMPPSynchronizedIO m_io = null;
	CMPPPacketCircle m_pc = null;
	
	public CMPPOutputStream(CMPPSynchronizedIO io,CMPPPacketCircle pc)
		throws CMPPException
	{
		if(io == null)
		{
			throw new CMPPException("CMPPOutputStream.CMPPOutputStream : null synchronized io !");
		}
		m_io = io;
		
		if(pc == null)
		{
			throw new CMPPException("CMPPOutputStream.CMPPOutputSteam : null packetcircle !");
		}
		m_pc = pc;
	}
	
	public void run ()
	{
		CMPPPacket packet = null;

		try
		{
			m_nStatus = THREAD_RUNNING;
			while(isRunning())
			{
				//读取数据包
				packet = m_pc.read();
				if(packet == null)
				{
					Thread.sleep(45);
					continue;
				}
				
				//进入阻塞状态
				m_bBlocking = true;
				//输出数据包
				m_io.write(packet);
				//退出阻塞状态
				m_bBlocking = false;
			}
		}
		catch(Exception e)
		{
			CMPPLog.log(e.getMessage(),
				LogRequest.LOG_EXCEPTION | CMPPLog.LOG_CMPP_OUTPUT_STREAM);
			CMPPLog.log("CMPPOutputStream.run : unexpected exit !",
				LogRequest.LOG_EXCEPTION | CMPPLog.LOG_CMPP_OUTPUT_STREAM);
		}

		m_nStatus = THREAD_STOPPED;		
		CMPPLog.log("CMPPOutputStream.run : thread stopped !",
			CMPPLog.LOG_CMPP_OUTPUT_STREAM);
	}
	
	public boolean isBlocking()
	{
		if(m_pc.isWritable())
		{
			return m_bBlocking;
		}
		
		return false;
	}
	
	public void startup()
	{
		super.startup();
		
		CMPPLog.log("CMPPOutputStream.startup : outputstream startup !",
			CMPPLog.LOG_CMPP_OUTPUT_STREAM);
	}
	
	public void shutdown()
	{
		super.shutdown();
		
		CMPPLog.log("CMPPOutputStream.shutdown : outputstream shutdown !",
			CMPPLog.LOG_CMPP_OUTPUT_STREAM);
	}
}