#命令下发队列优化

Junjie

2026-04-14 f7d2eda120867b3c5a2d9001d5f5c9d0396c65bd

 src/main/java/com/zy/core/thread/impl/station/StationSegmentExecutor.java

@@ -241,6 +241,9 @@
                                         Integer currentStationId) {
        // 在下发新分段前检查路由版本是否仍然有效，避免在路由版本已更新的情况下下发旧版本命令
        if (!isRouteDispatchable(command == null ? null : command.getTaskNo(), command == null ? null : command.getRouteVersion())) {
            // 首次校验失败可能是 Redis 写入延迟导致的，短暂等待后重试一次。
            sleepQuietly(50L);
            if (!isRouteDispatchable(command == null ? null : command.getTaskNo(), command == null ? null : command.getRouteVersion())) {
            if (traceRegistry != null && command != null) {
                traceRegistry.markCancelled(command.getTaskNo(), traceVersion, currentStationId,
                        buildDetails("reason", "route_version_replaced_before_segment_send", "routeVersion", command.getRouteVersion()));
@@ -251,6 +254,7 @@
                    "route_version_replaced_before_segment_send");
            return false;
        }
        }
        
        while (true) {
            SegmentSendResult sendResult = executeLockedSegmentSend(command, traceRegistry, traceVersion, currentStationId);