java操作rabbitmq實現簡單的消息發送（socket編程的升級）

准備：

　　1.下載rabbitmq並搭建環境(和python那篇一樣:http://www.cnblogs.com/g177w/p/8176797.html)

　　2.下載支持的jar包(http://repo1.maven.org/maven2/com/rabbitmq/amqp-client)

生產者方(Productor.java)：

package RabbitMQTest;


import java.util.HashMap;
import java.util.Map;

import com.rabbitmq.client.AMQP.Queue;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class Productor {
public static String QUEUE_NAME = "STEVEN";
public static void main(String[] args) {
    //初始化socket鏈接
    ConnectionFactory factory = new ConnectionFactory(); 
    //指定鏈接地址
    factory.setHost("localhost");
    try{
    //建立程序和rabbitmq的socket連接
    Connection connection = factory.newConnection();
    //創建管道
    Channel channel = connection.createChannel();
    //聲明隊列
    channel.queueDeclare(QUEUE_NAME,false,false,false,null);
    //讓當前線程睡眠8s，以檢驗rabbitmq的消息輪詢
    Thread.currentThread().sleep(8000);
    String message = "hello,world";
    //發送消息
    channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
    System.out.println("[x] send the message"+message);
    channel.close();
    connection.close();
    }catch (Exception e) {
        System.out.println("程序出錯:"+e);
    }
    
}
}

消費者方(Consummer.java):

package RabbitMQTest;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.QueueingConsumer;
import com.rabbitmq.client.QueueingConsumer.Delivery;
/**
 * 本程序為了練習rabbitmq的簡單操作
 * 
 * @author STEVEN
 * 
 */
public class Consumer {
    public static void main(String[] args) {
        try {
            //創建連接工廠對象
            ConnectionFactory factory = new ConnectionFactory();
            //設置工廠對象的參數，用來連接rabbitmq
            factory.setHost("localhost");
            //建立程序與rabbitmq的socket連接
            Connection connection = factory.newConnection();
            //創建管道
            Channel channel = connection.createChannel();
            //聲明隊列
            channel.queueDeclare(Productor.QUEUE_NAME, false, false, false, null);
            System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
            //創建隊列消費對象
            QueueingConsumer consumer = new QueueingConsumer(channel);
            //設置參數
            channel.basicConsume(Productor.QUEUE_NAME, true, consumer);
            //創建接收對象來接收來自服務端的消息
            Delivery delivery = null;
            //循環接收，相當於開啟了一個監聽
            while (true) {
                delivery = consumer.nextDelivery();
                String message = new String(delivery.getBody());
                System.out.println(" [x] Received '" + message + "'");
            }
        } catch (Exception e) {
            System.out.println(e);
        }
    }
}