proxycmpp.java~13~

移动CMPP3.0协议短信网关连接程序

//package Java.Test.miaomiao.sp_for_cmpp.src;
import java.io.*;
import java.net.*;
import java.util.*;
public class  ProxyCmpp {
    public static CMPP30DeliverMessage1 UpMessage1;
    public static CMPP30DeliverMessage1 DownMessage1;
    public ProxyCmpp()
    {
    }
public static void main(String[] args) {
      CmppThread CmppThread = new CmppThread();
      CmppThread.start();
//    CMPP30DeliverMessage1 UpMessage1;
//    byte[] msg_Content = {'1', '2'};
//    String phnum = "13277080176";
//******************************************************************************************
      ServerSocket socketConnection;
      Socket pipe;
        try {

            socketConnection = new ServerSocket(11112);
            do
            {
/*                if (pipe.isBound() != true)
                {
                    socketConnection = new ServerSocket(11112);
                    pipe = socketConnection.accept();
                    System.out.println("Server is waiting again...............");
                }
 */             Thread.sleep(10000);
                pipe = socketConnection.accept();
                System.out.println("Server1 Waiting");
                ObjectOutputStream serverOutputStream = new ObjectOutputStream(
                        pipe.getOutputStream());
                ObjectInputStream serverInputStream = new ObjectInputStream(
                        pipe.getInputStream());
                UpMessage1 = CmppThread.CmppReceive();
                while (UpMessage1 != null)
                {
                    System.out.println("主函数收到的内容:" +
                                       new String(UpMessage1.strcontent,
                                                  "GB2312"));
                    serverOutputStream.writeObject(UpMessage1);
                    UpMessage1 = CmppThread.CmppReceive();
                }
                UpMessage1=new CMPP30DeliverMessage1();
                serverOutputStream.writeObject(UpMessage1);
/*              for(int i=0;i<10;i++)
                {
                    UpMessage1=myProxy.UpMessage[i];
                    serverOutputStream.writeObject(UpMessage1);
                    if(myProxy.UpMessage[i].mark==0)
                    break;
                }
*/
                DownMessage1 = (CMPP30DeliverMessage1) serverInputStream.
                               readObject();
                CmppThread.CmppSend(DownMessage1.strcontent,DownMessage1.strnumber);
                serverInputStream.close();
                serverOutputStream.close();
            }while(true);
        } catch (java.io.IOException e) {
            e.printStackTrace();
            System.out.println(e.toString());
//            serverInputStream.close();
//            serverOutputStream.close();
            throw new IllegalStateException("发送失败,发送线程终止");
        } catch (Exception e) {
            System.out.println(e);
        }
//******************************************************************************************
    }
  }