问题标签 [consumer]

根据 JConsole 堆栈跟踪，我有一组生产者-消费者线程，但生产者卡在了一行不是..put()

根据堆栈跟踪，它只是停留while(true)在行上，没有通过循环前进，即使它应该。

第 25 行是该while(true) {行。

我猜消息的消费者应该一直在收听，或者应该批量设置以经常运行以检查和消费消息。

当我们做基本示例时，我们使用独立的 Java 程序，它会一直运行。我们如何使用 JBoss 之类的任何应用程序服务器在现实世界的 Web 应用程序中实现它们？可以说，我们使用 Spring MVC、Hibernate 和 JBoss。它通常是如何实现/设置的，以便它继续运行并使用消息？

（生产者可以是任何网页、按钮点击或类似的东西）

可能是非常基本的愚蠢问题。:-)

I am trying to understand producer consumer problem via above code .When i execute the above code i am getting

Program gets stuck here only (do not gets terminate).

Someone Please explain what wrong i am doing here?

你好美妙的社区！

我目前在业余时间写一个小游戏。它发生在一个大星系中，玩家可以控制一些星星。在这些星星上，您可以构建Buildings，每个建筑物都有一定数量（0..*）的输入，并产生一定数量的输出。这些建筑物具有最大容量/吞吐量，并且按比例缩小其输入会按比例缩小其输出。我想找到一种预算算法来优化（或近似）所有建筑物的吞吐量。这似乎是某种最大流量问题，但我读过的流量优化算法都没有不同类型的输入或依赖输出。

我一直在玩的玩具“科技树”是：

我愿意接受次优算法，并且我愿意保证输入/输出没有循环（它们从构建到构建形成 DAG）。这个想法是在没有玩家干预的情况下允许合理的吞吐量和科技树复杂性，因为在数百或数千颗星的规模上，允许玩家手动定义预算策略并不有趣，并且给没有生命的玩家一个独特的优势。

我目前的策略是建立一个有向无环图，给资源一个总排序（船比金属好比矿石比能源好），然后，循环遍历每个资源，找到最“后代”的建筑生产该资源，让它递归地贪婪地从其输入中获取（造船厂将需要 2 能量和 1 金属，然后精炼厂将获取 1 能量和 1 矿石等），然后在图表中找到任何“骗子”（太阳能发电厂提供 4 种能量，最大值为 2 种），缩减其生产并向前传播变化。为 DAG 解决所有问题后，从图中删除终端元素（造船厂），并从建筑物的最大吞吐量中减去每条边的“当前吞吐量”，然后对下一种资源重复该过程。我想如果有更好的方法，我会问比我聪明得多的人。:)

我们想要控制消费者在 HornetQ 中消费消息的速率。

问题是当我们使用 ServerLocator.setConsumerMaxRate(int) 方法时，无论我们传递的值如何，我们总是每秒收到 1 条消息。

当我们不调用这个方法时，消耗速度很快（每秒超过1个）。

我们的代码：

问题是——如何控制消费率？为什么这个设置不影响速率？

使用 Spring 配置的 ActiveMQ，监听器配置了 prefetch=0 connectionFactory 和 5-5 并发，我们看到监听器显然轮询新消息而不是代理推送消息，正如预期的那样。

但是，在我们队列的“Active Listeners”的 ActiveMQ Web 控制台中，我看到“Enqueues”列计数持续快速上升（大约每秒 1 个）。这是正常行为吗？既然我们有 prefetch=0，这是否只是反映了侦听器对新消息的每次轮询？当没有实际消息正在工作时，队列显示出越来越多的 Enqueue 计数似乎有点奇怪。还想知道是否有办法限制轮询频率，或者在每个消费者轮询代理以获取新消息之前有一些延迟。

控制台的图片，显示了 prefetch=0 时每个消费者不断增加的 Enqueue 计数，即使没有消息可以工作：

http://activemq.2283324.n4.nabble.com/file/n4666021/enqueues.png

用于执行以下操作的最佳数据结构是什么：

2个线程：

1. 1 产生（写入）数据结构
2. 1 从数据结构中使用（读取然后删除）。
3. 线程安全
4. 生产者和消费者可以同时访问数据结构
5. 高效处理大量数据

我正在使用带有 Spring Security 的 Grails 2.1.1，并且我的应用程序有一个链接到与我的 grails 应用程序在同一服务器上的另一个站点，我正在使用 osqa ( http://www.osqa.net )。我希望用户可以使用 spring security 在我的 grails 应用程序中正常注册，但使用这些凭据，他们也应该能够登录我的 osqa 应用程序。因此，我必须使用 openid，其中我的 grails 应用程序是 openId 提供者，而 osqa 应用程序是消费者。

现在，我的问题是，如何将我的 grails 应用程序配置为使用 spring security 作为 openid 提供程序。我查看了 spring security openid 插件和 doc 站点，但那里只是解释了如何通过 google 配置 openid 登录。

重新启动时，我在消费者方面遇到了问题。在转储堆并筛选线程后，我确定问题是由于 kahadb 本地存储库索引文件的压缩造成的。随着此文件变大，消费者再次开始获取消息所需的时间也会增加。我已经删除了我的本地存储库目录，重新启动并验证了消费者几乎可以立即收到消息。

有人在使用 ActiveMQ 和 KahaDB 时遇到过这个问题吗？有时，如果目录没有被清除，我的消费者可能需要长达 1.5 小时才能再次开始从代理获取消息。

我还验证了消息是及时发布的，它们只是没有被消费，因为索引压缩线程阻塞了“添加”线程。

任何见解将不胜感激！

我正在使用需要我们使用 API KEY/PAIR 的 OAuth 1.0 API。此外，它给了我 3 个网址：

• 请求令牌端点：/oauth/request_token
• 授权端点：/oauth/authorize
• 访问令牌端点：/oauth/access_token

以下是文档所述：

我们使用最新的 OAuth 1.0 协议规范 (RFC 5849) 来验证我们的 API 请求。我们使用 OAuth 1.0 是因为它是一个开放标准，并且我们将 OAuth 1.0 的“三足”客户端/用户/服务器协议流调整为“双足”客户端/服务器模型. 在我们为经过身份验证的客户端/服务器请求调整 OAuth 时，客户端既充当 API 客户端又充当用户（即，所请求资源的所有者）。因此，客户端不会被重定向到带有令牌验证器的客户端，而是充当用户并直接访问服务器以获取 OAuth 验证器。当客户端使用先前获得的验证器获得的访问令牌从服务器请求资源时，会发生可访问性检查。您可以重复使用访问令牌，直到它们过期（两小时后）。令牌过期后，您必须请求新的访问令牌。示例将进一步阐明这一点。

我想找到一个 PHP OAuth 库，它可以使用我访问第三方公司 API 的 API 要求。我真的不知道如何实现这一点。我目前的想法是对 facebook php api 进行逆向工程，但我不知道它是否使用 3 个端点。此外，一些帮助使其运行或将我引导到我自己可以弄清楚的资源会很棒。

谢谢！

** 注意：我发现了这个：点击这里这可以是我正在寻找的解决方案吗？