rabbitmq 術語：

ConnectionFactory、Connection、Channel都是RabbitMQ對外提供的API中最基本的物件。

Connection是RabbitMQ的socket連結，它封裝了socket協議相關部分邏輯。

ConnectionFactory為Connection的製造工廠。

Channel是我們與RabbitMQ打交道的最重要的一個介面，我們大部分的業務操作是在Channel這個介面中完成的，包括定義Queue、定義Exchange、繫結Queue與Exchange、釋出訊息接收訊息等。

Queue（佇列）是RabbitMQ的內部物件，用於儲存訊息，用下圖表示。

多個消費者可以訂閱同一個Queue，這時Queue中的訊息會被平均分攤給多個消費者進行處理，而不是每個消費者都收到所有的訊息並處理。

第一種： 直接傳送訊息給佇列

直接傳送訊息給佇列不需要指定exchange ,預設為空。直接傳送訊息給佇列之前需要先建立此佇列。

程式碼如下：

private static final String HOST = "XXXX";

private static final String USERNAME = "xxx";
private static final String PASSWORD = "xxx";

public static void main(String[] args) throws 
 
IOException, TimeoutException {
    ConnectionFactory connectionFactory = new ConnectionFactory();
    connectionFactory.setHost(HOST);
    connectionFactory.setUsername(USERNAME);
    connectionFactory.setPassword(PASSWORD);
    Connection connection = connectionFactory.newConnection();
    Channel channel = connection.createChannel();

// 一定先建立佇列，否則系統不會報錯，但是資訊被丟棄了。
    channel.queueDeclare("WSX", false,false,false,null);
    channel.basicPublish("","WSX",null,"wsx".getBytes());
    channel.close();
    connection.close();
}

public static void main(String[] args) throws IOException, TimeoutException {
    ConnectionFactory connectionFactory = new ConnectionFactory();
    connectionFactory.setHost(HOST);
    connectionFactory.setUsername(USERNAME);
    connectionFactory.setPassword(PASSWORD);
    Connection connection = connectionFactory.newConnection();
    Channel channel = connection.createChannel();
    channel.queueDeclare("WSX", false,false,false,null);
    channel.basicConsume("WSX",new ConsumerImpl(channel));
}

public class ConsumerImpl implements Consumer{

    private Channel channel;

    public ConsumerImpl(Channel channel){
        this.channel = channel;
    }

    public void handleConsumeOk(String consumerTag) {
        System.out.println("isOk");
    }

    public void handleCancelOk(String consumerTag) {

    }

    public void handleCancel(String consumerTag) throws IOException {

    }

    public void handleShutdownSignal(String consumerTag, ShutdownSignalException sig) {

    }

    public void handleRecoverOk(String consumerTag) {
        System.out.println("recoverOk");
    }

    public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
        System.out.println(new String(body));
        System.out.println(envelope.getDeliveryTag());
        channel.basicAck(envelope.getDeliveryTag(),false);
    }
}