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

请教如何判断SOCKET长连接通信中,一段时间内是否收到对方的信息.及相关问题.对方的接口文档中要求: 1.2 业务接口服务端地址：31 端口号：9007Tcp协议适合发送量大，发送和接收比较及时，对于Tcp客户端由于某些原因一段时间内不能连接到分发中心服务器，所有的发向该客户端的MO短信和报告都会被缓存起来，等该客户端一旦连接，便会很快补发。建议合作方建立一个发送一个接收2个连接，如果业务量很大，可以申请多于2个的连接，但须向业务申请后方可加连接，系统对于连接数是有限制的，每个合作方没有特殊声明时连接数是3，一般可以建2个连接，一个连接用于缓冲在某些情况下断开不能很好识别的情况。还有，对于每条连接，我们目前的速度限制是10条/秒，如果你的业务超过每连接每秒10条的限制，可以向业务申请调高每条连接的最高限速。服务器端要求每连接每分钟都要能从客户端接收到至少一条指令数据，如果超过一分钟没有收到，服务器会向客户端发送一个测试指令，只要合作方回应该指令，那么就认为连接是处于激活状态，如果3分钟内服务端都无法接收到客户端的测试回应，将主动断开连接。客户端程序也应该设置3分钟内不能收到服务器端任何指令将主动断开连接并重新连接。为了防止分发中心连接负载太重，我们要求任何一个连接因任何原因在断开后20秒内不得连接，20秒后再尝试连接，否则如果在1分钟内超过我们设定的连接次数，我们将限制其在后续10分钟之内不能连接，并向系统管理员告警，由系统管理员根据情况停止该用户的合作帐户。1.2.1 连接登陆指令连接登陆指令是在客户端成功连接后首先应当而且只能在此时发送的指令：格式：Login Name=【注册名】&Pwd=【注册密码】&Type=【注册类型，0：接收和发送；1：接收；2：发送；默认为0】（回车换行）如果所有服务注册成功，服务器返回给客户端字符串：Pass（回车换行）否则将断开连接。对于一次未连接成功，应至少在20秒以后再重试连接，禁止连续的重试连接。 请问红色的话,我应该如何设置三分钟内不收到服务器任何指令将主动断开连接并重新连接. 我写的主要的客户端的代码: 父类线程: public class ParentThread extends Thread private Socket socket; protected BufferedReader reader; protected BufferedWriter writer; protected boolean isConnection=false; protected boolean login(int type) LoginRequest login = new LoginRequest(type); /login.setRegType(type); login.create(); try writer.write(login.getOrder(); writer.flush(); String str_order = reader.readLine();System.out.println(str_order);/ PassResponse pass = new PassResponse(str_order);/ if(pass.isPass() if(Pass.equals(str_order) return true; else return false; catch (IOException e) e.printStackTrace(); return false; protected void init() try socket = new Socket(Const.distributeCenterIP,Const.distributeCenterPort); /socket.setSoTimeout(50000); reader =new BufferedReader(new InputStreamReader(socket.getInputStream(); writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(); isConnection=true; catch (UnknownHostException e) / TODO Auto-generated catch block e.printStackTrace(); catch (IOException e) / TODO Auto-generated catch block e.printStackTrace(); protected void closeSocket() isConnection=false; try if(reader != null)reader.close(); catch (IOException e) e.printStackTrace(); try if(writer != null)writer.close(); catch (IOException e) e.printStackTrace(); try if(socket != null)socket.close(); catch (IOException e) e.printStackTrace(); 接收短信连接,继承父类线程public class SmsReceiver extends ParentThread private boolean toReconnection=false; Override public void run() / TODO Auto-generated method stub try init(); /登陆 boolean b = login(Const.reg_type_receive); if(!b)/登陆失败，退出 SmsMain.log.error(登陆失败，程序退出！请检查注册名和口令是否正确; SmsM(注册名名:+Const.reg_name); SmsM(用户口令:+Const.reg_pwd); SmsM(注册类型:+Const.reg_type_receive); catch(Exception e) toReconnection = true; while(true) if(toReconnection) /*20秒连接一次*/ try sleep(20000); init(); /登陆 boolean b = login(Const.reg_type_receive); toReconnection=false; if(!b)/登陆失败，退出 SmsMain.log.error(登陆失败，程序退出！请检查注册名和口令是否正确; SmsM(注册名名:+Const.reg_name); SmsM(用户口令:+Const.reg_pwd); SmsM(注册类型:+Const.reg_type_receive); break; catch (InterruptedException e) e.printStackTrace(); if(!isConnection)/连接失败 toReconnection = true; continue; try String str_order = reader.readLine();System.out.println(str_order); Order order = new Order(str_order); /如果为测试指令，发送回应 /if(order.isTestOrder() if(test.equals(str_order)System.out.println(-测试-; writer.write(order.testOrder); writer.flush(); toReconnection = false; continue; /处理 SMSBusinessCenter sbc = new SMSBusinessCenter(order); Properties prop=sbc.performTask(); /发送回应System.out.println(prop.getProperty(CommandId); received(prop.getProperty(CommandId); catch (IOException e) e.printStackTrace(); private void received(String cid) /Received received = new Received(Utils.getCurrentCommandId();/ Received received = new Received(cid);/ received.create(); try writer.write(Received CommandId=+cid+rn; writer.flush(); catch (IOException e) e.printStackTrace(); 发送短信连接,继承父类线程:public class SmsSend extends ParentThread private boolean toReconnection=false; Override public void run() try init(); /登陆 boolean b = login(Const.reg_type_send); if(!b)/登陆失败，退出 SmsMain.log.error(登陆失败，程序退出！请检查注册名和口令是否正确; SmsM(注册名名:+Const.reg_name); SmsM(用户口令:+Const.reg_pwd); SmsM(注册类型:+Const.reg_type_send); catch(Exception e) toReconnection = true; while(true) if(toReconnection) /*20秒连接一次*/ try sleep(20000); init(); /登陆 boolean b = login(Const.reg_type_send); toReconnection=false; if(!b)/登陆失败，退出 SmsMain.log.error(登陆失败，程序退出！请检查注册名和口令是否正确; SmsM(注册名名:+Const.reg_name); SmsM(用户口令:+Const.reg_pwd); SmsM(注册类型:+Const.reg_type_send); break; catch (InterruptedException e) e.printStackTrace(); if(!isConnection)/连接失败 toReconnection = true; continue; try String str_order = reader.readLine(); Order order = new Order(str_order); /如果为测试指令，发送回应 if(order.isTestOrder() writer.write(order.testOrder); toReconnection = false; /continue; / /处理/ SMSBusinessCenter sbc = new SMSBusinessCenter(order);/ Vector msgs = sbc.getSendMsg();/ /发送短信/ /for()/ writer.write(;/ / /发送短信 if(SmsMain.list!=null&SmsMain.list.size()0) synchronized (SmsMain.list) for (Iterator iterator = SmsMain.list.iterator(); iterator .hasNext() SubmitRequest sr = (SubmitRequest) iterator.next(); StringBuffer sb = new StringBuffer(); sb.append(Const.order_submit+ ) .append(CommandId=+sr.getCommandId() .append(&GateWay=+sr.getGateWay() .append(&GateName=+sr.getGateName() .append(&ItemId=+sr.getItemId() .append(&SpNumber=+sr.getSpNumber() .append(&UserNumber:=+bin2hex(sr.getUserNumber() .append(&UserNumberType=+sr.getUserNumberType() .append(&FeeNumber=+sr.getFeeNumber() .append(&FeeNumberType=+sr.getFeeNumberType() .append(&FeeType=+sr.getFeeType() .append(&ScheduleTime=+sr.getScheduleTime() .append(&ExpireTime=+sr.getExpireTime() .append(&MtFlag=+sr.getMtFlag() .append(&ReportFlag=+sr.getReportFlag() .append(&MsgCode=+sr.getMsgCode() .append(&MsgId=+sr.getMsgId() .append(&ExtData:=+sr.getExtData() .append(&TP_pId=+sr.getTp_pId() .append(&TP_udhi=+sr.getTp_udhi() .append(&Msg:=+bin2hex(sr.getMsg() .append(&LinkID=+sr.getLinkID() .append(&ItemType=+sr.getItemType()+rn); writer.write(sb.toString(); writer.flush(); SmsMain.list.remove(sr); /接受回应 received(); catch (IOException e) e.printStackTrace(); private void received() try String line = reader.readLine();/ Received received = new Received(line);/ received.parse();System.out.println(line);SmsM(line); catch (IOException e) e.printStackTrace(); /* * 字符串转换成十六进制值 * param bin String 转换成十六进制的字符串 * return */ public static String bin2hex(String bin) char digital = 0123456789ABCDEF.toCharArray();