[rabbitmq-discuss] RabbitMQ 2.6.1 is unexpectedly eating up memory

ingo schramm schramm.ingo at googlemail.com
Wed Mar 7 14:26:58 GMT 2012


Today it happened again. When Rabbit had about 13G RAM usage on one node 
(<1G is the usual number), I connected to the node and got some infos. I 
post these below. Unfortunately, I cannot see that much in the data since I 
do not know what the processes are doing exactly inside Rabbit.

After a while the system seemed to recover but irritated clients started to 
connect in an unusual pattern and then - almost immediately - the RAM usage 
executed a Big Bang, up to 55G allocated, the machine began to swap ...

Here is the dump of the 10 most memory consuming processes.

(ram2 at tarazed)4> erlang:memory().
[{total,14709955672},
 {processes,9701451024},
 {processes_used,9685449080},
 {system,5008504648},
 {atom,1318801},
 {atom_used,1286285},
 {binary,4901053992},
 {code,15227889},
 {ets,23180616}]

[{{memory,1868315056},
  <0.21462.60>,
  [{current_function,{erl_eval,do_apply,5}},
   {initial_call,{erlang,apply,2}},
   {status,running},
   {message_queue_len,0},
   {messages,[]},
   {links,[<0.21461.60>]},
   {dictionary,[]},
   {trap_exit,false},
   {error_handler,error_handler},
   {priority,normal},
   {group_leader,<18922.32.0>},
   {total_heap_size,233539280},
   {heap_size,116769640},
   {stack_size,88},
   {reductions,8019756},
   {garbage_collection,[{fullsweep_after,65535},{minor_gcs,1}]},
   {suspending,[]}]},
 {{memory,1826853040},
  <0.252.0>,
  [{current_function,{gen,wait_resp_mon,3}},
   {initial_call,{proc_lib,init_p,5}},
   {status,waiting},
   {message_queue_len,3},
   {messages,[{'$gen_cast',{notify_sent,<0.26233.60>}},
              {'$gen_cast',{ack,[128755027],<0.22877.60>}},
              {'$gen_cast',{unblock,<0.22877.60>}}]},
   {links,[#Port<0.162932>,<0.250.0>,#Port<0.4466>]},
   {dictionary,[{{ch,<0.30314.59>},
                 {cr,1,<0.30314.59>,
                     {token,<0.30313.59>,true},
                     #Ref<0.0.913.261747>,
                     {set,1,16,16,8,80,...},
                     true,1}},
                {{ch,<0.11679.60>},
                 {cr,1,<0.11679.60>,
                     {token,<0.11678.60>,true},
                     #Ref<0.0.916.161564>,
                     {set,1,16,16,8,...},
                     true,0}},
                {{ch,<0.29890.59>},
                 {cr,1,<0.29890.59>,
                     {token,<0.29889.59>,true},
                     #Ref<0.0.913.256520>,
                     {set,1,16,16,...},
                     true,1}},
                {{ch,<0.24130.59>},
                 {cr,1,<0.24130.59>,
                     {token,<0.24129.59>,true},
                     #Ref<0.0.912.149255>,
                     {set,1,16,...},
                     true,1}},
                {{ch,<0.21656.59>},
                 {cr,1,<0.21656.59>,
                     {token,<0.21655.59>,true},
                     #Ref<0.0.911.188523>,
                     {set,1,...},
                     true,1}},
                {{ch,<0.15601.60>},
                 {cr,1,<0.15601.60>,
                     {token,<0.15600.60>,true},
                     #Ref<0.0.917.100808>,
                     {set,...},
                     true,...}},
                {{ch,<15215.21015.63>},
                 {cr,1,<15215.21015.63>,
                     {token,<15215.21014.63>,...},
                     #Ref<0.0.815.242631>,{...},...}},
                {{ch,<0.21015.12>},
                 {cr,1,<0.21015.12>,{token,...},#Ref<0.0.295.125075>,...}},
                {{ch,<0.17432.59>},{cr,1,<0.17432.59>,{...},...}},
                {{ch,<0.9598.46>},{cr,1,<0.9598.46>,...}},
                {{ch,<15215.20479.63>},{cr,1,...}},
                {{ch,<0.24362.59>},{cr,...}},
                {{ch,...},{...}},
                {{...},...},
                {...}|...]},
   {trap_exit,true},
   {error_handler,error_handler},
   {priority,normal},
   {group_leader,<0.108.0>},
   {total_heap_size,228065700},
   {heap_size,228065700},
   {stack_size,48},
   {reductions,86360443586},
   {garbage_collection,[{fullsweep_after,65535},{minor_gcs,0}]},
   {suspending,[]}]},
 {{memory,544009512},
  <0.218.0>,
  [{registered_name,delegate_11},
   {current_function,{gen,wait_resp_mon,3}},
   {initial_call,{proc_lib,init_p,5}},
   {status,waiting},
   {message_queue_len,45210},
   {messages,[{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[...]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,...}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{...}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
              {'$gen_cast',{invoke,...}},
              {'$gen_cast',{...}},
              {'$gen_cast',...},
              {...}|...]},
   {links,[<0.206.0>]},
   {dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
                               <0.109.0>]},
                {'$initial_call',{gen,init_it,7}}]},
   {trap_exit,false},
   {error_handler,error_handler},
   {priority,normal},
   {group_leader,<0.108.0>},
   {total_heap_size,67810415},
   {heap_size,8024355},
   {stack_size,32},
   {reductions,536435169},
   {garbage_collection,[{fullsweep_after,65535},{minor_gcs,1}]},
   {suspending,[]}]},
 {{memory,544003272},
  <0.213.0>,
  [{registered_name,delegate_6},
   {current_function,{gen,wait_resp_mon,3}},
   {initial_call,{proc_lib,init_p,5}},
   {status,waiting},
   {message_queue_len,45000},
   {messages,[{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[...]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,...}]}},
              {'$gen_call',{<15215.4753.67>,
                            {#Ref<15215.0.573.141891>,ram2 at tarazed}},
                           
{invoke,#Fun<rabbit_amqqueue.22.114209891>,[...]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
              {'$gen_cast',{invoke,...}},
              {'$gen_cast',{...}},
              {'$gen_cast',...},
              {...}|...]},
   {links,[<0.206.0>]},
   {dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
                               <0.109.0>]},
                {'$initial_call',{gen,init_it,7}}]},
   {trap_exit,false},
   {error_handler,error_handler},
   {priority,normal},
   {group_leader,<0.108.0>},
   {total_heap_size,67810415},
   {heap_size,8024355},
   {stack_size,32},
   {reductions,492300563},
   {garbage_collection,[{fullsweep_after,65535},
                        {minor_gcs,...}]},
   {suspending,[]}]},
 {{memory,543937016},
  <0.220.0>,
  [{registered_name,delegate_13},
   {current_function,{gen,wait_resp_mon,3}},
   {initial_call,{proc_lib,init_p,5}},
   {status,waiting},
   {message_queue_len,43117},
   {messages,[{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[...]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,...}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{...}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
              {'$gen_cast',{invoke,...}},
              {'$gen_cast',{...}},
              {'$gen_cast',...},
              {...}|...]},
   {links,[<0.206.0>]},
   {dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
                               <0.109.0>]},
                {'$initial_call',{gen,init_it,7}}]},
   {trap_exit,false},
   {error_handler,error_handler},
   {priority,normal},
   {group_leader,<0.108.0>},
   {total_heap_size,67810415},
   {heap_size,8024355},
   {stack_size,32},
   {reductions,516829717},
   {garbage_collection,[{fullsweep_after,...},{...}]},
   {suspending,[]}]},
 {{memory,509272344},
  <0.208.0>,
  [{registered_name,delegate_1},
   {current_function,{gen,wait_resp_mon,3}},
   {initial_call,{proc_lib,init_p,5}},
   {status,waiting},
   {message_queue_len,36921},
   {messages,[{'$gen_cast',{invoke,#Fun<rabbit_amqqueue.23.2473037>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[...]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,...}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{...}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
              {'$gen_cast',{invoke,...}},
              {'$gen_cast',{...}},
              {'$gen_cast',...},
              {...}|...]},
   {links,[<0.206.0>]},
   {dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
                               <0.109.0>]},
                {'$initial_call',{gen,init_it,7}}]},
   {trap_exit,false},
   {error_handler,error_handler},
   {priority,normal},
   {group_leader,<0.108.0>},
   {total_heap_size,63501410},
   {heap_size,15672560},
   {stack_size,32},
   {reductions,481258527},
   {garbage_collection,[{...}|...]},
   {suspending,[]}]},
 {{memory,484092056},
  <0.209.0>,
  [{registered_name,delegate_2},
   {current_function,{gen,wait_resp_mon,3}},
   {initial_call,{proc_lib,init_p,5}},
   {status,waiting},
   {message_queue_len,33987},
   {messages,[{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[...]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,...}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{...}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
              {'$gen_cast',{invoke,...}},
              {'$gen_cast',{...}},
              {'$gen_cast',...},
              {...}|...]},
   {links,[<0.206.0>]},
   {dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
                               <0.109.0>]},
                {'$initial_call',{gen,init_it,7}}]},
   {trap_exit,false},
   {error_handler,error_handler},
   {priority,normal},
   {group_leader,<0.108.0>},
   {total_heap_size,60366900},
   {heap_size,12538050},
   {stack_size,32},
   {reductions,439896730},
   {garbage_collection,[...]},
   {suspending,...}]},
 {{memory,383857832},
  <0.207.0>,
  [{registered_name,delegate_0},
   {current_function,{gen,wait_resp_mon,3}},
   {initial_call,{proc_lib,init_p,5}},
   {status,waiting},
   {message_queue_len,36015},
   {messages,[{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[<0.252.0>]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[...]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,...}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{...}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
              {'$gen_cast',{invoke,...}},
              {'$gen_cast',{...}},
              {'$gen_cast',...},
              {...}|...]},
   {links,[<0.206.0>]},
   {dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
                               <0.109.0>]},
                {'$initial_call',{gen,init_it,7}}]},
   {trap_exit,false},
   {error_handler,error_handler},
   {priority,normal},
   {group_leader,<0.108.0>},
   {total_heap_size,47828850},
   {heap_size,47828850},
   {stack_size,32},
   {reductions,464166560},
   {garbage_collection,...},
   {...}]},
 {{memory,322186712},
  <0.214.0>,
  [{registered_name,delegate_7},
   {current_function,{gen,wait_resp_mon,3}},
   {initial_call,{proc_lib,init_p,5}},
   {status,waiting},
   {message_queue_len,25955},
   {messages,[{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,[...]}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,...}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{...}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
              {'$gen_cast',{invoke,...}},
              {'$gen_cast',{...}},
              {'$gen_cast',...},
              {...}|...]},
   {links,[<0.206.0>]},
   {dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
                               <0.109.0>]},
                {'$initial_call',{gen,init_it,7}}]},
   {trap_exit,false},
   {error_handler,error_handler},
   {priority,normal},
   {group_leader,<0.108.0>},
   {total_heap_size,40160935},
   {heap_size,15672560},
   {stack_size,32},
   {reductions,...},
   {...}|...]},
 {{memory,245833600},
  <0.212.0>,
  [{registered_name,delegate_5},
   {current_function,{gen,wait_resp_mon,3}},
   {initial_call,{proc_lib,init_p,5}},
   {status,waiting},
   {message_queue_len,27354},
   {messages,[{'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{ram2 at tarazed,...}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,
                                   [{...}]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,[...]}},
              {'$gen_cast',{invoke,#Fun<rabbit_router.0.66097277>,...}},
              {'$gen_cast',{invoke,...}},
              {'$gen_cast',{...}},
              {'$gen_cast',...},
              {...}|...]},
   {links,[<0.206.0>]},
   {dictionary,[{'$ancestors',[delegate_sup,rabbit_sup,
                               <0.109.0>]},
                {'$initial_call',{gen,init_it,...}}]},
   {trap_exit,false},
   {error_handler,error_handler},
   {priority,normal},
   {group_leader,<0.108.0>},
   {total_heap_size,30610465},
   {heap_size,30610465},
   {stack_size,...},
   {...}|...]}]


