2.0.1

Author: lamborc

README.md

@@ -5,6 +5,7 @@ First make sure maven is properly installed
 command :
 mvn clean package appassembler:assemble -Dmaven.test.skip=true -X
 
+ipfs pubsub peers bmJzaW8ubmV0 
 # Version History
 ## Version 2.0.1
   - 聊天功能

conf/nbs.db

@@ -9,6 +9,7 @@
 import io.nbs.client.ui.panels.im.ChatPanel;
 import io.nbs.commons.helper.ConfigurationHelper;
 
+import io.nbs.commons.utils.UUIDGenerator;
 import io.nbs.sdk.beans.*;
 import io.nbs.sdk.prot.IPMParser;
 import io.nbs.sdk.prot.IPMTypes;
@@ -121,13 +122,14 @@ private void proccessMessage(List<String> jsonMessages){
                     logger.warn("消息JSON ：{}解析失败，忽略.",json);
                     continue;
                 }
-                if(standardIPFSMessage.getMtype().equals(IPMTypes.nomarl.name())){
+                if(standardIPFSMessage.getMtype().equals(IPMTypes.nomarl.name())
+                        || standardIPFSMessage.getMtype().equals(IPMTypes.unkonw)){
                     if(subscribeListener==null)continue;
                     MessageItem item = IPMParser.convertMessageItem(standardIPFSMessage);
                     item.setMessageType(1);
                     PeerInfo info =Launcher.currentPeer;
                     logger.info("{}<=====>{}",info.getId(),item.getFrom());
-
+                    item.setId(UUIDGenerator.getUUID());
                     subscribeListener.notifyRecvMessage(item);
                 }
                 if(standardIPFSMessage.getMtype().equals(IPMTypes.online.name())){

src/main/java/io/nbs/client/services/IpfsMessageReceiver.java

@@ -3,6 +3,7 @@
 import com.alibaba.fastjson.JSON;
 import io.ipfs.api.exceptions.IllegalIPFSMessageException;
 import io.nbs.commons.utils.Base64CodecUtil;
+import io.nbs.commons.utils.UUIDGenerator;
 import io.nbs.sdk.beans.*;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.util.Base64Utils;
@@ -141,6 +142,7 @@ public static StandardIPFSMessage decodeStandardIPFSMessage(String json) throws
     public static IMMessageBean convertIMMessageBean(StandardIPFSMessage message){
 
         IMMessageBean bean = new IMMessageBean();
+
         bean.setFrom(message.getFrom());
         bean.setSeqno(message.getSeqno());
         bean.setMtype(message.getMtype());
@@ -157,6 +159,7 @@ public static IMMessageBean convertIMMessageBean(StandardIPFSMessage message){
      */
     public static MessageItem convertMessageItem(StandardIPFSMessage message){
         MessageItem bean = new MessageItem();
+        bean.setId(UUIDGenerator.getUUID());
         bean.setNeedToResend(false);
         bean.setTimestamp(System.currentTimeMillis());
         bean.setFrom(message.getFrom());