Netty中Channel的isWritable方法理解

目录

初见  

深入

需要注意

对待超SIZE情况开源项目怎么做

1、seata中

2、SUMMER中

3、一些资料中

 总结


初见  

以下是包中注释

Returns true if and only if the I/O thread will perform the requested write operation immediately. Any write requests made when this method returns false are queued until the I/O thread is ready to process the queued write requests.

当且仅当I/O线程立即执行请求的写操作时,返回true。当这个方法返回false时,任何写请求都会排队等待,直到I/O线程准备好处理排队的写请求。

 刚开始接触到它是因为服务端给我断连,再写入时必然是不可写报错的(当时没区分isActive和isWritable,看了前辈的代码直接使用的是isWritable,此时是没区分场景的)。

后来测试中发现,发送流量过大时,isWritable仍然会返回false,然后对它就进行更进一步了解

深入

debug通过源码看

通常情况下,我们会使用writeAndFlush发送消息。它的具体流程是写入时会生成 WriteTask,交由 IO 线程处理,write 操作将消息写入 ChannelOutboundBuffer,最后再将 ChannelOutboundBuffer 缓冲区写 入socket 的发送缓冲区;

在创建WriteTask时初始化会调用incrementPendingOutboundBytes方法,去判断更改isWritable中判断要素变量ChannelOutboundBuffer中的unwritable。判断要素则为可配置的WriteBufferHighWaterMark(高水位线)

以上就是原理,通俗来说就是如ChannelOutboundBuffer中有一个缓冲区,这个缓冲区设有高位线和低位线,当 buffer 的大小超过高水位线的时候对应 channel 的 isWritable 就会变成 false,当 buffer 的大小低于低水位线的时候,isWritable 就会变成 true。writeAndFlush时会增加缓冲区大小。

需要注意

每次writeAndFlush时可以不判断channel的isWritable状态,但是根据我们通过简介也知道。当isWritable()方法返回false时,这意味着缓冲区已经被填满,无法再写入更多数据,此时如果强制写入数据会导致阻塞,一直阻塞,数据量特别大时会造成OOM。

对待超SIZE情况开源项目怎么做

我简单查看了以下github和资料,大致有以下做法,简单看了看,有错误请指出。

其中不乏有不处理只打印日志的,单总感觉差点意思。

1、seata中

 异步加阻塞方式

2、SUMMER中

 阻塞队列,在监听write事件上,再处理。

3、一些资料中

出处:如何解决 Netty Channel.isWritable 返回 false-CSDN博客

 总结

对待超BUFFER情况,还是要根据业务具体分析,合理计算、配置资源,比如限流什么的。

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

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

相关文章

Logstash的使用方法

Logstash是一个开源的数据收集引擎,主要用于数据的抽取、转换和加载(ETL)。它可以将来自不同数据源的数据收集、过滤并统一输出到指定的目的地,如Elasticsearch、Kafka等。 以下是Logstash的使用方法: 安装Logstash&a…

【GAMES101】二维变换和齐次坐标

这几天都在抽空学OpenGL、敲leetcode和看games,这里留点笔记给以后复习 games101第一节课在吹水,第二节课讲了线性代数的入门知识,比较简单,这里稍微回顾一下重点,然后开始讲第三节课的二维变换和齐次坐标 目录 向量…

湖南麒麟下默认使用串口输出系统日志

有时候为了调试方便,需要将系统日志通过CPU的串口进行输出,以下是针对至强E5V4处理器上安装湖南麒麟操作系统后将日志通过串口输出的配置。 首先在bios中打开串口重定向功能,这里的BIOS是AMI的BIOS 内部配置如下,波特率115200配置…

STM32学习笔记--闪存Flash

STM32F1系列的FLASH包含程序存储器、系统存储器和选项字节三个部分,通过闪存存储器接口(外设)可以对程序存储器和选项字节进行擦除和编程。 读写FLASH的用途:利用程序存储器的剩余空间来保存掉电不丢失的用户数据 ,通过…

《计算理论导引(原书第3版)》笔记

文章目录 [toc]第〇章:绪论0.1|自动机、可计算性与复杂性计算复杂性理论可计算性理论自动机理论 0.2|数学概念和术语集合关系等价关系 图简单路径连通图圈强连通图 字符串和语言字母表上的字符串空串 w w w的反转(倒序) x x x和 y y y的连接字…

java中AQS的实现原理是怎样的?

AbstractQueuedSynchronizer(AQS)的实现原理主要基于一个FIFO(先进先出)的等待队列和两个原子状态变量(state和exclusiveOwnerThread)。 状态变量: state:表示资源的状态&#xff…

c++--类型行为控制

1.c的类 1.1.c的类关键点 c类型的关键点在于类存在继承。在此基础上,类存在构造,赋值,析构三类通用的关键行为。 类型提供了构造函数,赋值运算符,析构函数来让我们控制三类通用行为的具体表现。 为了清楚的说明类的构…

