[rabbitmq-discuss] RabbitMQ blocking issue
Matthias Radestock
matthias at rabbitmq.com
Tue Feb 12 19:58:50 GMT 2013
Peter,
On 12/02/13 13:27, Konar Peter (Nokia-LC/Chicago) wrote:
> Connections:
> pid name port peer_port host peer_host ssl peer_cert_subject peer_cert_issuer peer_cert_validity auth_mechanism ssl_protocol ssl_key_exchange ssl_cipher ssl_hash protocol user vhost timeout frame_max client_properties recv_oct recv_cnt send_oct send_cnt send_pend state last_blocked_by last_blocked_age channels
> <rabbit at ajtrafp063.3.3992.0> 10.196.42.119:48485 -> 10.196.42.21:5672 5672 48485 10.196.42.21 10.196.42.119 false PLAIN {0,9,1} guest / 600 131072 [{"product","RabbitMQ"},{"information","Licensed under the MPL. See http://www.rabbitmq.com/"},{"platform","Java"},{"capabilities",[{"exchange_exchange_bindings",true},{"consumer_cancel_notify",true},{"basic.nack",true},{"publisher_confirms",true}]},{"copyright","Copyright (C) 2007-2012 VMware, Inc."},{"version","2.8.4"}] 149398118 6460971 2122464675 7082940 0 running none infinity 1
> <rabbit at ajtrafp063.3.4254.0> 10.196.42.120:59485 -> 10.196.42.21:5672 5672 59485 10.196.42.21 10.196.42.120 false PLAIN {0,9,1} guest / 600 131072 [{"product","RabbitMQ"},{"information","Licensed under the MPL. See http://www.rabbitmq.com/"},{"platform","Java"},{"capabilities",[{"exchange_exchange_bindings",true},{"consumer_cancel_notify",true},{"basic.nack",true},{"publisher_confirms",true}]},{"copyright","Copyright (C) 2007-2012 VMware, Inc."},{"version","2.8.4"}] 109362206 4866571 3624114636 5187935 0 running none infinity 1
> <rabbit at ajtrafp063.3.20125.0> 147.243.130.14:34613 -> 10.196.42.21:5672 5672 34613 10.196.42.21 147.243.130.14 false PLAIN {0,9,1} guest / 600 131072 [{"product","RabbitMQ"},{"information","Licensed under the MPL. See http://www.rabbitmq.com/"},{"platform","Java"},{"capabilities",[{"exchange_exchange_bindings",true},{"consumer_cancel_notify",true},{"basic.nack",true},{"publisher_confirms",true}]},{"copyright","Copyright (C) 2007-2012 VMware, Inc."},{"version","2.8.4"}] 2254516 41540 96969022 93165 0 running none infinity 1
> <rabbit at ajtrafp064.1.14970.129> 10.196.42.182:50012 -> 10.196.42.22:5672 5672 50012 10.196.42.22 10.196.42.182 false PLAIN {0,9,1} guest / 600 131072 [{"product","RabbitMQ"},{"information","Licensed under the MPL. See http://www.rabbitmq.com/"},{"platform","Java"},{"capabilities",[{"exchange_exchange_bindings",true},{"consumer_cancel_notify",true},{"basic.nack",true},{"publisher_confirms",true}]},{"copyright","Copyright (C) 2007-2013 VMware, Inc."},{"version","3.0.2"}] 892971313 13406695 65127580 4651947 0 running flow 708.153401 2
> <rabbit at ajtrafp064.1.13886.130> 10.196.42.180:57261 -> 10.196.42.22:5672 5672 57261 10.196.42.22 10.196.42.180 false PLAIN {0,9,1} guest / 600 131072 [{"product","RabbitMQ"},{"information","Licensed under the MPL. See http://www.rabbitmq.com/"},{"platform","Java"},{"capabilities",[{"exchange_exchange_bindings",true},{"consumer_cancel_notify",true},{"basic.nack",true},{"publisher_confirms",true}]},{"copyright","Copyright (C) 2007-2013 VMware, Inc."},{"version","3.0.2"}] 991521388 13254940 64474148 4605273 0 running flow 1012.465014 1
> <rabbit at ajtrafp064.1.5604.131> 10.196.42.128:38983 -> 10.196.42.22:5672 5672 38983 10.196.42.22 10.196.42.128 false PLAIN {0,9,1} guest / 600 131072 [{"product","RabbitMQ"},{"information","Licensed under the MPL. See http://www.rabbitmq.com/"},{"platform","Java"},{"capabilities",[{"exchange_exchange_bindings",true},{"consumer_cancel_notify",true},{"basic.nack",true},{"publisher_confirms",true}]},{"copyright","Copyright (C) 2007-2013 VMware, Inc."},{"version","3.0.2"}] 1260443690 13146545 63815924 4558257 0 running flow 713.080137 1
> <rabbit at ajtrafp064.1.31824.131> 10.196.42.179:41165 -> 10.196.42.22:5672 5672 41165 10.196.42.22 10.196.42.179 false PLAIN {0,9,1} guest / 600 131072 [{"product","RabbitMQ"},{"information","Licensed under the MPL. See http://www.rabbitmq.com/"},{"platform","Java"},{"capabilities",[{"exchange_exchange_bindings",true},{"consumer_cancel_notify",true},{"basic.nack",true},{"publisher_confirms",true}]},{"copyright","Copyright (C) 2007-2013 VMware, Inc."},{"version","3.0.2"}] 1207139221 13617335 66191024 4727907 0 running flow 1314.712837 1
So there are 7 connections here, all of them in the 'running' state,
which means they should be reading data...
> RabbitMQ Netstat
> Proto Recv-Q Send-Q Local Address Foreign Address State
> tcp 0 0 :::5672 :::* LISTEN
> tcp 0 0 ::ffff:10.196.42.21:5672 ::ffff:10.196.42.119:48485 ESTABLISHED
> tcp 0 0 ::ffff:10.196.42.21:5672 ::ffff:10.196.42.120:59485 ESTABLISHED
> tcp 0 0 ::ffff:10.196.42.21:5672 ::ffff:147.243.130.14:34613 ESTABLISHED
But why does this only show three connections? Is that really the
complete list?
Note that all the above connections show a Recv-Q of 0, indicating that
rabbit has read all the data from the socket. Contrary to what James
suggested. Though...
> TSA Client Netstat
> Proto Recv-Q Send-Q Local Address Foreign Address State
> tcp 0 246112 ::ffff:10.196.42.182:50012 ::ffff:10.196.42.22:5672 ESTABLISHED
...this client-side blocked connection (as evidenced by the non-zero
Send-Q) doesn't show up in the server netstat report. Which can't be
right since that connection *does* show up in the rabbit report (4th row).
So I think something went wrong with the server-side netstat report.
Matthias
More information about the rabbitmq-discuss
mailing list