README

Thumper 是一个 PHP 库，旨在抽象出可以在 RabbitMQ 上实现的几种消息模式。

在 examples 文件夹中，您可以查看如何实现 RPC、并行处理、简单的队列服务器和 pub/sub。

安装

通过 Composer

$ composer require php-amqplib/thumper

关于示例

每个示例都有一个 README.md 文件，说明如何执行它。所有示例都假定 RabbitMQ 正在运行。它们已经使用 RabbitMQ 2.1.1 进行了测试

例如，将消息发布到 RabbitMQ 与此类似

	$producer = new Thumper\Producer($connection);
	$producer->setExchangeOptions(array('name' => 'hello-exchange', 'type' => 'direct'));
	$producer->publish($argv[1]);

然后，在另一端消费它们

	$myConsumer = function($msg)
	{
	  echo $msg, "\n";
	};

	$consumer = new Thumper\Consumer($connection);
	$consumer->setExchangeOptions(array('name' => 'hello-exchange', 'type' => 'direct'));
	$consumer->setQueueOptions(array('name' => 'hello-queue'));
	$consumer->setCallback($myConsumer); //myConsumer could be any valid PHP callback
	$consumer->consume(5); //5 is the number of messages to consume.

队列服务器

此示例说明如何创建一个生产者，该生产者将作业发布到队列中。这些作业将由消费者（或多个消费者）稍后处理。

RPC

此示例说明如何在 RabbitMQ 上进行 RPC。我们有一个 RPC 客户端，它将请求发送到服务器，该服务器返回提供的字符串中的字符数。服务器代码位于 parallel_processing 文件夹中。

并行处理

此示例基于 RPC 示例。在这种情况下，它显示了如何使用 PHP 实现并行执行。假设您必须执行两个昂贵的任务。一个需要 5 秒，另一个需要 10 秒。我们不必等待 15 秒，而是可以并行发送请求，然后等待回复，这些回复现在应该只需要 10 秒——最慢任务的时间。

主题

在这种情况下，我们可以看到如何使用 RabbitMQ 实现发布/订阅。此示例是关于日志记录的。我们可以使用多个级别和主题进行日志记录，然后让监听不同日志级别的消费者相应地执行。

匿名消费者

在 topic 文件夹中还有一个匿名消费者示例。这里的想法是，对于那些需要将队列连接到某些交换机以“监视”正在发生的情况，但退出程序时希望队列自动删除的情况。我们可以使用未命名的队列来实现这一点。

变更日志

有关最近更改的更多信息，请参阅 CHANGELOG

测试

$ composer test

贡献

有关详细信息，请参阅 CONTRIBUTING 和 CONDUCT

免责声明

此代码是实验性的。目的是展示使用 RabbitMQ 和 AMQP 实现此类模式有多容易。

鸣谢

• 所有贡献者

许可证

MIT 许可证 (MIT)。有关更多信息，请参阅 许可证文件