anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

解决某些特殊情况下用户session错误问题

Browse Source
This commit is contained in:
heavyrain2012
2021-01-04 15:27:57 +08:00
parent 772940e50d
commit 9b0ca7ac3c
1 changed files with 15 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/persistence/MemorySessionStore.java
+15 -8
View File
@@ -349,18 +349,22 @@ public class MemorySessionStore implements ISessionsStore {
Session session = sessions.get(clientID);
if (session != null && !session.username.equals(username)) {
if (userSessions.get(username) != null) {
userSessions.get(username).remove(clientID);
if (userSessions.get(session.username) != null) {
userSessions.get(session.username).remove(clientID);
}
session = null;
}
ClientSession clientSession = new ClientSession(clientID, this);
session = databaseStore.getSession(username, clientID, clientSession);
if (session == null) {
session = databaseStore.createSession(username, clientID, clientSession, platform);
if(session == null) {
session = databaseStore.getSession(username, clientID, clientSession);
if (session == null) {
session = databaseStore.createSession(username, clientID, clientSession, platform);
}
}
sessions.put(clientID, session);
sessions.put(clientID, session);
ConcurrentSkipListSet<String> sessionSet = getUserSessionSet(username);
sessionSet.add(clientID);
if (session.getDeleted() > 0) {
session.setDeleted(0);
@@ -462,7 +466,6 @@ public class MemorySessionStore implements ISessionsStore {
session.setUsername(username);
sessions.put(clientID, session);
ConcurrentSkipListSet<String> sessionSet = getUserSessionSet(username);
sessionSet.add(clientID);
@@ -501,11 +504,15 @@ public class MemorySessionStore implements ISessionsStore {
@Override
public void loadUserSession(String username, String clientID) {
if (sessions.containsKey(clientID)) {
ConcurrentSkipListSet<String> sessionSet = getUserSessionSet(username);
sessionSet.add(clientID);
return;
}
Session session = databaseStore.getSession(username, clientID, new ClientSession(clientID, this));
if (session != null) {
sessions.put(clientID, session);
ConcurrentSkipListSet<String> sessionSet = getUserSessionSet(username);
sessionSet.add(clientID);
}
}