我有一个简单的测试配置:一个快速的 C++ 生产者通过 Stomp 向一个主题发送约 60 字节的消息,一个缓慢的消费者,以及设置为 DROP 的地址完整策略。
队列迅速增长,每秒接收数千条消息,直到达到我的最大大小字节数,即大约 300,000 条消息。HornetQ 开始按预期丢弃消息,但从那时起每秒只接受来自生产者的 3-4 条消息。什么会导致这种情况?如果它正在丢弃消息,它不应该能够从生产者那里全速接受它们吗?
我有一个简单的测试配置:一个快速的 C++ 生产者通过 Stomp 向一个主题发送约 60 字节的消息,一个缓慢的消费者,以及设置为 DROP 的地址完整策略。
队列迅速增长,每秒接收数千条消息,直到达到我的最大大小字节数,即大约 300,000 条消息。HornetQ 开始按预期丢弃消息,但从那时起每秒只接受来自生产者的 3-4 条消息。什么会导致这种情况?如果它正在丢弃消息,它不应该能够从生产者那里全速接受它们吗?