
























直接上代码
public static void main(String[] args) { // 启动心跳定时器,每分钟发送一次握手请求 Timer timer = new Timer(); timer.scheduleAtFixedRate(new TimerTask() { @Override public void run() { //client.send("握手请求"); //logger.info("发送:握手请求"); } }, 0, 60000); // 添加关闭钩子 Runtime.getRuntime().addShutdownHook(new Thread(() -> { logger.info("[ShPbxClient][信息] 收到停止信号,准备优雅退出..."); timer.cancel(); if (zmqClient != null) { zmqClient.close(); } if (audioReceiver != null) { audioReceiver.close();//收消息 内存录音 } if (audioSender != null) { audioSender.close();//发消息 内存放音 } })); logger.info("ZeroMQ 客服端已启动,等待接收服务器消息..."); logger.info("ZeroMQ 音频流接收器已启动,等待接收音频数据..."); }
此内容由惯性聚合(RSS阅读器)自动聚合整理,仅供阅读参考。 原文来自 — 版权归原作者所有。