优化session处理

wildfirechat · Dec 18, 2019 · 6c5354d · 6c5354d
1 parent c98bd1f
commit 6c5354d
Showing 1 changed file with 9 additions and 11 deletions.
diff --git a/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java b/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java
@@ -333,20 +333,18 @@ public Session updateOrCreateUserSession(String username, String clientID, int p
 
         Session session = sessions.get(clientID);
 
-        if (session == null || !session.username.equals(username)) {
-            if (session != null && !session.username.equals(username)) {
-                if (userSessions.get(username) != null) {
-                    userSessions.get(username).remove(clientID);
-                }
+        if (session != null && !session.username.equals(username)) {
+            if (userSessions.get(username) != null) {
+                userSessions.get(username).remove(clientID);
             }
-            ClientSession clientSession = new ClientSession(clientID, this);
-            session = databaseStore.getSession(username, clientID, clientSession);
+        }
+        ClientSession clientSession = new ClientSession(clientID, this);
+        session = databaseStore.getSession(username, clientID, clientSession);
 
-            if (session == null) {
-                session = databaseStore.createSession(username, clientID, clientSession, platform);
-            }
-            sessions.put(clientID, session);
+        if (session == null) {
+            session = databaseStore.createSession(username, clientID, clientSession, platform);
         }
+        sessions.put(clientID, session);
 
 
         if (session.getDeleted() > 0) {