当前位置：首页 > news >正文

JAVA异步的TCP 通讯-客户端

news 来源：原创 2025/5/13 11:45:42

一、客户端代码示例

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.AsynchronousSocketChannel;
import java.nio.channels.CompletionHandler;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class AdvancedAsyncTCPClient {private static final String SERVER_HOST = "localhost";private static final int SERVER_PORT = 8888;private static final int BUFFER_SIZE = 1024;private final AsynchronousSocketChannel clientChannel;private final ExecutorService threadPool;public AdvancedAsyncTCPClient() throws IOException {// 创建异步套接字通道clientChannel = AsynchronousSocketChannel.open();// 创建一个固定大小的线程池，用于处理业务逻辑threadPool = Executors.newFixedThreadPool(5);}public void connect() {// 异步连接到服务器clientChannel.connect(new InetSocketAddress(SERVER_HOST, SERVER_PORT), null, new CompletionHandler<Void, Void>() {@Overridepublic void completed(Void result, Void attachment) {System.out.println("Connected to server: " + SERVER_HOST + ":" + SERVER_PORT);// 连接成功后开始读取服务器数据startReading();// 发送初始消息sendMessage("Hello, server!");}@Overridepublic void failed(Throwable exc, Void attachment) {System.err.println("Failed to connect to server: " + exc.getMessage());closeChannel();}});}private void startReading() {ByteBuffer buffer = ByteBuffer.allocate(BUFFER_SIZE);// 异步读取服务器数据clientChannel.read(buffer, buffer, new CompletionHandler<Integer, ByteBuffer>() {@Overridepublic void completed(Integer bytesRead, ByteBuffer buffer) {if (bytesRead > 0) {buffer.flip();byte[] data = new byte[buffer.remaining()];buffer.get(data);String message = new String(data);System.out.println("Received message from server: " + message);// 继续读取服务器数据buffer.clear();clientChannel.read(buffer, buffer, this);} else if (bytesRead == -1) {// 服务器关闭连接System.out.println("Server closed the connection");closeChannel();}}@Overridepublic void failed(Throwable exc, ByteBuffer buffer) {System.err.println("Failed to read data from server: " + exc.getMessage());closeChannel();}});}public void sendMessage(String message) {ByteBuffer buffer = ByteBuffer.wrap(message.getBytes());// 异步发送消息到服务器clientChannel.write(buffer, buffer, new CompletionHandler<Integer, ByteBuffer>() {@Overridepublic void completed(Integer bytesWritten, ByteBuffer buffer) {if (buffer.hasRemaining()) {// 如果还有数据未发送完，继续发送clientChannel.write(buffer, buffer, this);} else {System.out.println("Message sent to server: " + message);}}@Overridepublic void failed(Throwable exc, ByteBuffer buffer) {System.err.println("Failed to send message to server: " + exc.getMessage());closeChannel();}});}private void closeChannel() {try {System.out.println("Closing client connection");clientChannel.close();threadPool.shutdown();} catch (IOException e) {System.err.println("Error closing client channel: " + e.getMessage());}}public static void main(String[] args) {try {AdvancedAsyncTCPClient client = new AdvancedAsyncTCPClient();client.connect();} catch (IOException e) {System.err.println("Error creating client: " + e.getMessage());}}
}

二、代码分析

AdvancedAsyncTCPClient 类：

构造函数：创建 AsynchronousSocketChannel 并初始化一个固定大小的线程池
connect() 方法：异步连接到服务器，连接成功后开始读取服务器数据并发送初始消息。
startReading() 方法：异步读取服务器发送的数据，使用 CompletionHandler 处理读取结果。
sendMessage() 方法：异步发送消息到服务器，处理可能的未发送完的数据。
closeChannel() 方法：关闭客户端通道并关闭线程池，处理关闭过程中可能出现的异常。

CompletionHandler：

在 connect()、startReading() 和 sendMessage() 方法中使用 CompletionHandler 来处理异步操作的完成结果。
completed() 方法处理操作成功的情况，failed() 方法处理操作失败的情况。

线程池：

1.使用 Executors.newFixedThreadPool(5) 创建一个固定大小的线程池，用于处理业务逻辑，避免阻塞 I/O 操作。

三、优点

异步 I/O：利用 Java NIO 2 的异步 I/O 特性，提高了客户端的并发处理能力。
线程池：使用线程池处理业务逻辑，减少了线程创建和销毁的开销。
异常处理：对各种异常情况进行了处理，增强了代码的健壮性。
资源管理：在关闭客户端时，正确关闭客户端通道和线程池，避免资源泄漏。

四、注意事项

该示例假设服务器运行在 localhost 的 8888 端口，你可以根据实际情况修改 SERVER_HOST 和 SERVER_PORT。
此代码只是一个基础示例，实际应用中可能需要根据具体需求进行扩展，如处理更复杂的消息格式、实现重连机制等。

JAVA异步的TCP 通讯-客户端

一、客户端代码示例 import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.AsynchronousSocketChannel; import java.nio.channels.CompletionHandler; import java.util.concurrent.ExecutorService; impo…...

编程日记 2025/5/13 11:45:42

4.回归与聚类算法 4.1线性回归

4.1.1 线性回归的原理 1 线性回归应用场景： 房价预测销售额度预测金融：贷款额度预测，利用线性回归以及系数分析因子 2 什么是线性回归 1） 定义：利用回归方程（函数）对一个或者多个自变量…...

编程日记 2025/5/13 14:06:08

联想拯救者开机进入bios

如果你的联想拯救者（Lenovo Legion）笔记本电脑开机后直接进入 BIOS 设置界面，可能是以下原因之一导致的。以下是解决方法： 1. 检查启动顺序进入 BIOS 后，找到 Boot（启动）选项卡。检查启动顺序…...

编程日记 2025/5/9 4:29:18

【贪心算法篇】：“贪心”之旅--算法练习题中的智慧与策略（四）

✨感谢您阅读本篇文章，文章内容是个人学习笔记的整理，如果哪里有误的话还请您指正噢✨ ✨ 个人主页：余辉zmh–CSDN博客 ✨ 文章所属专栏：贪心算法篇–CSDN博客文章目录前言例题1.合并区间2.无重叠的区间3.用最少数量的箭引爆气球…...

编程日记 2025/5/11 15:24:13

Junit5使用教程(3)

第三部分：JUnit 5 进阶 3. 动态测试一、动态测试是什么？ 动态测试（Dynamic Test）允许在运行时生成测试用例，而不是在编译时通过 Test 静态定义。它通过 TestFactory 注解标记的方法动态生成一组测试用例&#xff0…...

编程日记 2025/5/11 4:53:40

WPS中解除工作表密码保护（忘记密码）

1.下载vba插件项目首页 - WPS中如何启用宏附wps.vba.exe下载说明分享:WPS中如何启用宏：附wps.vba.exe下载说明本文将详细介绍如何在WPS中启用宏功能，并提供wps.vba.exe文件的下载说明 - GitCode 并按照步骤安装 2.wps中点击搜索，输入开发…...

编程日记 2025/5/8 5:46:28

通向AGI之路：人工通用智能的技术演进与人类未来

文章目录引言：当机器开始思考一、AGI的本质定义与技术演进1.1 从专用到通用：智能形态的范式转移1.2 AGI发展路线图二、突破AGI的五大技术路径2.1 神经符号整合（Neuro-Symbolic AI）2.2 世界模型架构（World Models）2.3 具身认知理论（Embodied Cognition）三、AGI安全：价…...

编程日记 2025/5/12 23:56:27

kamailio-osp模块

该文档详细讲解了如何在Kamailio中配置和使用OSP模块（Open Settlement Protocol Module），以实现基于ETSI标准的安全多边对等互联（Secure Multi-Lateral Peering）。以下是核心内容的总结： 1. 模块功能 OSP模…...

编程日记 2025/5/13 15:02:32

【Linux网络编程】：URL（encode），HTTP协议，telnet工具

🎁个人主页：我们的五年 🔍系列专栏：Linux网络编程 🌷追光的人，终会万丈光芒 🎉欢迎大家点赞👍评论📝收藏⭐文章 Linux网络编程笔记： https://mp.csdn…...

编程日记 2025/5/11 3:33:29

SpringMVC SpringMVC响应一、数据处理及跳转

1. 结果跳转方式 ①.ModelAndView 设置ModelAndView对象 , 根据view的名称 , 和视图解析器跳到指定的页面 <bean id"templateResolver" class"org.thymeleaf.spring4.templateresolver.SpringResourceTemplateResolver"><property name"p…...

编程日记 2025/5/12 8:02:59

C++SLT（三）——list

目录一、list的介绍二、list的使用list的定义方式三、list的插入和删除push_back和pop_backpush_front和pop_frontinserterase 四、list的迭代器使用五、list的元素获取六、list的大小控制七、list的操作函数sort和reversemergeremoveremove_ifuniqueassignswap 一、list的介…...

编程日记 2025/5/13 7:58:18

基于Coze平台实现抖音链接提取文案转小红书文案的智能体开发全流程解析

文章目录引言：跨平台内容运营的AI解法实例最终效果1. 平台特性对比与转化需求分析1.1 用户画像与内容风格对比1.2 文案转化核心需求2. Coze平台技术架构解析2.1 Coze核心能力矩阵2.2 关键技术组件选型3. 智能体工作流设计3.1 完整处理流程3.2 关键节点说明4. 核心模块实现详解…...

编程日记 2025/5/12 19:09:02

32. 最长有效括号

动态规划 dp[i]表示以i下标为结尾的最长有效括号的长度，取dp[i]中的最大值即可。 i从1开始判断，只有s[i])才需要判断： 如果s[i-1](，那么dp[i]dp[i-2]2，注意判断i-2的范围否则，如果dp[i-1]>0&#xff0…...

编程日记 2025/5/9 2:20:12

Linux常见问题解决方法--2

如何反爬后台对访问进行统计，如果单个 IP 访问超过阈值，予以封锁后台对访问进行统计，如果单个 session 访问超过阈值，予以封锁后台对访问进行统计，如果单个 userAgent 访问超过阈值，予以封锁以上的组…...

编程日记 2025/5/12 17:27:38

STM32H7和F7 主要区别

STM32H7和F7系列是STMicroelectronics推出的高性能ARM Cortex-M微控制器系列，二者在性能、外设和用途上有显著区别。以下是它们的主要区别： 1. 内核与性能 STM32H7： 内核：Cortex-M7（单核或双核，部分型号带…...

编程日记 2025/5/12 6:31:07

软件测试丨PyTorch 图像目标检测

随着人工智能和机器学习的飞速发展，图像目标检测技术在各个领域扮演着越来越重要的角色。无论是在安防监控、自动驾驶车辆，还是在医疗影像分析和智能家居中，图像目标检测都发挥着不可或缺的作用。今天，我们将深入探讨其中一种热门…...

编程日记 2025/5/3 11:57:44

利用TensorFlow.js实现浏览器端机器学习：一个全面指南

引言随着深度学习技术的不断发展，机器学习已从传统的服务器端运算逐渐转向了前端技术。TensorFlow.js 是 Google 推出的一个用于在浏览器中进行机器学习的开源库，它允许开发者在浏览器中直接运行机器学习模型，而无需依赖后端服务器。Tensor…...

编程日记 2025/5/13 12:09:30

全流程安装DeepSeek开源模型

目录安装Ollama选择大模型安装大模型对话备注安装Ollama 安装DeepSeek首先需要安装一个Ollama，这个软件相当于运行DeepSeek模型的底层，没有这个底层就没办法跑DeepSeek AI模型。下载地址： https://ollama.com/点击下载windows版本&…...

编程日记 2025/5/12 15:11:39

VulnHub | Prime - 1

https://vulnhub.com/entry/prime-1,358/https://vulnhub.com/entry/prime-1,358/ 0x01：靶场简介 Prime 1 是 VulHub 中的一台用于 OSCP 考试练习的靶机。通过本靶机，我们可以系统的了解的渗透测试的全流程。本靶机的通关目标如下： Get The…...

编程日记 2025/5/12 4:22:30

实验十 Servlet(一)

实验十 Servlet(一) 【实验目的】 1．了解Servlet运行原理 2．掌握Servlet实现方式【实验内容】 1、参考课堂例子，客户端通过login.jsp发出登录请求，请求提交到loginServlet处理。如果用户名和密码相同则视为登录成功&#xff0c…...

编程日记 2025/5/12 11:27:05

寒假刷题Day22

一、2570. 合并两个二维数组 - 求和法 class Solution { public:vector<vector<int>> mergeArrays(vector<vector<int>>& nums1, vector<vector<int>>& nums2) {int i 0, j 0, n1 nums1.size(), n2 nums2.size();int tmp 0;…...

编程日记 2025/5/11 10:27:27

KES数据库实践指南：探索KES数据库的事务隔离级别

引言前两篇文章我们详细讲解了如何安装KES金仓数据库，并提供了快速查询和搭建基于coze平台的智能体的解决方案。今天，我们的焦点将放在并发控制机制和事务隔离级别上。本文将通过一系列实验操作，深入探讨KES数据库中的并发控制机制和事务…...

编程日记 2025/5/12 9:49:41

基于STM32的智能加湿器设计（新版本）

目录 1、设计要求 2、系统功能 3、演示视频和实物 4、系统设计框图 5、软件设计流程图 6、原理图 7、主程序 8、总结 🤞大家好，这里是5132单片机毕设设计项目分享，今天给大家分享的是加湿器。设备的详细功能见网盘中的文章《12、基于…...

编程日记 2025/5/9 5:11:39

Electricity Market Optimization 探索系列（三）

本文参考链接link 电网容量规划是一个寻求最优发电容量的过程，找到的最优发电容量能够可靠地满足未来电网的需求发电机的容量和发电成本呈正相关关系，一台发电机的发电量不能超过其额定发电容量，结合我之前的博客所说的内容，可…...

编程日记 2025/5/11 11:32:21

JAVA进阶之线程

为神马有线程？这玩意儿在干嘛？？？ 回答这个问题，就先要知道一点点计算机的工作方式。总所周知，计算机有五部分：输入输出、计算器、存储器、控制器。而在计算机内，CPU、内存、I/O之…...

编程日记 2025/5/9 19:50:34

浙江安吉成新照明电器有限公司分布式光伏发电项目--安科瑞Acrel-1000DP分布式光伏监控系统

安科瑞崔丽洁项目背景随着可再生能源的发展，分布式光伏发电成为重要的能源利用方式。浙江安吉成新照明电器有限公司 3234.465kWp 分布式光伏发电项目应运而生。该公司是螺旋节能灯毛管专业生产企业，于 2007 年 6 月成立，具备全自动生产线、…...

编程日记 2025/5/12 15:09:36

pytorch实现主成分分析 (PCA)：用于数据降维和特征提取

人工智能例子汇总：AI常见的算法和例子-CSDN博客使用 PyTorch 实现主成分分析（PCA）可以通过以下步骤进行： 标准化数据：首先，需要对数据进行标准化处理，确保每个特征的均值为 0，方差…...

编程日记 2025/5/9 18:34:11

2025_2_4 C语言中关于free函数及悬空指针，链表的一级指针和二级指指针

1.free函数 free函数所接受的参数只能是动态分配出来的内存，，否者free的行为是未定义的同一片内存空间不能被free两次 free过后的内存可能会引发悬空指针的问题 2.悬空指针悬空指针的问题主要是free过后的内存空间，原先指向这片空间的指…...

编程日记 2025/5/7 21:26:25

pytorch逻辑回归实现垃圾邮件检测

人工智能例子汇总：AI常见的算法和例子-CSDN博客完整代码： import torch import torch.nn as nn import torch.optim as optim from sklearn.feature_extraction.text import TfidfVectorizer from sklearn.model_selection import train_test_split …...

编程日记 2025/3/26 5:06:10

一次线程数超限导致的hive写入hbase作业失败分析

1.集群配置操作系统：SuSe操作系统集群节点：100台相同配置的服务器单台：核心112Core，内存396G 2.问题现象现象1：跑单个入库任务报错，批量提交任务后出现OOM异常执行12个hivesql,将数据写入hbase.hbase入库有近一半的任务报错。每次报错的任务不是同一个，hivesql…...

编程日记 2025/5/13 22:19:20

JAVA安全—反射机制攻击链类对象成员变量方法构造方法

前言还是JAVA安全，哎，真的讲不完，太多啦。今天主要是讲一下JAVA中的反射机制，因为反序列化的利用基本都是要用到这个反射机制，还有一些攻击链条的构造，也会用到，所以就讲一下。什么是反射…...

编程日记 2025/5/13 8:39:31

Java集合面试总结（题目来源JavaGuide）

问题1：说说 List,Set,Map 三者的区别？ 在 Java 中，List、Set 和 Map 是最常用的集合框架（Collection Framework）接口，它们的主要区别如下： 1. List（列表） 特点&#xf…...

编程日记 2025/5/1 0:19:09

【区块链】深入理解椭圆曲线密码学(ECC)

🌈个人主页: 鑫宝Code 🔥热门专栏: 闲话杂谈｜ 炫酷HTML | JavaScript基础 💫个人格言: "如无必要，勿增实体" 文章目录深入理解椭圆曲线密码学(ECC)1. 概述2. 椭圆曲线的数学基础2.1 基本定义2.2 有限…...

编程日记 2025/5/10 0:33:09

接口游标分页

由于数据库本身的的限制（以MySQL为例），以 page_num，page_size 为代表的偏移分页方式不可避免的会遇到深分页问题。不过用户若要找符合条件的少量数据，通过翻页则十分低效，且大多用户也不会往后翻很多页，故对于C端筛选数据场景，限制分页数量增加筛选条件才是标准解决方…...

编程日记 2025/5/13 10:54:28

大数据数仓实战项目（离线数仓+实时数仓）2

目录 1.课程目标和课程内容介绍 2.数仓维度建模设计 3.数仓为什么要分层 4.数仓分层思想和作用 5.数仓中表的种类和同步策略 6.数仓中表字段介绍以及表关系梳理订单表itcast_orders 订单明细表 itcast_order_goods 商品信息表 itcast_goods 店铺表 itcast_shops 商…...

编程日记 2025/5/13 9:24:45

C++输入输出(上)

cin和cout cin是C中提供的标准输入流对象,一般针对的是键盘,也就是从键盘上输入的字符流,使用 cin来进行数据的提取,cin一般是和 >> (流提取运算符) 配合使用的。 cin的功能和scanf是类似的 cout是C中提供的标准输出流对象,一般针对的是控制台的窗口,也就是将数据以字符…...

编程日记 2025/5/13 7:13:18

SpringBoot 连接Elasticsearch带账号密码认证 ES连接加密连接

依赖 <dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-high-level-client</artifactId> </dependency>配置文件 es:ip: 172.23.4.130port: 9200user: elasticpassword: qwertyuiop读取配置文件…...

编程日记 2025/5/7 12:45:55

选择排序

选择排序的基本思想： 每⼀次从待排序的数据元素中选出最⼩（或最⼤）的⼀个元素，存放在序列的起始位置，直到全部待排序的数据元素排完。直接选择排序 1. 在元素集合 array[i]--array[n-1] 中选择关键码最⼤(⼩)的数据…...

编程日记 2025/5/10 1:04:29

Linux——进程概念

目录一、系统调用和库函数概念二、基本概念三、描述进程-PCB3.1 task_struct-PCB的一种3.2 task_ struct内容分类四、组织进程五、查看进程六、通过系统调用获取进程标示符七、通过系统调用创建进程- fork初始7.1 fork函数创建子进程7.2 fork 之后通常要用 if 进行分流八、进…...

编程日记 2025/5/12 7:29:59

强化学习笔记（5）——PPO

PPO视频课程来源首先理解采样期望的转换变量x在p(x)分布下，函数f(x)的期望等于f(x)乘以对应出现概率p(x)的累加经过转换后变成 x在q(x)分布下，f(x)*p(x)/q(x) 的期望。起因是：求最大化回报的期望，所以对ceta求梯度具体举例…...

编程日记 2025/5/12 14:21:38

Java设计模式：行为型模式→状态模式

Java 状态模式详解 1. 定义状态模式（State Pattern）是一种行为型设计模式，它允许对象在内部状态改变时改变其行为。状态模式通过将状态需要的行为封装在不同的状态类中，实现对象行为的动态改变。该模式的核心思想是分离不同状态…...

编程日记 2025/5/12 11:20:01

postgresql的用户、数据库和表

在 PostgreSQL 中，用户、数据库和表是关系型数据库系统的基本组成部分。理解这些概念对数据库管理和操作至关重要。下面是对这些概念的详细解释： 1. 用户（User） 在 PostgreSQL 中，用户（也称为角色&#…...

编程日记 2025/5/13 22:19:15

什么是Rust？它有什么特点？为什么要学习Rust？

什么是Rust？它有什么特点？为什么要学习Rust？ 如果你是一名编程初学者，或者已经有一些编程经验但对Rust感兴趣，那么这篇文章就是为你准备的！我们将用简单易懂的语言，带你了解Rust是什么、它有什…...

编程日记 2025/5/12 14:21:17

Maven（Ⅱ）：依赖范围，依赖传递，依赖阻断，可选依赖

1. Maven 依赖范围概念依赖范围（Dependency Scope）用于控制依赖在不同构建阶段的可见性和可用性。Maven 定义了几种不同的依赖范围，每种范围都有其特定的使用场景。常见依赖范围及用途 compile：默认的依赖范围，…...

编程日记 2025/5/10 12:58:22

个人c项目 java项目解释

1. 测试环境与方法中文： 本地测试环境：可以在一台配置中等的电脑上构建一个测试环境，利用现成的大词库数据（例如英文词典或自定义数据集）来构建 Trie。使用 C 语言的编译器（例如 gcc）编译项目&…...

编程日记 2025/5/5 22:21:02

51单片机看门狗系统

在 STC89C52 单片机中，看门狗控制寄存器的固定地址为 0xE1。此地址由芯片厂商在硬件设计时确定，但是它在头文件中并未给出，因此在使用看门狗系统时需要声明下这个特殊功能寄存器 sfr WDT_CONTR 0xE1; 本案将用一个小灯的工作状况来展示看门…...

编程日记 2025/5/12 18:22:31

爬虫基础（五）爬虫基本原理

目录一、爬虫是什么二、爬虫过程 （1）获取网页 （2）提取信息 （3）保存数据三、爬虫可爬的数据四、爬虫问题一、爬虫是什么互联网，后面有个网字，我们可以把它看成一张蜘蛛网…...

编程日记 2025/5/6 11:25:14

Android 使用ExpandableListView时，需要注意哪些细节

1. 布局属性设置尺寸属性宽度和高度：要合理设置 android:layout_width 和 android:layout_height 属性。如果设置为 match_parent，它会填满父容器；设置为 wrap_content，则会根据内容自动调整大小。例如，若想让 Exp…...

编程日记 2025/5/11 2:00:33

人工智能赋能企业系统架构设计：以ERP与CRM系统为例

一、引言 1.1 研究背景与意义在数字化时代，信息技术飞速发展，人工智能（Artificial Intelligence, AI）作为一项具有变革性的技术，正深刻地影响着各个领域。近年来，AI 在技术上取得了显著突破，…...

编程日记 2025/5/13 0:13:52

使用HttpClient和HttpRequest发送HTTP请求

项目中经常会用到向第三方系统发送请求来传递数据或者获得信息，一般用的比较多的为HttpClient 和 HttpRequest，这里简要总结一下 HttpClient 和 HttpRequest 的用法一、HttpClient 1. 发送get请求 public static String get(String url, Map<Stri…...

编程日记 2025/5/13 10:54:19

一、客户端代码示例

二、代码分析

三、优点

四、注意事项

相关文章：