H5W3
当前位置:H5W3 > 其他技术问题 > 正文

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

最近在做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,服务端如何区分收到的消息是心跳消息还是正常消息?

回答:

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

本文地址:H5W3 » 请问Java中Socket的心跳包如何实现?

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址