Shikong/gb28181-docking-platform-mocking
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

批量注册 改为一批 200个 每次间隔 500ms

Browse Source 
避免速度过快把 wvp 卡死
This commit is contained in:
shikong 2024-03-11 15:31:49 +08:00
parent 4b55f7fc54
commit d8cab292de
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/gb28181/register/RegisterService.java
View File

@ -52,11 +52,13 @@ public class RegisterService {
List<MockingDevice> enabledDevice = deviceService.getAllEnabledDevice(); List<MockingDevice> enabledDevice = deviceService.getAllEnabledDevice();
List<CompletableFuture<JsonResponse<Void>>[]> completableFutures = ListUtil.split(enabledDevice, 10).stream().map(items -> { List<CompletableFuture<JsonResponse<Void>>[]> completableFutures = new ArrayList<>();
CompletableFuture<JsonResponse<Void>>[] array = enabledDevice.stream().map(this::register).toArray(CompletableFuture[]::new); for (List<MockingDevice> mockingDevices : ListUtil.split(enabledDevice, 200)) {
CompletableFuture<JsonResponse<Void>>[] array = mockingDevices.stream().map(this::register).toArray(CompletableFuture[]::new);
CompletableFuture.allOf(array); CompletableFuture.allOf(array);
return array; Thread.sleep(500);
}).toList(); completableFutures.add(array);
}
List<CompletableFuture<JsonResponse<Void>>> reduce = completableFutures.stream().map(item -> Arrays.stream(item).toList()) List<CompletableFuture<JsonResponse<Void>>> reduce = completableFutures.stream().map(item -> Arrays.stream(item).toList())
.reduce(new ArrayList<>(), (prev, cur) -> { .reduce(new ArrayList<>(), (prev, cur) -> {