Am Dienstag, 6. März 2012 13:15:41 UTC+1 schrieb Simon MacMullen:
>
> On 06/03/12 11:38, ingo schramm wrote:
> > I do *not* use a mirrored queue :)
>
> Ah, right, that's how I read "queues distributed over all nodes".
>
> Hmm. It's still easier to figure out the memory use of RabbitMQ on 
> 2.7.1, but for 2.6.1 you could check per-queue memory use with 
> "rabbitmqctl list_queues name memory" (or look in mgmt). If this doesn't 
> bring anything useful up then:
>
> * Become the user the broker is running as
> * Run "erl -sname foo -remsh rabbit@$(hostname -s)" to get a shell into 
> the running broker
> * Invoke "erlang:memory()." for an overview of memory use in the VM.
> * Invoke "lists:sublist(lists:reverse(lists:sort([{process_info(Pid,
> memory), Pid, process_info(Pid)} || Pid <- processes()])), 10)." for a 
> lit of the top 10 memory using processes, and some information on each one.
>
> Cheers, Simon
>
> -- 
> Simon MacMullen
> RabbitMQ, VMware
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
Am Dienstag, 6. März 2012 13:15:41 UTC+1 schrieb Simon MacMullen:
>
> On 06/03/12 11:38, ingo schramm wrote:
> > I do *not* use a mirrored queue :)
>
> Ah, right, that's how I read "queues distributed over all nodes".
>
> Hmm. It's still easier to figure out the memory use of RabbitMQ on 
> 2.7.1, but for 2.6.1 you could check per-queue memory use with 
> "rabbitmqctl list_queues name memory" (or look in mgmt). If this doesn't 
> bring anything useful up then:
>
> * Become the user the broker is running as
> * Run "erl -sname foo -remsh rabbit@$(hostname -s)" to get a shell into 
> the running broker
> * Invoke "erlang:memory()." for an overview of memory use in the VM.
> * Invoke "lists:sublist(lists:reverse(lists:sort([{process_info(Pid,
> memory), Pid, process_info(Pid)} || Pid <- processes()])), 10)." for a 
> lit of the top 10 memory using processes, and some information on each one.
>
> Cheers, Simon
>
> -- 
> Simon MacMullen
> RabbitMQ, VMware
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
Am Dienstag, 6. März 2012 13:15:41 UTC+1 schrieb Simon MacMullen:
>
> On 06/03/12 11:38, ingo schramm wrote:
> > I do *not* use a mirrored queue :)
>
> Ah, right, that's how I read "queues distributed over all nodes".
>
> Hmm. It's still easier to figure out the memory use of RabbitMQ on 
> 2.7.1, but for 2.6.1 you could check per-queue memory use with 
> "rabbitmqctl list_queues name memory" (or look in mgmt). If this doesn't 
> bring anything useful up then:
>
> * Become the user the broker is running as
> * Run "erl -sname foo -remsh rabbit@$(hostname -s)" to get a shell into 
> the running broker
> * Invoke "erlang:memory()." for an overview of memory use in the VM.
> * Invoke "lists:sublist(lists:reverse(lists:sort([{process_info(Pid,
> memory), Pid, process_info(Pid)} || Pid <- processes()])), 10)." for a 
> lit of the top 10 memory using processes, and some information on each one.
>
> Cheers, Simon
>
> -- 
> Simon MacMullen
> RabbitMQ, VMware
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
Am Dienstag, 6. März 2012 13:15:41 UTC+1 schrieb Simon MacMullen:
>
> On 06/03/12 11:38, ingo schramm wrote:
> > I do *not* use a mirrored queue :)
>
> Ah, right, that's how I read "queues distributed over all nodes".
>
> Hmm. It's still easier to figure out the memory use of RabbitMQ on 
> 2.7.1, but for 2.6.1 you could check per-queue memory use with 
> "rabbitmqctl list_queues name memory" (or look in mgmt). If this doesn't 
> bring anything useful up then:
>
> * Become the user the broker is running as
> * Run "erl -sname foo -remsh rabbit@$(hostname -s)" to get a shell into 
> the running broker
> * Invoke "erlang:memory()." for an overview of memory use in the VM.
> * Invoke "lists:sublist(lists:reverse(lists:sort([{process_info(Pid,
> memory), Pid, process_info(Pid)} || Pid <- processes()])), 10)." for a 
> lit of the top 10 memory using processes, and some information on each one.
>
> Cheers, Simon
>
> -- 
> Simon MacMullen
> RabbitMQ, VMware
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
Am Dienstag, 6. März 2012 13:15:41 UTC+1 schrieb Simon MacMullen:
>
> On 06/03/12 11:38, ingo schramm wrote:
> > I do *not* use a mirrored queue :)
>
> Ah, right, that's how I read "queues distributed over all nodes".
>
> Hmm. It's still easier to figure out the memory use of RabbitMQ on 
> 2.7.1, but for 2.6.1 you could check per-queue memory use with 
> "rabbitmqctl list_queues name memory" (or look in mgmt). If this doesn't 
> bring anything useful up then:
>
> * Become the user the broker is running as
> * Run "erl -sname foo -remsh rabbit@$(hostname -s)" to get a shell into 
> the running broker
> * Invoke "erlang:memory()." for an overview of memory use in the VM.
> * Invoke "lists:sublist(lists:reverse(lists:sort([{process_info(Pid,
> memory), Pid, process_info(Pid)} || Pid <- processes()])), 10)." for a 
> lit of the top 10 memory using processes, and some information on each one.
>
> Cheers, Simon
>
> -- 
> Simon MacMullen
> RabbitMQ, VMware
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
Am Dienstag, 6. März 2012 13:15:41 UTC+1 schrieb Simon MacMullen:
>
> On 06/03/12 11:38, ingo schramm wrote:
> > I do *not* use a mirrored queue :)
>
> Ah, right, that's how I read "queues distributed over all nodes".
>
> Hmm. It's still easier to figure out the memory use of RabbitMQ on 
> 2.7.1, but for 2.6.1 you could check per-queue memory use with 
> "rabbitmqctl list_queues name memory" (or look in mgmt). If this doesn't 
> bring anything useful up then:
>
> * Become the user the broker is running as
> * Run "erl -sname foo -remsh rabbit@$(hostname -s)" to get a shell into 
> the running broker
> * Invoke "erlang:memory()." for an overview of memory use in the VM.
> * Invoke "lists:sublist(lists:reverse(lists:sort([{process_info(Pid,
> memory), Pid, process_info(Pid)} || Pid <- processes()])), 10)." for a 
> lit of the top 10 memory using processes, and some information on each one.
>
> Cheers, Simon
>
> -- 
> Simon MacMullen
> RabbitMQ, VMware
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20120307/3d4ef029/attachment.htm>


More information about the rabbitmq-discuss mailing list