moliparty/peko-java
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

mq延时任务,添加移除房间管理员缓存，

Browse Source
This commit is contained in:
hokli
2025-05-09 18:48:33 +08:00
parent 78364f3000
commit edf8f51666
21 changed files with 308 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
accompany-mq/accompany-mq-service/src/main/java/com/accompany/mq/producer/MQMessageProducer.java
View File

@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.MessageConst;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.messaging.Message;
import org.springframework.messaging.support.MessageBuilder;
@@ -189,4 +190,29 @@ public class MQMessageProducer {
}
}
/**
* @param queueName
* @param object
* @param delayMillis 对应定时的延时时间毫秒
* @param <T>
*/
public <T extends BaseMqMessage> SendResult sendDelay(String queueName, T object, Integer delayMillis) {
if (object == null) {
return null;
}
if (delayMillis == null) {
delayMillis = 0;
}
try {
String objectJson = JSON.toJSONString(object);
log.info("queueName : {}, message : {}, delayMillis:{}", queueName, objectJson, delayMillis);
SendResult sendResult = rocketMQTemplate.syncSendDelayTimeMills(queueName, objectJson, delayMillis);
log.info("queueName : {}, message : {}, delayMillis:{},sendResult:{}", queueName, objectJson, delayMillis, sendResult);
return sendResult;
} catch (Exception e) {
log.error(e.getMessage(), e);
}
return null;
}
}

23
accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/UserEventBeginEndConsumer.java Normal file
View File

@@ -0,0 +1,23 @@
package com.accompany.mq.consumer;
import cn.hutool.core.date.DateUtil;
import com.accompany.business.message.UserEventBeginEndMessage;
import com.accompany.mq.constant.MqConstant;
import com.accompany.mq.listener.AbstractMessageListener;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component;
import java.util.Date;
@Slf4j
@Component
@ConditionalOnProperty(name = "spring.application.name", havingValue = "admin")
@RocketMQMessageListener(topic = MqConstant.USER_ENEVT_DELAY_TOPIC, consumerGroup = MqConstant.USER_ENEVT_DELAY_CONSUME_GROUP)
public class UserEventBeginEndConsumer extends AbstractMessageListener<UserEventBeginEndMessage> {
@Override
protected void onMessage(UserEventBeginEndMessage eventBeginEndMessage) throws Exception {
log.info("onMessage gameMsgMessage: {}, begin:{},now:{}", eventBeginEndMessage.toString(), eventBeginEndMessage.getMsgDate(), DateUtil.formatDateTime(new Date()));
}
}