protected CMPP_HEAD ReadHead()
  {
   CMPP_HEAD head=new CMPP_HEAD();
   head.CommandID=0;
   Byte[] buffer=new Byte[12];
   try
   {
    if(m_NetworkStream.DataAvailable)
    {
     m_NetworkStream.Read(buffer,0,buffer.Length);
     head.TotalLength=(UInt32)Utility.NetBytesToInt(buffer,0,4);
     head.CommandID=(UInt32)Utility.NetBytesToInt(buffer,4,4);
     head.SequenceID=(UInt32)Utility.NetBytesToInt(buffer,8,4);
    }

   }
   catch
   {
    head.CommandID=CMD_ERROR;
   }
   return head;
  }

  protected CMPP_CONNECT_RESP ReadConnectResp(CMPP_HEAD Head)
  {
   CMPP_CONNECT_RESP resp=new CMPP_CONNECT_RESP();
   resp.Head=Head;
   try
   {
    if(m_NetworkStream.DataAvailable)
    {
     Byte[] buffer=new Byte[resp.Head.TotalLength-Marshal.SizeOf(resp.Head)];
     m_NetworkStream.Read(buffer,0,buffer.Length);
     resp.Status=(UInt32)Utility.NetBytesToInt(buffer,0,4);
     resp.AuthenticatorISMG=new Byte[16];
     Array.Copy(buffer,4,resp.AuthenticatorISMG,0,16);
     resp.Version=buffer[buffer.Length-1];
    }
   }
   catch
   {
    resp.Head.CommandID=CMD_ERROR;
   }

   return resp;

   
  }
  protected CMPP_SUBMIT_RESP ReadSubmitResp(CMPP_HEAD Head)
  {
   CMPP_SUBMIT_RESP resp=new CMPP_SUBMIT_RESP();
   resp.Head=Head;
   string strError=string.Empty;
   bool bOK=true;
   try
   {
    if(m_NetworkStream.DataAvailable)
    {
     Byte[] buffer=new Byte[resp.Head.TotalLength-Marshal.SizeOf(resp.Head)];
     m_NetworkStream.Read(buffer,0,buffer.Length);
     //resp.MsgID=(UInt64)Utility.NetBytesToInt(buffer,0,8);
     resp.Msg_ID=(UInt64)BitConverter.ToUInt64(buffer,0);
     resp.Result=(UInt32)Utility.NetBytesToInt(buffer,8,4);
     Monitor.Enter(SlidingWindow);
     for(int i=0;i<m_iSlidingWindowSize;i++)
     {
      if((SlidingWindow[i].Status==1)&&//已发送，等待回应
       (SlidingWindow[i].SequenceID==resp.Head.SequenceID)&&//序列号相同
       (SlidingWindow[i].Command==CMD_SUBMIT))//是Submit
      {
       SlidingWindow[i].Status=0;//清空窗口
       break;
      }
     }
     Monitor.Exit(SlidingWindow);
    }
    
   }
   catch(Exception ex)
   {
    resp.Head.CommandID=CMD_ERROR;
    strError=ex.Message;
    bOK=false;
   }
   if(bOK)
    RaiseEvent(SMS_STATE.SUBMIT_RESPONSE,resp);
   else
    RaiseEvent(SMS_STATE.SUBMIT_RESPONSE_ERROR,strError);
   return resp;

  }

  protected CMPP_DELIVER ReadDeliver(CMPP_HEAD Head)
  {
   CMPP_DELIVER deliver=new CMPP_DELIVER();
   deliver.Head=Head;
   string strError=string.Empty;
   try
   {
    if(m_NetworkStream.DataAvailable)
    {
     Byte[] buffer=new Byte[deliver.Head.TotalLength-Marshal.SizeOf(deliver.Head)];
     m_NetworkStream.Read(buffer,0,buffer.Length);
     deliver.Init(buffer);
     DeliverResponse(deliver.Head.SequenceID,deliver.Msg_ID,0);
    }
   }
   catch(Exception ex)
   {
    deliver.Head.CommandID=CMD_ERROR;
    strError=ex.Message;
   }
   if((deliver.Head.CommandID==CMD_DELIVER)&&(deliver.Registered_Delivery==0))是短消息
   {
    RaiseEvent(SMS_STATE.DELIVER,deliver);
   }
   else if((deliver.Head.CommandID==CMD_DELIVER)&&(deliver.Registered_Delivery==1))是状态报告
   {
    RaiseEvent(SMS_STATE.REPORT,deliver);
   }
   else//错误
   {
    RaiseEvent(SMS_STATE.DELIVER_ERROR,strError);
   }
   return deliver;

  }

  protected bool DeliverResponse(UInt32 SequenceID,UInt64 Msg_Id,UInt32 Result)
  {
   bool bOK=true;
   string strError=string.Empty;
   CMPP_DELIVER_RESP resp=new CMPP_DELIVER_RESP();
   resp.Head=new CMPP_HEAD();
   resp.Head.CommandID=CMPP30.CMD_DELIVER_RESP;
   resp.Head.SequenceID=SequenceID;
   resp.Msg_Id=Msg_Id;
   resp.Result=Result;

   DATA_PACKAGE dp=new DATA_PACKAGE();
   dp.SequenceID=resp.Head.SequenceID;
   dp.Command=resp.Head.CommandID;
   dp.SendCount=0;
   dp.Data=resp;
   dp.Status=1;
 
   Monitor.Enter(m_MessageQueue);
   m_MessageQueue.Enqueue(dp);
   Monitor.Exit(m_MessageQueue);

   return bOK;
  }

  protected bool ActiveTest()
  {
   bool bOK=true;
   TimeSpan ts=DateTime.Now-m_dtLastTransferTime;
   if(ts.TotalSeconds>m_iActiveTestSpan)
   {
    CMPP_HEAD Head=new CMPP_HEAD();
    Head.CommandID=CMPP30.CMD_ACTIVE_TEST;
    Head.SequenceID=CreateID();
    Head.TotalLength=12;
   
    DATA_PACKAGE dp=new DATA_PACKAGE();
    dp.SequenceID=Head.SequenceID;
    dp.Command=Head.CommandID;
    dp.SendCount=0;
    dp.Data=Head;
    dp.Status=1;
 
    Monitor.Enter(m_MessageQueue);
    m_MessageQueue.Enqueue(dp);
    Monitor.Exit(m_MessageQueue);

   }
   return bOK;

  }
  protected CMPP_ACTIVE_TEST_RESP ReadActiveTestResponse(CMPP_HEAD Head)
  {
   CMPP_ACTIVE_TEST_RESP resp=new CMPP_ACTIVE_TEST_RESP();
   resp.Head=Head;
   string strError=string.Empty;
   bool bOK=true;
   try
   {
    if(m_NetworkStream.DataAvailable)
    {
     Byte[] buffer=new Byte[resp.Head.TotalLength-Marshal.SizeOf(resp.Head)];
     m_NetworkStream.Read(buffer,0,buffer.Length);
     resp.Reserved=buffer[0];
     Monitor.Enter(SlidingWindow);
     for(int i=0;i<m_iSlidingWindowSize;i++)
     {
      if((SlidingWindow[i].Status==1)&&//已发送，等待回应
       (SlidingWindow[i].SequenceID==resp.Head.SequenceID)&&//序列号相同
       (SlidingWindow[i].Command==CMD_ACTIVE_TEST))//是ACTIVE_TEST
      {
       SlidingWindow[i].Status=0;//清空窗口
       break;
      }
     }
     Monitor.Exit(SlidingWindow);
    }
    
   }
   catch(Exception ex)
   {
    resp.Head.CommandID=CMD_ERROR;
    strError=ex.Message;
    bOK=false;
   }

   if(bOK)
    RaiseEvent(SMS_STATE.ACTIVE_TEST_RESPONSE,resp);
   else
    RaiseEvent(SMS_STATE.ACTIVE_TEST_RESPONSE_ERROR,strError);
   
   return resp;
  }
  protected bool ActiveTestResponse(UInt32 SequenceID)
  {
   bool bOK=true;
   CMPP_ACTIVE_TEST_RESP resp=new  CMPP_ACTIVE_TEST_RESP();
   resp.Head=new CMPP_HEAD();
   resp.Head.CommandID=CMPP30.CMD_ACTIVE_TEST_RESP;
   resp.Head.SequenceID=SequenceID;
   resp.Reserved=0;
   
   DATA_PACKAGE dp=new DATA_PACKAGE();
   dp.SequenceID=resp.Head.SequenceID;
   dp.Command=resp.Head.CommandID;
   dp.SendCount=0;
   dp.Data=resp;
   dp.Status=1;
 
   Monitor.Enter(m_MessageQueue);
   m_MessageQueue.Enqueue(dp);
   Monitor.Exit(m_MessageQueue);

   return bOK;
  }

  #endregion

  #region Public Methods
  //开始线程
  public void StartThread()
  {
   if(m_SendThread==null)
   {
    m_dtLastTransferTime=DateTime.Now;
    m_SendThread=new Thread(new ThreadStart(this.SendThreadProc));
    //m_SendThread.IsBackground=false;
    m_SendThread.Name=m_strSPID+"_Send";
    m_SendThread.Start();
   }
   if(m_ReceiveThread==null)
   {
    m_ReceiveThread=new Thread(new ThreadStart(this.ReceiveThreadProc));
    //m_ReceiveThread.IsBackground=false;
    m_ReceiveThread.Name=m_strSPID+"_Receive";
    m_ReceiveThread.Start();
   }
   m_eventConnect.Set();

  }
  //结束线程
  public void EndThread()
  {
   m_eventSend.Reset();
   m_eventReceive.Reset();
   m_eventReceiveExit.Set();
   m_eventSendExit.Set();
  }
  //发送函数
  public bool Submit(string Message,
   string[] Destination,
   string Source,
   string ServiceID,
   CODING Coding,
   bool NeedReport,
   byte FeeUserType,
   byte FeeType,
   int InfoFee,
   string FeeUser,
   string LinkID)
  {
   bool bOK=true;
   string strError=string.Empty;
   CMPP_SUBMIT submit=new CMPP_SUBMIT();
   submit.Head=new CMPP_HEAD();
   submit.Head.CommandID=CMPP30.CMD_SUBMIT;
   submit.Head.SequenceID=CreateID();
   submit.Msg_ID=0;
   submit.Pk_Total=1;
   submit.Pk_Number=1;
   submit.Registered_Delivery=Convert.ToByte(NeedReport);
   submit.Msg_Level=0;
   submit.Service_Id=ServiceID;
   submit.Fee_UserType=FeeUserType;
   submit.Fee_Terminal_Id=FeeUser;
   submit.Fee_Terminal_Type=0;//真实号码
   submit.TP_Pid=0;
   submit.TP_Udhi=0;
   submit.Msg_Fmt=(Byte)Coding;
   submit.Msg_Src=m_strSPID;
   submit.FeeType=string.Format("{0:d2}",FeeType);
   submit.FeeCode=InfoFee.ToString();
   submit.Valid_Time=string.Empty;
   submit.At_Time=string.Empty;
   submit.Src_Id=Source;
   submit.DestUsr_Tl=(Byte)Destination.Length;
   submit.Dest_Terminal_ID=Destination;
   submit.Dest_Terminal_Type=0;//真实号码
   submit.Msg_Length=(Byte)Utility.CountLength(Message,Coding);
   submit.Msg_Content=Message;
   submit.LinkID=LinkID;
   
   
   DATA_PACKAGE dp=new DATA_PACKAGE();
   dp.SequenceID=submit.Head.SequenceID;
   dp.Command=submit.Head.CommandID;
   dp.SendCount=0;
   dp.Data=submit;
   dp.Status=1;
 
   Monitor.Enter(m_MessageQueue);
   m_MessageQueue.Enqueue(dp);
   Monitor.Exit(m_MessageQueue);

   return bOK;
  }
  #endregion
 }
 //异步发送回调函数
 public delegate bool CMPPAsyncSubmit(string Message,
          string[] Destination,
          string Source,
          string ServiceID,
          CODING Coding,
          bool NeedReport,
          byte FeeUserType,
          byte FeeType,
          int InfoFee,
          string FeeUser,
          string LinkID);

}

 【待续】