同一 Beanstalkd 队列上的多个站点

Question

我目前在服务器上设置了几个站点，它们都使用 beanstalkd 作为队列。其中一些站点是临时站点。虽然我知道将暂存站点放在另一台服务器上是理想的，但在这种情况下为它启动另一台服务器在经济上没有意义。

我最近遇到了一个非常令人困惑的问题，我正在部署一个临时站点，其中包括数据库的重新播种。我在某些模型保存上设置了观察者，这将触发要排队的作业，这通常最终会发送一封电子邮件。暂存站点实际上没有设置任何队列工作程序来运行它们，但生产站点（在同一台服务器上）确实有队列工作程序正在运行。

似乎正在发生的是暂存站点正在生成队列作业，而生产站点正在运行这些队列作业！这会导致我的随机用户收到垃圾邮件，因为它会从 staging 序列化模型，当它反序列化运行作业时，它实际上与实际的生产用户匹配。

在一个服务器上运行队列似乎很常见，所以我很好奇是否有办法避免这个问题。 Elasticsearch 具有“集群”的概念，因此您可以在一台服务器上运行多个搜索“集群”。我很好奇 beanstalkd 或 redis 或任何其他队列提供程序是否具有此功能，因此我们在完全独立的网站之间没有串扰。

谢谢！

Answer 1

这是一个老问题，但您是否尝试过运行多个 beanstalkd 守护进程？只需绑定到另一个端口。

示例： beanstalkd -p 11301 &

使用& 进入后台。

Answer 2

Beanstalkd 有管​​的概念：

管是作业队列。

管的一个常见用例是拥有完全不同的集合 通过单个 beantalk 实例运行的生产者和消费者 这样给定的消费者将不知道如何处理产生的工作 由一些制作人。 Producer1 可以将作业排入 Tube1 和 Consumer1 可以完全独立地从那里接手工作 例如，Producer2 和 Consumer2 对 Tube2 做了什么。

例如，如果您使用的是 pheanstalk，生产者将调用useTube()：

$pheanstalk = new Pheanstalk();
$pheanstalk->useTube('foo')->put(...);

工人会打电话给watch()：

$pheanstalk = new Pheanstalk();
$pheanstalk->watch('foo')->ignore('default')->reserve();