最近在写Socket客户端的时候遇到点问题

客户端在创建时创建了2个线程

一个监听键盘输入事件，使用的是buffered，当检测到输入完成时写入流发送给服务端。

String content = "";

while (!(content = bufferedReader.readLine()).equals("exit")) {

byte[] type= new byte[1];

type[0] = Const.Message;

byte[] bytes = EncodeKit.encode(type, content);

outputStream.write(bytes);

outputStream.flush();

}

一个while循环不停发送心跳包

一个while循环接收服务端发回来的消息

现在的问题是我想在客户端知道服务端返回消息的时间有没超过规定时间，如果有则判定该连接已断开。

问题是接收消息的线程和发送心跳的线程是分开的？我如何知道当这条消息发送过去后服务端返回的消息有没有

超过指定时间？

总感觉我的设计有问题，但又不知道如何实现，求解答。

ps:使用三个线程的原因是线程读取方法是阻塞方法，如果在发送心跳的while循环中再写一个接收消息的方法，那么

就会一直执行这个接收消息的方法，没办法再发送心跳了。

发送心跳代码：

outputStream = socket.getOutputStream();

inputStream = socket.getInputStream();

while (true) {

Thread.sleep(time);//设置心跳间隔时间

byte[] type = new byte[1];

type[0] = Const.HEART;

byte[] bytes = EncodeKit.encode(type, "");

//发送心跳包

outputStream.write(bytes);

outputStream.flush();