<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>