如何判断SOCKET通信中,客户端在10s内未发送数据或者未收到服务器发送的数据,自动断开

SOCKET对方的接口文档中要求1.2业务接口服务端地址：31端口号：9007Tcp协议适合发送量大，发送和接收比较及时，对于Tcp客户端由于某些原因一段时MO起来，等该客户端一旦连接，便会很快补发。22个的连接，但须向业务申请后方可加连接，系统对于连接数是有限制的，每个合作方没有3,210条/秒，如果你10条的限制，可以向业务申请调高每条连接的最高限速。服务器端要求每连接每分钟都要能从客户端接收到至少一条指令数据，如果超过一分钟没有收到，服务器会向客户端发送一个测试指令，只要合作方回应该指令，那33分钟内不能收到服务器端任何指令将主动断开连接并重新连接。为了防止分发中心连接负载太重，我们要求任何一个连接因任20秒内不得连接，201分钟内超过我10分钟之内不能连接，并向系统管理员告警，由系统管理员根据情况停止该用户的合作帐户。1.2.1 连接登陆指令连接登陆指令是在客户端成功连接后首先应当而且只能在此时发送的指令：格式：LoginName=【注册名】&Pwd=【注册密码】&Type=【注册类型，0:发送；1：接收；2:0】（回车换行）如果所有服务注册成功，服务器返回给客户端字符串：Pass（回车换行）否则将断开连接。对于一次未连接成功，应至少在20重试连接。重新连接.我写的主要的客户端的代码：父类线程：publicclassParentThreadextendsThread{privateSocketsocket;protectedBufferedReaderreader;protectedBufferedWriterwriter;protectedbooleanisConnection=false;protectedbooleanlogin(inttype){LoginRequestlogin=newLoginRequest(type);〃login.setRegType(type);login.create();try{System.out.println(str_order);//PassResponsepass=newPassResponse(str_order);

writer.write(login.getOrder());writer.flush();Stringstr_order=reader.readLine();//if(pass.isPass()){

if("Pass".equals(str_order)){returntrue;}else{}

returnfalse;}catch(IOExceptione){e.printStackTrace();}returnfalse;}protectedvoidinit(){try{socket=newSocket(Const.distributeCenterIP,Const.distributeCenterPort);〃socket.setSoTimeout(50000);ocket.getInputStream()));ket.getOutputStream()));

