cmpp3login.java

java支持的短信平台

package com.khan.sms.cmpp3control;


import com.khan.util.*;
import java.net.Socket;

/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */

public class Cmpp3Login implements Runnable {
  static boolean flag = true;
  //static boolean connected = false;
  //CmppParam cp = new CmppParam("");
  private CmppParam cp = null;
  RecvQueue rq = null;

  public Cmpp3Login(CmppParam cp) {
    this.cp = cp;
    rq = new RecvQueue(cp.MAX_RECVQUEUE_SIZE);
    common.Assert("debug:" + Thread.currentThread().getName() + "处理线程建立!");
  }

  public static void stopThread() {
    flag = false;
  }


  public void run() {
    common.Assert("debug:" + Thread.currentThread().getName() + "线程运行!");
    while (flag) {
      try {
        Socket spc = null;
        if (!cp.Cmpp_Socket.getConnected()) {
          common.Assert("debug:" + Thread.currentThread().getName() + " 连接断开!");
          cp.Cmpp_Socket.setConnect(false);
          try {
            spc = cp.Cmpp_Socket.get();
          } finally {
            if (null != spc) {
              cp.Cmpp_Socket.setConnect(true);
            }
          }
        }
        common.sleep(cp.SEND_SLEEP);
      } catch (NullPointerException e) {
        e.printStackTrace();
      }

    }
    common.Assert("debug:" + Thread.currentThread().getName() + "线程停止!");
  }

  protected void finalize() {
    common.Assert("debug:" + Thread.currentThread().getName() + " 线程释放!");
  }
}