package org.springblade.modules.rabbitmq.config;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springblade.modules.rabbitmq.redis.RedisService;
|
import org.springblade.modules.rabbitmq.vo.TaskMessage;
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
import org.springframework.data.redis.core.script.RedisScript;
|
import org.springframework.stereotype.Service;
|
|
/**
|
* 队列消息接收
|
* @author zhongrj
|
* @since 2022-04-12
|
*/
|
@Service
|
public class MQreceiver {
|
|
|
private static Logger log = LoggerFactory.getLogger(MQreceiver.class);
|
|
|
@RabbitListener(queues = MQConfig.TASK_QUEUE)
|
public void receive(String message){
|
|
log.info("receive message:"+message);
|
|
|
TaskMessage taskMessage = RedisService.stringToBean(message, TaskMessage.class);
|
|
System.out.println("用户" + taskMessage.getManId() + "抢到了任务："+ taskMessage.getTaskId());
|
|
}
|
}
|
