Java心跳检测机制

news2024/11/25 2:39:52

版权声明

  • 本文原创作者：谷哥的小弟
  • 作者博客地址：http://blog.csdn.net/lfdfhl

在这里插入图片描述

心跳检测的定义

心跳检测是一种监控机制，在Java编程和分布式系统中具有广泛的应用。心跳检测，顾名思义，就像心跳一样，是一种周期性的信号或消息发送机制。在计算机系统或网络通信中，它通常用于检测系统组件、网络连接或远程节点的状态和可用性。

心跳检测的应用场景

心跳检测在多种场景下都有广泛的应用。例如，多线程编程中的线程活动监测、分布式系统中的节点状态检测、网络通信中的连接保持与检测以及设备状态监控等多个方面。这些应用场景都充分利用了心跳检测技术的优势，以确保系统的稳定性、可靠性和实时性。

  • 1、多线程编程中的线程活动监测
    在多线程编程环境中，心跳检测机制可用于监控线程的运行状态和活动情况。通过定时发送心跳信号，可以检测线程是否正常运行，是否出现卡死或无限循环等问题。这有助于及时发现并处理线程故障，确保程序的稳定性和可靠性。

  • 2、分布式系统中的节点状态检测
    在分布式系统中，各个节点之间需要保持通信以协同完成任务。心跳检测在这里扮演着至关重要的角色，通过周期性地发送心跳信号，可以检测各个节点的状态和可用性。例如，Cassandra、HBase等分布式数据库就采用了心跳检测机制来确保集群中各个节点的健康状态。例如，Cassandra和HBase等分布式数据库系统利用心跳检测机制来确保集群中各个节点的健康状态。这些系统通过节点之间定期交换心跳信号，来确认彼此的运行状态和数据同步情况，从而保障数据的一致性和高可用性。
    类似地，在微服务架构中，如Kubernetes等容器编排平台也利用心跳检测来监控节点和Pod的状态，确保服务的高可用性。

  • 3、网络通信中的连接保持与检测：
    在网络通信领域，心跳检测被广泛应用于保持连接的活跃状态并检测连接的可用性。对于需要长时间保持的连接，如IM系统、推送服务等，心跳检测可以确保连接的稳定性和实时性。通过定时发送心跳数据包，可以及时发现网络异常或连接中断，并采取相应的恢复措施。

  • 4、设备状态监控：
    在物联网(IoT)应用中，设备通常通过心跳信号向服务器汇报自己的状态。例如，智能家居设备会定期发送心跳信号以告知服务器其在线情况和运行状态。这种机制有助于服务器及时了解并管理设备的状态，提供更好的用户体验和服务质量。例如，在智能家居领域中智能家居设备，如智能灯泡、智能插座等，通过心跳信号定期向云端服务器汇报自己的工作状态和环境数据。这样，用户可以通过手机应用或智能音箱等控制方式，实时了解家中设备的状态，并进行远程控制。

  • 5、健康监测设备中的数据同步：
    可穿戴健康监测设备，如智能手环或手表，通过心跳信号与手机应用或云端服务器进行数据同步。这些设备会定期发送包含用户健康数据的心跳包，以确保数据的实时性和准确性。同时，服务器也可以通过心跳检测机制来判断设备是否在线，以便及时推送相关健康建议或提醒。

  • 6、长连接应用中的连接保持
    在需要保持长时间连接的应用中，如在线聊天室或实时数据推送服务，心跳检测用于确认客户端与服务器的连接状态。心跳包由客户端定期发送给服务器，不仅确认客户端的在线状态，还帮助服务器判断哪些客户端仍活跃，从而合理分配资源。心跳包的发送频率需根据应用需求和网络环境精确设定，以避免不必要的网络负担并确保及时检测断开连接。服务器通常会响应心跳包以确认连接的稳定性，或在某些情况下仅记录接收情况。若服务器在预定时间内未收到心跳包，则会视为客户端断开连接，进而执行关闭连接、释放资源等操作。在实际应用中，开发者还需根据网络状况、服务器负载等因素对心跳检测机制进行灵活调整，以平衡网络开销与连接稳定性的需求。这种机制确保了长连接应用的顺畅运行，同时也要求开发者对心跳包的大小、发送间隔等参数进行精细调整，以实现最佳的性能和资源利用率。。

心跳检测的原理

定时发送心跳信号：在Java编程中，可以通过定时任务（如使用ScheduledExecutorService）来周期性地发送心跳信号。这种信号可以是一个简单的数据包、消息或特定的方法调用，用于表明发送方（如一个线程、进程或服务器）仍然处于活动状态。接收方会监控这些心跳信号的到达。如果在预定的时间间隔内没有收到心跳信号，接收方可能会认为发送方已经出现故障或不可达。一旦检测到心跳信号缺失，接收方可以采取一系列措施，如重新连接、报告错误、触发警报或进行故障转移等。

