import?cmpp.*;
import?java.io.DataInputStream;
import?java.io.DataOutputStream;
import?java.io.IOException;
import?java.io.UnsupportedEncodingException;
import?java.net.Socket;
import?java.net.UnknownHostException;
import?java.util.ArrayList;
import?java.util.List;

/**
?*?Created?by?qq:599097707?輕舟?on?2017/12/5/005.
?*/
public?class?testMain?{
????public?static?Socket?socket;
????public?static?String?IP=“192.168.1.169“;//服務器IP
????public?static?int?port=9966;//端口號
????public?static?String?spid=“2123“;//企業代碼?和?spid?一樣
????public?static?String?secret=“abc@aaa“;//
????public?static?DataInputStream?in;
????public?static?DataOutputStream?out;


????/***
?????*?創建指定地址socket連接
?????*?@return
?????*/
????public?static?Socket?getSocketInstance（）{
????????try?{
????????????socket=new?Socket（IPport）;
????????????socket.setKeepAlive（true）;
????????????socket.setSoTimeout（10000）;
????????}?catch?（UnknownHostException?e）?{
????????????//?TODO?Auto-generated?catch?block
????????????e.printStackTrace（）;
????????}?catch?（IOException?e）?{
????????????//?TODO?Auto-generated?catch?block
????????????e.printStackTrace（）;
????????}
????????return?socket;
????}

????/***
?????*?connect初始化連接服務器
?????*?@throws?IOException
?????*/
????public?static?void?connectISMG（）?throws?IOException{
????????System.out.println（“正在連接到服務器“+IP）;
????????CMPP_CONNECT?connect=new?CMPP_CONNECT（）;

????????connect.setTotalLength（12+6+16+1+4）;
????????connect.setCommandId（0x00000001）;//請求連接
????????connect.setSequenceId（MsgUtils.getSequence（））;
????????connect.setSourceAddr（spid）;//源地址，此處為SP_Id，即SP的企業代碼。

????????String?timestamp=MsgUtils.getTimestamp（）;
????????connect.setAuthenticatorSource（MsgUtils.getAuthenticatorSource（spid?secret?timestamp））;//用于鑒別源地址。其值通過單向MD5?hash計算得出
????????connect.setTimestamp（Integer.parseInt（timestamp））;//時間戳的明文由客戶端產生格式為MMDDHHMMSS，即月日時分秒，10位數字的整型，右對齊?。
????????//connect.setVersion（（byte）0x20）;//雙方協商的版本號（高位4bit表示主版本號低位4bit表示次版本號）
????????connect.setVersion（（byte）0x14）;//雙方協商的版本號（高位4bit表示主版本號低位4bit表示次版本號）
????????List?dataList=new?ArrayList（）;
????????dataList.add（connect.toByteArray（））;
????????out=new?DataOutputStream（getSocketInstance（）.getOutputStream（））;
????????if（out!=null&&null!=dataList）{
????????????for（byte[]data:dataList）{
????????????????out.write（data）;
????????????????out.flush（）;
????????????????System.out.println（“connect數據發送完成“）;
????????????}
????????}
????????in=new?DataInputStream（socket.getInputStream（））;
????????int?len=in.readInt（）;
????????List?getData=new?ArrayList（）;
????????if（null!=in&&0!=len）{
????????????byte[]?data=new?byte[len-4];
????????????in.read（data）;
????????????getData.add（data）;
????????????for（byte[]?returnData:getData）{
????????????????Message_Header?header=new?Message_Header（returnData）;
????????????????switch（header.getCommandId（））{
????????????????????case?0x80000001:
????????????????????????CMPP_CONNE