问题标签 [queuing]

我是 HornetQ 的新手，所以请多多包涵。让我先告诉你我的要求：

我需要一个消息队列中间件，它可以在具有低延迟和持久性的不同进程之间传递大约 1k 大小的消息（即它应该能够在系统崩溃中幸存）。我将有多个进程写入同一个队列，并且类似地多个进程从同一个队列中读取。

为此，我选择了 HornetQ，因为它在持久性消息传递方面的评分最高。

我目前正在使用Hornetq v2.2.2Final作为独立服务器。
我能够使用核心 api (ClientSession)成功创建持久/非持久队列，并成功将消息发布到队列(ClientProducer)。
同样，我可以使用 core api (ClientConsumer)从队列中读取消息。

之后问题就来了，当客户端读取消息时，消息仍然保留在队列中，即队列中的消息数量保持不变。也许我弄错了，但我的印象是，一旦消息被消费 (read + ack)，它就会从队列中删除。但这在我的情况下没有发生，并且一遍又一遍地读取相同的消息再次。

另外，我想告诉大家，我已经尝试过将非持久队列与非持久消息一起使用。但问题依然存在。

我正在使用的生产者代码：

消费者的代码也是：

HornetQ 服务器配置 ::

我有以下动画：

这似乎在排队，我怎样才能确保 fadeTo() 不排队？

我们对排队解决方案的需求非常简单，生产者需要将事物放入持久队列中，而这些需要由消费者处理。排队系统需要集成在 Spring 应用程序中并分布在多个 tomcat 主机上。

例如，在阅读问题时，我看到很多人警告将 ActiveMQ 与 Spring 结合使用，因此我想知道在结合基于 Spring 的应用程序时考虑到简单性、可伸缩性和性能时的替代方案是什么。

我想为 linux 内核编写一个新的 tc 排队规则。目标是排队，例如。十个数据包，然后将它们全部发送出去（我知道，这对于网络来说并不是一件好事，但我想对此进行一些研究）。

那么，已经完成了什么：我有一个新的 sched 模块（入队、出队函数等）的骨架，它也可以正确编译和正常工作（一个数据包排队，一个数据包发送出去——没什么特别的）。我正在使用与运行内核相同的源代码在 ubuntu maverick 上编译它，并将我的模块放在 Makefile 和 Kconfig 中。

我发现，每次调用 enqueue 函数时，之后 qdisc_restart （在 sch_generic.c 中）都会调用 dequeue 函数，并且只发送一个数据包。

我的问题是：我怎样才能将多个数据包从我的模块发送到网络接口，就像我收集的那样。10个包，现在我想把它们都寄出去？

我尝试使用与 qdisc_restart （和锁定机制）相同的参数调用 sch_direct_xmit 函数（来自 sch_generic.c）- 但是，我的模块的编译失败：未知符号 sch_direct_xmit （但是 greping /proc/kallsyms 给了我结果）。任何想法，这有什么问题？如果需要一些代码，请告诉我（我包含与 sched_generic.c 中相同的 .h）

克里斯托夫

我正在使用 c#.net，数据库是 MS SQL 2008 R2。

我有一个问题似乎在这里的论坛中被问了很多。我想将数据库表用作队列...但是无法从数据库中完成对这些消息的处理。
我有一个表来存储我从 .Net 组件获得的请求。我现在必须从这些表中读取数据并对 2 个 Web 服务进行 http 调用。根据从 Web 服务收到的响应，数据会被存档或删除。
我有几个具体的问题：
1. 我如何确保如果我选择一条记录进行处理并且 http 调用失败，我应该能够继续下一条记录，然后在结束时回到这条记录运行
2. 是否有替代将数据库用作队列（如 MSMQ 等），哪个选项更好
3. 我想维护记录状态的审计跟踪。在编辑之前创建一个触发器来记录更改是最好的方法吗？

问候
狮子座

我创建了一个 AsyncTask，它在执行时从网站加载数据。目前我收到一个空指针异常，我认为这是因为我试图过早地填充 UI，所以我希望创建某种 if 语句来说明 AsyncTask 是否未完成显示加载图形以及何时填充数据。但我不知道该怎么做，有人知道我怎么能做到这一点，或者至少为我指明了正确的方向。

到目前为止，这是我的代码

我在 Oracle DB 中设置了一个队列，已经使用了一段时间，但是传播（到远程服务器）停止工作，现在突然任何操作挂起：我无法禁用/取消计划传播，无法停止/放弃队列本身。查询只挂了几个小时。我该如何清除这东西？

I have a wordpress page. I have a number of links which go to PayPalObjects. PayPalObjects requires that you put code in the footer of the page with triggers to IDs for the elements which trigger a purchase. eg...

...and then in the footer of the page:

Now, since I have dozens of such links, I wanted to avoid hard coding these ids into the content. eg...

So I added the following jQuery:

The rendered page correctly adds the ID attribute to each link, BUT the PayPal js does not trigger properly. IOW: I have to 'hardcode' the ids into the page. This makes me think that the jQuery is firing -after- the PayPal script.

So... how do I 'tell' the PayPalObjects script to only execute -after- the jQuery has assigned the IDs? OR... even if I accomplished that, would it -still- not work because assigning the ID attr. dynamically isn't reliable for what I want to do?

TIA,

---JC

我必须构建一个 PHP 队列系统，发现这篇精彩的文章 http://squirrelshaterobots.com/programming/php/building-a-queue-server-in-php-part-1-understanding-the-project，我用它来创建一个 PHP 队列系统，它非常易于设置和使用。

下面是 queue.php 的代码，从 shell（puTTy 或类似的）运行。

最难的部分是让 pcntl 函数在我的服务器上工作。

我的问题是“当/如果服务器必须重新启动时，我如何让工作自动启动？”

这是我的问题，我正在构建一个带有一些来自服务器的 JSON 返回的 iOS，在这里，没有问题，一切正常。

问题是当我运行程序时，需要很长时间才能将结果解析为NSMutableArray：这是日志

如您所见，实现数组真的很长。

我知道我必须使用排队和大中央调度来使我的 UI 响应，但我不知道怎么做，你能帮我做吗？

这是我的viewDidLoad方法