工业物联网有个常被低估的难题:并发。设备不是一台一台连的,是成百上千台同时上线、同时上报、同时断线重连。网关和平台要在同一时刻处理海量连接,还要在每个连接上做协议解析、数据入库、告警判断——每一步还都可能阻塞。

Java 21 的虚拟线程,是这两年 Java 社区最大的一次更新。它到底怎么解决工业物联网的并发难题、又能解决到哪一步,下面看。

工业物联网的并发,到底难在哪

先看场景。一个工厂网关下挂几百台 Modbus 设备,一个平台要同时接几千上万条连接:有 TCP 长连接、有 MQTT、有串口透传上来的 DTU。每条连接背后,是持续的"读数据→解析→入库→判断告警"。

难在三件事同时发生:

• 连接数量大——动辄几千上万,还随时有设备上线、掉线;
• 每步都可能阻塞——读数据库、写 MQTT、发通知,全是阻塞调用;
• 内存有限——边缘网关的内存按 G 算,扛不住"一个连接一个平台线程"的奢侈。

传统写法在这三件事面前,只有两条路,都不舒服。

传统两条路:一条费资源,一条费头发

第一条:thread-per-connection。 一个连接一个平台线程,代码最直观——但平台线程栈默认 1MB,开几千个就是几个 G 内存。网关几万台设备的规模,这条路直接走不通。

第二条:NIO + 异步/reactive。 用事件驱动解决连接数问题,像 Netty 那样。但这套的代价是代码彻底变难:状态机、回调链、背压,一个异步链路写完,能读懂的人没几个。而且一旦业务里混进一个阻塞调用(比如查库),整个异步管道就卡住了。

工业物联网开发经常卡在这两难里:要么内存扛不住,要么代码维护不动。

Java 21 虚拟线程,把线程变成了"廉价品"

虚拟线程的核心,是把"线程"从操作系统资源变成 JVM 里的轻量对象。它的调度由 JVM 完成:遇到阻塞,虚拟线程自动挂起,把底下的平台线程让给别的虚拟线程用;阻塞结束再恢复。结果是:

• 可以开上百万个虚拟线程,几 KB 一个,内存不再是瓶颈;
• 写代码和"每连接一线程"一样直观,阻塞式同步写,不用碰异步;
• 吞吐不降反升——平台线程不再被阻塞占用,利用率更高。

你拿回了最直观的写法,同时拿到了 NIO 的并发能力。

在工业物联网里的五个价值点

一、海量设备连接,终于不用拆逻辑了。 每台设备一个虚拟线程,连接、解析、入库全部同步顺序写,几万连接照扛。设备断线重连、心跳保活,一个连接一段代码,谁都能维护。

二、采集调度,几十万定时任务系统不崩。 每台设备按频率采集,传统做法要么线程池扛不住,要么堆 ScheduledExecutorService 到天上去。虚拟线程下,几十万条定时任务就是几十万个轻量对象,网关内存稳稳的。

三、协议处理的阻塞,不再是定时炸弹。 协议解析里查字典、对表、调外部服务,这些阻塞点以前在异步链路上是死穴。虚拟线程里,阻塞就是"挂起一下",该写的顺序写,不用再为阻塞提心吊胆。

四、告警/消息的并发外发。 设备告警触发时,要给几百个订阅者推 WebSocket、发短信、写通知——一个告警一个虚拟线程,批量外发,简单直接。

五、Spring Boot 3.2 一个开关,Web 层直接起飞。 spring.threads.virtual.enabled=true,Tomcat 的请求处理切到虚拟线程。管理端 API、北向接口、MQTT 桥接,并发能力立刻上一个台阶,几乎零改码。

一个直观的对比

传统 NIO 处理一个设备连接的读,是这种画风:回调里套回调,读完了在回调里再发下一个读。

while (设备在线) {
    byte[] data = channel.read();      // 阻塞读,挂起就行
    Object value = parse(data);        // 协议解析
    db.save(device, value);            // 入库,阻塞也随意
    checkAlert(value);                 // 告警判断
}

一样的并发能力,代码从"给异步框架写逻辑"回到"给设备写逻辑"。

边界也讲清楚:它不是什么都能干

• CPU 密集没用。 虚拟线程解决的是"阻塞+并发",不是计算吞吐。要做重型数据分析,该并行还是并行。
• synchronized 会 pin 住。 虚拟线程遇到锁竞争可能被钉在平台线程上,JDK21 修了大部分,但锁重的老代码仍要注意。
• 和 Netty 是互补,不是替代。 Netty 管 NIO 收发没问题,业务处理段可以切到虚拟线程,把异步链路中间最难写的部分变回同步。两条路怎么搭,是架构师该权衡的。

值得借鉴的做法:把并发红利留到该用的地方

我自己比较坚持的判断:工业物联网里,技术选型的价值不在于"用了什么新东西",而在于它让哪部分代码变简单了、哪部分资源变省了。虚拟线程恰好戳中两件事:海量连接 + 阻塞多。这也是一些做工业物联网的团队把底子选在 JDK21 上的原因——近期新晋的工业物联网平台(aiots)就是用 JDK21 + Spring Boot 3.5,配合 Netty 管设备 I/O、虚拟线程承接业务处理,把"连接多、阻塞多、内存紧"这三个工业现场的老大难,用更简单的代码接住了。