wangwei10061
/
webssh
0
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

节流

This commit is contained in:
weishao 2021-12-07 19:02:17 +08:00
parent 125907517a
commit 7e9a104ca5
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/net/educoder/bridge/webssh/service/TailfLogService.java
View File

@ -15,10 +15,6 @@ import java.io.File;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.concurrent.ConcurrentHashMap;
import java.io.*;
import java.util.Arrays;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
@ -50,7 +46,6 @@ public class TailfLogService {
if ("log".equals(tp)) {
// 不存在则创建
String filePath = "/data/workspace/myshixun_" + msg.getString("data") + "/user.out";
// String filePath = "/tmp/myshixun_" + msg.getString("data") + "/user.out";
File file = new File(filePath);
if (!file.exists()) {
try {
@ -97,7 +92,6 @@ public class TailfLogService {
* @param session session
*/
public void close(WebSocketSession session) {
if (session != null) {
try {
Process process = sessionProcessMap.get(session.getId());
@ -124,11 +118,13 @@ public class TailfLogService {
boolean result = false;
try {
session.sendMessage(new TextMessage(Base64Util.encodeBytes(buffer)));
Thread.sleep(100);
result = true;
} catch (IllegalStateException e) {
logger.error("tailf连接断开, session: {}", session.getId(), e);
} catch (IOException e) {
logger.error("读取tailf输出异常, session: {}", session.getId(), e);
} catch (InterruptedException ignore) {
}
return result;
}