zoukankan      html  css  js  c++  java
  • rabbitmq 死信队列 php

    <?php
    
    require_once './vendor/autoload.php';
    use PhpAmqpLibConnectionAMQPStreamConnection;
    use PhpAmqpLibMessageAMQPMessage;
    use PhpAmqpLibWireAMQPTable;
    use PhpAmqpLibExchangeAMQPExchangeType;
    
    $connection = new AMQPStreamConnection('127.0.0.1', 5672, 'test', 'test', '/');
    $channel = $connection->channel();
    
    $channel->exchange_declare('exchange.dlx', AMQPExchangeType::DIRECT, false, true);
    $channel->exchange_declare('exchange.normal', AMQPExchangeType::FANOUT, false, true);
    $args = new AMQPTable();
    // 消息过期方式:设置 queue.normal 队列中消息10s之后过期
    $args->set('x-message-ttl', 10000);
    $args->set('x-dead-letter-exchange', 'exchange.dlx');
    $args->set('x-dead-letter-routing-key', 'routingkey');
    $channel->queue_declare('queue.normal', false, true, false, false, false, $args);
    $channel->queue_declare('queue.dlx', false, true, false, false);
    
    $channel->queue_bind('queue.normal', 'exchange.normal');
    $channel->queue_bind('queue.dlx', 'exchange.dlx', 'routingkey');
    $message = new AMQPMessage('死信队列message');
    $channel->basic_publish($message, 'exchange.normal', 'rk');
    
    $channel->close();
    $connection->close();
    

      

  • 相关阅读:
    火狐显示不安全链接
    signal信号
    I/O缓冲
    [pe530]GCD of Divisors
    学校寒假集训作业
    纳克萨玛斯「GDOI2007」(网络流)
    [清华集训2016] 汽水
    有上下界网络流
    [AHOI2014]支线剧情(有上下界的网络流)
    [SCOI2016]妖怪
  • 原文地址:https://www.cnblogs.com/setevn/p/14645558.html
Copyright © 2011-2022 走看看