心跳检测的实现方式

在Java中，实现心跳检测的技术手段多种多样，常见的有如下三种。

  • 1、使用ScheduledExecutorService创建定时任务：Java提供的一个强大工具，用于在指定的时间间隔内重复执行任务。通过它，可以轻松实现心跳信号的周期性发送。
  • 2、Socket通信：在分布式系统或网络通信中，可以使用Socket来发送和接收心跳消息。通过Socket，一个节点可以定期向另一个节点发送数据包作为心跳信号，并等待响应。
  • 3、应用层协议设计：在某些复杂的系统中，可能会设计专门的应用层协议来支持心跳检测。这些协议通常包括特定的消息格式和交互规则，以确保心跳信号的准确传递和处理。

心跳检测示例

ServerEchoHeartbeat

在这里插入图片描述

package com.cn;

import java.io.*;
import java.net.Socket;
/**
 * 本文作者：谷哥的小弟
 * 博客地址：http://blog.csdn.net/lfdfhl
 */
public class ServerEchoHeartbeat implements Runnable{
    private final Socket clientSocket;

    public ServerEchoHeartbeat(Socket socket) {
        this.clientSocket = socket;
    }

    @Override
    public void run() {
        try {
            InputStream inputStream = clientSocket.getInputStream();
            InputStreamReader inputStreamReader = new InputStreamReader(inputStream);
            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
            OutputStream outputStream = clientSocket.getOutputStream();
            PrintWriter printWriter = new PrintWriter(outputStream, true);
            String line;
            while ((line = bufferedReader.readLine()) != null) {
                System.out.println("Received message: " + line);
                // Echo the message back to the client
                printWriter.println(line);
            }
        } catch (IOException e) {
            System.err.println("Exception caught when handling client: " + e);
        } finally {
            try {
                if (clientSocket != null) {
                    clientSocket.close();
                }
            } catch (IOException e) {
                System.err.println("Failed to close client socket: " + e);
            }
        }
    }
}

Server

在这里插入图片描述

package com.cn;

import java.io.*;
import java.net.*;
/**
 * 本文作者：谷哥的小弟
 * 博客地址：http://blog.csdn.net/lfdfhl
 */
public class Server {
    public static void main(String[] args) throws IOException {
        final int port = 8080;
        ServerSocket serverSocket = new ServerSocket(port);
        System.out.println("Server is running on port " + port);
        while (true) {
            Socket clientSocket = serverSocket.accept();
            ServerEchoHeartbeat serverEchoHeartbeat = new ServerEchoHeartbeat(clientSocket);
            Thread thread = new Thread(serverEchoHeartbeat);
            thread.start();
        }
    }

}

ClientHeartbeatTask

在这里插入图片描述

package com.cn;

import java.io.IOException;
import java.io.OutputStream;
/**
 * 本文作者：谷哥的小弟
 * 博客地址：http://blog.csdn.net/lfdfhl
 */
public class ClientHeartbeatTask implements Runnable {
  private OutputStream outputStream;

    public ClientHeartbeatTask(OutputStream outputStream) {
        this.outputStream = outputStream;
    }

    @Override
    public void run() {
        try {
            String heartbeatMessage = "HEARTBEAT";
            outputStream.write((heartbeatMessage+ "\n").getBytes());
            outputStream.flush();
            System.out.println("Sent heartbeat message at " + System.currentTimeMillis());
        } catch (IOException e) {
            System.err.println("Error sending heartbeat: " + e.getMessage());
            //处理连接断开的情况，比如尝试重连等
        }
    }
}

Client

在这里插入图片描述

package com.cn;

import java.io.OutputStream;
import java.net.Socket;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
/**
 * 本文作者：谷哥的小弟
 * 博客地址：http://blog.csdn.net/lfdfhl
 */
public class Client {
    private static final String SERVER_ADDRESS = "localhost";
    private static final int SERVER_PORT = 8080;
    // 发送心跳的间隔时间（秒）
    private static final int HEARTBEAT_INTERVAL = 5;
    private static Socket socket;
    private static OutputStream outputStream;
    private static ScheduledExecutorService executor;

