[rabbitmq-discuss] Per-Connection Flow Control - RMQ 2.8.1

DawgTool dawgtool at aol.com
Mon Mar 26 17:31:24 BST 2012


Hi Simon,

Memory seemed to be fine with 2.7.1, it ran without issue for several 
months before upgrading to 2.8.1.  For now I have increased the TCP 
buffer size, which I don't think will fix my issues, since I am getting 
locks with constant flow (normal flow causing control, not spikes).  Is 
there anyway to modify how much can be buffered on the exchange and queue?

Thanks

On 3/26/12 6:25 AM, Simon MacMullen wrote:
> Hi.
>
> There's no way to monitor what the flow control is doing.
>
> I would assume that with 7k msg/s on 2.7.1 you see memory use steadily 
> increasing? The flow control should just be preventing (significant 
> numbers of) messages being queued up anywhere else than in queues. The 
> idea is to ensure that whatever performance RabbitMQ is giving you is 
> sustainable, rather than letting it absorb more messages in the short 
> term at the cost of working itself into a hole that is difficult to 
> get out of.
>
> If you need the ability to absorb spikes in publishing rates then you 
> can increase the size of TCP buffers on the server.
>
> Cheers, Simon
>
> On 23/03/12 20:03, DawgTool wrote:
>> Hi All,
>>
>> Wondering is anyone having issues with the Per-Connection Flow Control
>> in 2.8.1?
>> Under 2.7.1 was able to push about 4.5MB/s per connection (about
>> ~7000msg/s).
>> Under 2.8.1 I am hitting the flow control constantly at about 2.4MB/s
>> per connection.
>> Clean installed 2.8.1 on the same hardware as 2.7.1.
>>
>> Is there someway to configure/monitor what is causing the Flow Control
>> to be tripped?
>>
>> Thanks in Advance.
>>
>>
>>
>> Config: (both 2.7.1/2.8.1)
>> Erlang R15B (erts-5.9) [source] [64-bit] [smp:4:4] [async-threads:30]
>> [hipe] [kernel-poll:true]
>>
>> ==> enabled_plugins <==
>> [rabbitmq_management,rabbitmq_management_agent].
>>
>> ==> rabbitmq.config <==
>> [
>> {rabbit, [{vm_memory_high_watermark, 0.6},
>> {collect_statistics_interval, 5000},
>> {hipe_compile, true}
>> ]
>> },
>> {mnesia, [{dc_dump_limit, 40},
>> {dump_log_write_threshold, 50000},
>> {no_table_loaders, 20},
>> {send_compressed, 9},
>> {snmp, true}
>> ]
>> },
>> {rabbitmq_management, [ {http_log_dir,
>> "/data/rabbitmq/dc001/rabbit-mgmt"} ] },
>> {rabbitmq_management_agent, [ {force_fine_statistics, true} ] }
>> ].
>>
>> ==> rabbitmq-env.conf <==
>> NODENAME=dc001
>> BASE=/data/rabbitmq/dc001
>> MNESIA_BASE=/data/rabbitmq/dc001/mnesia
>> LOG_BASE=/data/rabbitmq/dc001/log
>> SERVER_START_ARGS="+K true -smp enable"
>>
>>
>>
>>
>> _______________________________________________
>> rabbitmq-discuss mailing list
>> rabbitmq-discuss at lists.rabbitmq.com
>> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>



More information about the rabbitmq-discuss mailing list