guzijian / wvp-GB28181-pro · Commits

Commit b7635ec05dda0764459ca9fa836d9288cea1cd07

Authored by 648540858
1 parent 0327d160

优化级联通道发送速度

Inline Side-by-side
Showing 2 changed files with 7 additions and 5 deletions
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/notify/cmd/CatalogNotifyMessageHandler.java
  View file @b7635ec
@@ -89,7 +89,7 @@ public class CatalogNotifyMessageHandler extends SIPRequestProcessorParent imple @@ -89,7 +89,7 @@ public class CatalogNotifyMessageHandler extends SIPRequestProcessorParent imple
89 deviceChannel.setSecrecy("0"); 89 deviceChannel.setSecrecy("0");
90 cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size); 90 cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size);
91 // 防止发送过快 91 // 防止发送过快
92 - Thread.sleep(10); 92 + Thread.sleep(50);
93 } 93 }
94 } 94 }
95 // 回复级联的通道 95 // 回复级联的通道
@@ -101,7 +101,7 @@ public class CatalogNotifyMessageHandler extends SIPRequestProcessorParent imple @@ -101,7 +101,7 @@ public class CatalogNotifyMessageHandler extends SIPRequestProcessorParent imple
101 101
102 cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size); 102 cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size);
103 // 防止发送过快 103 // 防止发送过快
104 - Thread.sleep(10); 104 + Thread.sleep(50);
105 } 105 }
106 } 106 }
107 // 回复直播的通道 107 // 回复直播的通道
@@ -124,7 +124,7 @@ public class CatalogNotifyMessageHandler extends SIPRequestProcessorParent imple @@ -124,7 +124,7 @@ public class CatalogNotifyMessageHandler extends SIPRequestProcessorParent imple
124 deviceChannel.setSecrecy("0"); 124 deviceChannel.setSecrecy("0");
125 cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size); 125 cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size);
126 // 防止发送过快 126 // 防止发送过快
127 - Thread.sleep(10); 127 + Thread.sleep(50);
128 } 128 }
129 } 129 }
130 if (size == 0) { 130 if (size == 0) {
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/query/cmd/CatalogQueryMessageHandler.java
  View file @b7635ec
@@ -92,7 +92,7 @@ public class CatalogQueryMessageHandler extends SIPRequestProcessorParent implem @@ -92,7 +92,7 @@ public class CatalogQueryMessageHandler extends SIPRequestProcessorParent implem
92 deviceChannel.setSecrecy("0"); 92 deviceChannel.setSecrecy("0");
93 cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size); 93 cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size);
94 // 防止发送过快 94 // 防止发送过快
95 - Thread.sleep(10); 95 + Thread.sleep(50);
96 } 96 }
97 } 97 }
98 // 回复级联的通道 98 // 回复级联的通道
@@ -104,7 +104,7 @@ public class CatalogQueryMessageHandler extends SIPRequestProcessorParent implem @@ -104,7 +104,7 @@ public class CatalogQueryMessageHandler extends SIPRequestProcessorParent implem
104 deviceChannel.setParentId(channelReduce.getCatalogId()); 104 deviceChannel.setParentId(channelReduce.getCatalogId());
105 cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size); 105 cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size);
106 // 防止发送过快 106 // 防止发送过快
107 - Thread.sleep(10); 107 + Thread.sleep(50);
108 } 108 }
109 } 109 }
110 // 回复直播的通道 110 // 回复直播的通道
@@ -127,6 +127,8 @@ public class CatalogQueryMessageHandler extends SIPRequestProcessorParent implem @@ -127,6 +127,8 @@ public class CatalogQueryMessageHandler extends SIPRequestProcessorParent implem
127 deviceChannel.setSecrecy("0"); 127 deviceChannel.setSecrecy("0");
128 128
129 cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size); 129 cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size);
  130 + // 防止发送过快
  131 + Thread.sleep(50);
130 } 132 }
131 } 133 }
132 if (size == 0) { 134 if (size == 0) {