docker里Java服务执行ping命令模拟流式输出

news2024/11/23 11:21:18

文章目录

    • 业务场景
    • 处理解决
      • 实现ping功能并实时返回输出
      • 实现长ping和中断请求
      • docker容器找不到ping命令处理

业务场景

  • 我们某市的客户，一直使用CS版本的信控平台，直接安装客户Windows server服务器上，主要对信号机设备进行在线管理、方案配时、管控等
  • 其中有一项功能，在网络波动情况，对信号机管控失败，判断信号机是否在线。大致方法是直接调用Windows的dos窗口，发送 ping ip的命令，显示网络情况
  • 我们新的信控平台使用Spring Cloud微服务架构，使用Spring Boot构建Java服务，使用google的jib插件打成docker镜像包
  • 我们使用docker虚拟化部署，使用docker-compose统一管理所有服务，部署在Linux服务器里
  • 客户很喜欢之前的功能，需要我们在新平台里实现这个功能，调用dos窗口，ping网络
  • 而我们新平台是B/S架构，浏览器是很难调用Windows组件去弹出窗口实现ping功能，而且我们也没有限制一定使用的是Windows电脑访问，有网有浏览器就行
  • ping功能无论Windows还是Linux，都是有的，至于界面展现，只能自己实现了
    在这里插入图片描述

处理解决

实现ping功能并实时返回输出

  • 代码实现，有两个核心功能点
  • 一是根据不同的操作系统，执行对应的系统命令，进行结果接收与解析
    • 对于第一个问题，Java有现成的类库，使用Runtime.getRuntime().exec(ping命令)即可
    • 对于Windows服务器，需要使用GB2312解析命令执行结果
    • 对于Linux 服务器，需要使用UTF_8解析命令执行结果
    • 对于ServletOutputStream.println输出中文字符串报错Not an ISO 8859-1 character问题，可以使用PrintWriter.println输出代替
    • 也可以在ServletOutputStream.println输出时输出字符数组（string.getBytes()）
  • 二是流式输出到请求端，模拟再现一秒一次的逐步展示的效果
    • 对于第二个问题，核心是命令执行的结果输出流，要实时的返回给请求端，请求端能接收到
    • 主要是获取流，然后按行读取，按行flush()即可返回给请求端
    • 对于请求端实时渲染，需要在代码的response里指定ContentType为text/event-stream，这样flush刷新的返回流，才能实时被前端浏览器接收到（ChatGPT流式输出也是使用的这种content-type）
    • 一开始是考虑使用multipart，完全不行，流flush后，浏览器无法获取，只能在流输出完成后，浏览器才能获取到
  • 具体代码如下：
    /**
     * 获取信号机的网络状态
     * @param ip
     * @param count
     * @param response
     */
    @GetMapping("/ping/start")
    public void ping(String ip, Integer count, HttpServletResponse response) {
        logger.info("ping 信号机【{}】 开始 ......", ip);
        response.setStatus(HttpServletResponse.SC_OK);
        response.setContentType("text/event-stream");
        response.setCharacterEncoding("UTF-8");
        String line = null;
        Process pro = null;
        BufferedReader buf = null;
        try {
            if (null == count) {
                count = 4;
            }
            String osName = System.getProperty("os.name");
            if (osName.toLowerCase().contains("windows")){
                pro = Runtime.getRuntime().exec("ping -n " + count + " " + ip);
                buf = new BufferedReader(new InputStreamReader(pro.getInputStream(), "GB2312"));
            } else if (osName.toLowerCase().contains("linux")){
                pro = Runtime.getRuntime().exec("ping -c " + count + " " + ip);
                buf = new BufferedReader(new InputStreamReader(pro.getInputStream(), StandardCharsets.UTF_8));
            }
            PrintWriter out = response.getWriter();
            while (null != buf && (line = buf.readLine()) != null){
                out.println(line);
                out.flush();
            }
            logger.info("执行ping请求结束!");
            out.close();
        } catch (Exception e){
            logger.error("执行ping命令出现异常");
            e.printStackTrace();
        }finally {
            if (null != pro){
                pro.destroy();
            }
        }
    }

实现长ping和中断请求

  • 主要是在请求时传输一个唯一命令id，缓存到内存里
  • 当命令执行完成，或者接收到打断请求时，调用destroy()打断循环，结束请求
  • 当然，可以尝试使用kill -2去模拟CTRL + C的打断，可以使用Runtime.getRuntime().exec(中断命令)打断试下，我的代码已经满足自己的需求了，就没再尝试，有兴趣的小伙伴可以试一下
  • 具体代码如下：

