_serversmsthread.java

试用JAVA通过COMM口发送短信的代码.

// Decompiled by Jad v1.5.8g. Copyright 2001 Pavel Kouznetsov.
// Jad home page: http://www.kpdus.com/jad.html
// Decompiler options: packimports(3) 
// Source File Name:   _ServerSmsThread.java

package org.cross.sms;

import java.util.LinkedList;
import org.cross.sms.log.SmsLogger;
import org.cross.sms.msg.SMSMsg;
import org.cross.sms.msg.SMSMsgIn;
import org.cross.sms.serialPort.SMSPorter;

// Referenced classes of package org.cross.sms:
//            SmsServer

class _ServerSmsThread extends Thread
{

    public _ServerSmsThread(SMSPorter port, SmsServer server)
    {
        m_stillRun = true;
        m_port = port;
        m_server = server;
    }

    public void run()
    {
        int j = 0;
        while(m_stillRun) 
            try
            {
                Thread.sleep(2000L);
                m_port.CMD_getUnReadRecvMsg();
                LinkedList ll = null;
                ll = m_port.readPDUMsg();
                for(int i = 0; i < ll.size(); i++)
                {
                    SMSMsgIn msg = (SMSMsgIn)ll.get(i);
                    m_server.pushInMsg(msg);
                    SmsLogger.getInstance().logInSmsMsg(msg);
                }

                SMSMsg omsg = m_server.popOutMsg();
                while(omsg != null) 
                {
                    m_port.CMD_setPDUMode();
                    m_port.getResponse();
                    boolean isok = m_port.sendPduText(omsg.getPdu().toUpperCase());
                    if(!isok)
                        m_server.pushErrMsg(omsg);
                    else
                        SmsLogger.getInstance().logOutSmsMsg(omsg);
                    omsg = m_server.popOutMsg();
                }
            }
            catch(Exception ex)
            {
                ex.printStackTrace();
            }
        m_port.close();
    }

    public void setStop()
    {
        m_stillRun = false;
    }

    SMSPorter m_port;
    SmsServer m_server;
    boolean m_stillRun;
}