AMQPのデバッグ例

奇跡的に最初の部分に入らなかったのは......

$queue = new AMQPQueue($cnn, 'Habrauser')
1257461452685: conn#74 ch#1 -> {#method<queue.declare>(ticket=0,queue=Habrauser,passive=false,durable=false,exclusive=false,auto-delete=true,nowait=false,arguments={}),null,""}
1257461452686: conn#74 ch#1 <- {#method<queue.declare-ok>(queue=Habrauser,message-count=0,consumer-count=0),null,""}

キューのアナウンスが成功しました:メッセージの数message-count = 0、サブスクライバーなし:consumer-count = 0

キュー通知オプション:


$queue->bind("ex_2", '12345');

1257461452703: conn#74 ch#1 -> {#method<queue.bind>(ticket=0,queue=Habrauser,exchange=ex_test2,routing-key=12345,nowait=false,arguments={}),null,""}
1257461452703: conn#74 ch#1 <- {#method<queue.bind-ok>(),null,""}

メッセージを送る:
$mag='messsage 0';
$exchange = new Exchange('ex_2');
$exchange->publish( $msg, '12345' );

1257461452704: conn#74 ch#1 -> {#method<basic.publish>(ticket=0,exchange=ex_2,routing-key=12345,mandatory=false,immediate=false),#contentHeader(content-type=text/plain, content-encoding=null, headers=null, delivery-mode=null, priority=null, correlation-id=null, reply-to=null, expiration=null, message-id=null, timestamp=null, type=null, user-id=null, app-id=null, cluster-id=null),"messsage 0"}

: , ,
:
exchange=ex_2, routing-key=12345, mandatory=false, immediate=false
- ,
.

:

1257461452713: conn#74 ch#1 <- {#method<basic.deliver>(consumer-tag=amq.ctag-hnDha3s6i5xnJkkf0kB1DQ==,delivery-tag=6,redelivered=false,exchange=ex_test2,routing-key=12345),#contentHeader(content-type=text/plain, content-encoding=null, headers=null, delivery-mode=null, priority=null, correlation-id=null, reply-to=null, expiration=null, message-id=null, timestamp=null, type=null, user-id=null, app-id=null, cluster-id=null),"messsage 4"}

:
consumer-tag=amq.ctag-hnDha3s6i5xnJkkf0kB1DQ==, - ( )
delivery-tag=6 - .

, .

AMQP amqp-xml-doc0-8

.
$mag='messsage 0';
$exchange = new Exchange('ex_2');
$exchange->publish( $msg, '12345' );

1257461452704: conn#74 ch#1 -> {#method<basic.publish>(ticket=0,exchange=ex_2,routing-key=12345,mandatory=false,immediate=false),#contentHeader(content-type=text/plain, content-encoding=null, headers=null, delivery-mode=null, priority=null, correlation-id=null, reply-to=null, expiration=null, message-id=null, timestamp=null, type=null, user-id=null, app-id=null, cluster-id=null),"messsage 0"}

: , ,
:
exchange=ex_2, routing-key=12345, mandatory=false, immediate=false
- ,
.

:

1257461452713: conn#74 ch#1 <- {#method<basic.deliver>(consumer-tag=amq.ctag-hnDha3s6i5xnJkkf0kB1DQ==,delivery-tag=6,redelivered=false,exchange=ex_test2,routing-key=12345),#contentHeader(content-type=text/plain, content-encoding=null, headers=null, delivery-mode=null, priority=null, correlation-id=null, reply-to=null, expiration=null, message-id=null, timestamp=null, type=null, user-id=null, app-id=null, cluster-id=null),"messsage 4"}

:
consumer-tag=amq.ctag-hnDha3s6i5xnJkkf0kB1DQ==, - ( )
delivery-tag=6 - .

, .

AMQP amqp-xml-doc0-8

.


Source: https://habr.com/ru/post/J74613/


All Articles