<dependency>    
    <groupId>com.rabbitmq</groupId>    
    <artifactId>amqp-client</artifactId>    
    <version>最新版本號(hào)</version> <!-- 請(qǐng)?zhí)鎿Q為當(dāng)前可用的最新版本號(hào) -->    
</dependency>

import com.rabbitmq.client.ConnectionFactory;  
import com.rabbitmq.client.Connection;  
import com.rabbitmq.client.Channel;  
public class Sender {  
    private static final String QUEUE_NAME = "hello";  
    public static void main(String[] argv) throws Exception {  
        ConnectionFactory factory = new ConnectionFactory();  
        factory.setHost("localhost"); // 設(shè)置RabbitMQ服務(wù)器地址  
        try (Connection connection = factory.newConnection();  
             Channel channel = connection.createChannel()) {  
            channel.queueDeclare(QUEUE_NAME, false, false, false, null); // 聲明隊(duì)列  
            String message = "Hello World!";  
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8")); // 發(fā)送消息  
            System.out.println(" [x] Sent '" + message + "'");  
        }  
    }  
}

import com.rabbitmq.client.ConnectionFactory;  
import com.rabbitmq.client.Connection;  
import com.rabbitmq.client.Channel;  
import com.rabbitmq.client.DefaultConsumer;  
import com.rabbitmq.client.Envelope;  
import com.rabbitmq.client.AMQP.BasicProperties;  
import com.rabbitmq.client.Delivery;  
public class Receiver {  
    private static final String QUEUE_NAME = "hello";  
    public static void main(String[] argv) throws Exception {  
        ConnectionFactory factory = new ConnectionFactory();  
        factory.setHost("localhost"); // 設(shè)置RabbitMQ服務(wù)器地址  
        try (Connection connection = factory.newConnection();  
             Channel channel = connection.createChannel()) {  
            channel.queueDeclare(QUEUE_NAME, false, false, false, null); // 聲明隊(duì)列（確保隊(duì)列存在）  
            System.out.println(" [*] Waiting for messages. To exit press CTRL+C");  
            DefaultConsumer consumer = new DefaultConsumer(channel) {  
                @Override  
                public void handleDelivery(String consumerTag, Envelope envelope,  
                                          AMQP.BasicProperties properties, byte[] body) throws IOException {  
                    String message = new String(body, "UTF-8");  
                    System.out.println(" [x] Received '" + message + "'");  
                }  
            };  
            channel.basicConsume(QUEUE_NAME, true, consumer); // 開(kāi)始消費(fèi)消息，自動(dòng)確認(rèn)模式  
        }  
    }  
}