Skip to content

M
midjourney-proxy
Commit a464fa8f by songxiang
Options

RabbitMQ调整

parent e90a2295
Showing with 97 additions and 144 deletions
pcloud-common-core/src/main/java/com/pcloud/common/core/biz/ConvertQueueBiz.java
/** /**
* *
*/ */
package com.pcloud.common.core.biz; package com.pcloud.common.core.biz;
import com.pcloud.common.core.dto.ConvertQueueDto; import com.pcloud.common.core.dto.ConvertQueueDto;
import com.pcloud.common.exceptions.BizException; import com.pcloud.common.exceptions.BizException;
/** /**
* @描述： * @描述：
* *
* @作者：songx * @作者：songx
* @创建时间：2017年2月27日,下午2:48:49 * @创建时间：2017年2月27日,下午2:48:49 @版本：1.0
* @版本：1.0 */
*/ public interface ConvertQueueBiz {
public interface ConvertQueueBiz {
/**
/** * 通知转码(音视频)
* 发送消息 *
* * @param messageQueueDto
* @param messageQueueDto */
*/ public void sendConvertFileQueue(ConvertQueueDto convertQueueDto) throws BizException;
public void sendConvertFileQueue(ConvertQueueDto convertQueueDto) throws BizException;
}
}
pcloud-common-core/src/main/java/com/pcloud/common/core/biz/ConvertQueueBizImpl.java
/** /**
* *
*/ */
package com.pcloud.common.core.biz; package com.pcloud.common.core.biz;
import javax.jms.JMSException; import org.springframework.amqp.core.AmqpTemplate;
import javax.jms.ObjectMessage; import org.springframework.beans.factory.annotation.Autowired;
import javax.jms.Session; import org.springframework.stereotype.Service;
import org.slf4j.Logger; import com.pcloud.common.core.aspect.ParamLog;
import org.slf4j.LoggerFactory; import com.pcloud.common.core.constant.MQQueueConstant;
import org.springframework.beans.factory.annotation.Autowired; import com.pcloud.common.core.dto.ConvertQueueDto;
import org.springframework.beans.factory.annotation.Qualifier; import com.pcloud.common.exceptions.BizException;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator; /**
import org.springframework.stereotype.Service; * @描述：
*
import com.pcloud.common.core.dto.ConvertQueueDto; * @作者：songx
import com.pcloud.common.exceptions.BizException; * @创建时间：2017年2月27日,下午2:49:38 @版本：1.0
*/
/** @Service("convertQueueBiz")
* @描述： public class ConvertQueueBizImpl implements ConvertQueueBiz {
* @作者：songx
* @创建时间：2017年2月27日,下午2:49:38 @Autowired
* @版本：1.0 private AmqpTemplate amqpTemplate;
*/
@Service("convertQueueBiz") /**
public class ConvertQueueBizImpl implements ConvertQueueBiz { * 通知转码(音视频)
*/
/** @Override
* @ParamLog("通知转码(音视频)")
*/ public void sendConvertFileQueue(ConvertQueueDto convertFileQueueDto) throws BizException {
private final static Logger logger=LoggerFactory.getLogger(ConvertQueueBizImpl.class); amqpTemplate.convertAndSend(MQQueueConstant.CONVERT, convertFileQueueDto);
}
@Autowired(required=false)
@Qualifier("jmsConvertTemplate") }
private JmsTemplate jmsConvertTemplate;
/**
*
*/
@Override
public void sendConvertFileQueue(ConvertQueueDto convertFileQueueDto) throws BizException {
MessageCreator messageCreator = new MessageCreator() {
@Override
public ObjectMessage createMessage(Session session) throws JMSException {
return session.createObjectMessage(convertFileQueueDto);
}
};
try {
jmsConvertTemplate.send(messageCreator);
} catch (Exception e) {
logger.error("发送失败，" + e.getMessage(), e);
throw BizException.SEND_QUEUE_FAIL;
}
logger.info("发送成功，" + convertFileQueueDto);
}
}
pcloud-common-core/src/main/java/com/pcloud/common/core/biz/impl/TranscodeQueueBizImpl.java
/** /**
* *
*/ */
package com.pcloud.common.core.biz.impl; package com.pcloud.common.core.biz.impl;
import javax.jms.JMSException; import org.springframework.amqp.core.AmqpTemplate;
import javax.jms.ObjectMessage; import org.springframework.beans.factory.annotation.Autowired;
import javax.jms.Session; import org.springframework.stereotype.Service;
import org.slf4j.Logger; import com.pcloud.common.core.aspect.ParamLog;
import org.slf4j.LoggerFactory; import com.pcloud.common.core.biz.TranscodeQueueBiz;
import org.springframework.beans.factory.annotation.Autowired; import com.pcloud.common.core.constant.MQQueueConstant;
import org.springframework.beans.factory.annotation.Qualifier; import com.pcloud.common.core.dto.TranscodeMQDTO;
import org.springframework.jms.core.JmsTemplate; import com.pcloud.common.exceptions.BizException;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Service; /**
*
import com.pcloud.common.core.biz.TranscodeQueueBiz; *
import com.pcloud.common.core.dto.TranscodeMQDTO; * @author：songx
import com.pcloud.common.exceptions.BizException; * @date：2018年5月17日,下午4:19:54
*/
/** @Service("transcodeQueueBiz")
* public class TranscodeQueueBizImpl implements TranscodeQueueBiz {
*
* @author：songx @Autowired
* @date：2018年5月17日,下午4:19:54 private AmqpTemplate amqpTemplate;
*/
@Service("transcodeQueueBiz") /**
public class TranscodeQueueBizImpl implements TranscodeQueueBiz { * 文件转码QUEUE
*/
/** @Override
* @ParamLog(description = "文件转码QUEUE")
*/ public void sendTranscodeQueue(TranscodeMQDTO transcodeMQDTO) throws BizException {
private final static Logger logger = LoggerFactory.getLogger(TranscodeQueueBizImpl.class); amqpTemplate.convertAndSend(MQQueueConstant.TRANSCODE, transcodeMQDTO);
}
@Autowired(required = false)
@Qualifier("jmsTranscodeTemplate") }
private JmsTemplate jmsTranscodeTemplate;
/**
*
*/
@Override
public void sendTranscodeQueue(TranscodeMQDTO transcodeMQDTO) throws BizException {
MessageCreator messageCreator = new MessageCreator() {
@Override
public ObjectMessage createMessage(Session session) throws JMSException {
return session.createObjectMessage(transcodeMQDTO);
}
};
try {
jmsTranscodeTemplate.send(messageCreator);
} catch (Exception e) {
logger.error("【文件转码】MQ发送失败:" + e.getMessage(), e);
throw BizException.SEND_QUEUE_FAIL;
}
logger.info("【文件转码】MQ发送成功.[transcodeMQDTO]=" + transcodeMQDTO);
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment