“消息队列”是设计模式或软件工程组件,其定义用于两个或更多相互关联的过程或系统之间的通信的规则或API。消息队列强制执行异步处理和松散耦合。根据实施情况,它们还可以提供消息的传递和订单保证。消息处理保证明确排除在设计之外。
EasyNetQ - 如何重试失败的邮件并在邮件正文/标题中保留RetryCount?
我正在使用EasyNetQ并需要在原始队列上重试失败的消息。问题是:即使我成功递增了TriedCount变量(在每个消息的正文中),当EasyNetQ ...
使用EasyNetQ for RabbitMQ时的自定义错误队列名称?
而不是将我未处理的异常放入EasyNetQ_Default_Error_Queue,我想知道是否有一种方法可以明确说明应该用于给定的错误队列的名称...
我正在使用带有EasyNetQ库的C#中的RabbitMQ。我在这里使用了pub / sub模式。我仍然有一些问题,我希望任何人都可以帮助我:当消费消息时出现错误,...
我正在研究redis SMQ持久性。我的问题是,当发布者发布消息时,消费者突然停止了。当消费者再次连接时,是否可以订阅消息...
我有一个关于在一个队列中间歇发生的延迟的问题。我在Weblogic 10.0上使用JMS。因此,客户端通过名为RequestQueue的队列向服务器发送消息。 ......
我有一组来自消息队列的json消息。我需要收集一组相关的消息(基于“位置”字段)并从“描述”中删除一个公共前缀和后缀...
我可以用本机kubernetes消息队列替换RabbitMQ吗?
我没有发现我们可以用native kubernetes消息队列替换rabbitMQ / activeMQ / SQS吗?或者它们在功能方面完全不同?
有谁知道是否有办法从客户端应用程序检查RabbitMQ队列中的消息数量?我正在使用.NET客户端库。
如果MessageQueue中没有消息,MessageQueue如何知道阻塞多长时间?
据我了解,如果MessageQueue中只有消息带有未来的时间戳,MessageQueue会阻止Looper的循环,直到到达时间。但是这个机制如果......
在Linux中使用msgget在.c文件中创建消息队列接收函数未实现错误
当msgget运行时,我收到一个错误,我的代码在返回msgget行时给我一个返回:“:Function not Implemented”。我尝试了很多选项,我正在运行UBUNTU ...
如何检查消息队列是否已存在?我有2个不同的应用程序,一个创建队列,另一个从该队列读取。所以,如果我运行从...读取的客户端
该系统由一个或多个客户端和一个服务器组成。手动添加每个客户端并提供标识符(client.id)。每个客户端都可以向服务器发送消息。服务器可以......
我尝试使用具有azure功能的Azure存储队列,我想象它非常简单 - 从队列中获取消息,处理,必要时添加新消息。但是现在我弄得一团糟,在我的...
我有一个函数:public async static Task Run([QueueTrigger(“efs-api-call-last-datetime”,Connection =“StorageConnectionString”)] DateTime queueItem,[Queue(“efs-api-call-last-datetime”) ...
lparallel库中队列的基本讨论,请访问https://z0ltan.wordpress.com/2016/09/09/basic-concurrency-and-parallelism-in-common-lisp-part-4a-parallelism-using-lparallel-基本面/#...
在Azure微服务环境中,实现事件驱动的体系结构,我面临着对收到的事件采取行动的挑战。我也有检测持续时间的反击挑战......
发布单个消息到 RabbitMQ 队列可以使用 UI 轻松完成,只需将消息放入 UI 并单击“发布消息”按钮即可。 怎么发布一批乱七八糟的……
我们可以使用可配置参数在RabbitMQ中实现推送和拉取机制吗?这可能是一个广泛的问题,但寻求帮助设计SPA。更新:我们是新闻发布商网站。 ...
我在下面的代码中,了解了Linux中消息队列的线程安全性。但不确定该程序为什么会卡住。虽然在应用正确的锁之后它不会卡住。但是如果消息队列......