lsop encode opt (#339)

* opt for lsop getPayLoadContentSize

* add performa test for ObTableLsOperationRequest encode

* use ObByteBuf to encode lsop

* lsop request encode perf opt

* add default bytes cache for obkvparam and ohtablefilter

* Revert "add default bytes cache for obkvparam and ohtablefilter"

This reverts commit 8a555ef.

* add default bytes cache for obkvparam and ohtablefilter

* fix bug for indexName encode

Author: GroundWu

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/AbstractPayload.java

@@ -17,6 +17,7 @@
 
 package com.alipay.oceanbase.rpc.protocol.payload;
 
+import com.alipay.oceanbase.rpc.util.ObByteBuf;
 import com.alipay.oceanbase.rpc.util.Serialization;
 import io.netty.buffer.ByteBuf;
 
@@ -37,14 +38,18 @@
 public abstract class AbstractPayload implements ObPayload {
 
     private static final AtomicInteger CHANNELID = new AtomicInteger(1);
+    protected static final long        INVALID_PAYLOAD_CONTENT_SIZE = -1;
     private long                       uniqueId;
     private long                       sequence;
     private Integer                    channelId = null;
     protected long                     tenantId  = 1;
     private long                       version   = 1;
     protected long                     timeout   = RPC_OPERATION_TIMEOUT.getDefaultLong();
     protected int                      groupId   = 0;
-
+    // for perf opt
+    protected long                     payLoadContentSize = INVALID_PAYLOAD_CONTENT_SIZE;
+    protected static volatile byte[]   defaultEncodeBytes = null;
+    protected static volatile long 	   defaultPayLoadSize = INVALID_PAYLOAD_CONTENT_SIZE;
     /*
      * Get pcode.
      */
@@ -183,4 +188,22 @@ protected int encodeHeader(byte[] bytes, int idx) {
         return idx;
     }
 
+    protected void encodeHeader(ObByteBuf buf) {
+        encodeObUniVersionHeader(buf, getVersion(), getPayloadContentSize());
+    }
+
+    // for perf opt
+    protected byte[] encodeDefaultBytes() {
+        if (defaultEncodeBytes == null) {
+            synchronized (this.getClass()) {
+                if (defaultEncodeBytes == null) {
+                    defaultEncodeBytes = encode();
+                }
+            }
+        }
+        return defaultEncodeBytes;
+    }
+
+    protected boolean isUseDefaultEncode() { return false; }
+
 }