现代雷达车载应用——第2章 汽车雷达系统原理 2.1节

经典著作,值得一读,英文原版下载链接【免费】ModernRadarforAutomotiveApplications资源-CSDN文库。 2.1 基本雷达功能 雷达系统通过天线或天线阵列向空间辐射电磁能量。辐射的电磁能量“照亮”周围的目标。“被照亮”的目标拦截一些辐射能量&#xff0…

图片帧数超过300帧,调整后重新上传

发表公众号的时候,传了一些 GIF 格式的动图,但是提示:图片帧数超过300帧,调整后重新上传。怎么解决这个问题呢?GIF 格式的图片,是将多个图片保存在一起,并逐帧显示的,帧数越多&#…

java中CAS是什么?

CAS(Compare and Swap)是一种并发编程中常用的原子操作,也称为比较并交换。它是一种无锁算法,用于实现多线程环境下的数据同步。CAS 操作涉及三个操作数:内存位置(通常是某个变量的内存地址)、期…

[NAND Flash 2.2] NAND闪存及控制器的市场趋势 [2023]

依公知及经验整理&#xff0c;原创保护&#xff0c;禁止转载。 专栏 《深入理解NAND Flash》 <<<< 返回总目录 <<<< 一、NAND闪存市场分析 据欧洲知名半导体分析机构Yole发布的报告显示&#xff0c;2020年起&#xff0c;NAND闪存市场发展趋势保持稳定…

【链表】160.相交链表

题目 法1:写法不简练 public class Solution {public ListNode getIntersectionNode(ListNode headA, ListNode headB) {if (headA null || headB null) {return null;}ListNode curA headA, curB headB;int aMeetNull 0;while (aMeetNull < 2) {if (curA curB) {re…

pillow opencv matplotlib读写图片有什么区别

from PIL import Image import numpy as np import cv2 from matplotlib import pyplot as pltfile_path 1.png 读彩色图像 区别&#xff1a; opencv-python读出来的是BGR颜色通道的PIL读出的是PIL类格式的&#xff0c;而cv和plt是numpy数组 # 读取彩色图像 都是HWC img1 …

Redis中HyperLogLog的使用

目录 前言 HyperLogLog 前言 在学习HyperLogLog之前&#xff0c;我们需要先学习两个概念 UV&#xff1a;全称Unique Visitor&#xff0c;也叫独立访客量&#xff0c;是指通过互联网访问、浏览这个网页的自然人。1天内同一个用户多次访问该网站&#xff0c;只记录1次。PV&am…

Flink之DataStream API的转换算子

简单转换算子 函数的实现方式 自定义类,实现函数接口:编码麻烦&#xff0c;使用灵活匿名内部类:编码简单Lambda:编码简洁 public class Flink02_FunctionImplement {public static void main(String[] args) {//1.创建运行环境StreamExecutionEnvironment env StreamExecut…

二值图像分割统一项目

1. 项目文件介绍 本章为二值图像的分割任务做统一实现&#xff0c;下面是项目的实现目录 项目和文章绑定了&#xff0c;之前没用过&#xff0c;不知道行不行 data 文件夹下负责摆放数据的训练集测试集inference 负责放待推理的图片(支持多张图片预测分割)run_results 是网络训…

centos7 yum安装nginx

1.安装源 rpm -ivh http://nginx.org/packages/centos/5/noarch/RPMS/nginx-release-centos-5-0.el5.ngx.noarch.rpm 2.安装 (-y 的意思是自动yes) yum install nginx -y 3.查找安装到哪里了 whereis nginx 一般都是在 /etc/nginx下面 4.常用命令 检查配置文件是否正确 …

【华为OD题库-079】周末爬山-Java

题目 周末小明准备去爬山锻炼&#xff0c;0代表平地&#xff0c;山的高度使用1到9来表示&#xff0c;小明每次爬山或下山高度只能相差k及k以内&#xff0c;每次只能上下左右一个方向上移动—格&#xff0c;小明从左上角(0,0)位置出发 输入描述 第一行输入m n k(空格分隔)。代表…

InnoDB的数据存储结构

一 数据库的存储结构&#xff1a;页 索引结构提供了高效的检索方式&#xff0c;不过索引信息和数据记录都是保存在文件上的&#xff0c;确切的说是存储在页结构中。另一方面&#xff0c;索引是在引擎中实现的&#xff0c;MySQL服务器上的存储引擎负责对表中数据的读取和写入。…

R语言学习

Part1阶段1&#xff1a;入门基础 1安装R和RStudio&#xff1a; 下载并安装R&#xff1a;https://cran.r-project.org/ 下载并安装RStudio&#xff1a;https://www.rstudio.com/products/rstudio/download/ 2Hello World&#xff1a; 学习如何在R中输出"Hello, World!"…