    public static void main(String[] args) {
        try {
            socket = new Socket(SERVER_ADDRESS, SERVER_PORT);
            System.out.println("Connected to the server.");
            executor = Executors.newScheduledThreadPool(1);
            outputStream =socket.getOutputStream();
            ClientHeartbeatTask heartbeatTask = new ClientHeartbeatTask(outputStream);
            executor.scheduleAtFixedRate(heartbeatTask, 0, HEARTBEAT_INTERVAL, TimeUnit.SECONDS);
            // 模拟主程序持续运行，直到外部中断
            Thread.sleep(Long.MAX_VALUE);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try{
                if (outputStream != null) {
                    outputStream.close();
                }
                if (socket != null && !socket.isClosed()) {
                    socket.close();
                }
                if (executor != null && !executor.isShutdown()) {
                    executor.shutdownNow();
                }
            }catch (Exception e){
                System.out.println(e);
            }

        }
    }
}

测试

在这里插入图片描述

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1803861.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

计算机网络-数制转换与子网划分

计算机网络-数制转换与子网划分

目录 一、了解数制 1、计算机的数制 2、二进制 3、八进制 4、十进制 5、十六进制 二、数制转换 1、二进制转十进制 2、八进制转十进制 3、十六进制转十进制 4、十进制转二进制 5、十进制转八进制 6、十进制转十六进制 三、子网划分 1、IP地址定义 2、IP的两种协…
阅读更多...
【二】线控底盘

【二】线控底盘

GB/T 43947-2024 低速线控底盘通用技术要求 线控协议 转向 功能子功能信号描述性能要求分辨率线控转向功能转向控制使能人工切自驾标志位上升沿0-1,有效-线控转向功能转向控制电机输出转向轴的转角。目标方向盘转角范围(deg) -500~500，右负，左正响应延…
阅读更多...
easyexcel将csv转为excel处理数字问题

easyexcel将csv转为excel处理数字问题

使用easyexcel可以将csv格式的文件转为.xlsx文件，但是csv中有很多数字，比如："123","12.34","-111"，默认情况下会将其作为字符串写入.xlsx文件，就如同下面一样，字符类型的数字…
阅读更多...
transformers 阅读：BERT 模型

transformers 阅读：BERT 模型

前言 想深入理解 BERT 模型&#xff0c;在阅读 transformers 库同时记录一下。 笔者小白&#xff0c;错误的地方请不吝指出。 Embedding 为了使 BERT 能处理大量下游任务&#xff0c;它的输入可以明确表示单一句子或句子对&#xff0c;例如<问题&#xff0c;答案>。 …
阅读更多...
单元测试之CppTest测试框架

单元测试之CppTest测试框架

目录 1 背景2 设计3 实现4 使用4.1 主函数4.2 测试用例4.2.1 定义4.2.2 实现 4.3 运行 1 背景 前面文章CppTest实战演示中讲述如何使用CppTest库。其主函数如下&#xff1a; int main(int argc, char *argv[]) {Test::Suite mainSuite;Test::TextOutput output(Test::TextOut…
阅读更多...
Vue.js ECharts使用

Vue.js ECharts使用

一、介绍 ECharts 是一个使用 JavaScript 实现的开源可视化库&#xff0c;涵盖各行业图表&#xff0c;满足各种需求。ECharts 提供了丰富的图表类型和交互能力&#xff0c;使用户能够通过简单的配置生成各种各样的图表&#xff0c;包括但不限于折线图、柱状图、散点图、饼图、雷…
阅读更多...
【Java毕业设计】基于JavaWeb的洗衣店管理系统

【Java毕业设计】基于JavaWeb的洗衣店管理系统

文章目录 摘要ABSTRACT目 录1 概述1.1 研究背景及意义1.2 国内外研究现状1.3 拟研究内容1.4 系统开发技术1.4.1 SpringBoot框架1.4.2 MySQL数据库1.4.3 MVC模式 2 系统需求分析2.1 可行性分析2.2 功能需求分析 3 系统设计3.1 功能模块设计3.2 系统流程设计3.3 数据库设计3.3.1 …
阅读更多...
[每周一更]-(第100期)：介绍 goctl自动生成代码

[每周一更]-(第100期)：介绍 goctl自动生成代码

​ 在自己组件库中&#xff0c;由于部分设计会存在重复引用各个模板的文件&#xff0c;并且基础架构中需要基础模块内容&#xff0c;就想到自动生成代码模板&#xff0c;刚好之前有使用过goctl&#xff0c;以下就简单描述下gozero中goctl场景和逻辑&#xff0c;后续自己借鉴将自…
阅读更多...
【uni-app】申请高德地图key，封装map.js，实现H5、iOS、Android通过getlocation获取地图定位信息

【uni-app】申请高德地图key，封装map.js，实现H5、iOS、Android通过getlocation获取地图定位信息

文章目录 map组件基础使用封装map.js&#xff0c;实现定位1、使用第三方地图&#xff1a;高德&#xff0c;申请对应平台key1、申请H5 key2、申请微信小程序 key3、申请android key查看证书详情&#xff0c;可以看到SHA1查看/设置Android包名 4、申请ios key 2、封装map1、lib/m…
阅读更多...
【阿里YYDS】通义千问正式开源 Qwen2

