搜索[stream]结果-低调大师优秀个人博客

精选列表

搜索[stream]，共5332篇文章

10分钟让你彻底了解 Java 8 的 Lambda、函数式接口、Stream 用法和原理

Stream 就可以在一行代码搞定，当然也因为 Stream 都是链式操作，一行代码可能会调用好几个方法。

2020-06-10

MessagePack Java Jackson 在不关闭输出流（output stream）的情况下序列化多变量

com.fasterxml.jackson.databind.ObjectMapper在默认的情况下在写出输入后将会关闭输出流（output stream）。

2019-08-09

Node.js 中 stream.pipeline 的错误处理陷阱：为什么你的管道会泄漏内存

在 Node.js 里处理大文件或网络流时，stream.pipeline 几乎是标配，它能把多个流串联起来并自动管理销毁，比手动 pipe 加 on('error') 可靠得多。

2026-11-09

Node.js 中 stream.pipeline 与 pump 的差异以及异步迭代器下如何避免内存泄漏

社区常提 pump 和 stream.pipeline，两者看起来都能解决这个问题，但在异步迭代器、AbortSignal 和错误传播细节上并不完全等价。

2026-11-09

Node.js 中 stream.pipe 的错误传播陷阱：为什么你的管道没有正确关闭

用 Node.js 写文件处理或 HTTP 代理时，`stream.pipe()` 几乎是本能选择，但它有一个长期被低估的问题：源流的错误不会自动传递到目标流。

2026-10-27

MessagePack Java Jackson 在不关闭输入流（input stream）的情况下反序列化多变量

/** * Serialization Not Close input stream */ @Test public void testMessagePackSerializationNotCloseInputStream

2019-08-09

java B2B2C 源码 springmvc mybatis多租户电子商城系统- Stream重新入队（RabbitMQ）

在启动应用之前，还要记得配置一下输入输出通道对应的物理目标（exchange或topic名）、并设置一下分组，比如： spring.cloud.stream.bindings.example-topic-input.destination

2019-01-15

Node.js 中 stream.pipeline 的错误处理陷阱：为什么你的文件上传偶尔会卡死

在 Node.js 里处理文件上传、日志转发或者 CSV 解析时，stream.pipeline 几乎是最常用的工具。它帮我们把可读流、转换流、可写流串起来，并自动处理背压和资源销毁。

2026-11-12

Node.js 中 stream 背压处理不当导致的内存暴涨：一个真实爬虫的排查记录

这篇文章记录了定位过程、Node.js stream 背压的机制，以及几种在真实代码里处理背压的写法。

2026-11-10

Node.js 中 stream.pipeline 的错误传播与资源清理：一个被低估的坑

在 Node.js 里用 stream 处理文件上传、日志轮转或者数据库导出时，很多人会顺手写 `readable.pipe(writable)`，但一旦中间某个流报错，源流不会自动销毁，目标流也可能挂起

2026-10-29

Node.js 中 stream.pipeline 与 async 迭代器的混合使用：避免背压失控和内存泄漏

`stream.pipeline` 本身解决了错误传递和流生命周期管理，但它和 async 迭代器混用时，背压的处理方式很容易被误解。

2026-10-29

Java B2B2C多用户商城 springcloud架构-Stream 构建消息驱动的微服务框架

Spring Cloud Stream，用精简的语言概括，他本质上其实就是让开发人员使用消息中间件变得简单。

2019-01-15

Node.js 中 stream.pipeline 的错误处理：为什么你的管道总是泄漏文件描述符

在 Node.js 里用 stream.pipeline 处理文件上传、日志转存或者数据清洗时，很多人以为把 fs.createReadStream 和 fs.createWriteStream 串起来再挂个

2026-11-10

Node.js 中 stream 的背压机制：一个被忽略的 write 返回值导致的 OOM

处理大文件上传或者转发数据流时，stream.write() 的返回值经常被当成可有可无的东西。

2026-11-09

Node.js 中 stream.pipeline 的错误处理：为什么你的管道泄漏了文件描述符

用 Node.js 处理文件上传、日志转储或者数据导出时，stream.pipeline 几乎是标配。

2026-11-08

华为云PB级数据库GaussDB(for Redis)解析第二期：Redis消息队列Stream的应用探讨

摘要：本文将对Stream的常用命令和应用场景进行介绍，并探讨原生Redis Stream消息队列的缺陷以及GaussDB(for Redis)提供的解决方案，供大家学习和选用。

