Remove unnecessary copy of bytes. resolve apache#1085 (apache#1087)

nick-tan · Jul 12, 2019 · 876781f · 876781f
1 parent 824fbec
commit 876781f
Showing 1 changed file with 3 additions and 9 deletions.
diff --git a/core/src/main/java/io/seata/core/rpc/netty/MessageCodecHandler.java b/core/src/main/java/io/seata/core/rpc/netty/MessageCodecHandler.java
@@ -77,9 +77,7 @@ protected void encode(ChannelHandlerContext ctx, RpcMessage msg, ByteBuf out) th
             byteBuffer.putShort((short)0);
             byteBuffer.putLong(msg.getId());
             byteBuffer.flip();
-            byte[] content = new byte[byteBuffer.limit()];
-            byteBuffer.get(content);
-            out.writeBytes(content);
+            out.writeBytes(byteBuffer);
             return;
         }
 
@@ -89,9 +87,7 @@ protected void encode(ChannelHandlerContext ctx, RpcMessage msg, ByteBuf out) th
                 byteBuffer.putLong(msg.getId());
 
                 byteBuffer.flip();
-                byte[] content = new byte[byteBuffer.limit()];
-                byteBuffer.get(content);
-                out.writeBytes(content);
+                out.writeBytes(byteBuffer);
                 out.writeBytes(msgCodec.encode());
             } else {
                 if (LOGGER.isInfoEnabled()) {
@@ -103,9 +99,7 @@ protected void encode(ChannelHandlerContext ctx, RpcMessage msg, ByteBuf out) th
                 byteBuffer.put(body);
 
                 byteBuffer.flip();
-                byte[] content = new byte[byteBuffer.limit()];
-                byteBuffer.get(content);
-                out.writeBytes(content);
+                out.writeBytes(byteBuffer);
             }
         } catch (Exception e) {
             LOGGER.error(msg.getBody() + " encode error", "", e);