php 基于RabbitMQ 写一个自动取消订单功能

1. 首先安装 RabbitMQ 扩展，可以使用 PECL 安装：

pecl install amqp

2. 创建 RabbitMQ 队列和交换机

在 RabbitMQ 中，我们需要创建一个队列和一个交换机来处理自动取消订单功能。可以使用 RabbitMQ 的管理界面或者命令行工具 `rabbitmqctl` 创建，也可以使用 PHP 的 AMQP 扩展创建。

$connection = new AMQPConnection([
    'host' => 'localhost',
    'port' => 5672,
    'login' => 'guest',
    'password' => 'guest',
]);

$connection->connect();

$channel = new AMQPChannel($connection);

// 创建交换机
$exchange = new AMQPExchange($channel);
$exchange->setName('order_exchange');
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declare();

// 创建队列
$queue = new AMQPQueue($channel);
$queue->setName('order_queue');
$queue->declare();
$queue->bind('order_exchange', 'cancel_order');

3. 发布订单到 RabbitMQ 队列

在订单创建时，我们需要将订单信息发布到 RabbitMQ 队列中，以便后续处理。

$order = [
    'order_id' => 12345,
    'create_time' => time(),
    'expire_time' => time() + 3600, // 订单过期时间
];

$message = json_encode($order);

$exchange->publish($message, 'cancel_order');

4. 监听 RabbitMQ 队列

使用 RabbitMQ 的 AMQP 扩展，我们可以通过监听队列来实现自动取消订单功能。我们需要创建一个消费者，通过 `consume()` 方法监听队列。

$consumer = new AMQPConsumer($channel, $queue);

while (true) {
    $consumer->consume(function ($envelope, $queue) {
        $message = $envelope->getBody();
        $order = json_decode($message, true);

        if (time() > $order['expire_time']) {
            // 取消订单
            cancelOrder($order['order_id']);
        }

        $queue->ack($envelope->getDeliveryTag());
    });
}

在消费者回调函数中，我们可以获取订单信息，判断订单是否过期，如果过期就取消订单。取消订单的具体实现可以根据业务需求进行编写。

完整的代码示例：

$connection = new AMQPConnection([
    'host' => 'localhost',
    'port' => 5672,
    'login' => 'guest',
    'password' => 'guest',
]);

$connection->connect();

$channel = new AMQPChannel($connection);

// 创建交换机
$exchange = new AMQPExchange($channel);
$exchange->setName('order_exchange');
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declare();

// 创建队列
$queue = new AMQPQueue($channel);
$queue->setName('order_queue');
$queue->declare();
$queue->bind('order_exchange', 'cancel_order');

// 发布订单到队列
$order = [
    'order_id' => 12345,
    'create_time' => time(),
    'expire_time' => time() + 3600, // 订单过期时间
];

$message = json_encode($order);

$exchange->publish($message, 'cancel_order');

// 监听队列
$consumer = new AMQPConsumer($channel, $queue);

while (true) {
    $consumer->consume(function ($envelope, $queue) {
        $message = $envelope->getBody();
        $order = json_decode($message, true);

        if (time() > $order['expire_time']) {
            // 取消订单
            cancelOrder($order['order_id']);
        }

        $queue->ack($envelope->getDeliveryTag());
    });
}

function cancelOrder($orderId)
{
    // 实现取消订单的业务逻辑
}