diff --git a/pom.xml b/pom.xml index 0331404..5ccbb59 100644 --- a/pom.xml +++ b/pom.xml @@ -27,7 +27,7 @@ 2.1.0 1.30 - 1.0.0-SNAPSHOT + 1.0.2 diff --git a/src/main/java/com/yuandian/dataflow/grpc/CollectPackets.java b/src/main/java/com/yuandian/dataflow/grpc/CollectPackets.java index 1ff313a..eb6e775 100644 --- a/src/main/java/com/yuandian/dataflow/grpc/CollectPackets.java +++ b/src/main/java/com/yuandian/dataflow/grpc/CollectPackets.java @@ -115,8 +115,8 @@ public class CollectPackets extends CollectPacketsServerImplBase { - // private final ManagedChannelBuilder managedChannelBuilder; - // private final CollectPacketsServerStub blockingStub; + // private final ManagedChannelBuilder managedChannelBuilder; + // private final CollectPacketsServerStub blockingStub; // private final ManagedChannel channel; // public Client(String name, int port) { @@ -130,7 +130,7 @@ public class CollectPackets extends CollectPacketsServerImplBase { // MyThing.Response response = blockingStub.sayHi(request); // System.out.println(response.getName()); // } - var managedChannelBuilder = ManagedChannelBuilder.forAddress("localhost", 50051); + var managedChannelBuilder = ManagedChannelBuilder.forAddress("10.1.1.117", 50051); var channel = managedChannelBuilder.usePlaintext().build(); var stub = CollectPacketsServerGrpc.newBlockingStub(channel); // stub.withCompression("snappy"); @@ -151,6 +151,5 @@ public class CollectPackets extends CollectPacketsServerImplBase { log.info("条数:{}, {}:ms",i,Duration.between(now, Instant.now()).toMillis()); } - } } diff --git a/src/main/resources/logback.xml b/src/main/resources/logback.xml index 615c996..0ce9599 100644 --- a/src/main/resources/logback.xml +++ b/src/main/resources/logback.xml @@ -3,7 +3,7 @@ class="ch.qos.logback.core.ConsoleAppender"> - %d{yyyyMMdd HH:mm:ss.SSS} %-5level[%thread\(%file:%line\)]: %msg%n + %d{yyyyMMdd HH:mm:ss.SSS} %-5level%thread(%file:%line): %msg%n