【阿里YYDS】通义千问正式开源 Qwen2

Qwen2–72B正式开源&#xff0c;性能全面超越开源模型Llama3-70B&#xff0c;也超过文心4.0、豆包pro、混元pro等众多中国闭源大模型。 在过去一段时间里&#xff0c;Qwen系列模型从Qwen1.5升级到Qwen2&#xff0c;Qwen2分5个尺寸&#xff0c;包括Qwen2-0.5B、Qwen2-1.5B、Qwen…
阅读更多...
启动信息全掌握，Android 15 重磅 API：ApplicationStartInfo

启动信息全掌握，Android 15 重磅 API：ApplicationStartInfo

前言 App 进程启动的时候&#xff0c;开发者很难获悉到本次启动的详细信息&#xff0c;比如&#xff1a; 是冷启动的、暖启动的、还是热启动的&#xff1f;是被 Broadcast 拉起来的、Activity 拉起来的、还是 ContentProvider 拉起来的&#xff1f; 针对这些 pain-points&am…
阅读更多...
ssm物流管理系统-计算机毕业设计源码44323

ssm物流管理系统-计算机毕业设计源码44323

摘 要 科技进步的飞速发展引起人们日常生活的巨大变化&#xff0c;电子信息技术的飞速发展使得电子信息技术的各个领域的应用水平得到普及和应用。信息时代的到来已成为不可阻挡的时尚潮流&#xff0c;人类发展的历史正进入一个新时代。在现实运用中&#xff0c;应用软件的工作…
阅读更多...
解决：DevToolsActivePort file doesn‘t exist的问题

解决：DevToolsActivePort file doesn‘t exist的问题

DevToolsActivePort file doesn’t exist 报错信息&#xff1a;解决办法&#xff1a;直接把sandbox禁用了。 chromeOptions.addArguments("--headless"); //设置为 headless 模式 chromeOptions.addArguments("--disable-gpu");//谷歌文档提到需要加上这…
阅读更多...
代码随想录算法训练营第二十二天

代码随想录算法训练营第二十二天

题目&#xff1a;216. 组合总和 III 这道题和上道题非常类似&#xff0c;大体框架一样只不过修改一下终止条件而已 值得注意的是其中的剪枝条件的设置 一是靠现有的元素和已经大于目标和的话就提前终止&#xff0c;另一个是其中循环那个剪枝可以记住 i < n - (k - path.s…
阅读更多...
二开版微交易系统

二开版微交易系统

下载地址&#xff1a;二开版微交易系统
阅读更多...
Dockerfille解析

Dockerfille解析

用于构建Docker镜像的文本&#xff0c;由一条条指令构成 Docker执行Dockerfile的流程 1. Docker从基础镜像执行一个容器 2. 执行一条指令并对容器进行修改 3. 执行类型Docker commit的命令添加一个新的镜像层 4. Docker再基于新的镜像执行一个新的容器 5. 执行Dockerfile中…
阅读更多...
C语言 | Leetcode C语言题解之第132题分割回文串II

C语言 | Leetcode C语言题解之第132题分割回文串II

题目&#xff1a; 题解&#xff1a; int minCut(char* s) {int n strlen(s);bool g[n][n];memset(g, 1, sizeof(g));for (int i n - 1; i > 0; --i) {for (int j i 1; j < n; j) {g[i][j] (s[i] s[j]) && g[i 1][j - 1];}}int f[n];for (int i 0; i <…
阅读更多...
关于修改Python中pip默认安装路径的终极方法

关于修改Python中pip默认安装路径的终极方法

别想了&#xff0c;终极方法就是手动复制&#xff0c;不过我可以给你参考一下手动复制的方法 关于手动移动pip安装包的方法 别想了&#xff0c;终极方法就是手动复制&#xff0c;不过我可以给你参考一下手动复制的方法一、首先确认一下pip默认安装路径二、再确认一下需要移动到…
阅读更多...
SAP HCM OPT函数作用

SAP HCM OPT函数作用

导读 INTRODUCTION OPT函数&#xff1a;SAP HCM工资核算是很多函数的汇总集&#xff0c;原有有兴趣问过SAP的人为什么SCHEMA需要这样设计&#xff0c;SAP的人说是用汇编的逻辑设计的&#xff0c;当时是尽可能用机器语言加速速度读取&#xff0c;每个函数都有对应的业务逻辑代码…
阅读更多...
flutter 错误解决： Android sdkmanager tool was found, but failed to run （

flutter 错误解决： Android sdkmanager tool was found, but failed to run （

最好的方式&#xff1a;亲测成功了 点击我查看
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023