提取工具类

• 在消费者与生产者中代码前期的ConnectionFactory代码设置操作可以进行代码提取封装工具类

import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
public class RabbitUtils {
    static ConnectionFactory factory=new ConnectionFactory();
    static {
        factory.setPort(30672);
        factory.setHost("192.168.1.171");
        factory.setUsername("admin");
        factory.setPassword("admin");
        factory.setVirtualHost("/text01");
    }
    public synchronized static Connection getConnection() throws IOException, TimeoutException {
        return factory.newConnection();
    }
}

• 以后获取Connection可以直接

  Connection connection = RabbitUtils.getConnection();