package com.newatc.api.rest;


import com.newatc.api.signalcontrol.dto.PingRequestVO;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletResponse;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.Map;

/**
 * 调用系统命令并返回
 *
 * @author yanyulin
 * @date 2024-1-16 15:11:55
 */
@RestController
@RequestMapping(value = "/api/syscmd")
public class SysCmdController {

    private static final Logger logger = LoggerFactory.getLogger(SysCmdController.class);

    /**
     * 命令id-执行过程map
     */
    public static final Map<String, Boolean> COMMAND_REQUEST_MAP = new HashMap<>();
    /**
     * 开始信号机的网络状态诊断
     */
    @PostMapping("/ping/start")
    public void ping(@RequestBody PingRequestVO pingRequest, HttpServletResponse response) {
        String ip = pingRequest.getIp();
        String cmdId = pingRequest.getCmdId();
        Integer count = pingRequest.getCount();
        logger.info("ping 信号机【{}】 开始 ......", ip);
        response.setStatus(HttpServletResponse.SC_OK);
        response.setContentType("text/event-stream");
        response.setCharacterEncoding("UTF-8");
        String line = null;
        Process pro = null;
        BufferedReader buf = null;
        try {
            if (null == count) {
                count = 4;
            }
            if (count > 50) {
                count = 50;
            }
            String osName = System.getProperty("os.name");
            if (osName.toLowerCase().contains("windows")){
                pro = Runtime.getRuntime().exec("ping -n " + count + " " + ip);
                buf = new BufferedReader(new InputStreamReader(pro.getInputStream(), "GB2312"));
            } else if (osName.toLowerCase().contains("linux")){
                pro = Runtime.getRuntime().exec("ping -c " + count + " " + ip);
                buf = new BufferedReader(new InputStreamReader(pro.getInputStream(), StandardCharsets.UTF_8));
            }
            COMMAND_REQUEST_MAP.put(cmdId, true);
            PrintWriter out = response.getWriter();
            while (null != buf && (line = buf.readLine()) != null){
                out.println(line);
                out.flush();
                if (!COMMAND_REQUEST_MAP.get(cmdId)) {
                    pro.destroy();
                }
            }
            logger.info("执行ping请求结束!");
            out.close();
        } catch (Exception e){
            logger.error("执行ping命令出现异常");
            e.printStackTrace();
        }finally {
            if (null != pro){
                pro.destroy();
            }
            COMMAND_REQUEST_MAP.remove(cmdId);
        }
    }

    /**
     * 打断命令执行状态
     */
    @PostMapping("/ping/stop")
    public void ping(@RequestBody PingRequestVO requestVO) {
        COMMAND_REQUEST_MAP.put(requestVO.getCmdId(), false);
    }
}

docker容器找不到ping命令处理

  • 我们打包导出的docker镜像，无法使用ping命令，报错，找不到这个命令bash: ping:command not found
  • 我们使用的是极简镜像eclipse-temurin:11-jre-focal，这个版本里的ubuntu没有安装不需要的命令
  • 具体可以参考我的这篇博文：《自制Java镜像发布到dockerhub公网使用》
  • 也可以直接使用我发布到公网的包含ping命令的jre11镜像文件1363241277/jre11:11-jre-focal
  • 主要思路，就是打包使用的原始Java镜像里，要已经安装ping等需要的命令

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

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

相关文章

Windows下安装alipay-sdk-python时，pycrypto安装报错问题处理

Windows下安装alipay-sdk-python时，pycrypto安装报错问题处理

1、安装alipay-sdk-python 时&#xff0c;保存内容如下。 Building wheels for collected packages: pycryptoBuilding wheel for pycrypto (setup.py) ... error error: subprocess-exited-with-error python setup.py bdist_wheel did not run successfully.│ exit c…
阅读更多...
fastJson和jackson的日期数据处理

fastJson和jackson的日期数据处理

目录 1.jackson 2.fastjson 3.总结 1.jackson jackson是spring mvc默认的JSON解析方法&#xff0c;前端的数据序列化处理之后&#xff0c;后端经过反序列化处理可以直接使用实体对象进行接收。后端接口返回实体对象&#xff0c;经过序列化处理后前端可以接收并进行处理。 …
阅读更多...
深度学习：探索人工智能的前沿

