问题标签 [bunny]

在 Mac 中运行 Rails 应用程序。我在其他终端选项卡中启动 rabbit mq 服务器：

$rabbitmq 服务器

我在我的 Web 应用程序中工作，当邮件被发送时，我在/usr/local/var/log/rabbitmq/rabbit@localhost-sasl.log中得到了这个

=信息报告==== 2015 年 4 月 21 日::23:02:47 ===

接受 AMQP 连接 <0.4286.0> (127.0.0.1:57509 -> 127.0.0.1:5672)

=错误报告==== 2015 年 4 月 21 日::23:02:50 ===

关闭 AMQP 连接 <0.4286.0> (127.0.0.1:57509 -> 127.0.0.1:5672): {heartbeat_timeout,running}

笔记：

我将所有 rabbitmq 配置保留为默认配置，我的意思是在mailer.rb 中：

相同的配置在 Ubuntu 中完美运行。

我开发了一个算法来计算点集的体积，现在我打算用斯坦福兔子模型来测试我的算法，但是我还没有找到体积的真实值，所以我不知道这个值是否我计算的很准确。有谁知道斯坦福兔子模型的真实体积吗？

我有一个我在 .NET 中编写的应用程序，它可以使用单个使用者监视多个 RabbitMq 队列。

例如：

基本上，我只想能够跨多个队列分配工作，但只有一个应用程序将它们全部使用（或者可以部署多个应用程序并执行相同的功能）。

我正在尝试将工作分散到队列中，以便消费者在队列中平等地接受工作。

这是否可以使用 Bunny 或本机 Ruby 驱动程序？

当我的 Hutch 消费者失去与数据库的连接时，我想将我收到的所有消息重新排队并尝试稍后处理（并保存到数据库）它们。

我发现我可以使用重新排队！在我的消费者中这样的方法：

但随后我会立即从 Rabbit 收到该消息，因此，当它显然无法保存到 DB 时，我的消费者坚持尝试处理该消息。

在这种情况下，是否可以在 Hutch 或 RabbitMQ 站点上设置超时？

我正在试用 Bunny amqp 客户端 gem 版本 2.0.0。当我尝试时，我发现了以下错误：

W，[2015-08-03T07:36:21.913706 #9100] WARN -- #: 无法建立到 10.223.19.94:5672 的 TCP 连接：/usr/local/rvm/gems/ruby-1.9.2-p320/gems /bunny-2.0.0/lib/bunny/session.rb:298:inrescue in start': Could not establish TCP connection to any of the configured hosts (Bunny::TCPConnectionFailedForAllHosts) from /usr/local/rvm/gems/ruby-1.9.2-p320/gems/bunny-2.0.0/lib/bunny/session.rb:264:in从 rabbit-client-test.rb:12:in 开始<main>

另外，我注意到以前版本的 bunny 1.7.0 中没有出现同样的错误。它与宝石有关吗？

当我使用 Bunny 时，当我使用以下命令打开与包含 50,000 条消息的队列的连接时：

RabbitMQ 立即将所有消息从 移动READY到UNACKED，因此在READY.

如果我尝试使用相同的代码启动另一个兔子，它现在没有什么可读取的了READY。

我错过了一些明显的东西吗？

我有生产者通过消费者消费这些消息的小屋以扇出方式产生消息。在这里，我有一个 RabbitMq 服务器，其中运行多个 hutch 实例。

在本地/测试环境中一切正常，但是小屋实例在生产中崩溃（每小时）引发错误

在搜索了关于 stackoverflow 和其他地方的大量帖子之后，我开始明白这个错误与竞争条件有关。

但我没有找到任何针对hutch实施的解决方案。

如果有人在这里帮助我，我会很高兴的。

先决条件：

• RabbitMQ 3.3.4
• 厨具 (0.15.0)
  • 兔子 (>= 1.7.0)
  • 胡萝卜顶部 (~> 0.0.7)
  • multi_json (~> 1.5)

我是 RabbitMq 的新手。我们正在评估它与 Rails 应用程序的生产用途，目前用于后台邮件系统。RabbitMq 教程介绍了兔子宝石。在它的其他宝石清单上，还有运动鞋宝石。

了解它们之间有什么区别以及哪个对创建简单的后台邮件系统更有用会很有用？

在初始化程序中设置 rabbitmq 连接时

从我尝试创建交换和发布的地方抛出超时错误

错误跟踪

如果直接在 Publisher 中创建连接和通道而不是工作。

彪马设置

在我的情况下，我应该如何初始化连接并创建通道？谢谢

我正在将 tty 的 stdout 和 stderr 流式传输到 RabbitMQ（准确地说是日志）。这些日志可以在网站上查看，当内容流式传输到 RabbitMQ 时，它们由 Web 服务器使用并使用 WebSockets 转发到客户端。日志在发送到 RabbitMQ 后立即被持久化。

当用户访问网站时，会呈现持久化的日志，并使用 WebSockets 流式传输连续的部分。问题是存在竞争条件，因为持久化日志可能缺少在呈现站点和通过 WebSocket 接收第一个块之间发生的日志块。

我的想法是将所有块保留在队列中，并在连接后通过 WebSocket 发送它们。此外，我会添加一个工作人员来收听某种“已完成”事件，然后将队列中的所有内容都取出并立即持久化。

问题是我不知道这是否可以使用 RabbitMQ 或如何实现。有什么想法或其他解决方案吗？

我认为这并不重要，但我的堆栈正在使用 Ruby Sinatra 和 Bunny RabbitMQ 客户端。