mirror of
https://github.com/actiontech/dble.git
synced 2026-04-28 18:20:43 -05:00
@@ -24,7 +24,7 @@
|
||||
<project.build.sourceEncoding>
|
||||
UTF-8
|
||||
</project.build.sourceEncoding>
|
||||
<grpc.version>1.53.0</grpc.version><!-- CURRENT_GRPC_VERSION -->
|
||||
<grpc.version>1.4.0</grpc.version><!-- CURRENT_GRPC_VERSION -->
|
||||
<log4j2.version>2.18.0</log4j2.version>
|
||||
</properties>
|
||||
<repositories>
|
||||
@@ -76,7 +76,7 @@
|
||||
<dependency>
|
||||
<groupId>com.google.protobuf</groupId>
|
||||
<artifactId>protobuf-java</artifactId>
|
||||
<version>3.16.3</version>
|
||||
<version>2.6.1</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.iq80.leveldb</groupId>
|
||||
@@ -198,7 +198,7 @@
|
||||
<dependency>
|
||||
<groupId>com.google.protobuf</groupId>
|
||||
<artifactId>protobuf-java</artifactId>
|
||||
<version>3.16.3</version>
|
||||
<version>3.5.0</version>
|
||||
</dependency>
|
||||
<!--DOM4J FOR XML -->
|
||||
<dependency>
|
||||
|
||||
@@ -63,7 +63,7 @@ public final class UcoreSender extends AbstractClusterSender {
|
||||
LOGGER.error("error:", e);
|
||||
}
|
||||
Channel channel = ManagedChannelBuilder.forAddress(getIpList().get(0),
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = UcoreGrpc.newBlockingStub(channel).withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS);
|
||||
}
|
||||
|
||||
@@ -80,7 +80,7 @@ public final class UcoreSender extends AbstractClusterSender {
|
||||
LOGGER.error("error:", e);
|
||||
}
|
||||
Channel channel = ManagedChannelBuilder.forAddress(getIpList().get(0),
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = UcoreGrpc.newBlockingStub(channel).withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS);
|
||||
startUpdateNodes();
|
||||
}
|
||||
@@ -139,7 +139,7 @@ public final class UcoreSender extends AbstractClusterSender {
|
||||
ManagedChannel channel = null;
|
||||
try {
|
||||
channel = ManagedChannelBuilder.forAddress(ip,
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = UcoreGrpc.newBlockingStub(channel).withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS);
|
||||
output = stub.withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS).lockOnSession(input);
|
||||
return output.getSessionId();
|
||||
@@ -178,7 +178,7 @@ public final class UcoreSender extends AbstractClusterSender {
|
||||
ManagedChannel channel = null;
|
||||
try {
|
||||
channel = ManagedChannelBuilder.forAddress(ip,
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = UcoreGrpc.newBlockingStub(channel).withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS);
|
||||
stub.withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS).putKv(input);
|
||||
return;
|
||||
@@ -205,7 +205,7 @@ public final class UcoreSender extends AbstractClusterSender {
|
||||
ManagedChannel channel = null;
|
||||
try {
|
||||
channel = ManagedChannelBuilder.forAddress(ip,
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = UcoreGrpc.newBlockingStub(channel).withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS);
|
||||
output = stub.withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS).getKv(input);
|
||||
} catch (Exception e2) {
|
||||
@@ -240,7 +240,7 @@ public final class UcoreSender extends AbstractClusterSender {
|
||||
ManagedChannel channel = null;
|
||||
try {
|
||||
channel = ManagedChannelBuilder.forAddress(ip,
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = UcoreGrpc.newBlockingStub(channel).withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS);
|
||||
output = stub.withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS).getKvTree(input);
|
||||
} catch (Exception e2) {
|
||||
@@ -275,7 +275,7 @@ public final class UcoreSender extends AbstractClusterSender {
|
||||
ManagedChannel channel = null;
|
||||
try {
|
||||
channel = ManagedChannelBuilder.forAddress(ip,
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = UcoreGrpc.newBlockingStub(channel).withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS);
|
||||
stub.withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS).deleteKvTree(input);
|
||||
flag = true;
|
||||
@@ -302,7 +302,7 @@ public final class UcoreSender extends AbstractClusterSender {
|
||||
ManagedChannel channel = null;
|
||||
try {
|
||||
channel = ManagedChannelBuilder.forAddress(ip,
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = UcoreGrpc.newBlockingStub(channel).withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS);
|
||||
stub.withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS).deleteKv(input);
|
||||
return;
|
||||
@@ -330,7 +330,7 @@ public final class UcoreSender extends AbstractClusterSender {
|
||||
ManagedChannel channel = null;
|
||||
try {
|
||||
channel = ManagedChannelBuilder.forAddress(ip,
|
||||
Integer.parseInt(ClusterGeneralConfig.getInstance().getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
Integer.parseInt(ClusterGeneralConfig.getInstance().getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = UcoreGrpc.newBlockingStub(channel).withDeadlineAfter(GRPC_SUBTIMEOUT, TimeUnit.SECONDS);
|
||||
UcoreInterface.SubscribeKvPrefixOutput output = stub.withDeadlineAfter(GRPC_SUBTIMEOUT, TimeUnit.SECONDS).subscribeKvPrefix(input);
|
||||
return groupSubscribeResult(output);
|
||||
@@ -355,7 +355,7 @@ public final class UcoreSender extends AbstractClusterSender {
|
||||
for (String ip : getIpList()) {
|
||||
ManagedChannel channel = null;
|
||||
try {
|
||||
channel = ManagedChannelBuilder.forAddress(ip, Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
channel = ManagedChannelBuilder.forAddress(ip, Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = UcoreGrpc.newBlockingStub(channel).withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS);
|
||||
stub.withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS).alert(input);
|
||||
return;
|
||||
@@ -379,7 +379,7 @@ public final class UcoreSender extends AbstractClusterSender {
|
||||
for (String ip : getIpList()) {
|
||||
ManagedChannel channel = null;
|
||||
try {
|
||||
channel = ManagedChannelBuilder.forAddress(ip, Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
channel = ManagedChannelBuilder.forAddress(ip, Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = UcoreGrpc.newBlockingStub(channel).withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS);
|
||||
stub.withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS).alertResolve(input);
|
||||
return true;
|
||||
@@ -432,7 +432,7 @@ public final class UcoreSender extends AbstractClusterSender {
|
||||
ManagedChannel channel = null;
|
||||
try {
|
||||
channel = ManagedChannelBuilder.forAddress(ip,
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = UcoreGrpc.newBlockingStub(channel).withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS);
|
||||
stub.withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS).renewSession(input);
|
||||
return true;
|
||||
@@ -469,7 +469,7 @@ public final class UcoreSender extends AbstractClusterSender {
|
||||
ManagedChannel channel = null;
|
||||
try {
|
||||
channel = ManagedChannelBuilder.forAddress(ip,
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = UcoreGrpc.newBlockingStub(channel).withDeadlineAfter(GRPC_SUBTIMEOUT, TimeUnit.SECONDS);
|
||||
return stub.withDeadlineAfter(GRPC_SUBTIMEOUT, TimeUnit.SECONDS).subscribeNodes(subscribeNodesInput);
|
||||
} catch (Exception e2) {
|
||||
|
||||
@@ -41,7 +41,7 @@ public class UshardSender extends AbstractClusterSender {
|
||||
serverId = getValue(ClusterParamCfg.CLUSTER_CFG_SERVER_ID);
|
||||
sourceComponentId = getValue(ClusterParamCfg.CLUSTER_CFG_MYID);
|
||||
Channel channel = ManagedChannelBuilder.forAddress("127.0.0.1",
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = DbleClusterGrpc.newBlockingStub(channel).withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS);
|
||||
}
|
||||
|
||||
@@ -51,7 +51,7 @@ public class UshardSender extends AbstractClusterSender {
|
||||
serverId = getValue(ClusterParamCfg.CLUSTER_CFG_SERVER_ID);
|
||||
sourceComponentId = getValue(ClusterParamCfg.CLUSTER_CFG_MYID);
|
||||
Channel channel = ManagedChannelBuilder.forAddress("127.0.0.1",
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = DbleClusterGrpc.newBlockingStub(channel).withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS);
|
||||
startUpdateNodes();
|
||||
}
|
||||
@@ -302,7 +302,7 @@ public class UshardSender extends AbstractClusterSender {
|
||||
} catch (Exception e) {
|
||||
LOGGER.warn("error in ucore nodes watch,try for another time", e);
|
||||
Channel channel = ManagedChannelBuilder.forAddress("127.0.0.1",
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext().build();
|
||||
Integer.parseInt(getValue(ClusterParamCfg.CLUSTER_PLUGINS_PORT))).usePlaintext(true).build();
|
||||
stub = DbleClusterGrpc.newBlockingStub(channel).withDeadlineAfter(GENERAL_GRPC_TIMEOUT, TimeUnit.SECONDS);
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user