ly
/
Stwzhj-Cloud-Plus
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

宣城位置汇聚

ds-xuancheng
luyya 2025-07-07 10:39:57 +08:00
parent 13f78c74b0
commit 8c53620702
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
stwzhj-modules/wzhj-data2es/src/main/java/org/dromara/data2es/handler/RedisExpireListener.java
View File

@ -37,8 +37,6 @@ public class RedisExpireListener extends KeyExpirationEventMessageListener {
@Autowired @Autowired
DataToEsController dataToEsController; DataToEsController dataToEsController;
Logger logger = LoggerFactory.getLogger(RedisExpireListener.class);
/** /**
* Creates new {@link MessageListener} for {@code __keyevent@*__:expired} messages. * Creates new {@link MessageListener} for {@code __keyevent@*__:expired} messages.
@ -52,8 +50,10 @@ public class RedisExpireListener extends KeyExpirationEventMessageListener {
@Override @Override
public void onMessage(Message message, byte[] pattern) { public void onMessage(Message message, byte[] pattern) {
String expireKey = message.toString(); String expireKey = message.toString();
log.info("过期的Key={}",expireKey);
if(StringUtils.isNotEmpty(expireKey) && if(StringUtils.isNotEmpty(expireKey) &&
expireKey.startsWith(RedisConstants.ONLINE_USERS_TEN)){ expireKey.startsWith(RedisConstants.ONLINE_USERS_TEN)){
log.info("在线定位过期的Key={}",expireKey);
handleExpiredEvent(expireKey); handleExpiredEvent(expireKey);
} }
} }
@ -85,7 +85,10 @@ public class RedisExpireListener extends KeyExpirationEventMessageListener {
} catch (InterruptedException e) { } catch (InterruptedException e) {
e.printStackTrace(); e.printStackTrace();
} finally { } finally {
lock.unlock(); // 仅在当前线程持有锁时释放
if (lock.isHeldByCurrentThread()) {
lock.unlock();
}
} }
} }