问题标签 [subscriber]

我们一直在试验 RabbitMQ。在这些实验中，我们看到了一些关于工作队列的奇怪行为。

观察结果之一是，当我们添加或删除从该队列读取的进程时，队列的读取性能不会改变。例如：当单个进程以 800 msg/sec 的速率处理消息时。添加第二个（类似的）进程会导致两个进程以 400 msg/sec 的速率处理消息，总计 800 msg/sec。当我们关闭其中一个进程时，另一个进程的 msg 速率会增加到（您猜到的）800 msg/sec。

这不是我们所期望的。当我们向队列中添加第二个读取器时，为什么吞吐量没有翻倍？

我们正在使用 RabbitMQ .NET 客户端（结合 EasyNetQ 高级 API）。我们打开了发布者确认，使用 50 的 prefetch_count (Qos)，在消息被处理后确认消息，并使用持久交换、队列和消息。

我们一定做错了什么，非常欢迎任何指向正确方向的指针......

我到处找，似乎找不到代码。希望你们中的一个可以提供帮助！

我正在尝试获取 Youtube 订阅按钮的代码，因为它显示在当前的 youtube 视频下。它有 2 个状态：

• 未订阅它显示播放图标、“订阅”和订阅者数量
• 订阅它显示一个复选标记并“订阅”

它实际上看起来非常类似于 facebook 的“like”按钮和 twitter 的“tweet”按钮，这就是我想在我的页面上使用它的原因。我知道有一个 iframe 代码，但这看起来不像我需要的。有谁知道我在哪里可以找到代码？

谢谢！

我正在使用 ROS 节点（C++ 代码）执行一些图像处理，读取来自模拟器中不同视觉传感器的图像。我有一个大问题，到目前为止，没有解决方案......

假设我的节点处于活动状态并且正在对从主题“A”获取的图像执行一些操作；在某个点（所以在运行时）我需要取消订阅这个主题“A”并订阅另一个主题“B”（这个主题的名称“B”由另一个订阅者传达给节点）以读取图像另一个视觉传感器：我想这样做只是更改主题名称（例如使用字符串变量）并使用用于主题“A”的相同回调。

困难如下：

• 我无法读取所有图像并选择我需要的图像：传感器太多，无法处理这样的数据流，此外，该系统根本不可扩展。

• 我需要在一个“生命”足够长的范围内声明这个新订阅者，以便从主题中读取（我认为，这就是为什么订阅者在主范围中定义的原因，在此之前）但是，在同时，在一个让我有可能更新主题的范围内（所以是一种循环，而不是只执行一次的 while 之前的部分）。

请帮助我...我真的不知道该怎么做

我正在使用https://pubsubhubbub.appspot.com/通过众所周知的 PubSubHubHub 协议实现来订阅提要。

我已从以下页面订阅了所需的主题： https://pubsubhubbub.appspot.com/subscribe

我收到了订阅验证，并成功回复了 $_GET 参数中收到的 hub.challenge。我已经查看了我的 Web 服务器日志，它显示从集线器发送的通知的 POST 请求：http: //i.stack.imgur.com/LH44O.png

我有我的代码设置，它将来自 $_POST 和 $_GET 的任何 key=>value 对存储在我的数据库中。它已经过测试，并且运行良好。

问：有什么要知道的，集线器是如何发送通知源的？（它肯定不在 GET 或 POST 中）以及如何在 PHP 中解析它？

我也研究过协议的工作草案，无法找出可能可行的方法。 https://pubsubhubbub.googlecode.com/git/pubsubhubbub-core-0.4.html#contentdistribution

也搜索了代码示例，太多复杂的代码对我来说没有任何意义，我如何将它翻译成简单的 PHP 解析代码。（我认为链接会帮助你）

https://code.google.com/p/pubsubhubbub/wiki/SubscriberClients

https://code.google.com/p/pubsubhubbub/source/browse/

我正在使用 magento-1.7.2 并为时事通讯制作了模板。但我无法选择订阅者和通讯日期来发送它。

我如何发送时事通讯，任何人都可以描述它。谢谢

我正在尝试为 iPhone 构建 opentok，在使用 OpenTok-iOS-Hello-World 和 OpenTok-iOS-Basic-Tutorial（从 gi​​thub 下载）时遇到问题。它总是告诉我“订阅者超时”，所以我看不到其他发布者发送的视频。你能给我一些建议吗？这是回显到xcode的日志，

我们如何设置发布者，订阅信息存储在数据库中？您在发布者和订阅者的配置中需要什么？

我的发布/订阅实现有问题。我正在从 NServiceBus 版本 2.6 升级到 4.0.4，据我从日志中可以理解，一切似乎都很好，但订阅者处理消息的速度非常慢。我使用 NServiceBus.Host.exe。

在旧实现中，我将线程配置如下：

并且消息以很快的速度通过。

在新的实现中，我尝试进行配置所需的更改：

我错过了一些关键的东西吗？

我有一个有效的许可证，所以我应该使用最大线程数。我没有 RavenDB 或 SQL，实现使用 MSMQ，我在订阅者配置代码中禁用了 Sagas 和 TimeoutManager：

我做了一个粗略的测试，我的开发环境的不同之处在于，2.6 版本每秒处理大约 80 条消息，而 4.0.4 版本每秒处理大约 8 条消息——这真的很糟糕。所以这里出了点问题，我似乎无法找到它是什么。

编辑：看起来问题是由我们的项目结构产生的，由于某种原因，旧版本的 NServiceBus 并不介意我们使用通用订阅者的结构方法，该订阅者使用 MEF 加载实际的订阅者程序集，但新版本进入休眠状态。我更改了文件夹结构，现在订阅者按预期工作。所以我使用的配置工作得很好，但我确实从我的设置中删除了 MaximumMessageThroughputPerSecond，这样它就不会出现未来的问题，因为目标是尽可能快。

在一个用例中，我有一个主题的 N 个发布者和同一主题的 M 个订阅者，当传递消息时，每个订阅者是否有可能知道哪个是实际的发布者（通过 ID 或 IP场地）？此信息是否存储在消息的标头中（即设置 JMSReplyTo 标头）？还是让我手动设置它添加一些自定义属性？多谢

我想将数据从一个节点发送到另一个节点。例如：一个节点正在向主题发布数据，另一个节点/mobile_base/commands/velocity正在订阅/mobile_base/events/bumper。订阅者和发布者都工作正常。

我想要做的是一旦按下保险杠就让机器人向后移动。我不知道如何将按下保险杠的事件发送到另一个节点。

我认为的解决方案是使用管道或套接字或共享内存在两个节点之间交换数据。

这是正确的方法吗？还是 ROS 有一个内置的方法呢？

提前致谢。