问题标签 [consumer]

我正在寻找可以帮助我构建 OAuth 提供程序的 Java 库。我必须能够接收 OAuth 签名请求并确定它们是否有效（检查签名、时间戳和 nonce 值）。

你知道是否有什么东西可以让这项任务变得更容易吗？

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

我的问题是：

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

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

我有两个过程：

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

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

我如何实现这一目标？

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

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

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

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

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

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

这是我的代码。

使用 WCF 中的 netMsmqBinding 配置可以从 MSMQ 队列中提取消息的最大线程数的最佳方法是什么？

例如，假设我有一个 MSMQ 服务，我只想让 2 个（或 10 个，或任何数量的）工作线程一次提取消息。

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

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

谢谢

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

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

我的代码结构：

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

我在 C# 3.0 中使用 Generic.Queue 和 Monitor.Enter,wait,exit 等待在使用队列之前等待（等待元素入队）。现在我转向 C# 4。

任何人都可以建议我哪一个是快速和最好的，尤其是避免锁定..

BlockingCollection vs concurrentQueue 或其他任何东西......

笔记。我不想限制我的制作人

提前致谢..