2021-02-24

使用Java Stream API将List按自定义分组规则转换成Map的一个例子

Chengdu",104)); // group by City Map<String, List<Employee>> employeesByCity = employees.stream

2020-05-01

Codex 一直报 stream disconnected？别急着换模型，这份配置把 401、404 和断流一起查清楚

我碰到过一个很折磨人的问题：明明同一个模型在网页里可以正常回答，放进 Codex 后却不是 `401 Unauthorized`，就是 `404 Not Found`；好不容易开始生成了，又突然出现 `stream

2026-08-10

大数据分析处理框架——离线分析（hive，pig，spark）、近似实时分析（Impala）和实时分析（storm、spark stream...

大数据分析处理架构图数据源：除该种方法之外，还可以分为离线数据、近似实时数据和实时数据。按照图中的分类其实就是说明了数据存储的结构，而特别要说的是流数据，它的核心就是数据的连续性和快速分析性；计算层：内存计算中的Spark是UC Berkeley的最新作品，思路是利用集群中的所有内存将要处理的数据加载其中，省掉很多I/O开销和硬盘拖累，从而加快计算。而Impala思想来源于Google Dremel，充分利用分布式的集群和高效存储方式来加快大数据集上的查询速度，这也就是我上面说到的近似实时查询；底层的文件系统当然是HDFS独大，也就是Hadoop的底层存储，现在大数据的技术除了微软系的意外，基本都是HDFS作为底层的存储技术。上层的YARN就是MapReduce的第二版，和在一起就是Hadoop最新版本。基于之上的应用有Hive，Pig Latin，这两个是利用了SQL的思想来查询Hadoop上的数据。本文转自张昺华-sky博客园博客，原文链接：http://www.cnblogs.com/bonelee/p/6351722.html ，如需转载请自行联系原作者

2017-11-14

Node.js 中 stream.pipeline 回调捕获不到错误？检查你的错误处理中间件是否吞掉了异常

在 Node.js 里用 stream.pipeline 处理大文件上传或数据转换时，经常遇到一种尴尬情况：管道里某个流报错了，进程没有崩溃，pipeline 的回调也确实触发了，但错误对象是空的或者根本拿不到原始错误信息

2026-11-07

资源下载

更多资源

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

精选列表

10分钟让你彻底了解 Java 8 的 Lambda、函数式接口、Stream 用法和原理

MessagePack Java Jackson 在不关闭输出流（output stream）的情况下序列化多变量

Node.js 中 stream.pipeline 的错误处理陷阱：为什么你的管道会泄漏内存

Node.js 中 stream.pipeline 与 pump 的差异以及异步迭代器下如何避免内存泄漏

Node.js 中 stream.pipe 的错误传播陷阱：为什么你的管道没有正确关闭

MessagePack Java Jackson 在不关闭输入流（input stream）的情况下反序列化多变量

java B2B2C 源码 springmvc mybatis多租户电子商城系统- Stream重新入队（RabbitMQ）

Node.js 中 stream.pipeline 的错误处理陷阱：为什么你的文件上传偶尔会卡死

Node.js 中 stream 背压处理不当导致的内存暴涨：一个真实爬虫的排查记录

Node.js 中 stream.pipeline 的错误传播与资源清理：一个被低估的坑

Node.js 中 stream.pipeline 与 async 迭代器的混合使用：避免背压失控和内存泄漏

Java B2B2C多用户商城 springcloud架构-Stream 构建消息驱动的微服务框架

Node.js 中 stream.pipeline 的错误处理：为什么你的管道总是泄漏文件描述符

Node.js 中 stream 的背压机制：一个被忽略的 write 返回值导致的 OOM

Node.js 中 stream.pipeline 的错误处理：为什么你的管道泄漏了文件描述符

华为云PB级数据库GaussDB(for Redis)解析第二期：Redis消息队列Stream的应用探讨

使用Java Stream API将List按自定义分组规则转换成Map的一个例子

Codex 一直报 stream disconnected？别急着换模型，这份配置把 401、404 和断流一起查清楚

大数据分析处理框架——离线分析（hive，pig，spark）、近似实时分析（Impala）和实时分析（storm、spark stream...

Node.js 中 stream.pipeline 回调捕获不到错误？检查你的错误处理中间件是否吞掉了异常

资源下载

Nacos

Spring

Rocky Linux

优质分享App

欢迎您来访！