?? socketlogic.java
字號:
break; //全部處理成功，退出
}
}
}
catch (IOException ioexception) {
System.err.println("socketLogic.submit Failed I/O: " + ioexception);
for (int i = 0; i < multi.length; i++) {
if (multi[i].result != -1) {
multi[i].result = configure.ERROR_SEND_FAILED;
//return;
}
}
}
}
// return errorCode;
}
/********************************************************************************
*
* 登錄系統(tǒng)
*
*/
public int login(SMGPHeadStruct head, byte body[],socketStruct socket,int retryTimes,int timeout)
{
DataInputStream dataRec;
DataOutputStream dataSend;
int errorCode=0;
try {
head.sequenceId = socket.seq++;
if(socket.seq == 0x7fffffff)
socket.seq = 1;
socket.socket.setSoTimeout(timeout); //設(shè)置超時時間
dataRec = new DataInputStream(socket.socket.getInputStream());
dataSend = new DataOutputStream(socket.socket.getOutputStream());
errorCode=send(head,body,dataSend);
}
catch (IOException ioexception) {
System.err.println("socketLogic.login Failed I/O: " + ioexception);
return configure.ERROR_SEND_FAILED;
}
return errorCode;
}
/*********************************************************************************
*
* 發(fā)送數(shù)據(jù)
* @return 0:成功 1:失敗
*/
public int send(SMGPHeadStruct head, byte body[],DataOutputStream dataSend)
{
try{
int i = head.packageSize - 12;
byte abyte1[] = fun.head2Byte(head);
dataSend.write(abyte1, 0, 12);
if (i > 0 && body != null)
dataSend.write(body, 0, i);
dataSend.flush();
}catch(InterruptedIOException e)
{//超時
System.err.println("socketLogic.timeout receive timeout: " + e);
return configure.SOCKET_SO_TIMEOUT;
}
catch(IOException ioexception)
{//其它錯誤
System.err.println("socketLogic.send Failed I/O: " + ioexception);
return configure.ERROR_CONNECT_FAILED;
}
catch (Exception ioexception) {
System.err.println("socketLogic.send Exception: " + ioexception);
return configure.ERROR_SEND_FAILED;
}
return 0;
}
/********************************************************************************************
*
* 保存接收deliver數(shù)據(jù)并返回response(主要用于發(fā)送數(shù)據(jù)后接收response時，意外接收到的deliver)
*由activeTest或submit等調(diào)用，端口鎖定由調(diào)用的method處理
* type: 0－－發(fā)送端口，1--接收端口 2－－收發(fā)端口
*
**/
public int dealDeliver(socketStruct socket,Hashtable hash,deliverVector deliverQueue,int type )
{
DataInputStream dataRec;
DataOutputStream dataSend;
int errorCode=0;
try {
SMGPHeadStruct head=(SMGPHeadStruct)hash.get("head");
if ( head.requestId==3 &&( (String) hash.get("result")).equals("ok"))
{ //接收deliver成功
//if(deliverQueue(head,(byte[])hash.get("body"),deliverQueue))
if(type==0||(type!=0&&deliverQueue(head,(byte[])hash.get("body"),deliverQueue)))
{//接收的數(shù)據(jù)正確，返回deliver_resp
head.requestId=0x80000003;
head.packageSize=26;
byte[] body=new byte[14];
System.arraycopy((byte[])hash.get("body"),0,body,0,10);
/* int status=0; //若為收發(fā)、收端口，則返回正確信息
if(type==0)
status=128; //若是發(fā)送端口，返回“接口處理錯”的信息
byte[] s=fun.int2Byte(status);
body[10]=s[0];*/
body[10]=0; //若為收發(fā)、收端口，則返回正確信息
if(type==0)
body[10]=(byte)0x80; //若是發(fā)送端口，返回“接口處理錯”的信息
// byte[] s=fun.int2Byte(status);
// body[10]=s[0];
body[11]=0;
body[12]=0;
body[13]=0;
dataSend = new DataOutputStream(socket.socket.getOutputStream());
send(head,body,dataSend);
}
}
else
{//接收失敗
errorCode=configure.ERROR_RECEIVE_FAILED;
}
}
catch(InterruptedIOException e)
{//超時退出
}
catch (IOException ioexception) {
System.err.println("socketLogic.dealDeliver Failed I/O: " + ioexception);
return configure.ERROR_RECEIVE_FAILED;
}
catch (Exception ioexception) {
System.err.println("socketLogic.dealDeliver Exception: " + ioexception);
return configure.ERROR_RECEIVE_FAILED;
}
return errorCode;
}
/**********************************************************************************************
*
* 循環(huán)接收deliver數(shù)據(jù)
*返回接收的數(shù)量
*/
public int cycleReceive(socketStruct socket,deliverVector deliverQueue)
{
DataInputStream dataRec;
DataOutputStream dataSend;
int receiveTotal=0;
int errorCode=0;
long startTime=System.currentTimeMillis();
do{//循環(huán)接收數(shù)據(jù)，直到?jīng)]有數(shù)據(jù)接收或socket超時
synchronized (socket) {
try {
socket.socket.setSoTimeout(configure.SOCKET_RECEIVE_TIMEOUT); //設(shè)置超時時間
dataRec = new DataInputStream(socket.socket.getInputStream());
Hashtable hash = receive(socket);
if (hash == null) {
errorCode = configure.ERROR_RECEIVE_FAILED;
return errorCode;
}
SMGPHeadStruct head = (SMGPHeadStruct) hash.get("head");
if (head.requestId == 3 && ( (String) hash.get("result")).equals("ok")) { //接收deliver成功
if (deliverQueue(head, (byte[]) hash.get("body"), deliverQueue)) { //接收的數(shù)據(jù)正確，返回deliver_resp
head.requestId = 0x80000003;
head.packageSize = 26;
byte[] body = new byte[14];
System.arraycopy( (byte[]) hash.get("body"), 0, body, 0, 10);
body[10] = 0;
body[11] = 0;
body[12] = 0;
body[13] = 0;
dataSend = new DataOutputStream(socket.socket.getOutputStream());
send(head, body, dataSend);
receiveTotal++;
if(System.currentTimeMillis()-startTime>900) //900毫秒后退出接收
break;
}
}
else { //接收失敗
errorCode = configure.ERROR_RECEIVE_FAILED;
break;
}
// }
}
catch (InterruptedIOException e) { //超時退出
break;
}
catch (IOException ioexception) {
System.err.println("socketLogic.cycleDeliver Failed I/O: " +
ioexception);
return configure.ERROR_RECEIVE_FAILED;
}
catch(Exception ioexception)
{//其它錯誤
System.err.println("socketLogic.cycleReceive(socketStruct socket,deliverVector deliverQueue) eXCEPTION: " + ioexception);
return configure.ERROR_RECEIVE_FAILED;
}
}}
while(true);
return receiveTotal;
// return errorCode;
}
/****************************************************************************************
*
* 將deliver數(shù)據(jù)送入相應(yīng)的接收隊列
*@param head、body 接受到的數(shù)據(jù)
*@param deliverQueue 數(shù)據(jù)接收隊列
*/
public boolean deliverQueue(SMGPHeadStruct head,byte[] body,deliverVector deliverQueue)
{
boolean result=true;
try{
deliverStruct deliver=new deliverStruct();
deliver.setPackageLength(head.packageSize);
deliver.setRequestId(head.requestId);
deliver.setSequenceId(head.sequenceId);
int k=0;
byte[] msgId=new byte[10];
System.arraycopy(body,k,msgId,0,10);
deliver.setMsgId(msgId);
k+=10;
deliver.setIsReport(fun.byte2Int(body[k]));
k+=1;
deliver.setMsgFormat(fun.byte2Int(body[k]));
k+=1;
byte[] recvTime=new byte[14];
System.arraycopy(body,k,recvTime,0,10);
deliver.setRecvTime(recvTime);
k+=14;
byte[] srcTermId=new byte[21];
System.arraycopy(body,k,srcTermId,0,21);
deliver.setSrcTermId(srcTermId);
k+=21;
byte[] destTermId=new byte[21];
System.arraycopy(body,k,destTermId,0,21);
deliver.setDestTermId(destTermId);
k+=21;
deliver.setMsgLength(fun.byte2Int(body[k]));
k+=1;
byte[] msgContent=new byte[deliver.getMsgLength()];
System.arraycopy(body,k,msgContent,0,msgContent.length);
deliver.setMsgContent(msgContent);
k+=deliver.getMsgLength();
byte[] reserve=new byte[8];
System.arraycopy(body,k,reserve,0,8);
deliver.setReserve(reserve);
k+=8;
synchronized(deliverQueue)
{ //將接收到的數(shù)據(jù)放入接收隊列
/* if(deliver.getIsReport()==1)
System.out.println("report");
else
System.out.println("deliver");*/
if (configure.QUEUE_DELIVER_MAX == 0 ||
deliverQueue.size() < configure.QUEUE_DELIVER_MAX)
deliverQueue.add(deliver);
else
result=false; //接收隊列已滿
}
// System.out.println("deliverQueue length="+deliverQueue.size());
}
catch(Exception e)
{
System.out.println("deliverQueue(SMGPHeadStruct head,byte[] body,deliverVector deliverQueue):"+e);
result=false;
}
return result;
}
/********************************************************************************************
*
* 接收數(shù)據(jù)，不進(jìn)行任何處理
*
* dataRec接收數(shù)據(jù)
*/
public Hashtable receive(socketStruct socket)
{
DataInputStream dataRec=null;
Hashtable hash=new Hashtable();
String result="error";
SMGPHeadStruct head=new SMGPHeadStruct();
byte[] body=new byte[0];
try{
dataRec = new DataInputStream(socket.socket.getInputStream());
}
catch(IOException ioexception)
{//IO錯誤
System.err.println("1 socketLogic.receivet(DataInputStream dataRec) Failed I/O: " + ioexception);
result="error";
hash.put("head",head);
hash.put("body",body);
hash.put("result",result);
return hash;
}
try
{
head.packageSize = dataRec.readInt();
head.requestId = dataRec.readInt();
head.sequenceId = dataRec.readInt();
//System.out.println("head.packageSize:"+head.packageSize);
if(head.packageSize>100000||head.requestId ==0||head.packageSize <12)
{//接收倒的數(shù)據(jù)出錯，需復(fù)位socket連接
socket.socket.close();
socket.socket=null;
return null;
}
body = new byte[head.packageSize-12];
result="wait"; //等待接收包體
for(int readBytes=0;readBytes<head.packageSize-12;)
{
readBytes+=dataRec.read(body, readBytes, head.packageSize-12-readBytes);
}
result="ok";
}
catch(InterruptedIOException e)
{//超時
//System.err.println("socketLogic.receivet(DataInputStream dataRec) receive timeout: " + e);
try{
if ("wait".equals(result)) { //socket超時時，數(shù)據(jù)未接收完畢，需復(fù)位socket連接
socket.socket.close();
socket.socket=null;
return null;
}
}catch(IOException ioexception){}
result="timeout";
}
catch(IOException ioexception)
{//IO錯誤
System.err.println(" socketLogic.receivet(DataInputStream dataRec) Failed I/O: " + ioexception);
try{
socket.socket.close(); //端口IO錯誤，關(guān)閉端口
socket.socket=null;
}catch(IOException ioexception1){}
result="error";
}
catch(Exception ioexception)
{//其它錯誤
System.err.println(" socketLogic.receivet(DataInputStream dataRec) eXCEPTION: " + ioexception);
result="error";
}
hash.put("head",head);
hash.put("body",body);
hash.put("result",result);
return hash;
}
}?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -