526互联

netty nio

Netty源码学习4——服务端是处理新连接的&netty的reactor模式

系列文章目录和关于我 零丶引入 在前面的源码学习中，梳理了服务端的启动，以及NioEventLoop事件循环的工作流程，并了解了Netty处理网络io重要的Channel ，ChannelHandler，ChannelPipeline。 这一篇将学习服务端是如何构建新的连接。 一丶网络包接收流程 当 ......
源码 reactor 模式 Netty netty

Netty-基础篇（2）

ByteBuf——Netty的数据容器 概念：Netty提供的字节容器，可以对字节进行高效操作，包括读写、查找等。 数据处理组件 1.abstract class ByteBuf 2.interface ByteBufHolder ByteBuf API的优点： 1.它可以被用户自定义的缓冲类型扩展 ......
基础 Netty

Netty-基础篇

核心组件 EventLoopGroup 概念：由一个或多个EventLoop组成的组，用于处理所有的Channel的I/O操作，可以将其看作是一个线程池。 1.包含多个EventLoop。 2.EventLoopGroup将为每个新创建的Channel分配一个EventLoop。在每个Channel ......
基础 Netty

netty tls单向认证通讯

需求背景 项目主要分为监管侧和企业侧，企业侧实时上传数据到云端，云端汇聚业务数据，上传过程需要保证传输的安全性。 技术实现 数据上传考虑到用HTTPS或者是TCP + TLS传输。其实使用HTTPS传输协议是比较简单的，但是项目硬件使用的4G无线网卡，而且需要实时检测设备运行状态，所以使用了TCP ......
单向 通讯 netty tls

Netty - 快速开始

一、为什么使用Netty 1. NIO的缺点 NIO的类库和API繁杂，学习成本高，你需要熟练掌握Selector、ServerSocketChannel、SocketChannel、ByteBuffer等。 需要熟悉Java多线程编程。这是因为NIO编程涉及到Reactor模式，你必须对多线程和网 ......
Netty

使用Java实现NIO

以下是一个使用 Java NIO 实现 Reactor 模型的简单示例代码，并附有详细的注释： import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java ......
Java NIO

Netty（四）NIO多线程优化

Netty（四）NIO多线程优化 ​ 前面的代码都只有一个选择器，没有充分利用多核CPU，因此可以分两组选择器 boss：单线程配一个选择器，专门处理accept事件，不负责数据的读写 worker：创建CPU核心数的线程，每个线程配一个选择器，轮流处理read事件 1 多线程问题分析 关键是这一部 ......
线程 Netty NIO

Netty（二）文件编程

Netty（二）文件编程 1 FileChannel 不能够直接打开FileChannel，只能够通过FileInputStream、FIleOutPutStream和RandomAccessFile的getChannel()方法来获取FileChannel FileInputStream获得的ch ......
文件 Netty

Netty（三）网络编程

Netty（三）网络编程 1 阻塞和非阻塞 堵塞： 在没有数据可读的时候，包括数据复制的过程，线程必须堵塞等待，不会占用CPU但是线程相当于闲置 在单线程下，两个堵塞的方法会相互影响，必须使用多线程，32位JVM一个线程320K，64位JVM一个线程1024K，为了减少线程数，需要采用线程池技术 但 ......
网络编程 Netty 网络

Netty

IO模型 阻塞IO 客户端与服务端通过IP与断开进行流传输，客户端与服务端传输数据是以阻塞的方式进行传输的，在传输的过程中，其他客户端请求将会阻塞调，无法处理其他客户端的连接，可以利用多线程来尽量的处理多个客户端请求，但是线程消耗的资源是有限的，所有这种IO模型无法适用于大并发从场景下。服务端需要一 ......
Netty

org.yaml.snakeyaml.error.YAMLException: java.nio.charset.MalformedInputException: Input length = 2

1.报错 在运行SpringBoot项目时遇到报错： 17:44:47.558 [main] ERROR org.springframework.boot.SpringApplication -- Application run failed org.yaml.snakeyaml.error.YAM ......
MalformedInputException YAMLException snakeyaml charset length

NIO之Selectors

Selector是Java NIO中实现多路复用的关键，用于检查一个或多个NIO Channel 的状态是否处于可连接、可接收、可读、可写状态。单个单线程通过Selector来管理多个Channel，减少线程上下文切花能带来的开销。 Selector是一个抽象类，具体是通过SelectorProvi ......
Selectors NIO

NIO之Buffers

Buffer？我们很容易想到缓冲区的概念，在NIO中，它是直接和Channel打交道的缓冲区，通常场景或是从Buffer写入Channel，或是从Channel读入Buffer。Buffer是一个抽象类，Java提供如下图的实现类，我是直接在Eclipse截出来的_ 其实核心是ByteBuffer， ......
Buffers NIO

NIO之Channels

Channel介绍 Channel? 我们在使用Buffer的时候，需要往Buffer中放数据，再从Buffer中取数据，那么在NIO体系中，与Buffer交互是什么呢，没错，就是Channel。所有的NIO的I/O操作都是从Channel 开始的，读操作的时候将Channel中的数据填充到Buff ......
Channels NIO

Java NIO包结构简介

layout: post read_time: true show_date: true title: Java NIO包结构 date: 2023-07-09 10:12:10 -0600 description: Java NIO包结构简述. img: posts/java-nio/cover. ......
结构 简介 Java NIO

【Netty】使用Netty搭建简易Sokect客户端

