From c762adb39d6057ee5baff8742ca25ab689fafff3 Mon Sep 17 00:00:00 2001 From: pizihao <2335715300@qq.com> Date: Tue, 15 Nov 2022 18:34:59 +0800 Subject: [PATCH] fix : Modify some comments and code structure --- hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/Client.java | 2 ++ .../src/main/java/cn/hippo4j/rpc/client/ClientConnection.java | 2 ++ .../main/java/cn/hippo4j/rpc/client/NettyClientConnection.java | 2 ++ hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/RPCClient.java | 2 ++ .../java/cn/hippo4j/rpc/coder/CompactObjectOutputStream.java | 2 ++ .../src/main/java/cn/hippo4j/rpc/coder/NettyEncoder.java | 2 ++ .../src/main/java/cn/hippo4j/rpc/discovery/ClassRegistry.java | 2 ++ .../src/main/java/cn/hippo4j/rpc/discovery/DefaultInstance.java | 2 ++ .../main/java/cn/hippo4j/rpc/discovery/DiscoveryAdapter.java | 2 ++ .../src/main/java/cn/hippo4j/rpc/discovery/Instance.java | 2 ++ .../src/main/java/cn/hippo4j/rpc/discovery/ServerPort.java | 2 ++ .../java/cn/hippo4j/rpc/discovery/SpringContextInstance.java | 2 ++ .../src/main/java/cn/hippo4j/rpc/exception/CoderException.java | 2 ++ .../main/java/cn/hippo4j/rpc/exception/ConnectionException.java | 2 ++ .../main/java/cn/hippo4j/rpc/exception/TimeOutException.java | 2 ++ .../cn/hippo4j/rpc/handler/AbstractNettyHandlerManager.java | 2 ++ .../java/cn/hippo4j/rpc/handler/AbstractNettyTakeHandler.java | 2 ++ .../src/main/java/cn/hippo4j/rpc/handler/ConnectHandler.java | 1 + .../src/main/java/cn/hippo4j/rpc/handler/Connection.java | 2 ++ .../src/main/java/cn/hippo4j/rpc/handler/HandlerManager.java | 2 ++ .../java/cn/hippo4j/rpc/handler/NettyClientPoolHandler.java | 2 ++ .../java/cn/hippo4j/rpc/handler/NettyClientTakeHandler.java | 2 ++ .../java/cn/hippo4j/rpc/handler/NettyServerTakeHandler.java | 2 ++ .../src/main/java/cn/hippo4j/rpc/model/DefaultRequest.java | 2 ++ .../src/main/java/cn/hippo4j/rpc/model/DefaultResponse.java | 2 ++ hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/Request.java | 2 ++ hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/Response.java | 2 ++ .../src/main/java/cn/hippo4j/rpc/process/ActivePostProcess.java | 2 ++ .../main/java/cn/hippo4j/rpc/process/ActiveProcessChain.java | 1 + .../main/java/cn/hippo4j/rpc/server/NettyServerConnection.java | 2 ++ hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/RPCServer.java | 2 ++ hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/Server.java | 2 ++ .../src/main/java/cn/hippo4j/rpc/server/ServerConnection.java | 2 ++ .../src/main/java/cn/hippo4j/rpc/support/ClientFactoryBean.java | 1 + .../main/java/cn/hippo4j/rpc/support/NettyClientSupport.java | 1 + .../src/main/java/cn/hippo4j/rpc/support/NettyConnectPool.java | 2 ++ .../java/cn/hippo4j/rpc/support/NettyConnectPoolHolder.java | 2 ++ .../src/main/java/cn/hippo4j/rpc/support/NettyProxyCenter.java | 2 ++ .../main/java/cn/hippo4j/rpc/support/NettyServerSupport.java | 1 + .../src/main/java/cn/hippo4j/rpc/support/ResultHolder.java | 2 ++ 40 files changed, 75 insertions(+) diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/Client.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/Client.java index c1199a8c..c4efcd25 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/Client.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/Client.java @@ -44,6 +44,8 @@ import java.io.Closeable; * * The client implements Closeable and supports automatic shutdown, However, you can manually * disable it when you want to use it + * + * @since 1.5.1 */ public interface Client extends Closeable { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/ClientConnection.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/ClientConnection.java index 5588d8e2..e3fb241c 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/ClientConnection.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/ClientConnection.java @@ -23,6 +23,8 @@ import cn.hippo4j.rpc.model.Response; /** * Applicable to client connections
+ * + * @since 1.5.1 */ public interface ClientConnection extends Connection { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/NettyClientConnection.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/NettyClientConnection.java index 3a3b92e1..31ded8c1 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/NettyClientConnection.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/NettyClientConnection.java @@ -42,6 +42,8 @@ import java.util.concurrent.locks.LockSupport; /** * Client implemented using netty + * + * @since 1.5.1 */ @Slf4j public class NettyClientConnection implements ClientConnection { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/RPCClient.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/RPCClient.java index 76b4d8f9..f9eb8eea 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/RPCClient.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/client/RPCClient.java @@ -25,6 +25,8 @@ import java.io.IOException; /** * The client, which provides a closing mechanism, maintains a persistent connection if not closed
* Delegate the method to the {@link ClientConnection} for implementation + * + * @since 1.5.1 */ public class RPCClient implements Client { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/coder/CompactObjectOutputStream.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/coder/CompactObjectOutputStream.java index 599cf118..36c34f9c 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/coder/CompactObjectOutputStream.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/coder/CompactObjectOutputStream.java @@ -24,6 +24,8 @@ import java.io.OutputStream; /** * object OutputStream + * + * @since 1.5.1 */ public class CompactObjectOutputStream extends ObjectOutputStream { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/coder/NettyEncoder.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/coder/NettyEncoder.java index 856aae2a..7cbfaff7 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/coder/NettyEncoder.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/coder/NettyEncoder.java @@ -29,6 +29,8 @@ import java.io.Serializable; /** * this is a encoder, For custom gluing and unpacking
* {@link io.netty.handler.codec.serialization.ObjectEncoder} + * + * @since 1.5.1 */ public class NettyEncoder extends MessageToByteEncoder { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/ClassRegistry.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/ClassRegistry.java index 5af58c87..68419e1b 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/ClassRegistry.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/ClassRegistry.java @@ -25,6 +25,8 @@ import java.util.concurrent.ConcurrentHashMap; /** * the registration center for Client and Server + * + * @since 1.5.1 */ @NoArgsConstructor(access = AccessLevel.PRIVATE) public class ClassRegistry { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/DefaultInstance.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/DefaultInstance.java index 4c6d6741..44b9a6f4 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/DefaultInstance.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/DefaultInstance.java @@ -27,6 +27,8 @@ import java.util.ServiceLoader; * You simply create an instance of a class based on its name and specific type. * Load through the ServiceLoader first. If the load fails, load directly through the instantiation. * If it is an interface, throw an exception. This is not elegant implementation + * + * @since 1.5.1 */ public class DefaultInstance implements Instance { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/DiscoveryAdapter.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/DiscoveryAdapter.java index 3a788f30..119fde6e 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/DiscoveryAdapter.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/DiscoveryAdapter.java @@ -22,6 +22,8 @@ import java.net.InetSocketAddress; /** * The adaptation layer of different service centers is used to know * the host of different services through the registration center + * + * @since 1.5.1 */ public interface DiscoveryAdapter { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/Instance.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/Instance.java index aab7163c..83f649f0 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/Instance.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/Instance.java @@ -19,6 +19,8 @@ package cn.hippo4j.rpc.discovery; /** * Instance interface to get an instance + * + * @since 1.5.1 */ public interface Instance { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/ServerPort.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/ServerPort.java index 5795058c..82e240a7 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/ServerPort.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/ServerPort.java @@ -19,6 +19,8 @@ package cn.hippo4j.rpc.discovery; /** * Gets the top-level interface of the instance port + * + * @since 1.5.1 */ @FunctionalInterface public interface ServerPort { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/SpringContextInstance.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/SpringContextInstance.java index 5cbc79c7..fa25d4c9 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/SpringContextInstance.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/discovery/SpringContextInstance.java @@ -21,6 +21,8 @@ import cn.hippo4j.common.config.ApplicationContextHolder; /** * Adapter Spring, The requested object is managed by spring + * + * @since 1.5.1 */ public class SpringContextInstance implements Instance { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/exception/CoderException.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/exception/CoderException.java index 5ac64a5a..e891772c 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/exception/CoderException.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/exception/CoderException.java @@ -20,6 +20,8 @@ package cn.hippo4j.rpc.exception; /** * During decoding and encoding, if an exception occurs, an exception of type {@link CoderException} is thrown, * which is not different from a {@link RuntimeException}, but is more explicit about the type of exception + * + * @since 1.5.1 */ public class CoderException extends RuntimeException { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/exception/ConnectionException.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/exception/ConnectionException.java index 87e29423..aaf6edd2 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/exception/ConnectionException.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/exception/ConnectionException.java @@ -21,6 +21,8 @@ package cn.hippo4j.rpc.exception; * If an exception occurs during the connection between the server and the client, an exception of type * {@link ConnectionException} is thrown, which is not different from {@link RuntimeException}, but is more explicit * about the type of exception + * + * @since 1.5.1 */ public class ConnectionException extends RuntimeException { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/exception/TimeOutException.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/exception/TimeOutException.java index ef808b57..43d51057 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/exception/TimeOutException.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/exception/TimeOutException.java @@ -20,6 +20,8 @@ package cn.hippo4j.rpc.exception; /** * If there is a timeout between the server and the client, you will get a {@link TimeOutException}, * which is not different from {@link RuntimeException}, but it will be more explicit about the type of exception, right + * + * @since 1.5.1 */ public class TimeOutException extends RuntimeException { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/AbstractNettyHandlerManager.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/AbstractNettyHandlerManager.java index 0460bb5e..2157c202 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/AbstractNettyHandlerManager.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/AbstractNettyHandlerManager.java @@ -26,6 +26,8 @@ import java.util.stream.Collectors; /** * Processor manager for ChannelHandler in netty + * + * @since 1.5.1 */ public abstract class AbstractNettyHandlerManager implements HandlerManager { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/AbstractNettyTakeHandler.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/AbstractNettyTakeHandler.java index 9d037b33..3bc02728 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/AbstractNettyTakeHandler.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/AbstractNettyTakeHandler.java @@ -28,6 +28,8 @@ import java.util.Optional; /** * the abstract base of {@link ConnectHandler} and {@link ChannelInboundHandlerAdapter} + * + * @since 1.5.1 */ public abstract class AbstractNettyTakeHandler extends ChannelInboundHandlerAdapter implements ConnectHandler { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/ConnectHandler.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/ConnectHandler.java index f12a846e..35c900fc 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/ConnectHandler.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/ConnectHandler.java @@ -25,6 +25,7 @@ import cn.hippo4j.rpc.model.Response; * must be specified, such as serialization and parsing, requesting and receiving * requests, and so on
* + * @since 1.5.1 */ public interface ConnectHandler { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/Connection.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/Connection.java index 0cb5a97d..943b4f54 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/Connection.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/Connection.java @@ -26,6 +26,8 @@ import java.io.Closeable; * operations that should be done in the connection. It is more like integrating the * connection and the connection channel together, so creating {@link Connection} is * very resource intensive, for which caching is recommended + * + * @since 1.5.1 */ public interface Connection extends Closeable { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/HandlerManager.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/HandlerManager.java index cf72aea3..c5071829 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/HandlerManager.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/HandlerManager.java @@ -25,6 +25,8 @@ import lombok.Getter; /** * Manage the Handler used in the processing.
* The Handler must be able to exist multiple times and be invoked once in a single execution + * + * @since 1.5.1 */ public interface HandlerManager { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/NettyClientPoolHandler.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/NettyClientPoolHandler.java index 3b0b7753..429a4435 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/NettyClientPoolHandler.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/NettyClientPoolHandler.java @@ -32,6 +32,8 @@ import java.util.List; /** * Processing by the client connection pool handler to clean the buffer and define new connection properties + * + * @since 1.5.1 */ @Slf4j public class NettyClientPoolHandler extends AbstractNettyHandlerManager implements ChannelPoolHandler { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/NettyClientTakeHandler.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/NettyClientTakeHandler.java index 1841d7f9..b1852bd5 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/NettyClientTakeHandler.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/NettyClientTakeHandler.java @@ -24,6 +24,8 @@ import io.netty.channel.ChannelHandlerContext; /** * Interconnect with the netty mediation layer + * + * @since 1.5.1 */ @ChannelHandler.Sharable public class NettyClientTakeHandler extends AbstractNettyTakeHandler implements ConnectHandler { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/NettyServerTakeHandler.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/NettyServerTakeHandler.java index 936f136f..185de796 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/NettyServerTakeHandler.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/handler/NettyServerTakeHandler.java @@ -35,6 +35,8 @@ import java.util.List; /** * netty adaptation layer + * + * @since 1.5.1 */ @ChannelHandler.Sharable public class NettyServerTakeHandler extends AbstractNettyTakeHandler implements ConnectHandler { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/DefaultRequest.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/DefaultRequest.java index 04ca4191..4dc30bb8 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/DefaultRequest.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/DefaultRequest.java @@ -25,6 +25,8 @@ import java.util.Objects; /** * default request
* Use the fully qualified name key of the interface and override equals and hashCode + * + * @since 1.5.1 */ public final class DefaultRequest implements Request { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/DefaultResponse.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/DefaultResponse.java index d6602a72..0fc68f44 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/DefaultResponse.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/DefaultResponse.java @@ -25,6 +25,8 @@ import java.util.Objects; /** * default request
* Use the fully qualified name key of the interface and override equals and hashCode + * + * @since 1.5.1 */ public class DefaultResponse implements Response { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/Request.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/Request.java index 461e40e5..128d069e 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/Request.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/Request.java @@ -21,6 +21,8 @@ import java.io.Serializable; /** * request + * + * @since 1.5.1 */ public interface Request extends Serializable { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/Response.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/Response.java index 83b31444..a7b2642a 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/Response.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/model/Response.java @@ -21,6 +21,8 @@ import java.io.Serializable; /** * Response + * + * @since 1.5.1 */ public interface Response extends Serializable { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/process/ActivePostProcess.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/process/ActivePostProcess.java index 9e7fee18..a183d335 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/process/ActivePostProcess.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/process/ActivePostProcess.java @@ -22,6 +22,8 @@ import cn.hippo4j.rpc.model.Response; /** * Callback while the connection is in progress + * + * @since 1.5.1 */ public interface ActivePostProcess { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/process/ActiveProcessChain.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/process/ActiveProcessChain.java index cb59491e..aa181ee4 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/process/ActiveProcessChain.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/process/ActiveProcessChain.java @@ -30,6 +30,7 @@ import java.util.List; * reference resources: spring HandlerExecutionChain * * @see ActivePostProcess + * @since 1.5.1 */ @Slf4j public final class ActiveProcessChain { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/NettyServerConnection.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/NettyServerConnection.java index 8a30d055..f4cf86d0 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/NettyServerConnection.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/NettyServerConnection.java @@ -37,6 +37,8 @@ import java.util.List; /** * adapter to the netty server + * + * @since 1.5.1 */ @Slf4j public class NettyServerConnection extends AbstractNettyHandlerManager implements ServerConnection { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/RPCServer.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/RPCServer.java index d5247a38..bc35957e 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/RPCServer.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/RPCServer.java @@ -25,6 +25,8 @@ import java.util.concurrent.CompletableFuture; /** * Server Implementation + * + * @since 1.5.1 */ public class RPCServer implements Server { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/Server.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/Server.java index 9c21f788..5c346525 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/Server.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/Server.java @@ -21,6 +21,8 @@ import java.io.Closeable; /** * the service for RPC, Explain the role of the service in the request + * + * @since 1.5.1 */ public interface Server extends Closeable { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/ServerConnection.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/ServerConnection.java index 37edfc62..a1a830ca 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/ServerConnection.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/server/ServerConnection.java @@ -22,6 +22,8 @@ import cn.hippo4j.rpc.handler.Connection; /** * This applies to server-side connections + * + * @since 1.5.1 */ public interface ServerConnection extends Connection { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/ClientFactoryBean.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/ClientFactoryBean.java index 3b115bca..37b63596 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/ClientFactoryBean.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/ClientFactoryBean.java @@ -54,6 +54,7 @@ import java.util.Optional; *
  • {@link DisposableBean}
    • * * + * @since 1.5.1 * @deprecated With {@link cn.hippo4j.config.service.ThreadPoolAdapterService} structure, FactoryBean is not the best choice */ @Deprecated diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyClientSupport.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyClientSupport.java index a604a8b2..a6dff592 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyClientSupport.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyClientSupport.java @@ -52,6 +52,7 @@ import java.util.concurrent.ConcurrentHashMap; * @see cn.hippo4j.rpc.client.NettyClientConnection * @see NettyServerSupport * @see ClientFactoryBean + * @since 1.5.1 */ @NoArgsConstructor(access = AccessLevel.PRIVATE) public final class NettyClientSupport { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyConnectPool.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyConnectPool.java index 594c754f..dc2f9b57 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyConnectPool.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyConnectPool.java @@ -35,6 +35,8 @@ import java.util.concurrent.TimeUnit; /** * This parameter applies only to the connection pool of netty + * + * @since 1.5.1 */ @Slf4j public class NettyConnectPool { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyConnectPoolHolder.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyConnectPoolHolder.java index f1f88856..6af34cd6 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyConnectPoolHolder.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyConnectPoolHolder.java @@ -31,6 +31,8 @@ import java.util.concurrent.ConcurrentHashMap; /** * To avoid creating multiple connection pools for the same host:port, save all connection pools of the client + * + * @since 1.5.1 */ @NoArgsConstructor(access = AccessLevel.PRIVATE) public class NettyConnectPoolHolder { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyProxyCenter.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyProxyCenter.java index 836070ea..1a0dd1fd 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyProxyCenter.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyProxyCenter.java @@ -36,6 +36,8 @@ import java.util.concurrent.ConcurrentHashMap; /** * Add a proxy for the request, {@link Proxy} and {@link InvocationHandler} + * + * @since 1.5.1 */ @NoArgsConstructor(access = AccessLevel.PRIVATE) public class NettyProxyCenter { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyServerSupport.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyServerSupport.java index 0099663a..580b12a8 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyServerSupport.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/NettyServerSupport.java @@ -40,6 +40,7 @@ import java.util.List; * @see RPCServer * @see NettyServerConnection * @see NettyClientSupport + * @since 1.5.1 */ public class NettyServerSupport implements Server { diff --git a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/ResultHolder.java b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/ResultHolder.java index 613a079b..19ebc5db 100644 --- a/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/ResultHolder.java +++ b/hippo4j-rpc/src/main/java/cn/hippo4j/rpc/support/ResultHolder.java @@ -31,6 +31,8 @@ import java.util.concurrent.locks.LockSupport; * The unique remote call can be determined by the key of request and * response, and the result of the call is stored in the secondary cache, * which is convenient for the client to use at any time. + * + * @since 1.5.1 */ @Slf4j @NoArgsConstructor(access = AccessLevel.PRIVATE)