From c16081fedad432740f20165e2dc8b940032cee57 Mon Sep 17 00:00:00 2001 From: Guoqs <123@jsowell.com> Date: Thu, 1 Aug 2024 10:54:13 +0800 Subject: [PATCH] rpc --- .../java/com/jsowell/netty}/rpc/ClientChannelInitializer.java | 2 +- .../src/main/java/com/jsowell/netty}/rpc/Message.java | 2 +- .../src/main/java/com/jsowell/netty}/rpc/MessageConstant.java | 2 +- .../src/main/java/com/jsowell/netty}/rpc/MessageDecode.java | 2 +- .../src/main/java/com/jsowell/netty}/rpc/MessageEncode.java | 2 +- .../src/main/java/com/jsowell/netty}/rpc/RpcClient.java | 2 +- .../src/main/java/com/jsowell/netty}/rpc/RpcRequest.java | 2 +- .../src/main/java/com/jsowell/netty}/rpc/RpcRequestHandler.java | 2 +- .../src/main/java/com/jsowell/netty}/rpc/RpcResponse.java | 2 +- .../main/java/com/jsowell/netty}/rpc/RpcResponseHandler.java | 2 +- .../src/main/java/com/jsowell/netty}/rpc/RpcServer.java | 2 +- .../src/main/java/com/jsowell/netty}/rpc/RpcUtil.java | 2 +- .../java/com/jsowell/netty}/rpc/ServerChannelInitializer.java | 2 +- .../src/main/java/com/jsowell/netty}/rpc/SyncPromise.java | 2 +- .../src/main/java/com/jsowell/netty}/rpc/TestRpcClient.java | 2 +- .../src/main/java/com/jsowell/netty}/rpc/TestRpcServer.java | 2 +- 16 files changed, 16 insertions(+), 16 deletions(-) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/ClientChannelInitializer.java (94%) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/Message.java (76%) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/MessageConstant.java (94%) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/MessageDecode.java (97%) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/MessageEncode.java (96%) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/RpcClient.java (97%) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/RpcRequest.java (91%) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/RpcRequestHandler.java (97%) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/RpcResponse.java (89%) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/RpcResponseHandler.java (95%) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/RpcServer.java (98%) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/RpcUtil.java (98%) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/ServerChannelInitializer.java (94%) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/SyncPromise.java (97%) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/TestRpcClient.java (98%) rename {jsowell-admin/src/test/java => jsowell-netty/src/main/java/com/jsowell/netty}/rpc/TestRpcServer.java (79%) diff --git a/jsowell-admin/src/test/java/rpc/ClientChannelInitializer.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/ClientChannelInitializer.java similarity index 94% rename from jsowell-admin/src/test/java/rpc/ClientChannelInitializer.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/ClientChannelInitializer.java index d086c5383..4c1f813f3 100644 --- a/jsowell-admin/src/test/java/rpc/ClientChannelInitializer.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/ClientChannelInitializer.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelPipeline; diff --git a/jsowell-admin/src/test/java/rpc/Message.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/Message.java similarity index 76% rename from jsowell-admin/src/test/java/rpc/Message.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/Message.java index 3323b79ea..0b733044e 100644 --- a/jsowell-admin/src/test/java/rpc/Message.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/Message.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; import lombok.Data; diff --git a/jsowell-admin/src/test/java/rpc/MessageConstant.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/MessageConstant.java similarity index 94% rename from jsowell-admin/src/test/java/rpc/MessageConstant.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/MessageConstant.java index f3f78453b..930cab4b8 100644 --- a/jsowell-admin/src/test/java/rpc/MessageConstant.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/MessageConstant.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; diff --git a/jsowell-admin/src/test/java/rpc/MessageDecode.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/MessageDecode.java similarity index 97% rename from jsowell-admin/src/test/java/rpc/MessageDecode.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/MessageDecode.java index 083f43166..d391a2943 100644 --- a/jsowell-admin/src/test/java/rpc/MessageDecode.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/MessageDecode.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; import com.jsowell.common.util.bean.SerializationUtil; import io.netty.buffer.ByteBuf; diff --git a/jsowell-admin/src/test/java/rpc/MessageEncode.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/MessageEncode.java similarity index 96% rename from jsowell-admin/src/test/java/rpc/MessageEncode.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/MessageEncode.java index 338a74ac3..b96edcb01 100644 --- a/jsowell-admin/src/test/java/rpc/MessageEncode.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/MessageEncode.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; import com.jsowell.common.util.bean.SerializationUtil; import io.netty.buffer.ByteBuf; diff --git a/jsowell-admin/src/test/java/rpc/RpcClient.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcClient.java similarity index 97% rename from jsowell-admin/src/test/java/rpc/RpcClient.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcClient.java index 92b615f73..2caefc9ae 100644 --- a/jsowell-admin/src/test/java/rpc/RpcClient.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcClient.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; import io.netty.bootstrap.Bootstrap; import io.netty.channel.*; diff --git a/jsowell-admin/src/test/java/rpc/RpcRequest.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcRequest.java similarity index 91% rename from jsowell-admin/src/test/java/rpc/RpcRequest.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcRequest.java index f55e85b71..8ffc0fcfb 100644 --- a/jsowell-admin/src/test/java/rpc/RpcRequest.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcRequest.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; import lombok.Data; import lombok.ToString; diff --git a/jsowell-admin/src/test/java/rpc/RpcRequestHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcRequestHandler.java similarity index 97% rename from jsowell-admin/src/test/java/rpc/RpcRequestHandler.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcRequestHandler.java index 74b432bca..59c034caf 100644 --- a/jsowell-admin/src/test/java/rpc/RpcRequestHandler.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcRequestHandler.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.DefaultEventLoopGroup; diff --git a/jsowell-admin/src/test/java/rpc/RpcResponse.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcResponse.java similarity index 89% rename from jsowell-admin/src/test/java/rpc/RpcResponse.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcResponse.java index 43e5a7ad8..075ae9186 100644 --- a/jsowell-admin/src/test/java/rpc/RpcResponse.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcResponse.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; import lombok.Data; import lombok.ToString; diff --git a/jsowell-admin/src/test/java/rpc/RpcResponseHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcResponseHandler.java similarity index 95% rename from jsowell-admin/src/test/java/rpc/RpcResponseHandler.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcResponseHandler.java index 085c5bf31..d98837b8a 100644 --- a/jsowell-admin/src/test/java/rpc/RpcResponseHandler.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcResponseHandler.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.SimpleChannelInboundHandler; diff --git a/jsowell-admin/src/test/java/rpc/RpcServer.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcServer.java similarity index 98% rename from jsowell-admin/src/test/java/rpc/RpcServer.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcServer.java index a1b55da49..ab72fbabe 100644 --- a/jsowell-admin/src/test/java/rpc/RpcServer.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcServer.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; import io.netty.bootstrap.ServerBootstrap; import io.netty.channel.*; diff --git a/jsowell-admin/src/test/java/rpc/RpcUtil.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcUtil.java similarity index 98% rename from jsowell-admin/src/test/java/rpc/RpcUtil.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcUtil.java index 5d8c4bf89..cc85f8581 100644 --- a/jsowell-admin/src/test/java/rpc/RpcUtil.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/RpcUtil.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; import io.netty.channel.Channel; diff --git a/jsowell-admin/src/test/java/rpc/ServerChannelInitializer.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/ServerChannelInitializer.java similarity index 94% rename from jsowell-admin/src/test/java/rpc/ServerChannelInitializer.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/ServerChannelInitializer.java index 283d00b5d..36858b982 100644 --- a/jsowell-admin/src/test/java/rpc/ServerChannelInitializer.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/ServerChannelInitializer.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelPipeline; diff --git a/jsowell-admin/src/test/java/rpc/SyncPromise.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/SyncPromise.java similarity index 97% rename from jsowell-admin/src/test/java/rpc/SyncPromise.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/SyncPromise.java index 4bcdb13fa..41ef7b322 100644 --- a/jsowell-admin/src/test/java/rpc/SyncPromise.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/SyncPromise.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; diff --git a/jsowell-admin/src/test/java/rpc/TestRpcClient.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/TestRpcClient.java similarity index 98% rename from jsowell-admin/src/test/java/rpc/TestRpcClient.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/TestRpcClient.java index aeba06cbb..b239e92a3 100644 --- a/jsowell-admin/src/test/java/rpc/TestRpcClient.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/TestRpcClient.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; import java.util.concurrent.TimeUnit; diff --git a/jsowell-admin/src/test/java/rpc/TestRpcServer.java b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/TestRpcServer.java similarity index 79% rename from jsowell-admin/src/test/java/rpc/TestRpcServer.java rename to jsowell-netty/src/main/java/com/jsowell/netty/rpc/TestRpcServer.java index c15d9e211..b346613c0 100644 --- a/jsowell-admin/src/test/java/rpc/TestRpcServer.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/rpc/TestRpcServer.java @@ -1,4 +1,4 @@ -package rpc; +package com.jsowell.netty.rpc; public class TestRpcServer { public static void main(String[] args) {