我有一个小的Spring Boot应用程序，它充当某些队列的生产者。它使用以下依赖项:
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
<version>1.4.0.RELEASE</version>
</dependency>
在应用程序中，我启动了4个线程。在每个任务中，将创建随机消息，最大大小为10KB。使用AmqpTemplate中的convertAndSend方法将这些消息发送到直接交换。对于每个线程，使用单独的 channel 。到目前为止，一切运行顺利。
在运行时，我使用Java VisualVM研究了JVM。我可以看到这4个线程正常工作，但感到有些惊讶，因为这些线程大多数时候都处于监视(阻塞)状态。请参见以下屏幕截图:
http://i.stack.imgur.com/i8uX7.png
这是堆栈跟踪的一部分:
java.lang.Thread.State: BLOCKED
at com.rabbitmq.client.impl.SocketFrameHandler.writeFrame(SocketFrameHandler.java:144)
- waiting to lock <1407a47> (a java.io.DataOutputStream) owned by "Thread-7" t@35
at com.rabbitmq.client.impl.AMQConnection.writeFrame(AMQConnection.java:514)
at com.rabbitmq.client.impl.AMQCommand.transmit(AMQCommand.java:102)
- locked <316a68> (a com.rabbitmq.client.impl.CommandAssembler)
at com.rabbitmq.client.impl.AMQChannel.quiescingTransmit(AMQChannel.java:334)
- locked <1d8e172> (a java.lang.Object)
at com.rabbitmq.client.impl.AMQChannel.transmit(AMQChannel.java:310)
- locked <1d8e172> (a java.lang.Object)
at com.rabbitmq.client.impl.ChannelN.basicPublish(ChannelN.java:657)
因此，对我而言，这看起来不像是并行发布。
谁能说出这种行为是否正确？在我看来，事实并非如此，但我无法弄清楚出了什么问题。
如果我在另一台机器上启动相同的生产者应用程序，则阻塞状态似乎会变得更糟，就像rabbitmq代理正在同步访问一样。经纪人本身很好。没有 body 上的限制。无流量控制。使用额外的生产者应用程序，即使传入的消息速率也几乎翻了一番。
这对我来说没有任何意义。有人有主意吗？我要担心吗？
提前致谢!
最佳答案
可能是这个问题:
https://groups.google.com/forum/#!topic/rabbitmq-users/15cv2qroCps
我也遇到了这个问题，原因是:
因此，如果您增加此阈值/为计算机添加内存，则可以对其进行修复。
http://www.rabbitmq.com/memory.html