深度学习：探索人工智能的前沿

1. 引言 1.1 人工智能的演进 人工智能&#xff08;Artificial Intelligence&#xff0c;简称AI&#xff09;是一门研究如何使计算机能够执行通常需要人类智能的任务的领域。从早期的符号推理到现代的深度学习&#xff0c;人工智能经历了漫长的发展过程。 20世纪50年代&#xff…
阅读更多...
Golang通过Gorm操作Mysql时遇到的datetime时区问题

Golang通过Gorm操作Mysql时遇到的datetime时区问题

情景描述 golang使用Gorm操作MySQL&#xff0c;MySQL中数据类型是datetime&#xff0c;Golang中用的是time.now。 但是会导致存储的时间与北京时间有8h误差&#xff0c; 显然是没有初始化时区导致。 问题修复 初始化设置时区 参考我自己之前写过的一篇总结——Mysql中多种日…
阅读更多...
Qt应用开发(安卓篇)——Hello Qt On Android

Qt应用开发(安卓篇)——Hello Qt On Android

一、前言 这一篇从实际出发&#xff0c;讲述如何创建、编译和部署Qt On Android项目。 二、ADB调试 ADB的全称为Android Debug Bridge&#xff0c;就是起到调试桥的作用&#xff0c;主要用于连接计算机与Android 设备&#xff0c;以便进行调试和数据传输。ADB 可以实现以下主要…
阅读更多...
工作中使用Redis10种场景

工作中使用Redis10种场景

前言 Redis作为一种优秀的基于key/value的缓存&#xff0c;有非常不错的性能和稳定性&#xff0c;无论是在工作中&#xff0c;还是面试中&#xff0c;都经常会出现。 今天这篇文章就跟大家一起聊聊&#xff0c;我在实际工作中使用Redis的10种场景&#xff0c;希望对你会有所帮…
阅读更多...
快速傅里叶变化检测轻微划痕

快速傅里叶变化检测轻微划痕

像这种轻微划痕,普通算法鲁棒性差,通用性也不是很好,通过一些特殊处理,基本上可以满足客户需求. 图像处理,检测无非这个几个步骤. 预处理----分割----筛选—满足设定条件NG read_image (Image, ‘轻微划痕.bmp’) dev_close_window() get_image_size(Image, Width, Height) dev…
阅读更多...
HTTPS：如何确保您的网站数据传输安全？

HTTPS：如何确保您的网站数据传输安全？

目录 博客前言 一.HTTPS 1.1 HTTPS简介 1.2 HTTP和HTTPS区别 1.3 TLS/SSL协议工作原理 1.3.1 TLS/SSL协议结构 1.3.2 SSL/TLS握手协议建立连接过程 1.2.3 SSL/TLS报文分析 博客前言 以下是一个关于HTTPS协议的博客前言示例&#xff1a; 欢迎来到我的博客&#xff0c;今…
阅读更多...
vue 解决el-table 表体数据发生变化时，未重新渲染问题

vue 解决el-table 表体数据发生变化时，未重新渲染问题

效果图父组件中数量改变后总数重新计算 子组件完整代码 <template><el-tableshow-summaryref"multipleTable"v-bind"$props"selection-change"handleSelectionChange"row-click"handleRowClick":summary-method"getSum…
阅读更多...
20230118-【UNITY 学习】增加攀登系统

20230118-【UNITY 学习】增加攀登系统

