请问Java中Socket的心跳包如何实现?

Question

最近在做Socket长连接，出现了一些问题，没有什么好的思路，希望能够获得解答。
我现在只做BIO，也就是传统IO，阻塞式操作，目的是为了学习。所以没有用NIO,AIO等。
1.客户端开启两个线程，一个监听控制台输入，并在这个线程中再开启另一个线程监听服务端返回的数据

            new Thread(new ReadContentTask(bufferedReader)).start();//监听服务端返回数据
            bufferedReader = new BufferedReader(new InputStreamReader(System.in));
            String content = "";
            while (!(content = bufferedReader.readLine()).equals("exit")) {
                //增加一个\n，由于服务端读取数据也是使用的readline()方法，该方法只有在识别到\n时会以字符串形式返回这一行的数据
                bufferedWriter.write(content + "\n");
                bufferedWriter.flush();
            }

监听服务端返回数据线程代码：

 @Override
    public void run() {
        try{
            String content = "";
            while((content = bufferedReader.readLine())!=null){
                System.out.println(content);
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try{
                bufferedReader.close();
            }catch (Exception e2){
                e2.printStackTrace();
            }
        }
    }

服务端代码：

bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));//读取客户端消息
            bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));//向客户端写消息
            String lineString = "";
            //new Thread(new ReceiveHeart(socket)).start();       //开启心跳检测线程
            while (!(lineString = bufferedReader.readLine()).equals("quit")) {
                System.out.println("收到来自客户端的发送的消息是：" + lineString);
                bufferedWriter.write("服务器返回：" + lineString + "\n");
                bufferedWriter.flush();
            }

现在的问题是我想做心跳包，该如何设计？
我的想法是比如说客户端再开启一个线程，每隔30秒发送一个为"x"的字节数组给服务端，服务端接收到之后也返回一个个"x"给客户端，并重置心跳时间。如果客户端在一定时间内没收到服务端返回的数据，则判断心跳断开，开启新的线程重连。

我现在做的设计是客户端发送一个字节的数据给服务端，同时客户端在控制台写的数据也发送给服务端，两者走的是同一个socket的inputstream，服务端如何区分收到的消息是心跳消息还是正常消息？

Answer 1

在消息中设置一个位，或者一个字节来表示消息的类型，服务端解析消息后，取出那个字节，根据消息的类型处理。