Connection conn = getConnection();
Channel channel = conn.createChannel();
MessageConsumer consumer = ...
channel.basicConsume(realQueue, true, consumer);

final public class ConsumerWorkService {
    private static final int MAX_RUNNABLE_BLOCK_SIZE = 16;
    private static final int DEFAULT_NUM_THREADS = Runtime.getRuntime().availableProcessors() * 2;
    private final ExecutorService executor;
    private final boolean privateExecutor;
    private final WorkPool<Channel, Runnable> workPool;
    private final int shutdownTimeout;
    public ConsumerWorkService(ExecutorService executor, ThreadFactory threadFactory, int queueingTimeout, int shutdownTimeout) {
        this.privateExecutor = (executor == null);
        this.executor = (executor == null) ? Executors.newFixedThreadPool(DEFAULT_NUM_THREADS, threadFactory)
                                           : executor;
        this.workPool = new WorkPool<>(queueingTimeout);
        this.shutdownTimeout = shutdownTimeout;
    }
  ...

public Connection newConnection(ExecutorService executor) throws IOException, TimeoutException;

public class RabbitMqUtil {
    public static Channel getChannel() throws Exception{
        //創(chuàng)建一個(gè)連接工廠
        ConnectionFactory factory = new ConnectionFactory();
        //連接服務(wù)器
        factory.setHost("114.***.***.***");
        //用戶名
        factory.setUsername("admin");
        //密碼
        factory.setPassword("123");
        //創(chuàng)建連接
//        ExecutorService executor = Executors.newFixedThreadPool(1);  設(shè)置線程池中的個(gè)數(shù)，把executor傳給newConnection()
        Connection connection = factory.newConnection();
        //獲取信道
        Channel channel = connection.createChannel();
        return channel;
    }
}