reader=newBufferedReader(newInputStreamReader(swriter=newBufferedWriter(newOutputStreamWriter(socisConnection=true;}catch(UnknownHostExceptione){//TODOAuto-generatedcatchblocke.printStackTrace();}catch(IOExceptione){//TODOAuto-generatedcatchblocke.printStackTrace();}}protectedvoidcloseSocket(){isConnection=false;try{if(reader!=null)reader.close();}catch(IOExceptione){e.printStackTrace();}try{if(writer!=null)writer.close();}catch(IOExceptione){e.printStackTrace();}try{if(socket!=null)socket.close();}catch(IOExceptione){e.printStackTrace();))接收短信连接，继承父类线程publicclassSmsReceiverextendsParentThread{privatebooleantoReconnection=false;@Overridepublicvoidrun(){//TODOAuto-generatedmethodstubtry{init();//登陆booleanb=login(Const.reg_type_receive);if(!b){//登陆失败，退出查注册名和口令是否正确";

SmsMain.log.error("登陆失败，程序退出!请检名:"+Const.reg_name);

SmsM("

注 册 名令:"+Const.reg_pwd);型:"+Const.reg_type_receive);

用户口注册类}catch(Exceptione){toReconnection=true;}while(true){if(toReconnection){/**20秒连接一次*/try{

sleep(20000);init();//登陆booleanb=login(Const.reg_type_receive);toReconnection=false;if(!b){〃登陆失败，退出失败，程序退出！请检查注册名和口令是否正确";名:"+Const.reg_name);令:"+Const.reg_pwd);型:"+Const.reg_type_receive);}

SmsMain.log.error("登陆注册名用户口注册类break;}catch(InterruptedExceptione){e.printStackTrace();)if(!isConnection){//连接失败toReconnection=true;continue;try{Stringstr_order=reader.readLine();System.out.println(str_order);Orderorder=newOrder(str_order);//如果为测试指令，发送回应//if(order.isTestOrder()){if("test".equals(str_order)){System.out.println("---测试 ";writer.write(order.testOrder);writer.flush();toReconnection=false;continue;//处理SMSBusinessCenter(order);prop=sbc.performTask();

SMSBusinessCentersbc=newProperties//发送回应System.out.println(prop.getProperty("CommandId");received(prop.getProperty("CommandId");}catch(IOExceptione){e.printStackTrace();}}}privatevoidreceived(Stringcid){//Receivedreceived=newReceived(Utils.getCurrentCommandId());//Receivedreceived=newReceived(cid);//received.create();try{writer.write("ReceivedCommandId="+cid+"\r\n”;writer.flush();}catch(IOExceptione){e.printStackTrace();}}发送短信连接，继承父类线程:publicclassSmsSendextendsParentThread{privatebooleantoReconnection=false;@Overridepublicvoidrun(){try{init();//登陆booleanb=login(Const.reg_type_send);if(!b){//登陆失败，退出检查注册名和口令是否正确";

SmsMain.log.error("登陆失败，程序退出!请SmsM("注册名名:"+Const.reg_name);SmsM("用户口令:"+Const.reg_pwd);SmsM(" 注 册 类型:"+Const.reg_type_send);}}catch(Exceptione){toReconnection=true;}while(true){if(toReconnection){/**20秒连接一次*/try{

sleep(20000);init();//登陆end);

booleanb=login(Const.reg_type_stoReconnection=false;if(!b){〃登陆失败，退出失败，程序退出！请检查注册名和口令是否正确";

SmsMain.log.error("登陆SmsM("注册名名:"+Const.reg_name);SmsM("用户口令:"+Const.reg_pwd);SmsM("注册类型:"+Const.reg_type_send);break;}}catch(InterruptedExceptione){e.printStackTrace();}}if(!isConnection){//连接失败toReconnection=true;continue;try(Stringstr_order=reader.readLine();Orderorder=newOrder(str_order);//如果为测试指令，发送回应if(order.isTestOrder()){writer.write(order.testOrder);toReconnection=false;//continue;////SMSBusinessCenter(order);

SMSBusinessCentersbc=new//处理// Vectormsgs=sbc.getSendMsg();// //发送短信// //for(){// writer.write("";//////发送短信if(SmsMain.list!=null&&SmsMain.list.size()>0){synchronized(SmsMain.list){iterator=SmsMain.list.iterator();iterator.hasNext(){SubmitRequestsr=(SubmitRequest)iterator.next();StringBuffersb=newStringBuffer();sb.append(Const.order_submit+"")pend("CommandId="+sr.getCommandId())pend("&GateWay="+sr.getGateWay())pend("&GateName="+sr.getGateName())pend("&ItemId="+sr.getItemId())pend("&SpNumber="+sr.getSpNumber())pend("&UserNumber:="+bin2hex(sr.getUserNumber()))pend("&UserNumberType="+sr.getUserNumberType())pend("&FeeNumber="+sr.getFeeNumber())pend("&FeeNumberType="+sr.getFeeNumberType())pend("&FeeType="+sr.getFeeType())

for(Iterator.ap.ap.ap.ap.ap.ap.ap.ap.ap.ap.append("&ScheduleTime="+sr.getScheduleTime())pend("&ExpireTime="+sr.getExpireTime())pend("&MtFlag="+sr.getMtFlag())pend("&ReportFlag="+sr.getReportFlag())pend("&MsgCode="+sr.getMsgCode())pend("&MsgId="+sr.getMsgId())pend("&ExtData:="+sr.getExtData())pend("&TP_pId="+sr.getTp_pId())pend("&TP_udhi="+sr.getTp_udhi())pend("&Msg:="+bin2hex(sr.getMsg()))pend("&LinkID="+sr.getLinkID())pend("&ItemType="+sr.getItemType()+"\r\n");writer.write(sb.toString());writer.flush();SmsMain.list.remove(sr);)

.ap.ap.ap.ap.ap.ap.ap.ap.ap.ap.ap//接受回应received();)}catch(lOExceptione){e.printStackTrace();}}}privatevoidreceived(){try{Stringline=reader.readLine();//Receivedreceived=newReceived(line);//received.parse();System.out.println(line);SmsM(line);}catch(IOExceptione){e.printStackTrace();}字符串转换成十六进制值@parambinString转换成十六进制的字符申@return/publicstaticStringbin2hex(Stringbin){char[]digital="0123456789ABCDEF”.toCharArray();StringBuffersb=newStringBuffe