<div dir="ltr">Maybe you could take a look at your basic_qos settings, setting the prefetch_count to some reasonable number?<div><br></div><div>See�<a href="http://www.rabbitmq.com/amqp-0-9-1-quickref.html#basic.qos" target="_blank">http://www.rabbitmq.com/amqp-0-9-1-quickref.html#basic.qos</a></div>
<div><br></div><div>and�<a href="http://www.rabbitmq.com/blog/2011/10/27/performance-of-queues-when-less-is-more/">http://www.rabbitmq.com/blog/2011/10/27/performance-of-queues-when-less-is-more/</a></div><div><br></div>
<div style>Regards,</div><div style><br></div><div style>Alvaro</div></div><div class="gmail_extra"><br><br><div class="gmail_quote">On Mon, Jan 14, 2013 at 10:21 PM, Pavel Kogan <span dir="ltr"><<a href="mailto:pavel.kogan@cortica.com" target="_blank">pavel.kogan@cortica.com</a>></span> wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">Hi all,<div><br></div><div>I have a rabbit server on single dedicated CentOS machine (Quad Core with 16Gb RAM) connected to 1Gbit LAN.</div>
<div>I have many queues running, but total number of messages is not very high for such a machine.</div>
<div><br></div><div>The problem is following:</div><div>1) I connect client A to some queue (with many many messages ready) with some routing key - it processes 150 messages per sec (its limit).</div><div>2) I connect another client A in parallel on identical server to same queue with same routing key. Now I have 2 identical consumers on same queue and messages are distributed on round robin�</div>
<div>� � manner, but somehow second unit receives only 50 messages per sec.�</div><div>3) If I disconnect A1, A2 starts working normally. If I connect A1 back it becomes a slow node.</div><div><br></div><div>The model is TOPIC with�acknowledgments.</div>
<div>Attached screenshots from manager and top command on rabbit machine.</div><div>Did anyone experience similar problem?�</div><div><br></div><div>Thanks a lot,</div><div>� �Pavel</div><div><br></div><div><br></div><div>
<div style="min-width:120px;font-size:14px;text-align:center;padding:10px;margin:0px 20px 0px 0px;color:rgb(136,136,136);border-top-left-radius:10px;border-top-right-radius:10px;border-bottom-right-radius:10px;border-bottom-left-radius:10px;float:left;background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(240,240,240)),to(rgb(224,224,224)));border:1px solid rgb(224,224,224);font-family:Verdana,sans-serif">
Publish<strong style="font-size:2em;display:block;color:rgb(68,68,68);font-weight:normal">148</strong>msg/s</div><div style="min-width:120px;font-size:14px;text-align:center;padding:10px;margin:0px 20px 0px 0px;color:rgb(136,136,136);border-top-left-radius:10px;border-top-right-radius:10px;border-bottom-right-radius:10px;border-bottom-left-radius:10px;float:left;background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(240,240,240)),to(rgb(224,224,224)));border:1px solid rgb(224,224,224);font-family:Verdana,sans-serif">
Deliver<strong style="font-size:2em;display:block;color:rgb(68,68,68);font-weight:normal">744</strong>msg/s</div><div style="min-width:120px;font-size:14px;text-align:center;padding:10px;margin:0px 20px 0px 0px;color:rgb(136,136,136);border-top-left-radius:10px;border-top-right-radius:10px;border-bottom-right-radius:10px;border-bottom-left-radius:10px;float:left;background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(240,240,240)),to(rgb(224,224,224)));border:1px solid rgb(224,224,224);font-family:Verdana,sans-serif">
Redelivered<strong style="font-size:2em;display:block;color:rgb(68,68,68);font-weight:normal">0.00</strong>msg/s</div><div style="min-width:120px;font-size:14px;text-align:center;padding:10px;margin:0px 20px 0px 0px;color:rgb(136,136,136);border-top-left-radius:10px;border-top-right-radius:10px;border-bottom-right-radius:10px;border-bottom-left-radius:10px;float:left;background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(240,240,240)),to(rgb(224,224,224)));border:1px solid rgb(224,224,224);font-family:Verdana,sans-serif">
Acknowledge<strong style="font-size:2em;display:block;color:rgb(68,68,68);font-weight:normal">746</strong>msg/s</div></div><div><br></div><div><br></div><div><br></div><div><div><br></div><div><br></div><div><br></div><div>
<br></div><div><br></div><div><table style="border-collapse:collapse;border-width:1px;border-bottom-style:solid;border-bottom-color:rgb(204,204,204);margin-bottom:0px;font-family:Verdana,sans-serif"><tbody><tr>
<th style="font-weight:normal;font-size:12px;line-height:17px;padding:4px;vertical-align:top;min-width:5em;width:auto;border:1px solid rgb(204,204,204);text-align:center">Name</th><th style="font-weight:normal;font-size:12px;line-height:17px;padding:4px;vertical-align:top;min-width:5em;width:auto;border:1px solid rgb(204,204,204);text-align:center">
File descriptors�<span style="color:rgb(136,136,136)">(?)</span><sub style="display:block;font-size:0.8em;color:rgb(136,136,136)">(used / available)</sub></th><th style="font-weight:normal;font-size:12px;line-height:17px;padding:4px;vertical-align:top;min-width:5em;width:auto;border:1px solid rgb(204,204,204);text-align:center">
Socket descriptors�<span style="color:rgb(136,136,136)">(?)</span><sub style="display:block;font-size:0.8em;color:rgb(136,136,136)">(used / available)</sub></th><th style="font-weight:normal;font-size:12px;line-height:17px;padding:4px;vertical-align:top;min-width:5em;width:auto;border:1px solid rgb(204,204,204);text-align:center">
Erlang processes<sub style="display:block;font-size:0.8em;color:rgb(136,136,136)">(used / available)</sub></th><th style="font-weight:normal;font-size:12px;line-height:17px;padding:4px;vertical-align:top;min-width:5em;width:auto;border:1px solid rgb(204,204,204);text-align:center">
Memory</th><th style="font-weight:normal;font-size:12px;line-height:17px;padding:4px;vertical-align:top;min-width:5em;width:auto;border:1px solid rgb(204,204,204);text-align:center">Disk space</th><th style="font-weight:normal;font-size:12px;line-height:17px;padding:4px;vertical-align:top;min-width:5em;width:auto;border:1px solid rgb(204,204,204);text-align:center">
Uptime</th><th style="font-weight:normal;font-size:12px;line-height:17px;padding:4px;vertical-align:top;min-width:5em;width:auto;border:1px solid rgb(204,204,204);text-align:center">Type</th></tr><tr><td style="font-size:12px;line-height:17px;font-family:Verdana,sans-serif;padding:4px;vertical-align:top;min-width:5em;width:auto;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);border-right-width:1px;border-right-style:solid;border-right-color:rgb(204,204,204);background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(240,240,240)),to(rgb(224,224,224)))">
<br></td><td style="font-size:12px;line-height:17px;font-family:Verdana,sans-serif;padding:4px;text-align:center;vertical-align:top;min-width:5em;width:auto;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);border-right-width:1px;border-right-style:solid;border-right-color:rgb(204,204,204);background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(240,240,240)),to(rgb(224,224,224)))">
<div style="padding:5px;border-top-left-radius:5px;border-top-right-radius:5px;border-bottom-right-radius:5px;border-bottom-left-radius:5px;background-color:rgb(144,238,144)">297 / 1024</div></td><td style="font-size:12px;line-height:17px;font-family:Verdana,sans-serif;padding:4px;text-align:center;vertical-align:top;min-width:5em;width:auto;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);border-right-width:1px;border-right-style:solid;border-right-color:rgb(204,204,204);background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(240,240,240)),to(rgb(224,224,224)))">
<div style="padding:5px;border-top-left-radius:5px;border-top-right-radius:5px;border-bottom-right-radius:5px;border-bottom-left-radius:5px;background-color:rgb(144,238,144)">135 / 829</div></td><td style="font-size:12px;line-height:17px;font-family:Verdana,sans-serif;padding:4px;text-align:center;vertical-align:top;min-width:5em;width:auto;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);border-right-width:1px;border-right-style:solid;border-right-color:rgb(204,204,204);background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(240,240,240)),to(rgb(224,224,224)))">
<div style="padding:5px;border-top-left-radius:5px;border-top-right-radius:5px;border-bottom-right-radius:5px;border-bottom-left-radius:5px;background-color:rgb(144,238,144)">16815 / 1048576</div></td><td style="font-size:12px;line-height:17px;font-family:Verdana,sans-serif;padding:4px;text-align:center;vertical-align:top;min-width:5em;width:auto;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);border-right-width:1px;border-right-style:solid;border-right-color:rgb(204,204,204);background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(240,240,240)),to(rgb(224,224,224)))">
<div style="padding:5px;border-top-left-radius:5px;border-top-right-radius:5px;border-bottom-right-radius:5px;border-bottom-left-radius:5px;background-color:rgb(144,238,144)">826.6MB</div><sub style="display:block;font-size:0.8em;color:rgb(136,136,136)">6.2GB high waterm</sub></td>
</tr></tbody></table></div><div><br></div><div><br></div><div>Tasks: 598 total, � 1 running, 597 sleeping, � 0 stopped, � 0 zombie</div><div>Cpu0 �: 29.8%us, �6.0%sy, �0.0%ni, 64.2%id, �0.0%wa, �0.0%hi, �0.0%si, �0.0%st</div>
<div>Cpu1 �: 33.2%us, �5.6%sy, �0.0%ni, 61.1%id, �0.0%wa, �0.0%hi, �0.0%si, �0.0%st</div><div>Cpu2 �: 34.7%us, �6.1%sy, �0.0%ni, 59.3%id, �0.0%wa, �0.0%hi, �0.0%si, �0.0%st</div><div>Cpu3 �: 30.1%us, �4.7%sy, �0.0%ni, 64.5%id, �0.7%wa, �0.0%hi, �0.0%si, �0.0%st</div>
<div>Cpu4 �: 29.7%us, �5.3%sy, �0.0%ni, 65.0%id, �0.0%wa, �0.0%hi, �0.0%si, �0.0%st</div><div>Cpu5 �: 34.2%us, �6.2%sy, �0.0%ni, 56.8%id, �0.0%wa, �0.0%hi, �2.7%si, �0.0%st</div><div>Cpu6 �: 19.9%us, �3.4%sy, �0.0%ni, 76.4%id, �0.0%wa, �0.0%hi, �0.3%si, �0.0%st</div>
<div>Cpu7 �: �2.3%us, �1.0%sy, �0.0%ni, 96.7%id, �0.0%wa, �0.0%hi, �0.0%si, �0.0%st</div><div>Mem: �16217336k total, 13285852k used, �2931484k free, � 191072k buffers</div><div>Swap: �2097144k total, � � 4904k used, �2092240k free, 10533540k cached</div>
<div><br></div><div>�PID USER � � �PR �NI �VIRT �RES �SHR S %CPU %MEM � �TIME+ �COMMAND � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � ��</div><div>
19404 rabbitmq �20 � 0 3551m 806m 2480 S 254.6 �5.1 �21417:07 beam.smp ��</div></div>
<br>_______________________________________________<br>
rabbitmq-discuss mailing list<br>
<a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a><br>
<a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss" target="_blank">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br>
<br></blockquote></div><br></div>