diff --git a/pom.xml b/pom.xml
index 7bb9866..63fa134 100644
--- a/pom.xml
+++ b/pom.xml
@@ -17,14 +17,21 @@
     <name>com.loafle.overflow.container-java</name>
 
     <properties>
+        <commons.rpc-java.version>1.0.0-SNAPSHOT</commons.rpc-java.version>
         <commons.server-java.version>1.0.0-SNAPSHOT</commons.server-java.version>
         <overflow.commons-java.version>1.0.0-SNAPSHOT</overflow.commons-java.version>
         <overflow.crawler-java.version>1.0.0-SNAPSHOT</overflow.crawler-java.version>
 
+        <netty.version>4.1.24.Final</netty.version>
         <spring.version>5.0.5.RELEASE</spring.version>
     </properties>
 
     <dependencies>
+        <dependency>
+            <groupId>com.loafle.commons</groupId>
+            <artifactId>rpc-java</artifactId>
+            <version>${commons.rpc-java.version}</version>
+        </dependency>
         <dependency>
             <groupId>com.loafle.commons</groupId>
             <artifactId>server-java</artifactId>
@@ -41,6 +48,11 @@
             <version>${overflow.crawler-java.version}</version>
         </dependency>
 
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-handler</artifactId>
+            <version>${netty.version}</version>
+        </dependency>
         <dependency>
             <groupId>org.springframework</groupId>
             <artifactId>spring-context</artifactId>
diff --git a/src/main/java/com/loafle/overflow/container/server/RPCServerHandler.java b/src/main/java/com/loafle/overflow/container/server/RPCServerHandler.java
new file mode 100644
index 0000000..7c1ebc0
--- /dev/null
+++ b/src/main/java/com/loafle/overflow/container/server/RPCServerHandler.java
@@ -0,0 +1,53 @@
+package com.loafle.overflow.container.server;
+
+import com.loafle.commons.rpc.RPCException;
+import com.loafle.commons.rpc.protocol.RPCServerCodec;
+import com.loafle.commons.rpc.protocol.RPCServerRequestCodec;
+import com.loafle.commons.rpc.registry.RPCInvoker;
+import com.loafle.commons.server.socket.netty.handler.codec.SocketFrame;
+import com.loafle.commons.server.socket.netty.handler.codec.TextSocketFrame;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.SimpleChannelInboundHandler;
+
+/**
+ * RPCDecoder
+ */
+public class RPCServerHandler extends SimpleChannelInboundHandler<SocketFrame> {
+  private static final Logger logger = LoggerFactory.getLogger(RPCServerHandler.class);
+  private RPCServerCodec serverCodec;
+  private RPCInvoker rpcInvoker;
+
+  public RPCServerHandler(RPCServerCodec serverCodec, RPCInvoker rpcInvoker) {
+    this.serverCodec = serverCodec;
+    this.rpcInvoker = rpcInvoker;
+  }
+
+  @Override
+  protected void channelRead0(ChannelHandlerContext ctx, SocketFrame frame) throws Exception {
+    if (frame instanceof TextSocketFrame) {
+      byte[] requestBytes = null;
+      RPCServerRequestCodec requestCodec = null;
+      Object reply = null;
+      RPCException error = null;
+      try {
+        requestBytes = new byte[frame.content().readableBytes()];
+        frame.content().readBytes(requestBytes);
+
+        requestCodec = this.serverCodec.request(requestBytes);
+        reply = this.rpcInvoker.invoke(requestCodec);
+        
+      } catch (RPCException e) {
+        error = e;
+      }
+
+      byte[] responseBytes = requestCodec.response(reply, error);
+      ctx.channel().writeAndFlush(responseBytes);
+    } else {
+        throw new UnsupportedOperationException(String.format("unsupported frame type: %s", frame.getClass().getName()));
+    }
+  }
+}
\ No newline at end of file