add rpc-java server

Author: wenweihu86

.gitignore

@@ -0,0 +1,15 @@
+*.swp
+*.swo
+target
+.classpath
+.project
+.settings
+.svn
+output
+.idea
+*.iml
+*.pyc
+logs/
+*MANIFEST
+*artifacts
+.DS_Store

pom.xml

@@ -0,0 +1,71 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.wenweihu86.rpc</groupId>
+    <artifactId>rpc-java</artifactId>
+    <version>1.0.0-SNAPSHOT</version>
+    <packaging>jar</packaging>
+
+    <name>rpc-java</name>
+    <url>http://maven.apache.org</url>
+
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.6.1</version>
+                <configuration>
+                    <source>1.7</source>
+                    <target>1.7</target>
+                    <encoding>UTF-8</encoding>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+    <dependencies>
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-all</artifactId>
+            <version>4.1.9.Final</version>
+        </dependency>
+        <dependency>
+            <groupId>com.google.protobuf</groupId>
+            <artifactId>protobuf-java</artifactId>
+            <version>3.2.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>1.7.25</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-slf4j-impl</artifactId>
+            <version>2.8.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-core</artifactId>
+            <version>2.8.1</version>
+        </dependency>
+        <dependency>
+            <groupId>com.google.protobuf</groupId>
+            <artifactId>protobuf-java</artifactId>
+            <version>3.2.0</version>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>4.12</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+</project>

src/main/java/com/wenweihu86/rpc/codec/proto3/ProtoV3Decoder.java

@@ -0,0 +1,43 @@
+package com.wenweihu86.rpc.codec.proto3;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.ByteToMessageDecoder;
+
+import java.util.List;
+
+/**
+ * Created by wenweihu86 on 2017/4/25.
+ */
+public class ProtoV3Decoder extends ByteToMessageDecoder {
+
+    public static final int FIXED_LEN = 8;
+
+    @Override
+    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
+        // 解决半包问题，此时头部8字节长度还没有接收全，channel中留存的字节流不做处理
+        if (in.readableBytes() < FIXED_LEN) {
+            return;
+        }
+        in.markReaderIndex();
+        int headerLen = in.readInt();
+        int bodyLen = in.readInt();
+        // 解决半包问题，此时header和body还没有接收全，channel中留存的字节流不做处理，重置readerIndex
+        if (in.readableBytes() < headerLen + bodyLen) {
+            in.resetReaderIndex();
+            return;
+        }
+        in.markReaderIndex();
+        byte[] headBytes = new byte[headerLen];
+        in.readBytes(headBytes, 0, headerLen);
+        byte[] bodyBytes = new byte[bodyLen];
+        in.readBytes(bodyBytes, 0, bodyLen);
+
+        ProtoV3Request request = new ProtoV3Request();
+        ProtoV3Header.RequestHeader header = ProtoV3Header.RequestHeader.parseFrom(headBytes);
+        request.setHeader(header);
+        request.setBody(bodyBytes);
+
+        out.add(request);
+    }
+}

src/main/java/com/wenweihu86/rpc/codec/proto3/ProtoV3Encoder.java

@@ -0,0 +1,27 @@
+package com.wenweihu86.rpc.codec.proto3;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.ByteBufAllocator;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.MessageToMessageEncoder;
+
+import java.util.List;
+
+/**
+ * Created by wenweihu86 on 2017/4/25.
+ */
+public class ProtoV3Encoder extends MessageToMessageEncoder<ProtoV3Response> {
+
+    @Override
+    protected void encode(ChannelHandlerContext ctx, ProtoV3Response response, List<Object> out)
+            throws Exception {
+        byte[] headerBytes = response.getHeader().toByteArray();
+        int totalLength = 4 + 4 + headerBytes.length + response.getBody().length;
+        ByteBuf byteBuf = ByteBufAllocator.DEFAULT.buffer(totalLength);
+        byteBuf.writeInt(headerBytes.length);
+        byteBuf.writeInt(response.getBody().length);
+        byteBuf.writeBytes(headerBytes);
+        byteBuf.writeBytes(response.getBody());
+        out.add(byteBuf);
+    }
+}