modify readme.md

Author: SongranZhang

README.md

@@ -109,8 +109,71 @@ public class TestSimpleProxy implements ApiProxy {
 * MessageBuf.JMTransfer: this is important, this class is created by protobuf, it include header and body, header is app information, you can get the detail from this project.
 #### Output Parameter:
 * MessageWrapper: it is message response wrapper. It include protocol, sessionId and body. Body is response data.
-
 body is byte type, and it also a protobuf bytes.
+### Send Notify to Client
+```java 
+private NotifyProxy notify;
+
+final int timeout = 10 * 1000;
+final int NOTIFY = 3;
+
+/**
+ * session
+ */
+final String VERSION = "version";
+final String DEVICE_ID = "deviceId";
+final String PLATFORM = "platform";
+final String PLATFORM_VERSION = "platformVersion";
+final String TOKEN = "token";
+final String APP_KEY = "appKey";
+final String TIMESTAMP = "timestamp";
+final String SIGN = "sign";
+
+/**
+ * need session into redis, then when you notify you can get info from redis by session
+ */
+final Map<String, Map<String, Object>> testSessionMap = null;
+
+public boolean send(long seq, String sessionId, int cmd, ByteString body) throws Exception {
+    boolean success = false;
+    MessageBuf.JMTransfer.Builder builder = generateNotify(sessionId, seq, cmd, body);
+    if (builder != null) {
+        MessageWrapper wrapper = new MessageWrapper(MessageWrapper.MessageProtocol.NOTIFY, sessionId, builder);
+        int ret = notify.notify(seq, wrapper, timeout);
+        if (ret == Constants.NOTIFY_SUCCESS) {
+            success = true;
+        } else if (ret == Constants.NOTIFY_NO_SESSION) {
+            /** no session on this machine **/
+            success = true;
+        }
+    } else {
+        /** no session in the cache **/
+        success = true;
+    }
+    return success;
+}
+
+protected MessageBuf.JMTransfer.Builder generateNotify(String sessionId, long seq, int cmd, ByteString body) throws Exception {
+    Map<String, Object> map = testSessionMap.get(sessionId);
+
+    MessageBuf.JMTransfer.Builder builder = MessageBuf.JMTransfer.newBuilder();
+    builder.setVersion(String.valueOf(map.get(VERSION)));
+    builder.setDeviceId(String.valueOf(map.get(DEVICE_ID)));
+    builder.setCmd(cmd);
+    builder.setSeq(seq);
+    builder.setFormat(NOTIFY);
+    builder.setFlag(0);
+    builder.setPlatform(String.valueOf(map.get(PLATFORM)));
+    builder.setPlatformVersion(String.valueOf(map.get(PLATFORM_VERSION)));
+    builder.setToken(String.valueOf(map.get(TOKEN)));
+    builder.setAppKey(String.valueOf(map.get(APP_KEY)));
+    builder.setTimeStamp(String.valueOf(map.get(TIMESTAMP)));
+    builder.setSign(String.valueOf(map.get(SIGN)));
+    builder.setBody(body);
+
+    return builder;
+}
+```
 ## Tcp Client 
 support iOS, android, C++ languages 
 ### Serialize protobuf

src/test/java/com/linkedkeeper/tcp/server/TestNotify.java

@@ -0,0 +1,73 @@
+package com.linkedkeeper.tcp.server;
+
+import com.google.protobuf.ByteString;
+import com.linkedkeeper.tcp.connector.tcp.codec.MessageBuf;
+import com.linkedkeeper.tcp.constant.Constants;
+import com.linkedkeeper.tcp.message.MessageWrapper;
+import com.linkedkeeper.tcp.notify.NotifyProxy;
+
+import java.util.Map;
+
+public class TestNotify {
+
+    private NotifyProxy notify;
+
+    final int timeout = 10 * 1000;
+    final int NOTIFY = 3;
+
+    /**
+     * session
+     */
+    final String VERSION = "version";
+    final String DEVICE_ID = "deviceId";
+    final String PLATFORM = "platform";
+    final String PLATFORM_VERSION = "platformVersion";
+    final String TOKEN = "token";
+    final String APP_KEY = "appKey";
+    final String TIMESTAMP = "timestamp";
+    final String SIGN = "sign";
+
+    final Map<String, Map<String, Object>> testSessionMap = null;
+
+    public boolean send(long seq, String sessionId, int cmd, ByteString body) throws Exception {
+        boolean success = false;
+        MessageBuf.JMTransfer.Builder builder = generateNotify(sessionId, seq, cmd, body);
+        if (builder != null) {
+            MessageWrapper wrapper = new MessageWrapper(MessageWrapper.MessageProtocol.NOTIFY, sessionId, builder);
+            int ret = notify.notify(seq, wrapper, timeout);
+            if (ret == Constants.NOTIFY_SUCCESS) {
+                success = true;
+            } else if (ret == Constants.NOTIFY_NO_SESSION) {
+                /** no session on this machine **/
+                success = true;
+            }
+        } else {
+            /** no session in the cache **/
+            success = true;
+        }
+        return success;
+    }
+
+
+    protected MessageBuf.JMTransfer.Builder generateNotify(String sessionId, long seq, int cmd, ByteString body) throws Exception {
+        Map<String, Object> map = testSessionMap.get(sessionId);
+
+        MessageBuf.JMTransfer.Builder builder = MessageBuf.JMTransfer.newBuilder();
+        builder.setVersion(String.valueOf(map.get(VERSION)));
+        builder.setDeviceId(String.valueOf(map.get(DEVICE_ID)));
+        builder.setCmd(cmd);
+        builder.setSeq(seq);
+        builder.setFormat(NOTIFY);
+        builder.setFlag(0);
+        builder.setPlatform(String.valueOf(map.get(PLATFORM)));
+        builder.setPlatformVersion(String.valueOf(map.get(PLATFORM_VERSION)));
+        builder.setToken(String.valueOf(map.get(TOKEN)));
+        builder.setAppKey(String.valueOf(map.get(APP_KEY)));
+        builder.setTimeStamp(String.valueOf(map.get(TIMESTAMP)));
+        builder.setSign(String.valueOf(map.get(SIGN)));
+        builder.setBody(body);
+
+        return builder;
+    }
+
+}