TCP Server工具类，BIO阻塞和非阻塞NIO

启动自定义代码的方式

WebServer Initialized Event

	//@Component//ApplicationContext context 注入//@PostConstruct//@Async@EventListener(ApplicationReadyEvent.class)@Componentpublic class TcpServerListener implements ApplicationListener<WebServerInitializedEvent> {@Overridepublic void onApplicationEvent(WebServerInitializedEvent event) {//int serverPort = event.getWebServer().getPort();// 在此处添加代码以创建和启动 TCP 服务器updateServer.startServer(8082);}}

ServerSocket

基本代码

            // 创建ServerSocket并绑定端口ServerSocket serverSocket = new ServerSocket(8080);// 启动一个新线程来接受客户端连接while (true) {try {// 接受客户端连接Socket clientSocket = serverSocket.accept();// 关闭客户端连接clientSocket.close();} catch (IOException e) {e.printStackTrace();}}

DataInputStream

	@PostConstruct@Asyncpublic void startServer() throws Exception {//开启TCP ServerServerSocket serverSocket = new ServerSocket(8082);log.info("服务端打开了 Server started on port {}", 8082);while (true) {//等待连接Socket socket = serverSocket.accept();//获取 输入流DataInputStream inputStream = new DataInputStream(socket.getInputStream());DataOutputStream outputStream = new DataOutputStream(socket.getOutputStream());log.info("服务端收到了连接：Accepted connection from client: {}", socket.getInetAddress());//读取的字节数byte[] buffer = new byte[380];//1024//真正读取到了多少个int bytesRead;//循环进行读取while ((bytesRead = inputStream.read(buffer)) != -1) {//处理二进制数据processBinaryData(buffer, bytesRead, socket, outputStream);}//循环读取，正常每次都会读取完毕inputStream.close();outputStream.close();socket.close();}//死循环接收连接}//初始化方法结束*///关闭输入流//socket.shutdownInput();//关闭输出流，关闭 Socket//socket.shutdownOutput();//关闭Socket//socket.close();

InputStreamReader 字符流

  • BufferedReader(new InputStreamReader(socket.getInputStream()))
  • new PrintWriter(socket.getOutputStream(), true)
public class TcpServer {public static void main(String[] args) {try {//连接ServerSocket serverSocket = new ServerSocket(5555);System.out.println("服务器启动，等待客户端连接...");//阻塞Socket socket = serverSocket.accept();System.out.println("客户端已连接.");//创建 输入流。读取BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));//创建 输出流。写入PrintWriter out = new PrintWriter(socket.getOutputStream(), true);String message = in.readLine();System.out.println("收到客户端消息：" + message);// 解析 JSON 消息// 发送响应给客户端out.println("构建响应 JSON");// 关闭连接socket.close();serverSocket.close();} catch (IOException e) {e.printStackTrace();}}
}

NIO Selector

ServerSocketChannel

@Configuration
public class TcpServerConfig {//@Value("${tcp.ip}")//private String tcpIp;//ApplicationContext context//@PostConstruct//@Async@EventListener(ApplicationReadyEvent.class)public void startServer() {// throws IOException//异步执行//ThreadUtil.execAsync(() -> {try {//1.打开选择器Selector selector = Selector.open();//2.打开通道 serverSocketChannelServerSocketChannel channel = ServerSocketChannel.open();//3.设置非阻塞channel.configureBlocking(false);//4.绑定本机IPchannel.bind(new InetSocketAddress(tcpIp, 8082));//5.进行注册channel.register(selector, SelectionKey.OP_ACCEPT);log.info("===============Server started on port 8082===================");while (true) {//6.选择通道int readyChannels = selector.select();//校验下if (readyChannels == 0) {continue;}//7.获取所有的keySet<SelectionKey> selectedKeys = selector.selectedKeys();//8.获取迭代器Iterator<SelectionKey> keyIterator = selectedKeys.iterator();//如果存在while (keyIterator.hasNext()) {//9.获取这个keySelectionKey key = keyIterator.next();//10.如果是个连接if (key.isAcceptable()) {//11.接收这个通道SocketChannel clientSocketChannel = serverSocketChannel.accept();//12.非阻塞的clientSocketChannel.configureBlocking(false);//13.注册为可读clientSocketChannel.register(selector, SelectionKey.OP_READ);log.info("收到连接：Accepted connection from: {}", clientSocketChannel.getRemoteAddress());} else if (key.isReadable()) {//14.如果是可读，获取通道SocketChannel clientSocketChannel = (SocketChannel) key.channel();//读取数量ByteBuffer buffer = ByteBuffer.allocate(38);//1024//15.真实读取到了多少个int bytesRead = -1;try {//这里报错了，增加防护，如果没防护，这个nio就断了bytesRead = clientSocketChannel.read(buffer);} catch (Exception e) {log.info("未读取到");e.printStackTrace();}//未读取到 关闭if (bytesRead == -1) {clientSocketChannel.close();} else if (bytesRead > 0) { //读到的 > 0//读取到了buffer.flip();//读到这个字节里byte[] data = new byte[bytesRead];buffer.get(data);//处理逻辑processBinaryData(data, bytesRead, clientSocketChannel);//String message = new String(data).trim();//System.out.println("Received message: " + message);//清理buffer.clear();}//读到了}//是可读的//移除keykeyIterator.remove();}//如果存在}//死循环} catch (Exception e) {e.printStackTrace();}//}, "MyTcpServerThread").start();
}

    //有错误，往外层抛private void sendUpdateMessage(SocketChannel clientSocketChannel) {//转为bytebyte[] binaryData = hexStringToBytes("dfsfsdfdsaf");//1.申请字节ByteBuffer buffer = ByteBuffer.allocate(binaryData.length);//2.放入buffer.put(binaryData);//3. 快速翻阅，浏览buffer.flip();//3.循环是否有：剩下的，遗留的；尚未使用、解决的while (buffer.hasRemaining()) {try {//进行写入clientSocketChannel.write(buffer);log.info("发送了一次升级的消息");} catch (IOException e) {log.info("发送升级失败");e.printStackTrace();}}}

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

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

相关文章

静态时序分析：建立时间分析

静态时序分析：建立时间分析

静态时序分析https://blog.csdn.net/weixin_45791458/category_12567571.html?spm1001.2014.3001.5482 在静态时序分析中&#xff0c;建立时间检查约束了触发器时钟引脚&#xff08;时钟路径&#xff09;和输入数据引脚&#xff08;数据路径&#xff09;之间的时序关系&#x…
阅读更多...
android中实现设备尺寸适配

android中实现设备尺寸适配

1、引言 设备尺寸适配的重要性想必就不用我多说了&#xff0c;在我发布的历史文章中我曾谈过Qt中的设备尺寸适配问题&#xff0c;那这里我就来教大家如何在android中做设备尺寸适配。在android中设备尺寸适配的方式有好几种&#xff0c;但我喜欢的还是使用获取设备真实尺寸然后…
阅读更多...
MySQL基础查询篇(8)-日期和时间函数的应用

MySQL基础查询篇(8)-日期和时间函数的应用

MySQL数据库是一种流行的关系型数据库管理系统&#xff0c;具有强大的日期和时间函数&#xff0c;用于对日期和时间数据进行各种操作和计算。在本篇博客中&#xff0c;我们将介绍MySQL数据库中一些常用的日期和时间函数&#xff0c;并提供详细示例说明其用法。 1. CURDATE()和…
阅读更多...
简单介绍算法的基本概念

简单介绍算法的基本概念

算法的基本概念 计算机所进行的一切操作都是由程序决定的&#xff0c;程序是由人们事先编好并输入计算机的。 一个程序包括以下两方面的内容: 对数据的描述&#xff1a;在程序中要指定用到哪些数据以及这些数据的类型和数据的组织形式&#xff0c;即数据结构 对操作的描述&a…
阅读更多...
c语言游戏实战（4）：人生重开模拟器

c语言游戏实战（4）：人生重开模拟器

前言&#xff1a; 人生重开模拟器是前段时间非常火的一个小游戏&#xff0c;接下来我们将一起学习使用c语言写一个简易版的人生重开模拟器。 网页版游戏&#xff1a; 人生重开模拟器 (ytecn.com) 1.实现一个简化版的人生重开模拟器 &#xff08;1&#xff09; 游戏开始的时…
阅读更多...
Transformer实战-系列教程10：SwinTransformer 源码解读3（SwinTransformerBlock类）

Transformer实战-系列教程10：SwinTransformer 源码解读3（SwinTransformerBlock类）

&#x1f6a9;&#x1f6a9;&#x1f6a9;Transformer实战-系列教程总目录 有任何问题欢迎在下面留言 本篇文章的代码运行界面均在Pycharm中进行 本篇文章配套的代码资源已经上传 点我下载源码 SwinTransformer 算法原理 SwinTransformer 源码解读1&#xff08;项目配置/SwinTr…
阅读更多...
PLC在物联网中位置—承上启下，与上位机下位机的关联。

PLC在物联网中位置—承上启下，与上位机下位机的关联。

谈到物联网&#xff0c;就绕不开PLC&#xff0c;本文着重介绍PLC的定义、与单片机的区分&#xff0c;价值、物联网中的位置&#xff0c;以及和上位机、下位机的关联&#xff0c;让友友们对PLC有个全面的认知。 一、什么是PLC PLC是可编程逻辑控制器&#xff08;Programmable L…
阅读更多...
UI自动刷新大法：DataBinding数据绑定

UI自动刷新大法：DataBinding数据绑定

之前我们讲了DataBinding在Activity、Fragment、RecyclerView中的基础使用&#xff0c;而那些常规使用方法里&#xff0c;每当绑定的变量发生数据变化时&#xff0c;都需要ViewDataBinding重新设值才会刷新对应UI。而DataBinding通过内部实现的观察者模式来进行自动刷新UI&…
阅读更多...
go消息队列RabbitMQ - 订阅模式-direct

go消息队列RabbitMQ - 订阅模式-direct

1.发布订阅 在Fanout模式中&#xff0c;一条消息&#xff0c;会被所有订阅的队列都消费。但是&#xff0c;在某些场景下&#xff0c;我们希望不同的消息被不同的队列消费。这时就要用到Direct类型的Exchange。 在Direct模型下&#xff1a; 队列与交换机的绑定&#xff0c;不能…
阅读更多...
第 384 场 LeetCode 周赛题解

第 384 场 LeetCode 周赛题解

A 修改矩阵 模拟 class Solution { public:vector<vector<int>> modifiedMatrix(vector<vector<int>> &matrix) {int m matrix.size(), n matrix[0].size();vector<int> mx(n, INT32_MIN);for (int i 0; i < m; i)for (int j 0; j &l…
阅读更多...
Java微服务学习Day1

Java微服务学习Day1

文章目录 认识微服务服务拆分及远程调用服务拆分服务远程调用提供者与消费者 Eureka注册中心介绍构建EurekaServer注册user-serviceorder-service完成服务拉取 Ribbon负载均衡介绍原理策略饥饿加载 Nacos注册中心介绍配置分级存储负载均衡环境隔离nacos注册中心原理 认识微服务…
阅读更多...
ChatGPT学习大纲

ChatGPT学习大纲

引言 在2023年2月份左右开始使用ChatGPT时&#xff0c;就被它强大的理解能力和应答效果所折服&#xff0c;这期间一直在断断续续的学习和使用&#xff0c;也没形成一个完整的学习过程&#xff0c;最近刚好有空&#xff0c;就寻思着好好再学习总结一下&#xff0c;故写出了ChatG…
阅读更多...
Python : 使用python实现学生管理系统的功能，详细注释

Python : 使用python实现学生管理系统的功能，详细注释

一、学生管理系统 学生描述&#xff1a;姓名、年龄、成绩 学生管理系统功能&#xff1a;添加学生信息、删除学生信息、根据姓名修改学生信息、根据姓名查询学生信息、显示所有学生信息、退出系统 二、代码说明 1. 将每一个学生的信息放一个元组中&#xff0c;再把元组添加到列表…
阅读更多...
java中使用Lambda表达式实现参数化方法

java中使用Lambda表达式实现参数化方法

Lambda表达式实现参数化方法说明 Lambda表达式在Java中是一种简洁、函数式的方式来表示匿名函数。它们特别适用于那些需要一个函数作为参数的方法&#xff0c;即函数式接口。参数化方法&#xff08;通常指的是泛型方法&#xff09;是那些可以接受类型参数的方法&#xff0c;这…
阅读更多...
2.3 Verilog 数据类型

2.3 Verilog 数据类型

Verilog 最常用的 2 种数据类型就是线网&#xff08;wire&#xff09;与寄存器&#xff08;reg&#xff09;&#xff0c;其余类型可以理解为这两种数据类型的扩展或辅助。 线网&#xff08;wire&#xff09; wire 类型表示硬件单元之间的物理连线&#xff0c;由其连接的器件输…
阅读更多...
单片机基础入门：简单介绍51单片机的工作原理

单片机基础入门：简单介绍51单片机的工作原理

在电子技术领域&#xff0c;单片机是实现智能化控制不可或缺的关键元件。它们集成了许多功能于一身&#xff0c;成为了各种电子系统的心脏。为了更好地理解单片机如何工作&#xff0c;本文将重点介绍51单片机的基本组成和工作原理。 51单片机是一种广泛使用的微控制器&#xf…
阅读更多...
Android 车载应用之快速入门

Android 车载应用之快速入门

一、Android Automotive OS 概览 车载 Android 系统也被称为 Android Automotive OS，是对原始 Android 系统的一个功能扩充版本。与手机系统一样，Android Automotive OS 源代码完全开放，第三方供应商和汽车制造商可以官方源码的基础上自行开发和拓展，无论是编程语言还是各…
阅读更多...
CI/CD到底是啥？持续集成/持续部署概念解释

CI/CD到底是啥？持续集成/持续部署概念解释

前言 大家好&#xff0c;我是chowley&#xff0c;日常工作中&#xff0c;我每天都在接触CI/CD&#xff0c;今天就给出我心中的答案。 在现代软件开发中&#xff0c;持续集成&#xff08;Continuous Integration&#xff0c;CI&#xff09;和持续部署&#xff08;Continuous D…
阅读更多...
【UE 求职】学了虚幻引擎可以应聘哪些岗位？

【UE 求职】学了虚幻引擎可以应聘哪些岗位？

目录 1 领域1.1 游戏开发领域1.2 影视和动画制作1.3 建筑和工程可视化1.4 模拟和训练1.5 其他领域 2 如何做好一份简历1. 明确简历目标2. 突出UE5相关技能3. 展示相关项目经验4. 教育背景5. 专业经验6. 软技能7. 证书和奖项8. 定制化和校对 &#x1f64b;‍♂️ 作者&#xff1…
阅读更多...
Day41- 动态规划part09

Day41- 动态规划part09

一、打家劫舍 题目一&#xff1a;198. 打家劫舍 198. 打家劫舍 你是一个专业的小偷&#xff0c;计划偷窃沿街的房屋。每间房内都藏有一定的现金&#xff0c;影响你偷窃的唯一制约因素就是相邻的房屋装有相互连通的防盗系统&#xff0c;如果两间相邻的房屋在同一晚上被小偷闯…
阅读更多...
最新文章

Copyright @ 2022~2023