|
|
|
@ -12,10 +12,10 @@ import okhttp3.OkHttpClient;
|
|
|
|
|
import org.apache.logging.log4j.LogManager; |
|
|
|
|
import org.apache.logging.log4j.Logger; |
|
|
|
|
|
|
|
|
|
import java.io.IOException; |
|
|
|
|
import java.io.InputStream; |
|
|
|
|
import java.io.InputStreamReader; |
|
|
|
|
import java.net.URI; |
|
|
|
|
import java.nio.charset.StandardCharsets; |
|
|
|
|
import java.util.List; |
|
|
|
|
import java.util.Properties; |
|
|
|
|
import java.util.concurrent.TimeUnit; |
|
|
|
@ -43,14 +43,14 @@ public class AgentStarter {
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private void createSocket(String[][] DBs) throws IOException { |
|
|
|
|
private void createSocket(String[][] DBs){ |
|
|
|
|
logger.debug("加载配置"); |
|
|
|
|
IO.Options options = new IO.Options(); |
|
|
|
|
try{ |
|
|
|
|
InputStream in = this.getClass().getResourceAsStream("/socket.properties"); |
|
|
|
|
Properties props = new Properties(); |
|
|
|
|
|
|
|
|
|
InputStreamReader inputStreamReader = new InputStreamReader(in, "UTF-8"); |
|
|
|
|
InputStreamReader inputStreamReader = new InputStreamReader(in, StandardCharsets.UTF_8); |
|
|
|
|
props.load(inputStreamReader); |
|
|
|
|
|
|
|
|
|
options.transports = new String[]{WebSocket.NAME}; |
|
|
|
@ -101,14 +101,14 @@ public class AgentStarter {
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private void configDefaultSocket(Socket socket) throws IOException { |
|
|
|
|
socket.on(Socket.EVENT_CONNECT, objects -> { |
|
|
|
|
logger.info("default-socket connected!"); |
|
|
|
|
}); |
|
|
|
|
private void configDefaultSocket(Socket socket){ |
|
|
|
|
socket.on(Socket.EVENT_CONNECT, (objects) -> |
|
|
|
|
logger.info("default-socket connected!") |
|
|
|
|
); |
|
|
|
|
|
|
|
|
|
socket.on(Socket.EVENT_CONNECT_ERROR, objects -> { |
|
|
|
|
logger.info("default-socket error: " + objects[0].toString()); |
|
|
|
|
}); |
|
|
|
|
socket.on(Socket.EVENT_CONNECT_ERROR, objects -> |
|
|
|
|
logger.info("default-socket error: " + objects[0].toString()) |
|
|
|
|
); |
|
|
|
|
|
|
|
|
|
socket.on(Socket.EVENT_DISCONNECT, objects -> { |
|
|
|
|
for(Object obj : objects){ |
|
|
|
@ -117,10 +117,10 @@ public class AgentStarter {
|
|
|
|
|
}); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private void configSocket(Socket socket, String dbName) throws IOException { |
|
|
|
|
socket.on(Socket.EVENT_CONNECT, objects -> { |
|
|
|
|
logger.info(dbName + "-socket connected!"); |
|
|
|
|
}); |
|
|
|
|
private void configSocket(Socket socket, String dbName){ |
|
|
|
|
socket.on(Socket.EVENT_CONNECT, objects -> |
|
|
|
|
logger.info(dbName + "-socket connected!") |
|
|
|
|
); |
|
|
|
|
|
|
|
|
|
socket.on(Socket.EVENT_DISCONNECT, objects -> { |
|
|
|
|
for(Object obj : objects){ |
|
|
|
@ -128,9 +128,9 @@ public class AgentStarter {
|
|
|
|
|
} |
|
|
|
|
}); |
|
|
|
|
|
|
|
|
|
socket.on(Socket.EVENT_CONNECT_ERROR, objects -> { |
|
|
|
|
logger.info(dbName + "-socket error: " + objects[0].toString()); |
|
|
|
|
}); |
|
|
|
|
socket.on(Socket.EVENT_CONNECT_ERROR, objects -> |
|
|
|
|
logger.info(dbName + "-socket error: " + objects[0].toString()) |
|
|
|
|
); |
|
|
|
|
|
|
|
|
|
socket.on("RPCRequest", objects -> { |
|
|
|
|
RpcRequest rpcRequest = SERIALIZER.deserialize((byte[]) objects[0], RpcRequest.class); |
|
|
|
|