RabbitMQ HelloWorld消息在本地主机上被阻止？

Question

我已经运行与下面的代码的Hello World RabbitMQ的例子：

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

public class Send { 
    private final static String QUEUE_NAME = "hello"; 

    public static void main(String[] argv) throws java.io.IOException { 
     ConnectionFactory factory = new ConnectionFactory(); 
     factory.setHost("localhost"); 
     Connection connection = factory.newConnection(); 
     Channel channel = connection.createChannel(); 

     channel.queueDeclare(QUEUE_NAME, false, false, false, null); 
     String message = "Hello World!"; 
     channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); 

     System.out.println(" [x] Sent '" + message + "'"); 
     channel.close(); 
     connection.close(); 
     } 
    } 

和：

import com.rabbitmq.client.ConnectionFactory; 
import com.rabbitmq.client.Connection; 
import com.rabbitmq.client.Channel; 
import com.rabbitmq.client.QueueingConsumer; 

public class Recv { 
     private final static String QUEUE_NAME = "hello"; 

     public static void main(String[] argv) 
      throws java.io.IOException, 
       java.lang.InterruptedException { 

      ConnectionFactory factory = new ConnectionFactory(); 
      factory.setHost("localhost"); 
      Connection connection = factory.newConnection(); 
      Channel channel = connection.createChannel(); 

      channel.queueDeclare(QUEUE_NAME, false, false, false, null); 
      System.out.println(" [*] Waiting for messages. To exit press CTRL+C"); 

      QueueingConsumer consumer = new QueueingConsumer(channel); 
      channel.basicConsume(QUEUE_NAME, true, consumer); 

      while (true) { 
       QueueingConsumer.Delivery delivery = consumer.nextDelivery(); 
       String message = new String(delivery.getBody()); 
       System.out.println(" [x] Received '" + message + "'"); 
     } 
    } 
} 

当我运行它监听的队列接收器和发送者表示，其发送消息，但似乎并没有结束。然后我运行：

rabbitmqctl list_queues 

队列肯定是在创建。

然而，当我运行：

rabbitmqctl list_connections 

我得到以下输出

benuni@DeShawn:~$ sudo rabbitmqctl list_connections 
ls: cannot access /etc/rabbitmq/rabbitmq.conf.d: No such file or directory 
Listing connections ... 
guest 127.0.0.1 64700 blocked 
guest 127.0.0.1 64709 blocked 
guest 127.0.0.1 64614 blocked 
guest 127.0.0.1 64716 blocked 
guest 127.0.0.1 64717 blocked 
guest 127.0.0.1 64701 blocked 
guest 127.0.0.1 64699 blocking 
guest 127.0.0.1 64613 blocking 
guest 127.0.0.1 64708 blocking 
guest 127.0.0.1 64718 blocked 
guest 127.0.0.1 64706 blocked 
...done. 

SO由于某些原因的RabbitMQ服务器阻止我的连接？ 有谁知道我需要做什么？ 谢谢， 本

Answer 1

检查日志，查找类似的消息：

=INFO REPORT==== 2-Jul-2012::13:38:02 === 
Disk free space limit now exceeded. Free bytes:13114646528 Limit:15740784640 

见http://comments.gmane.org/gmane.comp.networking.rabbitmq.general/16493更多信息

Answer 2

当你看到阻止这样的连接，这意味着你可能超出了水印水平的磁盘和/或内存。

请参阅：http://www.rabbitmq.com/memory.html了解更多信息。