sgipserver.java

WAP PUSH后台源码,WAP PUSH后台源码

package com.tssx.ebiz.sgip;
import java.net.*;
import java.io.*;

public class SgipServer implements Runnable {
     private static int spPort = 8808;
     private static String loginName = "internet";
     private static String loginPassword = "internet";
//     private static String loginName = "qq";
//     private static String loginPassword = "qq";
//     private static int loginType=2;

     public java.net.Socket m_sk;
     DataOutputStream m_os;
     DataInputStream m_is;
     /**
      * SgipServer 构造子注解。
      */
     public SgipServer() {
          super();
     }
     /**
      * SgipServer 构造子注解。
      */
     public void connect(int spPort) throws  IOException {
          ServerSocket serversocket =new ServerSocket(spPort);
          this.m_sk=serversocket.accept();
          this.m_os = new DataOutputStream(m_sk.getOutputStream());
          this.m_is = new DataInputStream(new BufferedInputStream(m_sk.getInputStream()));

     }
     public void run() {
          try{
          }catch(Exception e){
          }
     }
     public SMSDeliver deliver() throws SgipException,IOException {
          SMSDeliver smsdeliver=new SMSDeliver();
          smsdeliver.read(m_is);
          int messageLength=smsdeliver.getMessageLength();
          int commandID=smsdeliver.getCommandID();
          int seqAddr=smsdeliver.getSeqAddr();
          int seqDate=smsdeliver.getSeqDate();
          int sequence=smsdeliver.getSequence();
          String userNumber=smsdeliver.getUserNumber();
          String spNumber=smsdeliver.getSpNumber();
          int tp_pid=smsdeliver.getTp_pid();
          int tp_udhi=smsdeliver.getTp_udhi();
          int messageCoding=smsdeliver.getMessageCoding();
          int msgLen=smsdeliver.getMsgLen();
          String messageContent=smsdeliver.getMessageContent();
          String reserve=smsdeliver.getReserve();

          SMSDeliverResp smsdeliverresp=new SMSDeliverResp();
          smsdeliverresp.setSeqAddr(seqAddr);
          smsdeliverresp.setSeqDate(seqDate);
          smsdeliverresp.setSequence(sequence);
          smsdeliverresp.setResult(0);
          smsdeliverresp.write(m_os);

          return smsdeliver;
     }
     public SMSBind bind() throws SgipException,IOException {
          SMSBind smsbind=new SMSBind();
          smsbind.read(m_is);
          int messageLength=smsbind.getMessageLength();
          int commandID=smsbind.getCommandID();
          int seqAddr=smsbind.getSeqAddr();
          int seqDate=smsbind.getSeqDate();
          int sequence=smsbind.getSequence();
          int loginType=smsbind.getLoginType();
          String loginName=smsbind.getLoginName();
          String loginPassword=smsbind.getLoginPassword();
          String reserve=smsbind.getReserve();

          SMSBindResp smsbindresp=new SMSBindResp();
          smsbindresp.setSeqAddr(seqAddr);
          smsbindresp.setSeqDate(seqDate);
          smsbindresp.setSequence(sequence);
          smsbindresp.setResult(0);
          smsbindresp.write(m_os);

          return smsbind;
     }
     public SMSUnBind unbind() throws SgipException,IOException {
          SMSUnBind smsunbind=new SMSUnBind();
          smsunbind.read(m_is);
          int messageLength=smsunbind.getMessageLength();
          int commandID=smsunbind.getCommandID();
          int seqAddr=smsunbind.getSeqAddr();
          int seqDate=smsunbind.getSeqDate();
          int sequence=smsunbind.getSequence();

          SMSUnBindResp smsunbindresp=new SMSUnBindResp();
          smsunbindresp.setSeqAddr(seqAddr);
          smsunbindresp.setSeqDate(seqDate);
          smsunbindresp.setSequence(sequence);
          smsunbindresp.write(m_os);

          return smsunbind;
     }
}