悠悠楠杉
网站页面
PHP使用enqueue/amqp-lib实现rabbitmq任务处理
06/26
首先，确保你的开发环境中已安装PHP和Composer。然后，通过Composer安装enqueue/amqp-lib：
bash
composer require php-enqueue/amqp-lib
同时，确保RabbitMQ服务已经安装并运行。你可以从RabbitMQ官网下载并安装。
步骤 2: 创建RabbitMQ队列
打开RabbitMQ Management Console（通常在http://localhost:15672），创建一个新的队列，例如命名为article_queue。同时，创建一个交换机（如articles_exchange），并确保它被绑定到刚才创建的队列上。
步骤 3: PHP脚本编写
发送端（生产者）
生产者负责将“生成文章”的任务发送到RabbitMQ。
```php
<?php
require 'vendor/autoload.php';
use Enqueue\AmqpLib\AmqpConnectionFactory;
use Enqueue\Client\PsrConnectionFactory;
use Psr\Client\Job;
use Psr\Client\Topic;
$factory = new AmqpConnectionFactory('localhost', 5672, 'guest', 'guest');
$context = new PsrConnectionFactory($factory);
$producer = $context->createTopicProducer('articlesexchange');
$topic = 'articlequeue';
$job = new Job();
$job->setBody(json_encode([
'title' => '示例标题',
'keywords' => ['关键词1', '关键词2'],
'description' => '这是一篇关于PHP和RabbitMQ的描述。',
]));
$producer->send($topic, $job);
echo "Article generation task sent successfully.\n";
```
接收端（消费者）
```php
require 'vendor/autoload.php';
use Enqueue\AmqpLib\AmqpConnectionFactory;
use Enqueue\Client\PsrConnectionFactory;
use Psr\Client\Consumer;
use Psr\Client\Topic;
use function file_put_contents; // 用于输出Markdown文件（实际使用中可能不适用）
use function preg_replace; // 用于清理字符串（可选）
use function array_map; // 用于处理数组（可选）
use function array_filter; // 用于清理数组（可选）
use function chunk_split; // 用于分割长字符串（可选）
use function date; // 用于添加时间戳（可选）
use function trim; // 用于清理字符串两端空白（可选）
use function sort; // 对关键词进行排序（可选）
use function strtoupper; // 将字符串转为大写（可选）等。
require 'path/to/your/markdown/generator.php'; // 假设你有一个Markdown生成器函数或类。
// 这里仅提供部分示例代码，实际应用中需根据具体需求调整和实现Markdown生成逻辑。 仅做示范之用。 真正的Markdown生成可能涉及更复杂的逻辑和格式化选项。 示例已省略复杂实现细节。 实际应用中请根据需求进行相应处理。 如: 文章标题、内容等转换为Markdown格式并保存到文件等。 下面是概念性的代码片段以说明如何保存Markdown文件: 示例代码假设您有一个自定义的markdown函数 `generateMarkdown($title, $content)`，它会根据标题和内容生成Markdown格式的文本: file_put_contents("path/to/your/file.md", generateMarkdown("示例标题", "这里是文章内容...")); } ?>
