message-queue 相关问题

“消息队列”是设计模式或软件工程组件,其定义用于两个或更多相互关联的过程或系统之间的通信的规则或API。消息队列强制执行异步处理和松散耦合。根据实施情况,它们还可以提供消息的传递和订单保证。消息处理保证明确排除在设计之外。

RabbitMQ或Kafka消息队列是1:1消息系统吗?

正如答案中提到的,消息队列是一个单向管道:一个进程向队列写入数据,另一个进程按顺序读取数据 SysV消息队列就是一个例子 所以,我的理解是,......

回答 1 投票 0

Symfony:通过电子邮件发送失败的消息

我有一个简单的messanger配置:framework: messenger: failure_transport: failed transports: async: dsn: '%env(MESSENGER_TRANSPORT_DSN)%'...。

回答 1 投票 0

延迟优先级 Rabbitmq

我正面临这样一种情况,即队列中的每条消息都应在延迟后被消耗,而延迟是可以使用 RabbitMQ 中的 TTL 和死信交换实现的,但当最大 TTL 将在队首时,比......

回答 1 投票 0

从性能上看,RabbitMQ交换的意义是什么?

我已经试图找到一个答案,但无法找到任何固体。比方说,我有一个系统,分裂到3个模块。(只是一个例子)用户产品订单,我可以创建3个交易所,每个1 ....

回答 1 投票 0

事件队列和消息队列之间的差异

我只是看到了三种方法的文档,当我们在工作线程中工作时,可用于在UI线程中执行一段代码。方法是:public final void ...

回答 1 投票 4

Pub-Sub模式和消息代理,如何确保所有订阅者完成对事件的处理

首先,我知道可以使用像NATS这样的优质(轻量级)消息代理。如果这是一项工作,我当然会采用行之有效的解决方案,这更多是关于好奇心和意志……

回答 1 投票 1

资源公告-Kubernetes上的消息查询注册表

我有一个使用RabbitMQ消息的应用程序-它发送消息。其他应用程序可以对这些消息做出反应,但是他们需要知道系统上可用的消息以及什么...

回答 1 投票 0

Spring boot-使用RabbitMQ进行消息传递以连续监听消息队列

[当我运行“使用RabbitMQ进行消息传递”指南[我尝试了此演示应用程序] [1]时,侦听器仅接收到消息一次(运行器发送一次然后退出)。我希望听众可以...

回答 1 投票 0

替换邮件队列中的项目

我们的系统要求说,我们需要构建一个稍微不寻常的生产者-消费者处理系统。假设我们有多个数据流,并且每隔X秒拍摄一次快照,并将其放入...

回答 1 投票 0

分割后从骆驼路线获取原始消息

我有一条骆驼路线,该路线从队列中批量读取消息,处理该消息,然后继续将它们逐一发送到api,并等待api响应。我对...

回答 1 投票 0

多个后缀输出IP

我有一台具有多个公共IP地址的服务器。我想在此服务器上发送活动电子邮件。有时我想从特定IP发送邮件(这是对发件人电子邮件地址的过滤器...

回答 1 投票 3

Spring boot JMS:当JMS接收器发生内部应用程序错误时,如何不丢失jms消息

如果JMS接收器由于数据库连接失败等原因而失败,那么JMS消息将丢失。有人可以建议我,什么是常见的解决方案,以避免使用spring丢失JMS消息...

回答 1 投票 0

为什么放置队列可以解决数据不一致?

我正在研究一个名为Cadence的工具,该工具可用于降低开发分布式系统的复杂性。我看到了这段视频,https://youtu.be/llmsBGKOuWI?t=108。从1开始:...

回答 1 投票 0

无法更新类内部字段的值

此函数从消息容器中删除过期的消息void Broker :: removeExpiredMessages(){while(true){std :: this_thread :: sleep_for(std :: chrono :: milliseconds(1000)); ...

回答 1 投票 0

如何在Rabbit队列上使用同步消息?

我有一个node.js函数,需要针对我的应用程序上的每个订单执行该函数。在此函数中,我的应用程序从oracle数据库获取订单号,处理订单,然后在该订单号上加+1 ...

回答 1 投票 0

每个用户处理一封邮件

我有一个redis列表,可以用作队列。我将元素推向左侧,然后从右侧弹出,将来自不同用户的请求推入队列。我有一个goroutines池,可以读取请求...

回答 1 投票 0

我需要什么样的EC2实例从sqs队列系统中拉出消息?

我对Amazon中的队列服务很熟悉。 SQS是基于请求的,而不是基于请求的,因此我必须有一个EC2实例从队列中提取消息。那些实例是EC2 AMI VM吗?或...

回答 1 投票 0

使用Spring从Amazon SQS消费消息

我正在使用Amazon SQS作为消息队列。我正在研究如何在Tomcat中设置将使用消息的Spring使用者。但是我环顾四周,似乎在说...

回答 1 投票 2

Apache Pulsar消息传递语义

我查看了Apache Pulsar文档中的消息传递语义。为Apache函数提到的传递语义(至少一次,至少一次,一次有效),如果我们不使用Apache ...

回答 1 投票 0

使用GraphQL可以用基于消息的方法(例如MQ)替换用于订阅的websocket

尽管我正在工作的公司环境接受基于http(s)的请求响应模式的使用,这对于GraphQL查询和突变是可以的,但它们在将websocket用作...时存在问题,

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.