添加分段同步好友/好友请求/用户设置的功能

broker/src/main/java/io/moquette/BrokerConstants.java

@@ -157,6 +157,7 @@ public final class BrokerConstants {
     public static final String GROUP_Visible_Quit_Kickoff_Notification = "group.visible_quit_or_kickoff_notification";
 
     public static final String USER_HIDE_PROPERTIES = "user.hide_properties";
+    public static final String SYNC_Data_Part_Size = "sync.data_part_size";
 
     public static final String MESSAGES_FORBIDDEN_CLIENT_SEND_TYPES = "message.forbidden_client_send_types";
     public static final String MESSAGES_BLACKLIST_EXCEPTION_TYPES = "message.blacklist_exception_types";

broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java

@@ -154,6 +154,7 @@ public class MemoryMessagesStore implements IMessagesStore {
     private String mChatroomMemberUpdateCallback;
     private boolean mGroupAllowClientCustomOperationNotification;
     private int mGroupVisibleQuitKickoffNotification;
+    private int mSyncDataPartSize = 0;
 
     private Set<Integer> mUserHideProperties = new HashSet<>();
 
@@ -381,6 +382,12 @@ public class MemoryMessagesStore implements IMessagesStore {
 
         }
 
+        try {
+            mSyncDataPartSize = Integer.parseInt(server.getConfig().getProperty(SYNC_Data_Part_Size, "0"));
+        } catch (Exception e) {
+
+        }
+
 
         try {
             String userHideStr = server.getConfig().getProperty(USER_HIDE_PROPERTIES);
@@ -2573,6 +2580,11 @@ public class MemoryMessagesStore implements IMessagesStore {
             }
         }
 
+        if(mSyncDataPartSize > 0 && out.size() > mSyncDataPartSize) {
+            out.sort(Comparator.comparingLong(FriendData::getTimestamp));
+            out = out.subList(0, mSyncDataPartSize);
+        }
+
         return out;
     }
 
@@ -2618,6 +2630,10 @@ public class MemoryMessagesStore implements IMessagesStore {
             }
         }
 
+        if(mSyncDataPartSize > 0 && out.size() > mSyncDataPartSize) {
+            out.sort(Comparator.comparingLong(WFCMessage.FriendRequest::getUpdateDt));
+            out = out.subList(0, mSyncDataPartSize);
+        }
         return out;
     }
 
@@ -3111,6 +3127,12 @@ public class MemoryMessagesStore implements IMessagesStore {
             }
         }
 
+        if(mSyncDataPartSize > 0 && ec == ErrorCode.ERROR_CODE_SUCCESS && builder.getEntryCount() > mSyncDataPartSize) {
+            List<WFCMessage.UserSettingEntry> list = new ArrayList<>(builder.getEntryList());
+            list.sort(Comparator.comparingLong(WFCMessage.UserSettingEntry::getUpdateDt));
+            list = list.subList(0, mSyncDataPartSize);
+            builder.clearEntry().addAllEntry(list);
+        }
         return ec;
     }