替换脚本PlayerMovement_04.cs using System.Collections; using System.Collections.Generic; using UnityEngine;public class PlayerMovement_05 : MonoBehaviour {private float moveSpeed; // 玩家移动速度public float walkSpeed 7; // 行走速度public float sprintSpee…
阅读更多...
基于麻雀优化算法SSA的CEEMDAN-BiLSTM-Attention的预测模型

基于麻雀优化算法SSA的CEEMDAN-BiLSTM-Attention的预测模型

往期精彩内容&#xff1a; 时序预测&#xff1a;LSTM、ARIMA、Holt-Winters、SARIMA模型的分析与比较-CSDN博客 风速预测&#xff08;一&#xff09;数据集介绍和预处理-CSDN博客 风速预测&#xff08;二&#xff09;基于Pytorch的EMD-LSTM模型-CSDN博客 风速预测&#xff…
阅读更多...
网络安全 | 苹果承认 GPU 安全漏洞存在，iPhone 12、M2 MacBook Air 等受影响

网络安全 | 苹果承认 GPU 安全漏洞存在，iPhone 12、M2 MacBook Air 等受影响

1 月 17 日消息&#xff0c;苹果公司确认了近期出现的有关 Apple GPU 存在安全漏洞的报告&#xff0c;并承认 iPhone 12 和 M2 MacBook Air 受影响。 该漏洞可能使攻击者窃取由芯片处理的数据&#xff0c;包括与 ChatGPT 的对话内容等隐私信息。 安全研究人员发现&#xff0c;…
阅读更多...
论文阅读：Vary论文阅读笔记

论文阅读：Vary论文阅读笔记

目录 引言整体结构图数据集构造Vary-tiny部分Document Data数据构造Chart Data构造Negative natural image选取 Vary-base部分 引言 论文&#xff1a;Vary: Scaling up the Vision Vocabulary for Large Vision-Language Models Paper | Github | Demo 许久不精读论文了&#x…
阅读更多...
基于Harris角点的多视角图像全景拼接算法matlab仿真

基于Harris角点的多视角图像全景拼接算法matlab仿真

目录 1.算法运行效果图预览 2.算法运行软件版本 3.部分核心程序 4.算法理论概述 4.1 Harris角点检测 4.2 图像配准 4.3 图像变换和拼接 4.4 全景图像优化 5.算法完整程序工程 1.算法运行效果图预览 2.算法运行软件版本 matlab2022a 3.部分核心程序 function [ImageB…
阅读更多...
鸿蒙开发-ArkUI框架实战【日历应用 】

鸿蒙开发-ArkUI框架实战【日历应用 】

对于刚刚接触OpenHarmony应用开发的开发者&#xff0c;最快的入门方式就是开发一个简单的应用&#xff0c;下面记录了一个日历应用的开发过程&#xff0c;通过日历应用的开发&#xff0c;来熟悉基本图形的绘制&#xff0c;ArkUI的组件的使用&#xff0c;UI组件生命周期&#xf…
阅读更多...
新版AndroidStudio dependencyResolutionManagement出错

新版AndroidStudio dependencyResolutionManagement出错

在新版AndroidStudio中想像使用4.2版本或者4.3版本的AndroidStudio来构造项目&#xff1f;那下面这些坑我们就需要来避免了&#xff0c;否则会出各种各样的问题。 一.我们先来看看新旧两个版本的不同。 1.jdk版本的不同 新版默认是jdk17 旧版默认是jdk8 所以在新版AndroidSt…
阅读更多...
什么是SFP光学模块？

什么是SFP光学模块？

SFP光模块是一个十亿位电信号到光信号接口设备&#xff0c;是行业标准的小型可插拔千兆光收发器模块&#xff0c;集成可插拔交换机&#xff0c;路由器和其他网络设备&#xff0c;媒体转换器SFP端口&#xff0c;用于连接到光或铜线数据传输网络&#xff0c;我们通常可以在以太网…
阅读更多...
Numpy的学习 第一课 了解以及使用

Numpy的学习 第一课 了解以及使用

1.输入模式 1.编辑模式 绿色2.命令模式 蓝色 2.运行 直接输入jupyter notebook 3.文档注释 查看函数帮助文档命令 help(函数) 单问号与多问号 单问号显示文档 多问号显示文档代码 3.shifttab 显示参数 4.运行外部文件 %run 路径,可绝对可相对 这里运行了就相当于方法了,或者…
阅读更多...
Python爬虫 - 网易云音乐下载

Python爬虫 - 网易云音乐下载

爬取网易云音乐实战&#xff0c;仅供学习&#xff0c;不可商用&#xff0c;出现问题&#xff0c;概不负责&#xff01; 分为爬取网易云歌单和排行榜单两部分。 因为网页中&#xff0c;只能显示出歌单的前20首歌曲&#xff0c;所以仅支持下载前20首歌曲&#xff08;非VIP音乐&…
阅读更多...
Hamcrest断言：自动化测试的利器

Hamcrest断言：自动化测试的利器

Hamcrest断言&#xff1a;自动化测试中的可读性与表达力利器 背景&#xff1a;在软件开发中&#xff0c;自动化测试是确保软件质量和稳定性的重要环节。为了编写可靠且易于维护的自动化测试脚本&#xff0c;我们需要使用可读性强且表达力强的断言工具。Hamcrest是一个优秀的断言…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023