Java的Socket通信完整实例(心跳包,客户端断线重连,服务端超时断开客户端连接)的客户端和服务端

时间: 2023-11-03 11:04:15 浏览: 43
好的,下面是 Java Socket 通信的完整实例,包含心跳包、客户端断线重连和服务端超时断开客户端连接的实现。 服务端代码: ```java import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class Server { private static final int PORT = 8888; private static final int TIMEOUT = 5000; // 服务端超时时间 private static final String HEARTBEAT_MSG = "ping"; // 心跳包内容 private ServerSocket serverSocket; private List<Socket> clientList = new ArrayList<>(); private ExecutorService executorService = Executors.newCachedThreadPool(); public Server() { try { serverSocket = new ServerSocket(PORT); System.out.println("服务端已启动,监听端口:" + PORT); while (true) { Socket socket = serverSocket.accept(); clientList.add(socket); executorService.execute(new ClientHandler(socket)); } } catch (IOException e) { e.printStackTrace(); } } private class ClientHandler implements Runnable { private Socket socket; private OutputStream outputStream; public ClientHandler(Socket socket) { this.socket = socket; try { outputStream = socket.getOutputStream(); } catch (IOException e) { e.printStackTrace(); } } @Override public void run() { try { InputStream inputStream = socket.getInputStream(); byte[] buffer = new byte[1024]; int len; boolean isRunning = true; long lastReceiveTime = System.currentTimeMillis(); while (isRunning) { // 接收数据 if ((len = inputStream.read(buffer)) != -1) { String receiveMsg = new String(buffer, 0, len); System.out.println("服务端接收到消息:" + receiveMsg); if (HEARTBEAT_MSG.equals(receiveMsg)) { // 心跳包消息 outputStream.write(HEARTBEAT_MSG.getBytes()); // 返回心跳包 outputStream.flush(); } else { // 处理业务逻辑 // ... } lastReceiveTime = System.currentTimeMillis(); // 更新最后接收时间 } // 判断客户端是否断开连接 if (System.currentTimeMillis() - lastReceiveTime > TIMEOUT) { System.out.println("客户端超时未发送消息,断开连接:" + socket.getInetAddress().getHostAddress()); isRunning = false; } // 等待一段时间再次接收数据 Thread.sleep(1000); } // 关闭连接 inputStream.close(); outputStream.close(); socket.close(); clientList.remove(socket); } catch (IOException | InterruptedException e) { e.printStackTrace(); } } } public static void main(String[] args) { new Server(); } } ``` 客户端代码: ```java import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.Socket; public class Client { private static final String SERVER_IP = "127.0.0.1"; private static final int SERVER_PORT = 8888; private static final int HEARTBEAT_INTERVAL = 3000; // 心跳包发送间隔 private static final int RECONNECT_INTERVAL = 5000; // 断线重连间隔 private static final String HEARTBEAT_MSG = "ping"; // 心跳包内容 private Socket socket; private OutputStream outputStream; private InputStream inputStream; public Client() { try { // 第一次连接 connect(); // 循环发送心跳包 new Thread(() -> { while (true) { try { Thread.sleep(HEARTBEAT_INTERVAL); if (socket != null && socket.isConnected()) { outputStream.write(HEARTBEAT_MSG.getBytes()); outputStream.flush(); } } catch (IOException | InterruptedException e) { e.printStackTrace(); } } }).start(); while (true) { // 接收数据 byte[] buffer = new byte[1024]; int len; if ((len = inputStream.read(buffer)) != -1) { String receiveMsg = new String(buffer, 0, len); System.out.println("客户端接收到消息:" + receiveMsg); } // 等待一段时间再次接收数据 Thread.sleep(1000); } } catch (IOException | InterruptedException e) { e.printStackTrace(); } } private void connect() { try { socket = new Socket(SERVER_IP, SERVER_PORT); outputStream = socket.getOutputStream(); inputStream = socket.getInputStream(); System.out.println("连接服务器成功:" + SERVER_IP + ":" + SERVER_PORT); } catch (IOException e) { System.out.println("连接服务器失败,5秒后重试:" + SERVER_IP + ":" + SERVER_PORT); try { Thread.sleep(RECONNECT_INTERVAL); } catch (InterruptedException ex) { ex.printStackTrace(); } connect(); // 断线重连 } } public static void main(String[] args) { new Client(); } } ``` 这个例子实现了基本的 Socket 通信,并且加入了心跳包、客户端断线重连和服务端超时断开客户端连接的功能。其中,心跳包的发送和接收是在两个线程中分别实现的。客户端发送心跳包的间隔为 3 秒,服务端超时时间为 5 秒,客户端断线重连的间隔为 5 秒。

