优化

liusuyi

2026-06-01 3496700a5ba18be8ca0590a79e21a867782d1ea9

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
package com.ard.work.sdk.zlxd.netty.tcp;
 
import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ConcurrentHashMap;
 
public class ResponseFutureHolder {
 
    // 1. 键改为 String 类型，格式为 "相机ID_序列号"
    private static final Map<String, CompletableFuture<String>> FUTURE_MAP =
            new ConcurrentHashMap<>();
 
    /**
     * 保存 future（新增重载方法，适配唯一键）
     * @param uniqueKey 格式：cameraId_seq
     * @param future 待保存的异步结果
     */
    public static void put(String uniqueKey, CompletableFuture<String> future) {
        FUTURE_MAP.put(uniqueKey, future);
    }
 
    /**
     * 兼容旧方法（不推荐使用，仅用于过渡）
     */
    @Deprecated
    public static void put(int seq, CompletableFuture<String> future) {
        FUTURE_MAP.put(String.valueOf(seq), future);
    }
 
    /**
     * 获取 future（新增重载方法）
     * @param uniqueKey 格式：cameraId_seq
     */
    public static CompletableFuture<String> get(String uniqueKey) {
        return FUTURE_MAP.get(uniqueKey);
    }
 
    /**
     * 兼容旧方法（不推荐使用）
     */
    @Deprecated
    public static CompletableFuture<String> get(int seq) {
        return FUTURE_MAP.get(String.valueOf(seq));
    }
 
    /**
     * 移除 future（新增重载方法）
     * @param uniqueKey 格式：cameraId_seq
     */
    public static void remove(String uniqueKey) {
        FUTURE_MAP.remove(uniqueKey);
    }
 
    /**
     * 兼容旧方法（不推荐使用）
     */
    @Deprecated
    public static void remove(int seq) {
        FUTURE_MAP.remove(String.valueOf(seq));
    }
 
    /**
     * 完成并移除（新增重载方法）
     * @param uniqueKey 格式：cameraId_seq
     * @param response 响应结果
     */
    public static void complete(String uniqueKey, String response) {
        CompletableFuture<String> future = FUTURE_MAP.remove(uniqueKey);
        if (future != null) {
            future.complete(response);
        }
    }
 
    /**
     * 兼容旧方法（不推荐使用）
     */
    @Deprecated
    public static void complete(int seq, String response) {
        complete(String.valueOf(seq), response);
    }
 
    /**
     * 异常完成并移除（新增重载方法）
     * @param uniqueKey 格式：cameraId_seq
     * @param ex 异常信息
     */
    public static void completeExceptionally(String uniqueKey, Throwable ex) {
        CompletableFuture<String> future = FUTURE_MAP.remove(uniqueKey);
        if (future != null) {
            future.completeExceptionally(ex);
        }
    }
 
    /**
     * 兼容旧方法（不推荐使用）
     */
    @Deprecated
    public static void completeExceptionally(int seq, Throwable ex) {
        completeExceptionally(String.valueOf(seq), ex);
    }
 
    /**
     * 新增：按相机ID清理所有相关的Future（断开连接时调用）
     * @param cameraId 相机ID
     */
    public static void clearByCamera(String cameraId) {
        // 遍历并移除所有以该相机ID开头的键
        FUTURE_MAP.keySet().removeIf(key -> key.startsWith(cameraId + "_"));
        // 打印日志（可选，用于调试）
        // System.out.println("清理相机[" + cameraId + "]的所有未完成Future");
    }
 
    /**
     * 新增：清空所有Future（应用关闭时调用）
     */
    public static void clearAll() {
        FUTURE_MAP.clear();
    }
}