直接上代码 创建客户端，连接到服务端，并发送消息： /** * 发送一条消息到socket服务端 */ private void sendOne(String rawMessage) { NioEventLoopGroup group = new NioEventLoopGroup(); try { ......
Netty 简易 客户端 客户 Sokect

spark由于shuffle中read过大造成netty申请DirectMemor异常（转）

1.报错日志： ​ WARN TaskSetManager: Lost task 29.0 in stage 22.0 (TID 1851, wn108-cdlcns.bjduloineequ3adfbkrpgi4p2c.shax.internal.chinacloudapp.cn, executo ......
DirectMemor shuffle spark netty read

tomcat nio2源码分析

一、 前言 ​ 最近在看tomcat connector组件的相关源码，对Nio2的异步回调过程颇有兴趣，平时读源码不读，自己读的时候很多流程都没搞明白，去查网上相关解析讲的给我感觉也不是特别清晰，于是就自己慢慢看源码，以下是我自己的见解，因为开发经验也不多，刚成为社畜不久，有些地方讲错如果有大佬看 ......
源码 tomcat nio2 nio

用springBoot、netty写TCP客户端/服务端，并用TCP工具测试

1.启动客户端和连接服务端 package com.pkx.cloud.test.netty; import io.netty.bootstrap.Bootstrap; import io.netty.channel.*; import io.netty.channel.nio.NioEventLo ......
springBoot TCP 客户端 客户 工具

Netty实践 -- Netty处理粘包拆包

TCP 粘包/拆包 TCP是以流的方式来处理数据， 拆包：一个完整的数据包可能会被TCP拆分成多个包进行发送。 粘包：TCP 可能把多个小的包粘成一个大的数据包。 粘包拆包示例： 服务端 EchoServer： /** * 服务端收到客户端的消息后，会进行响应。 */ public final cl ......
Netty

在Java中，可以使用`java.nio.file`包中的`Files`类来进行文件搜索。以下是一种模糊搜索文件的方法

在Java中，可以使用`java.nio.file`包中的`Files`类来进行文件搜索。以下是一种模糊搜索文件的方法： ```javaimport java.io.IOException;import java.nio.file.*;import java.nio.file.attribute.B ......
文件 方法 Files Java java

Netty实践 -- echo

Netty实践 学习netty，可以从netty源码的 netty-example 模块开始。 netty-example 有一个例子 echo，非常适合入门学习。 这里稍微改造一下，用作示例学习。 引入依赖包： <dependency> <groupId>io.netty</groupId> <a ......
Netty echo

netty常用类

netty架构图 ServerBootstrap 、 Bootstrap ServerBootstrap ：服务器的引导类，可以绑定服务器和端口，配置 Channel、ChannelHandler等。 Bootstrap：客户端的引导类。可以开启客户端，连接服务端的端口，配置 Channel、Cha ......
常用 netty

深入理解 Netty FastThreadLocal

本文以线上诡异问题为切入点，通过对比JDK ThreadLocal和Netty FastThreadLocal实现逻辑以及优缺点，并深入解读源码，由浅入深理解Netty FastThreadLocal。 ......
FastThreadLocal Netty

基于SpringBoot+Netty实现即时通讯（IM）功能

简单记录一下实现的整体框架，具体细节在实际生产中再细化就可以了。 第一步 引入netty依赖 SpringBoot的其他必要的依赖像Mybatis、Lombok这些都是老生常谈了 就不在这里放了 <dependency> <groupId>io.netty</groupId> <artifactId ......
SpringBoot 通讯 功能 Netty

Java IO 与 NIO：高效的输入输出操作探究

引言 输入输出（IO）是任何编程语言中的核心概念，而在Java中，IO操作更是应用程序成功运行的基石。随着计算机系统变得越来越复杂，对IO的要求也日益增加。在本文中，我们将探讨Java IO和非阻塞IO（NIO）的重要性以及如何在Java中实现高效的输入输出操作。 传统IO（阻塞IO） 传统IO是大 ......
Java NIO IO

Netty源码编译

Netty源码编译 想了解Netty源码，最好先从 netty-example 开始，多跑几个 example，了解Netty的实际应用。 编译 netty-example 会出现很多乱七八糟的问题，根本原因是因为缺少 io.netty.util.collection 包。 解决方法 1.先 ins ......
源码 Netty

java nio

Java NIO（New IO 或 Non Blocking IO）是从 Java 1.4 版本开始引入的一个新的 IO API，可以替代标准的 Java IO API。NIO 支持面向缓冲区的、基于通道的 IO 操 作。NIO 将以更加高效的方式进行文件的读写操作 阻塞IO 通常在进行同步I/O操 ......
java nio

Netty 4.1.98.Final 发布

Netty 4.1.98 稳定版已发布。Netty 是一个异步事件驱动的网络应用框架，主要用于可维护的高性能协议服务器和客户端的快速开发。 此版本还原了上一版本中所做的更改，这些更改导致 HTTP header 验证比所需的更严格 (#13615)。除此之外，当使用 native SSL 实现时，该 ......
Netty Final 98

Netty 黏包半包分析

Netty 黏包半包分析 1 具体现象 粘包 现象，发送 abc def，接收 abcdef 原因 应用层：接收方 ByteBuf 设置太大（Netty 默认 1024） 滑动窗口：假设发送方 256 bytes 表示一个完整报文，但由于接收方处理不及时且窗口大小足够大，这 256 bytes 字节 ......
Netty
共227篇  :2/8页 首页上一页2下一页尾页