smsserver.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:   SmsServer.java

package org.cross.sms;

import java.util.Vector;
import org.cross.sms.msg.SMSMsg;
import org.cross.sms.msg.SMSMsgOut;
import org.cross.sms.msg.SmsUtil;
import org.cross.sms.serialPort.SMSPorter;

// Referenced classes of package org.cross.sms:
//            SimpleMsg, _ServerSmsThread

public class SmsServer
{

    public SmsServer()
    {
        m_inBuf = new Vector();
        m_outBuf = new Vector();
        m_errBuf = new Vector();
        m_comName = "";
        m_baut = 9600;
        SmsUtil.loadLib();
    }

    protected void pushErrMsg(SMSMsg msg)
    {
        m_errBuf.add(msg);
    }

    protected SMSMsg popErrMsg()
    {
        int len = m_errBuf.size();
        if(len > 0)
        {
            SMSMsg msg = (SMSMsg)m_errBuf.get(0);
            m_errBuf.remove(msg);
            return msg;
        } else
        {
            return null;
        }
    }

    protected void pushInMsg(SMSMsg msg)
    {
        m_inBuf.add(msg);
    }

    protected SMSMsg popInMsg()
    {
        int len = m_inBuf.size();
        if(len > 0)
        {
            SMSMsg msg = (SMSMsg)m_inBuf.get(0);
            m_inBuf.remove(msg);
            return msg;
        } else
        {
            return null;
        }
    }

    protected void pushOutMsg(SMSMsg msg)
    {
        m_outBuf.add(msg);
    }

    protected SMSMsg popOutMsg()
    {
        int len = m_outBuf.size();
        if(len > 0)
        {
            SMSMsg msg = (SMSMsg)m_outBuf.get(0);
            m_outBuf.remove(msg);
            return msg;
        } else
        {
            return null;
        }
    }

    public void send(String receiver, String text)
    {
        Vector v = SmsUtil.buildMsgOut(receiver, text, true);
        for(int i = 0; i < v.size(); i++)
        {
            SMSMsgOut out = (SMSMsgOut)v.get(i);
            pushOutMsg(out);
        }

    }

    public void sendWapPush(String receiver, String text, String url)
    {
        Vector v = SmsUtil.buildWapMsg(receiver, url, text);
        for(int i = 0; i < v.size(); i++)
        {
            SMSMsgOut out = (SMSMsgOut)v.get(i);
            pushOutMsg(out);
        }

    }

    public SimpleMsg readInMsg()
    {
        SMSMsg m = popInMsg();
        if(m != null)
            return new SimpleMsg(m);
        else
            return null;
    }

    public SimpleMsg readErrMsg()
    {
        SMSMsg m = popErrMsg();
        if(m != null)
            return new SimpleMsg(m);
        else
            return null;
    }

    public void start()
    {
        SMSPorter port = new SMSPorter(m_comName);
        port.setBaud(m_baut);
        try
        {
            port.open();
            port.CMD_setStorageToMT();
            thread = new _ServerSmsThread(port, this);
            thread.start();
        }
        catch(Exception ex)
        {
            ex.printStackTrace();
        }
    }

    public void restart()
    {
        stop();
        start();
    }

    public void stop()
    {
        if(thread != null)
            thread.setStop();
    }

    public void setComName(String comName)
    {
        m_comName = comName;
    }

    public void setBaut(int baut)
    {
        m_baut = baut;
    }

    _ServerSmsThread thread;
    private Vector m_inBuf;
    private Vector m_outBuf;
    private Vector m_errBuf;
    String m_comName;
    int m_baut;
}