diff --git a/apm-collector/apm-collector-worker/bin/collector-service.bat b/apm-collector/apm-collector-worker/bin/collector-service.bat
index de24690d45decb9bd93b0c8d97649b55cfbddacb..fbc273ef5f0d368b6d49141af3332bee3ef73787 100644
--- a/apm-collector/apm-collector-worker/bin/collector-service.bat
+++ b/apm-collector/apm-collector-worker/bin/collector-service.bat
@@ -14,7 +14,7 @@ if ""%JAVA_HOME%"" == """" (
   set _EXECJAVA="%JAVA_HOME%"/bin/java
 )
 
-start /MIN "%COLLECOTR_PROCESS_TITLE%" %_EXECJAVA% "%COLLECTOR_RUNTIME_OPTIONS%" -cp "%CLASSPATH%" CollectorBootStartUp &
+start /MIN "%COLLECOTR_PROCESS_TITLE%" %_EXECJAVA% "%COLLECTOR_RUNTIME_OPTIONS%" -cp "%CLASSPATH%" org.skywalking.apm.collector.worker.CollectorBootStartUp &
 echo Collector started successfully!
 
 endlocal
diff --git a/apm-collector/apm-collector-worker/bin/collector-service.sh b/apm-collector/apm-collector-worker/bin/collector-service.sh
index 542bc6117aca54a3ee9140e40a9c325c355f40b5..7b0eef4657eeef32e0a69781364f2480596ebf08 100644
--- a/apm-collector/apm-collector-worker/bin/collector-service.sh
+++ b/apm-collector/apm-collector-worker/bin/collector-service.sh
@@ -21,13 +21,17 @@ do
 done
 
 echo "Starting collector...."
-eval exec "\"$_RUNJAVA\" ${JAVA_OPTS} -classpath $CLASSPATH CollectorBootStartUp \
+eval exec "\"$_RUNJAVA\" ${JAVA_OPTS} -classpath $CLASSPATH org.skywalking.apm.collector.worker.CollectorBootStartUp \
         2>${COLLECTOR_LOGS_DIR}/collector.log 1> /dev/null &"
 
-if [ $? -eq 0 ]; then
-    sleep 1
-	echo "Collector started successfully!"
-else
-	echo "Collector started failure!"
-	exit 1
+retval=$?
+pid=$!
+FAIL_MSG="Collector started failure!"
+SUCCESS_MSG="Collector started successfully!"
+[ ${retval} -eq 0 ] || (echo ${FAIL_MSG}; exit ${retval})
+sleep 1
+if ! ps -p ${pid} > /dev/null ; then
+    echo ${FAIL_MSG}
+    exit 1
 fi
+echo ${SUCCESS_MSG}
diff --git a/apm-commons/apm-trace/src/main/java/org/skywalking/apm/trace/SegmentsMessage.java b/apm-commons/apm-trace/src/main/java/org/skywalking/apm/trace/SegmentsMessage.java
index b31e9237fdbe5abf42972a67265329c8bb775505..f68165a588458d5d2aa0bd931c0a76089519c2ae 100644
--- a/apm-commons/apm-trace/src/main/java/org/skywalking/apm/trace/SegmentsMessage.java
+++ b/apm-commons/apm-trace/src/main/java/org/skywalking/apm/trace/SegmentsMessage.java
@@ -1,13 +1,6 @@
 package org.skywalking.apm.trace;
 
 import com.google.gson.Gson;
-import com.google.gson.GsonBuilder;
-import com.google.gson.TypeAdapter;
-import com.google.gson.annotations.JsonAdapter;
-import com.google.gson.stream.JsonReader;
-import com.google.gson.stream.JsonWriter;
-
-import java.io.IOException;
 import java.util.Collections;
 import java.util.LinkedList;
 import java.util.List;
@@ -18,7 +11,6 @@ import java.util.List;
  *
  * @author wusheng
  */
-@JsonAdapter(SegmentsMessage.Serializer.class)
 public class SegmentsMessage {
     private List<TraceSegment> segments;
 
@@ -34,40 +26,23 @@ public class SegmentsMessage {
         return Collections.unmodifiableList(segments);
     }
 
-    public static class Serializer extends TypeAdapter<SegmentsMessage> {
-
-        @Override
-        public void write(JsonWriter out, SegmentsMessage value) throws IOException {
-            Gson gson = new GsonBuilder()
-                .excludeFieldsWithoutExposeAnnotation()
-                .create();
-
-            out.beginArray();
-            try {
-                for (TraceSegment segment : value.segments) {
-                    out.jsonValue(gson.toJson(segment));
-                }
-            } finally {
-                out.endArray();
-            }
-        }
-
-        @Override
-        public SegmentsMessage read(JsonReader in) throws IOException {
-            SegmentsMessage message = new SegmentsMessage();
-            in.beginArray();
-            Gson gson = new GsonBuilder()
-                .excludeFieldsWithoutExposeAnnotation()
-                .create();
-            try {
-                while (in.hasNext()) {
-                    TraceSegment traceSegment = gson.fromJson(in, TraceSegment.class);
-                    message.append(traceSegment);
-                }
-            } finally {
-                in.endArray();
-            }
-            return message;
+    /**
+     * This serialization mechanism started from 3.1, it is similar to network package.
+     * The data protocol is
+     *
+     * segment1.json.length + ' '(one blank space) + segment1.json
+     * + segment2.json.length + ' '(one blank space) + segment2.json
+     * + etc.
+     *
+     * @param gson the serializer for {@link TraceSegment}
+     * @return the string represents the <code>SegmentMessage</code>
+     */
+    public String serialize(Gson gson) {
+        StringBuilder buffer = new StringBuilder();
+        for (TraceSegment segment : segments) {
+            String segmentJson = gson.toJson(segment);
+            buffer.append(segmentJson.length()).append(' ').append(segmentJson);
         }
+        return buffer.toString();
     }
 }
diff --git a/apm-commons/apm-trace/src/test/java/org/skywalking/apm/trace/TraceSegmentTestCase.java b/apm-commons/apm-trace/src/test/java/org/skywalking/apm/trace/TraceSegmentTestCase.java
index 2a9c399a9718791c8d13987fb0d149ac50181d89..326e741831002bcc82d418ad568fe6e4429371f1 100644
--- a/apm-commons/apm-trace/src/test/java/org/skywalking/apm/trace/TraceSegmentTestCase.java
+++ b/apm-commons/apm-trace/src/test/java/org/skywalking/apm/trace/TraceSegmentTestCase.java
@@ -108,15 +108,18 @@ public class TraceSegmentTestCase {
 
         SegmentsMessage message = new SegmentsMessage();
         message.append(segment);
-        String json = gson.toJson(message);
 
-        message = gson.fromJson(json, SegmentsMessage.class);
+        String jsonString = message.serialize(gson);
+        int length = Integer.parseInt(jsonString.substring(0, 4));
 
-        TraceSegment newSegment = message.getSegments().get(0);
+        String segmentJson = jsonString.substring(5);
 
-        Assert.assertEquals(segment.getSpans().size(), newSegment.getSpans().size());
-        Assert.assertEquals(segment.getRefs().get(0).getTraceSegmentId(), newSegment.getRefs().get(0).getTraceSegmentId());
-        Assert.assertEquals(Tags.SPAN_LAYER.get(segment.getSpans().get(1)), Tags.SPAN_LAYER.get(newSegment.getSpans().get(1)));
-        Assert.assertEquals(segment.getSpans().get(1).getLogs().get(0).getTime(), newSegment.getSpans().get(1).getLogs().get(0).getTime());
+        Assert.assertEquals(length, segmentJson.length());
+        TraceSegment recoverySegment = gson.fromJson(segmentJson, TraceSegment.class);
+
+        Assert.assertEquals(segment.getSpans().size(), recoverySegment.getSpans().size());
+        Assert.assertEquals(segment.getRefs().get(0).getTraceSegmentId(), recoverySegment.getRefs().get(0).getTraceSegmentId());
+        Assert.assertEquals(Tags.SPAN_LAYER.get(segment.getSpans().get(1)), Tags.SPAN_LAYER.get(recoverySegment.getSpans().get(1)));
+        Assert.assertEquals(segment.getSpans().get(1).getLogs().get(0).getTime(), recoverySegment.getSpans().get(1).getLogs().get(0).getTime());
     }
 }
diff --git a/apm-sniffer/apm-agent-core/src/main/java/org/skywalking/apm/agent/core/client/CollectorClient.java b/apm-sniffer/apm-agent-core/src/main/java/org/skywalking/apm/agent/core/client/CollectorClient.java
index 09ac7c5b699fe5d32a2c49135873ea645ec5bf70..279d95a0e74d0262b41c93d7d3a04a8e0d171d75 100644
--- a/apm-sniffer/apm-agent-core/src/main/java/org/skywalking/apm/agent/core/client/CollectorClient.java
+++ b/apm-sniffer/apm-agent-core/src/main/java/org/skywalking/apm/agent/core/client/CollectorClient.java
@@ -32,6 +32,7 @@ public class CollectorClient implements Runnable {
     private static long SLEEP_TIME_MILLIS = 500;
     private String[] serverList;
     private volatile int selectedServer = -1;
+    private Gson serializer;
 
     public CollectorClient() {
         serverList = Config.Collector.SERVERS.split(",");
@@ -39,6 +40,9 @@ public class CollectorClient implements Runnable {
         if (serverList.length > 0) {
             selectedServer = r.nextInt(serverList.length);
         }
+        serializer = new GsonBuilder()
+            .excludeFieldsWithoutExposeAnnotation()
+            .create();
     }
 
     @Override
@@ -84,10 +88,7 @@ public class CollectorClient implements Runnable {
         if (message == null) {
             return;
         }
-        Gson gson = new GsonBuilder()
-            .excludeFieldsWithoutExposeAnnotation()
-            .create();
-        String messageJson = gson.toJson(message);
+        String messageJson = message.serialize(serializer);
         CloseableHttpClient httpClient = HttpClients.custom().build();
         try {
             HttpPost httpPost = ready2Send(messageJson);
diff --git a/docker-compose.yml b/docker-compose.yml
index fef08691585683942b34108207fcc85dc5d53516..1dec8122c54ceb0f01107e36984bbbca7639790d 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -1,7 +1,7 @@
 version: '2.1'
 services:
   skywalking-webui:
-    image: sky-walking-ui:3.0.1-2017
+    image: sky-walking-ui:3.1-2017
     expose:
       - "8080"
     ports:
@@ -9,10 +9,10 @@ services:
     links:
       - skywalking-collector
     environment:
-      - COLLECTOR_SERVERS=skywalking-collector:7001
+      - COLLECTOR_SERVERS=skywalking-collector:12800
 
   skywalking-collector:
-    image: skywalking-collector:3.0.1-2017
+    image: skywalking-collector:3.1-2017
     expose:
       - "12800"
       - "1000"