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)：

 1 package RabbitMQTest;
 2 
 3 
 4 import java.util.HashMap;
 5 import java.util.Map;
 6 
 7 import com.rabbitmq.client.AMQP.Queue;
 8 import com.rabbitmq.client.Channel;
 9 import com.rabbitmq.client.Connection;
10 import com.rabbitmq.client.ConnectionFactory;
11 
12 public class Productor {
13 public static String QUEUE_NAME = "STEVEN";
14 public static void main(String[] args) {
15     //初始化socket链接
16     ConnectionFactory factory = new ConnectionFactory(); 
17     //指定链接地址
18     factory.setHost("localhost");
19     try{
20     //建立程序和rabbitmq的socket连接
21     Connection connection = factory.newConnection();
22     //创建管道
23     Channel channel = connection.createChannel();
24     //声明队列
25     channel.queueDeclare(QUEUE_NAME,false,false,false,null);
26     //让当前线程睡眠8s，以检验rabbitmq的消息轮询
27     Thread.currentThread().sleep(8000);
28     String message = "hello,world";
29     //发送消息
30     channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
31     System.out.println("[x] send the message"+message);
32     channel.close();
33     connection.close();
34     }catch (Exception e) {
35         System.out.println("程序出错:"+e);
36     }
37     
38 }
39 }

View Code