问题标签 [producer]

我想在两个进程中使用 ActiveMQ 作为 C++ 组件和 Java 组件之间通信的消息代理。例如。C++ 组件是发布者，Java 组件是订阅者（可能有多个订阅者）。我查看了 ActiveMQ 网站，它提到了 OpenWire 和 ActiveMQ-CPP 工具。但是，网站上的所有示例都对生产者和消费者使用相同的语言。

我的问题是：

1.ActiveMQ可以为不同语言的生产者/消费者工作吗？

2.在不同的过程中？如何？

我有两个过程：

他们有一个共同映射的共享内存区域

现在，Producer 将内容写入内存。消费者从内存中读取内容。

我如何实现这一目标？

我有一个由 Apache 提供的 Pylons Web 应用程序（mod_wsgi，prefork）。由于 Apache，有多个单独的进程同时运行我的应用程序代码。我希望将应用程序的一些非关键任务推迟到后台处理，以提高“实时”响应时间。所以我在考虑任务队列，许多 Apache 进程向这个队列添加任务，一个单独的 Python 进程一个接一个地处理它们并从队列中删除。

队列最好保存在磁盘上，这样排队的未处理任务就不会因为断电、服务器重启等而丢失。问题是什么是实现这种队列的合理方法？

至于我尝试过的事情：我从简单的 SQLite 数据库和用于存储队列项目的单个表开始。在负载测试中，当提高并发级别时，正如预期的那样，我开始收到“数据库锁定”错误。快速的解决方法是用 MySQL 替换 SQLite——它可以很好地处理并发问题，但对于我需要做的简单事情来说感觉有点矫枉过正。与队列相关的数据库操作也在我的分析报告中突出显示。

我需要使用一些东西来协调我的系统与多个消费者/生产者，每个消费者/生产者都在具有不同操作系统的不同机器上运行。我一直在研究使用 MySql 来做到这一点，但这似乎非常困难。

我的要求很简单：我希望能够随时添加或删除消费者/生产者，因此它们根本不应该相互依赖。自然，数据库会很好地将两者分开。

我一直在查看 MySql 的 Q4M 消息队列插件，但使用起来似乎很复杂。

我真的需要一些关于如何最好地构建我的系统的意见。

我正在编写一个解决生产者/消费者问题的程序，特别是有界缓冲区版本（我相信它们的意思相同）。生产者将生成 x 个随机数，其中 x 是我的程序的命令行参数。目前，我相信我的程序正在进入一个无限循环，但我不确定它为什么会发生。我相信我正确地执行了信号量。

你像这样编译它： gcc -o prodcon prodcon.cpp -lpthread -lrt 然后运行，./prodcon 100（产生的随机数）

这是我的代码。

请复制下面的程序并尝试在您的 IDE 中运行。这是一个简单的 Produce Consumer 实现 - 当我使用一个 Producer 和一个 Consumer 线程时它运行良好，但在每个使用 2 个时失败。请让我知道这个程序挂起的原因或者它还有什么问题。

任何人都可以指出有关如何在 activemq 中实现单个消费者多个生产者的参考吗？或者可以给出一个非常简单的实现。这将非常有帮助。

谢谢

我打算从一个独立的 Java Web 应用程序生成 WSRP 接口，以便可以将其前端嵌入到门户（Liferay、IBM websphere 门户）中，除了独立的前端和后端。

实现这一目标的推荐方法是什么？我找不到似乎可以完成这项工作的 WSRP 生产者 Java 库。WSRP 的常见做法似乎是在它们之间链接门户，因为它们本身就支持 WSRP 提供者、消费者和 portlet 规范。

谢谢你的帮助，

我想知道如何在 Android/DalvikVM 中处理处理程序。我正在为 Android 编写一个应用程序，在一个类中我有一个 Handler 方法，它接收来自另一个类的消息。Handler 方法会充当 Thread 并与同一类中的 run() 方法异步，还是会等到 run() 方法中的一行代码完成（某种原子操作）？或者是其他东西？

我想知道，因为我想在 Handler 方法中将消息添加到队列中，并在 run() 方法（生产者-消费者）中处理和删除它们。

我的代码结构：

处理程序中的代码何时运行？它会在任何时候中断 run() 方法中的代码吗？我是否必须在 run() 和处理程序方法中的代码周围有一些同步或信号量或其他东西，以免损坏缓冲区？

有谁知道作为生产者时 Jboss Portal 2.7.2 是否支持 WSRP URL 重写？

目前，URL 重写是在消费者身上完成的，消费者必须解析标记（从 Jboss 返回）以找到特殊的 WSRP 令牌。这可能会对性能产生影响，可以通过将 URL 直接提供给生产者（在我们的例子中为 Jboss）来改进。

问候，乔纳森