zouxuan 5 years ago
parent
commit
6505b7b040

+ 0 - 1
edu-im/edu-im-server/src/main/java/com/keao/edu/im/dao/RoomMemberDao.java

@@ -20,7 +20,6 @@ public interface RoomMemberDao extends JpaRepository<RoomMember, Long> {
 
     public List<RoomMember> findByRidAndMsidFlag(String rid,boolean msidFlag);
 
-    @Lock(value = LockModeType.PESSIMISTIC_WRITE)
     public RoomMember findByRidAndUid(String rid, String uid);
 
     public List<RoomMember> findByRidAndRole(String rid, int role);

+ 1 - 1
edu-im/edu-im-server/src/main/java/com/keao/edu/im/service/Impl/RoomServiceImpl.java

@@ -1285,7 +1285,7 @@ public class RoomServiceImpl implements RoomService {
     }
 
     @Override
-    @Transactional(rollbackFor = Exception.class, isolation = Isolation.READ_COMMITTED)
+    @Transactional(rollbackFor = Exception.class, isolation = Isolation.SERIALIZABLE)
     public boolean statusSync(ChannelStateNotify notify) throws Exception {
         String roomId = notify.getChannelId();
         String userId = notify.getUserId();