package com.matrix.component.rabbitmq;
|
|
import com.matrix.core.tools.LogUtil;
|
import com.rabbitmq.client.Connection;
|
import com.rabbitmq.client.ConnectionFactory;
|
|
import java.io.IOException;
|
import java.util.concurrent.TimeoutException;
|
|
/**
|
* mq消息模板工程
|
*
|
* @Author jyy
|
*/
|
public class RabiitMqTemplateFactory {
|
|
private static RabiitMqTemplate rabiitMqTemplate = null;
|
|
/**
|
* 构建mq消息模板，mq模板是单例的
|
*
|
* @param host
|
* @param port
|
* @param username
|
* @param password
|
* @return
|
*/
|
public static RabiitMqTemplate buildTemplate(String host, int port, String username, String password) {
|
|
if (rabiitMqTemplate == null) {
|
ConnectionFactory factory = new ConnectionFactory();
|
factory.setHost(host);
|
factory.setPort(port);
|
factory.setUsername(username);
|
factory.setPassword(password);
|
/**
|
* 网络故障自动连接恢复
|
*/
|
factory.setAutomaticRecoveryEnabled(true);
|
Connection connection = null;
|
try {
|
connection = factory.newConnection();
|
} catch (IOException | TimeoutException e) {
|
LogUtil.error("RabiitMqTemplate初始化失败" + e.getMessage(), e);
|
}
|
rabiitMqTemplate = new RabiitMqTemplate(connection);
|
}
|
return rabiitMqTemplate;
|
}
|
}
|
