//package com.xzx.gc.system.service;
|
//
|
//import cn.hutool.core.collection.CollUtil;
|
//import cn.hutool.core.exceptions.ExceptionUtil;
|
//import cn.hutool.json.JSONUtil;
|
//import com.xzx.gc.common.constant.Constants;
|
//import com.xzx.gc.common.dto.MessageDto;
|
//import com.xzx.gc.common.utils.BusinessUtil;
|
//import com.xzx.gc.common.utils.RedisUtil;
|
//import com.xzx.gc.common.utils.SpringUtil;
|
//import lombok.extern.slf4j.Slf4j;
|
//import org.springframework.amqp.core.AmqpTemplate;
|
//import org.springframework.amqp.core.Message;
|
//import org.springframework.amqp.core.MessageBuilder;
|
//import org.springframework.amqp.core.MessageProperties;
|
//import org.springframework.beans.factory.annotation.Autowired;
|
//import org.springframework.scheduling.annotation.Async;
|
//import org.springframework.scheduling.annotation.Scheduled;
|
//import org.springframework.stereotype.Service;
|
//import org.springframework.transaction.annotation.Transactional;
|
//
|
//import java.util.List;
|
//
|
//@Service
|
//@Transactional
|
//@Slf4j
|
//public class QueueService {
|
//
|
// @Autowired
|
// private RedisUtil redisUtil;
|
//
|
// @Autowired
|
// private AmqpTemplate amqpTemplate;
|
//
|
// @Autowired
|
// private BusinessUtil businessUtil;
|
//
|
// @Scheduled(cron = "${cron.errorQueue}")
|
// @Async
|
// public void syncQueue() {
|
// log.trace("********定时同步错误队列*********");
|
// if(!SpringUtil.isCloud()) {
|
// List<String> queueList = redisUtil.lrange(Constants.REDIS_LOG_KEY + "err:queue", 0, -1);
|
// if (CollUtil.isNotEmpty(queueList)) {
|
// for (String queue : queueList) {
|
// MessageDto messageDto = JSONUtil.toBean(queue, MessageDto.class);
|
// String uuid = messageDto.getUuid();
|
// Message message = MessageBuilder.withBody(messageDto.getJson().getBytes())
|
// .setContentType(MessageProperties.CONTENT_TYPE_JSON).setContentEncoding("utf-8")
|
// .setMessageId(uuid).build();
|
// String queueName = messageDto.getQueueName();
|
// String errMsg = "";
|
// try {
|
// redisUtil.set(Constants.REDIS_LOG_KEY + uuid, queueName);
|
// amqpTemplate.convertAndSend(queueName, message);
|
// //删除元素
|
// redisUtil.lremAll(Constants.REDIS_LOG_KEY + "err:queue", queue);
|
// } catch (Exception e) {
|
// redisUtil.del(Constants.REDIS_LOG_KEY + uuid);
|
// log.error("定时同步错误队列失败");
|
// errMsg = ExceptionUtil.getMessage(e);
|
// } finally {
|
// businessUtil.queueConsole(queueName, uuid, errMsg);
|
// }
|
// }
|
// }
|
// }
|
// log.trace("********定时同步错误队列结束*********");
|
// }
|
//}
|