相关推荐

最新推荐

recommend-type

Java基于socket实现的客户端和服务端通信功能完整实例

主要介绍了Java基于socket实现的客户端和服务端通信功能,结合完整实例形式分析了Java使用socket建立客户端与服务器端连接与通信功能,需要的朋友可以参考下
recommend-type

详解C# Socket简单例子(服务器与客户端通信)

主要介绍了详解C# Socket简单例子(服务器与客户端通信) ,具有一定的参考价值,感兴趣的小伙伴们可以参考一下。
recommend-type

python服务器与android客户端socket通信实例

主要介绍了python服务器与android客户端socket通信的实现方法,实例形式详细讲述了Python的服务器端实现原理与方法,以及对应的Android客户端实现方法,需要的朋友可以参考下
recommend-type

python网络编程socket实现服务端、客户端操作详解

主要介绍了python网络编程socket实现服务端、客户端操作,结合实例形式分析了python基于socket实现服务端、客户端相关操作技巧与使用注意事项,需要的朋友可以参考下
recommend-type

python使用socket创建tcp服务器和客户端

主要为大家详细介绍了python使用socket创建tcp服务器和客户端,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
recommend-type

zigbee-cluster-library-specification

最新的zigbee-cluster-library-specification说明文档。
recommend-type

管理建模和仿真的文件

管理Boualem Benatallah引用此版本:布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学,1996年。法语。NNT:电话:00345357HAL ID:电话:00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆,用于存放和传播科学研究论文,无论它们是否被公开。论文可以来自法国或国外的教学和研究机构,也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire
recommend-type

实现实时数据湖架构:Kafka与Hive集成

![实现实时数据湖架构:Kafka与Hive集成](https://img-blog.csdnimg.cn/img_convert/10eb2e6972b3b6086286fc64c0b3ee41.jpeg) # 1. 实时数据湖架构概述** 实时数据湖是一种现代数据管理架构,它允许企业以低延迟的方式收集、存储和处理大量数据。与传统数据仓库不同,实时数据湖不依赖于预先定义的模式,而是采用灵活的架构,可以处理各种数据类型和格式。这种架构为企业提供了以下优势: - **实时洞察:**实时数据湖允许企业访问最新的数据,从而做出更明智的决策。 - **数据民主化:**实时数据湖使各种利益相关者都可
recommend-type

云原生架构与soa架构区别?

云原生架构和SOA架构是两种不同的架构模式,主要有以下区别: 1. 设计理念不同: 云原生架构的设计理念是“设计为云”,注重应用程序的可移植性、可伸缩性、弹性和高可用性等特点。而SOA架构的设计理念是“面向服务”,注重实现业务逻辑的解耦和复用,提高系统的灵活性和可维护性。 2. 技术实现不同: 云原生架构的实现技术包括Docker、Kubernetes、Service Mesh等,注重容器化、自动化、微服务等技术。而SOA架构的实现技术包括Web Services、消息队列等,注重服务化、异步通信等技术。 3. 应用场景不同: 云原生架构适用于云计算环境下的应用场景,如容器化部署、微服务
recommend-type

JSBSim Reference Manual

JSBSim参考手册,其中包含JSBSim简介,JSBSim配置文件xml的编写语法,编程手册以及一些应用实例等。其中有部分内容还没有写完,估计有生之年很难看到完整版了,但是内容还是很有参考价值的。