diff --git a/threadpool/rpc/src/main/java/cn/hippo4j/rpc/handler/Connection.java b/threadpool/rpc/src/main/java/cn/hippo4j/rpc/connection/ServerConnection.java similarity index 84% rename from threadpool/rpc/src/main/java/cn/hippo4j/rpc/handler/Connection.java rename to threadpool/rpc/src/main/java/cn/hippo4j/rpc/connection/ServerConnection.java index 5f93bab7..3441c7e2 100644 --- a/threadpool/rpc/src/main/java/cn/hippo4j/rpc/handler/Connection.java +++ b/threadpool/rpc/src/main/java/cn/hippo4j/rpc/connection/ServerConnection.java @@ -15,28 +15,34 @@ * limitations under the License. */ -package cn.hippo4j.rpc.handler; +package cn.hippo4j.rpc.connection; + +import cn.hippo4j.rpc.discovery.ServerPort; import java.io.Closeable; /** + * This applies to server-side connections + *
* Represents a network request connection and provides IO layer support
*
* This is not a strict and stateless Connection interface, it contains the necessary
* 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
+ * connection and the connection channel together, so creating {@link ServerConnection} is
* very resource intensive, for which caching is recommended
*
* @since 2.0.0
*/
-public interface Connection extends Closeable {
+public interface ServerConnection extends Closeable {
+
+ /**
+ * Bind ports and process them
+ */
+ void bind(ServerPort port);
/**
* Gets the state of the connection, which is interpreted differently by different programs
*
- * Client: Active connection indicates that a connection is being maintained with the server.
- * Inactive connection indicates that no connection is being established with the server
- *
* Server: The active connection indicates that the server has been started, is receiving ports, * and can obtain requests at any time. The inactive connection indicates that the server has been * shut down and the ports have been released diff --git a/threadpool/rpc/src/main/java/cn/hippo4j/rpc/server/ServerConnection.java b/threadpool/rpc/src/main/java/cn/hippo4j/rpc/server/ServerConnection.java deleted file mode 100644 index a72d2318..00000000 --- a/threadpool/rpc/src/main/java/cn/hippo4j/rpc/server/ServerConnection.java +++ /dev/null @@ -1,35 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package cn.hippo4j.rpc.server; - -import cn.hippo4j.rpc.discovery.ServerPort; -import cn.hippo4j.rpc.handler.Connection; - -/** - * This applies to server-side connections - * - * @since 2.0.0 - */ -public interface ServerConnection extends Connection { - - /** - * Bind ports and process them - */ - void bind(ServerPort port); - -}