我正在开发一个应用程序。我使用的是activemq。有没有办法做到这一点:一个生产者总是向一个代理发送消息,而在另一边,有3个consumers.Each消费者监听代理,并可以从queue.Is获取任何消息。
我正在使用activemq编写我的应用程序。logs to db.As你知道将日志写入db是一个耗时的过程,这就是为什么消费者比producer.For ex更慢的原因。I send 100.000 message (大型对象).Producer在20 mins.But内完成发送消息当生产者完成时,消费者已经完成了4.000消息的处理。
发布于 2013-09-19 16:09:27
是的,你所描述的是可能的。实际上,您可以让任意数量的使用者监听单个队列。消息以循环方式在消费者之间分发。
您应该知道的是,ActiveMQ发送小消息的性能比发送大消息要好得多。如果您需要发送非常大的有效负载(例如100mb),最好将消息保存到生产者和消费者都可以访问的位置(例如网络文件系统),然后发送消息的位置。然后,消费者可以使用它来手动读取消息。这样,通过message broker获得的通信量相对较少。
https://stackoverflow.com/questions/18888835
复制相似问题