Java通过socket客户端保持连接服务端实现代码

Java通过Socket客户端与服务端进行通信的过程需要通过以下几个步骤完成：

1. 创建Socket对象：客户端通过创建Socket对象来连接服务端，指定服务端的地址和端口号。

Socket socket = new Socket("服务端IP地址", 端口号);

1. 创建输入流和输出流：创建输入流和输出流来进行数据的读写操作，对于客户端而言，输出流用于向服务端发送数据，输入流用于接收服务端的响应数据。

InputStream is = socket.getInputStream();
OutputStream os = socket.getOutputStream();

1. 发送数据：客户端通过输出流向服务端发送数据，可以将要发送的数据存储在字节数组中。

byte[] bytes = "Hello, server!".getBytes();
os.write(bytes);

1. 接收数据：客户端通过输入流读取服务端的响应数据，也可以将数据读取到字节数组中。

byte[] bytes = new byte[1024];
int len = is.read(bytes);
String response = new String(bytes, 0, len);
System.out.println("服务端的响应数据：" + response);

1. 关闭连接：在使用完Socket对象后需要关闭连接来释放资源，及时进行清理工作。

socket.close();

为了保持连接，客户端需要在合适的时候以合适的方式向服务端发送心跳包。以下是示例代码：

示例一：

客户端通过Socket连接服务端，每10秒向服务端发送一次心跳包，保持连接：

public class Client {
    public static void main(String[] args) throws Exception {
        // 创建客户端Socket
        Socket socket = new Socket("127.0.0.1", 8888);
        // 客户端心跳包内容
        byte[] heartBeatData = "HearBeat".getBytes();

        // 定时发送心跳包
        Timer timer = new Timer();
        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                try {
                    OutputStream os = socket.getOutputStream();
                    os.write(heartBeatData);
                    System.out.println("发送心跳包成功");
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }, 0, 10000); // 每10秒钟发送一次心跳包

        // 关闭Socket连接
        Thread.sleep(100000);
        socket.close();
    }
}

示例二：

客户端通过Socket连接服务端，持续与服务端进行通信，并将服务端的响应输出到控制台：

public class Client {
    public static void main(String[] args) throws Exception {
        Scanner scanner = new Scanner(System.in);
        // 创建Socket连接
        Socket socket = new Socket("127.0.0.1", 8888);

        // 获取输入流和输出流
        InputStream is = socket.getInputStream();
        OutputStream os = socket.getOutputStream();

        while (true) {
            // 从控制台读取要发送的数据
            System.out.println("请输入要发送的数据：");
            String msg = scanner.nextLine();
            byte[] sendBytes = msg.getBytes();
            // 将数据发送给服务端
            os.write(sendBytes);
            os.flush();

            // 从服务端读取响应数据
            byte[] bytes = new byte[1024];
            int len = is.read(bytes);
            String response = new String(bytes, 0, len);
            System.out.println("服务端的响应数据：" + response);
        }

        // 关闭Socket连接
        // socket.close();
    }
}