SMGP协议源码For JAVA

/************************************************************************************ * * 与服务器唯一的发送接口，采用独占式发送，不自动连接；有active_test判断断线并连接 * */ package com.ut.smgp.api.logic; import com.ut.smgp.api.structure.*; import com.ut.smgp.api.configure.*; import com.ut.smgp.api.function.*; import java.io.*; import java.net.*; import java.util.*; public class socketLogic { private function fun=new function(); private int error_code=0; private initStruct currentInit=new initStruct(); //保存当前建立连接使用的配置 public socketLogic() { } /********************************************************************** * *退出 * @param SMGPHeadStruct 包头 * @return int 0：成功 1：失败 * */ public int exit(socketStruct socket,int timeout,deliverVector deliverQueue,int type) { DataInputStream dataRec; DataOutputStream dataSend; SMGPHeadStruct head=new SMGPHeadStruct(); head.packageSize=12; head.requestId=6; int errorCode=0; byte[] body=new byte[0]; synchronized(socket) { try { int startTime=(int)(System.currentTimeMillis()/1000L); head.sequenceId = socket.seq++; if(socket.seq == 0x7fffffff) socket.seq = 1; socket.socket.setSoTimeout(timeout); //设置超时时间 dataRec = new DataInputStream(socket.socket.getInputStream()); dataSend = new DataOutputStream(socket.socket.getOutputStream()); if(send(head,body,dataSend)!=0) { return configure.ERROR_SEND_FAILED; } for (; ; ) { //接收response if((int)(System.currentTimeMillis()/1000L)-startTime>timeout) {//超时 break; } Hashtable hash = receive(socket); if(hash==null) { errorCode=configure.ERROR_RECEIVE_FAILED; break; } if ( ( (String) hash.get("result")).equals("ok")) { //接收成功 SMGPHeadStruct h = (SMGPHeadStruct) hash.get("head"); if (h.sequenceId == head.sequenceId&&h.requestId==head.requestId+0x80000000){ return 0; //发送成功 } else //不是要接收的response，继续接收 dealDeliver(socket,hash,deliverQueue,type); //若是deliver数据，则保存入deliver接收队列并返回response continue; } else {//接收失败 errorCode=configure.ERROR_SEND_FAILED; break; } } } catch (IOException ioexception) { System.err.println("socketLogic.exit Failed I/O: " + ioexception); return configure.ERROR_SEND_FAILED; } catch (Exception ioexception) { //System.err.println("socketLogic.exit1 Exception: " + ioexception); return configure.ERROR_RECEIVE_FAILED; } } return errorCode; } /********************************************************************** * *发送active数据包 * @param SMGPHeadStruct 包头 * @return int 0：成功 1：失败 * */ public int activeTest(socketStruct socket,int retryTimes,int timeout,deliverVector deliverQueue,int type) { DataInputStream dataRec; DataOutputStream dataSend; SMGPHeadStruct head=new SMGPHeadStruct(); head.packageSize=12; head.requestId=4; int errorCode=0; byte[] body=new byte[0]; synchronized(socket) { try { for(int j=0;j<retryTimes;j++) {//retry int startTime=(int)(System.currentTimeMillis()/1000L); head.sequenceId = socket.seq++; if(socket.seq == 0x7fffffff) socket.seq = 1; socket.socket.setSoTimeout(timeout); //设置超时时间 dataRec = new DataInputStream(socket.socket.getInputStream()); dataSend = new DataOutputStream(socket.socket.getOutputStream()); if(send(head,body,dataSend)!=0) { errorCode=configure.ERROR_SEND_FAILED; continue; } for (; ; ) { //接收response if((int)(System.currentTimeMillis()/1000L)-startTime>timeout) {//超时 break; } Hashtable hash = receive(socket); if(hash==null) { errorCode=configure.ERROR_RECEIVE_FAILED; break; } if ( ( (String) hash.get("result")).equals("ok")) { //接收成功 SMGPHeadStruct h = (SMGPHeadStruct) hash.get("head"); if (h.sequenceId == head.sequenceId&&h.requestId==head.requestId+0x80000000){ return 0; //发送成功 } else //不是要接收的response，继续接收 dealDeliver(socket,hash,deliverQueue,type); //若是deliver数据，则保存入deliver接收队列并返回response continue; } else {//接收失败 errorCode=configure.ERROR_SEND_FAILED; break; } } } } catch (IOException ioexception) { System.err.println("socketLogic.activeTest Failed I/O: " + ioexception); return configure.ERROR_SEND_FAILED; } catch (Exception ioexception) { System.err.println("socketLogic.activeTest Exception: " + ioexception); return configure.ERROR_RECEIVE_FAILED; } } return errorCode; } /********************************************************************** * *发送SMGP数据包 * @param SMGPHeadStruct 包头 * @return int 0：成功 1：失败 * */ public int submit(SMGPHeadStruct head, byte body[],socketStruct socket,int retryTimes,int timeout,deliverVector deliverQueue,byte[] msgId,int type) { DataInputStream dataRec; DataOutputStream dataSend; int errorCode=0; synchronized(socket) { try { for(int j=0;j<retryTimes;j++) {//retry head.sequenceId = socket.seq++; long startTime=System.currentTimeMillis(); if(socket.seq == 0x7fffffff) socket.seq = 1; socket.socket.setSoTimeout(timeout); //设置超时时间 dataRec = new DataInputStream(socket.socket.getInputStream()); dataSend = new DataOutputStream(socket.socket.getOutputStream()); int sendResult=send(head,body,dataSend); if(sendResult!=0) { errorCode=sendResult; continue; } for (; ; ) { //接收response if(System.currentTimeMillis()-startTime>timeout) {//超时 break; } Hashtable hash = receive(socket); if(hash==null) { errorCode=configure.ERROR_RECEIVE_FAILED; break; } if ( ( (String) hash.get("result")).equals("ok")) { //接收成功 SMGPHeadStruct h = (SMGPHeadStruct) hash.get("head"); if (h.sequenceId == head.sequenceId&&h.requestId==head.requestId+0x80000000){ byte[] d