在RabbitMQ管理UI中查看延迟消息

作者: 明天会更好
发布时间: 2024-08-13 05:07:47 (1小时前)
转自：

3 条回复

0#
回复此人
v-star*위위 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> 延迟的消息存储在里面 <code> Mnesia </code> ，如： <a href="https://i.stack.imgur.com/NvvqF.png" rel="nofollow noreferrer"> <img src =“https://i.stack.imgur.com/NvvqF.png”alt =“在此处输入图片说明”/> </A> 所以你无法在管理UI中看到它。 的 编辑 </强> 你云使用： <code> rabbitmqctl eval 'ets:tab2list(rabbit_delayed_messagerabbit@Your_HOST_NAME).' </code> 例如： <code> ? sbin ./rabbitmqctl eval 'ets:tab2list(rabbit_delayed_messagerabbit@mac).' [{delay_entry, {delay_key,1487934959224, {exchange, {resource,<<"/">>,exchange,<<"my-exchange">>}, 'x-delayed-message',true,false,false, [{<<"x-delayed-type">>,longstr,<<"direct">>}], undefined,undefined, {[],[]}}}, {delivery,false,false,<10495.911.0>, {basic_message, {resource,<<"/">>,exchange,<<"my-exchange">>}, [<<>>], {content,60, {'P_basic',undefined,undefined, [{<<"x-delay">>,signedint,90000}], undefined,undefined,undefined,undefined,undefined, undefined,undefined,undefined,undefined,undefined, undefined}, <<32,0,0,0,0,13,7,120,45,100,101,108,97,121,73,0,1,95,144>>, rabbit_framing_amqp_0_9_1, [<<"delayed payload">>]}, <<174,59,245,237,135,189,175,240,121,105,31,191,47,97,189,156>>, false}, undefined,noflow}, #Ref<10495.0.1.3514>}, </code> （playload可能无法读取） 的 EDIT2 </强> 此功能将从版本开始提供 <code> 3.7.0 </code> <a href="https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/issues/3" rel="nofollow noreferrer"> https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/issues/3 </A> </DIV>

编辑
1#
回复此人
不见你 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> 如果您确实需要在管理UI中查看消息，并且如果您不能等待Gabriele提到的3.7.0，您可以忽略该插件，而是将TTL和DLX结合起来以延迟消息传递。 您可以将消息发布到队列，该队列将在TTL之后使其消息到期（您可以从此队列中查看消息）。然后，您可以使用死信路由密钥将消息重新路由到交换机，以便消息最终出现在您消耗的队列中，如上所述 <a href="https://www.cloudamqp.com/docs/delayed-messages.html" rel="nofollow noreferrer"> 这里 </A> 。 <pre> <code> # declare a queue with the DELAYED_QUEUE name ch.queue(DELAYED_QUEUE, arguments: { # set the dead-letter exchange to the default queue 'x-dead-letter-exchange' => '', # set the routing key into the destination queue name 'x-dead-letter-routing-key' => DESTINATION_QUEUE, # the time in milliseconds to keep the message in the queue 'x-message-ttl' => 3000 }) # publish to the default exchange with the the delayed queue name # as routing key, so that the message ends up in the delayed queue ch.default_exchange.publish 'message content', routing_key: DELAYED_QUEUE </code> </pre> </DIV>

编辑

登录后才能参与评论