优化级联通道发送速度

648540858

2022-02-20 b7635ec05dda0764459ca9fa836d9288cea1cd07

优化级联通道发送速度

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/CatalogNotifyMessageHandler.java

@@ -89,7 +89,7 @@
                    deviceChannel.setSecrecy("0");
                    cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size);
                    // 防止发送过快
                    Thread.sleep(10);
                    Thread.sleep(50);
                }
            }
            // 回复级联的通道
@@ -101,7 +101,7 @@

                    cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size);
                    // 防止发送过快
                    Thread.sleep(10);
                    Thread.sleep(50);
                }
            }
            // 回复直播的通道
@@ -124,7 +124,7 @@
                    deviceChannel.setSecrecy("0");
                    cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size);
                    // 防止发送过快
                    Thread.sleep(10);
                    Thread.sleep(50);
                }
            }
            if (size == 0) {

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/query/cmd/CatalogQueryMessageHandler.java

@@ -92,7 +92,7 @@
                    deviceChannel.setSecrecy("0");
                    cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size);
                    // 防止发送过快
                    Thread.sleep(10);
                    Thread.sleep(50);
                }
            }
            // 回复级联的通道
@@ -104,7 +104,7 @@
                    deviceChannel.setParentId(channelReduce.getCatalogId());
                    cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size);
                    // 防止发送过快
                    Thread.sleep(10);
                    Thread.sleep(50);
                }
            }
            // 回复直播的通道
@@ -127,6 +127,8 @@
                    deviceChannel.setSecrecy("0");

                    cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size);
                    // 防止发送过快
                    Thread.sleep(50);
                }
            }
            if (size == 0) {