回答情况：
提问时间：
问题标签：
2回答
请有人推荐一个与Perl兼容的异步消息队列。
我并不担心它是否纯粹是用perl编写的，如果它是用其他东西(c二进制等)编写的，并且只有一个perl客户端，那就没问题了。为了设置一些上下文，我正在通知催化剂应用程序中的许多人，我谨慎地避免同时从应用程序发送过多的电子邮件，因此我打算使用异步队列来处理电子邮件发送，然后希望不会降低用户体验。
浏览 2修改于2014-08-11得票数 1
3回答
基本上，我有一个从消息队列接收并处理消息的程序。程序可以在任何时候停止，在这种情况下，消息循环在程序退出之前完成了它正在做的事情。this.idle.Set(); }
}
很显然，Stop方法将清除消息队列但是，消息循环仍在继续！我已经释放了消息队列，但它仍然设法从消
浏览 5修改于2011-03-30得票数 5
回答已采纳
2回答
我一直在尝试确定在网站背后使用哪种包组合来提供推送消息服务……我现在的想法是使用旋风+ Socket.IO (旋风)和ZMQ。但我也在考虑让Mongrel2参与进来。
浏览 1修改于2020-06-20得票数 2
回答已采纳
2回答
我有一个在某些情况下异步使用消息队列的站点。这很好用，但是现在站点将在集群上，这就开始了我的问题。我不能确保AJAX调用将由发送消息的同一服务器接收。这个问题有什么已知的解决方案吗？有什么建议吗？
谢谢，迭戈
浏览 4修改于2012-01-06得票数 1
回答已采纳
我正在寻找一个Python类(最好是标准语言的一部分，而不是第三方库)来管理异步的“广播式”消息。我将有一个线程将消息放到队列中( 'putMessageOnQueue‘方法不能阻塞)，然后是多个其他线程，它们都将等待消息，可能已经调用了一些阻塞的'waitForMessage’函数。当一条消息被放入队列时，我希望每个等待的线程都能获得它自己的消息副本。
我看过内置的Queue类，但我不认为这是合适的，因为消费消息
浏览 1提问于2013-05-31得票数 9
回答已采纳
我认为我应该做的是有某种类型的消息队列，客户端线程可以将其数据请求放在其中，数据库线程将在轮到它时执行此操作。如果有数据要从数据访问调用中返回，那么它可以将其放在一个队列中，以供客户端线程拾取。因此，我认为我想实现一个异步消息队列，客户端线程可以将消息放在该队列中，数据库线程将从中提取消息。这是正确的方法吗？任何关于实现的想法和链接，我都将不胜感激。
浏览 2提问于2010-12-02得票数 2
我需要在Java中动态创建异步消息队列。我的用例是通过多个SMTP服务器发送电子邮件:我需要强制要求发送到同一SMTP服务器的电子邮件是按顺序处理的，但发送到不同SMTP服务器的电子邮件可以同时处理。我过去使用过JMS，但据我所知，它只允许在编译时创建队列，而我需要在运行时创建队列(每个SMTP服务器一个队列)。
我是不是遗漏了一些关于JMS的东西，或者有没有什么其他的工具/提案需要我去看看？
浏览 1修改于2009-12-16得票数 7
回答已采纳
1回答
在db中插入某些内容Class A { doRedis() // 1.set some key-valuesdoDB() // 2.insert something in db}
@async}
另一个解决方案是向MQ发送消息我认为使用@async就足够了，没有必要使用MQ
浏览 9修改于2022-05-25得票数 2
当通过http请求在Microservices之间进行相互通信时，很容易将错误消息回复给用户，您只需捕捉到不同服务的错误并将其转发给用户即可。但是，在通过消息队列进行通信时，错误处理是如何工作的呢？
例如，用户向Auth Service发出请求，Auth Service发布一条消息，指示需要创建一个新用户。用户服务将使用此消息并尝试创建新用户。但是，如果用户服务抛出错误，可能已经收到了电子邮件。我们如何通知用户他的请求失败？我的猜测是，不可能用此错误响应用户，因为对Auth Server的初始请求在将<
浏览 0提问于2021-11-23得票数 1
回答已采纳
下面是如何使用while循环使用简单检查实现异步消息队列的方法。我认为这是一个比使用互斥的更好的方法，如果它可以的话。通过在我的机器上运行一些测试，它似乎可以正常工作，但我不确定这是否安全，因为我在为多个线程/进程编写异步系统方面没有太多经验。我的工作是否低于安全防止比赛的条件？
浏览 4修改于2015-04-09得票数 1
回答已采纳
我的JMS使用者在白天在JMS队列上生成任意数量的消息。一条消息一到达，它就会流向消息侦听器。如果在中间我需要一些其他的消息来，它去另一个消息侦听器不等待第一个？根据我在这里的理解，我需要创建两个使用者(假设我想同时处理2条消息)，每个用户都有自己的会话。两个使用者都可以使用相同的消息侦听器。对吗？
浏览 2修改于2017-05-23得票数 0
回答已采纳
当处理消息的函数异步地操作时，我如何处理传递到函数的一系列消息，按照它们的顺序进行处理？this.processBaz(()=> { }); }备注
这类问题是否有任何事实上的/标准的解决办法？
浏览 2修改于2016-08-19得票数 2
回答已采纳
我使用过web服务(WCF和异步回调)。现在我正在学习消息队列。当我们可以选择消息队列而不是Web服务时
例如:如果我实现了一个异步web服务(带有异步回调或异步REST服务的WCF)，我可以请求一些东西，同时也可以继续其他操作。那么，什么时候我们可以更喜欢消息队列而不是异步web服务？
浏览 0提问于2019-06-21得票数 2
因此，我正在研究PHP的异步处理，特别是CakePHP。
我应该使用什么消息队列？德德尔？贝恩斯塔克？还有别的吗？队列中的作业可以简单地由任务名称和参数数组组成。PHP守护进程将监视传入的作业，并将它们传递给其子线程
浏览 2修改于2014-08-23得票数 33
回答已采纳
我正在尝试将持久消息放到WebSphere MQ队列中，但是这些消息需要是异步put。我似乎能够使异步工作的唯一方法是消息是非持久的(这里我的意思是putSuccessCount等于放在MQAsyncStatus上的消息的数量，其他时候都是零)。MQAsyncStatus asyncStatus = qMgr.getAsyncStatus(); }我将我在大量消息中看到的性能提升归因于
浏览 1修改于2014-10-05得票数 2
回答已采纳
1回答
我使用异步模块进行异步通信。每个传入的消息都被解析，设备地址被添加到参与者列表中。在参与者被添加之后，我想把一个OK返回给发件人。对于发送和接收消息，我使用asyncio.Queue。这是我的问题，在我添加了地址之后，我无法将我的ok message放入Queue中，因为它将接收到的消息发送回发件人。我知道我不知道把/打电话给ack_msg()。我得到的错误消息是：
RuntimeWarning:人们从未期待过coroutine 'Table.add_
浏览 4修改于2019-12-07得票数 0
回答已采纳
在我的应用程序中，我希望使用设置的消息泵检查主队列和死信队列。我遇到的问题是默认实现上的线程。这是Azure消息泵的默认实现。现在发生的情况是，onmessage方法是否运行，它会命中waitone进程，并处于那里直到另一条消息传入，这是应该发生的，但是我如何使其中的两个同时运行呢？
浏览 3修改于2018-12-08得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号