[rabbitmq-discuss] Pika Question (publish and consume as fast as possible)

Mon Jul 18 16:06:29 BST 2011

On Mon, Jul 18, 2011 at 14:39, Josh Geisser <josh at gebaschtel.ch> wrote:
> Anyway, I want to write a little AMPQ Ping tool which should allow us to test various delivery patterns over a Rabbit Cluster.
>
> For that I want to have the possibility to publish and consume as fast as possible, also kind of benchmarking the system.

You are aware that Python is not the fastest language, right?

My rough guess would be that for a decent client you should be able to
get something like 1k - 6k msgs/sec for simple messaging patterns.

>
> I made some progress in getting into Pika and think I understand the idea of the TCP_Backpressure, but I find it a bit hard to implement it on the 'enduser' side. (I found the old idea of TX_ and TX_commit easier to prevent overflow...)
>
> Long speech short, I ended up with using 'BlockingConnection' for publishing and 'SelectConnection' for consuming, otherwise i always ran into buffer-warnings and eventually crashes ....
>
> Could someone provide me with a quick snipped that publish/consumes as fast as possible, the way you'd implement it?
>
> Cheers & thanks a lot
> Josh
>
> (pika in my case latest git-version, Python 2.7.2)
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>