git00ll 最近的时间轴更新
git00ll
ONLINE

git00ll

V2EX 第 447415 号会员,加入于 2019-10-17 12:19:31 +08:00
今日活跃度排名 3163
Project Reactor,如何实现主线程消费报错时停止 Flux 流
Java  •  git00ll  •  31 天前  •  最后回复来自 git00ll
5
git00ll 最近回复了
可以使用加签的链接在后端鉴权。但其他用户拿到了加签后的链接,肯定也是可以访问的。
16 天前
回复了 111qqz 创建的主题 问与答 给女票选生日礼物,有什么建议?
无论买啥,建议再搭配一把鲜花
@chaosrb79 酷安,qq 浏览器评论区 找找看
for update 。简单 暴力。性能也不差
30 天前
回复了 lianglu 创建的主题 程序员 Java 有什么开源框架值得深入研究?
jackson 也值得看
30 天前
回复了 lianglu 创建的主题 程序员 Java 有什么开源框架值得深入研究?
netty
project.reactor
openFeign
spring gateway
vertx
@yazinnnn
业务场景里有一些限制,
1. 需要保持输入和输出的顺序一致,
2. 流中的数据从文件中读取的,数据量非常大,无法全部加载到内存。只能边读取边处理。
3.处理过程中其中一条处理错误时,算失败,中断流不再继续。

一方面 stream 的并行流没有拉模式,无法精准控制载入内存的数据行数。
且并行 stream 提供的 api 太少,相比于 reactor 提供的控制选项不足
@yazinnnn 假设 toInt 这个操作是比较耗时的,可以实现将 toInt 放置在多核上运行,最终结果再汇聚到主线程上。
因为主线程上开启了传统注解事务,需要在主线程上操作 Flux 的处理结果
30 分钟是指现实世界中的每 30 分钟作为一个区间吗?
感觉建张表存就可以了,内存里持有当前区间最大值,处理数据时比内存中值大就更新到数据库,否则就跳过。

如果是滚动 30 分钟,可以使用找个时序数据库用一下。
33 天前
回复了 awanganddong 创建的主题 MySQL mysql 并发操作的问题
for update 没问题的,每秒 4000 次
关于   ·   帮助文档   ·   API   ·   FAQ   ·   我们的愿景   ·   广告投放   ·   感谢   ·   实用小工具   ·   2756 人在线   最高记录 5497   ·     Select Language
创意工作者们的社区
World is powered by solitude
VERSION: 3.9.8.5 · 21ms · UTC 05:15 · PVG 13:15 · LAX 21:15 · JFK 00:15
Developed with CodeLauncher
♥ Do have faith in what you're doing.