message-queue 相关问题

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

使用mosca MQTT的请求响应模式

是否有任何方法可以通过mosca MQTT来实现请求-响应模式,以“检查来自客户端的答复,如果我没有在预期的时间内收到预期的答复,则重新发布”。我相信这是...

回答 2 投票 0

MPI-跨进程共享队列

我有一个MPI程序,其中主节点等待,直到从节点完成一定数量的任务(例如1000)为止。从属节点处于while(True)循环中,并继续从...

回答 1 投票 1

改善Amazon SQS性能

我所能找到的有关Amazon Simple Queue Service(SQS)性能的所有信息,包括其自己的文档,都表明获得高吞吐量需要多个线程。我已经验证过了...

回答 1 投票 1

Azure Service Bus和Service Bus 1.1有什么区别?

据我了解,Service Bus 1.1于2013年发布。AzureSB较新。我正在寻找有关SB 1.1的文档,但是我只能找到我最近加入了一个团队的Azure SB的新文档...

回答 1 投票 0

RabbitMQ 2队列

看到类似的问题,但预期答案不同。我的问题是,我是否可以创建一个消费者以专注于单个队列,直到它清空后再切换到另一个队列,直到将新工作发送到...

回答 1 投票 0

Kafka:单个使用者组,没有分区和多个主题

我有22个主题,主题中的顺序对我很重要。我没有任何分区。基本上我有11个租户,每个租户需要两个主题。我对是否要拥有...

回答 2 投票 0

事件驱动的Kubernetes服务

我正在寻找一种服务间通信解决方案。我有1个服务和带有传入gRPC流的多个Pod。最初的请求调出一个外部资源,该资源最终...

回答 1 投票 1

如何解释RabbitMQ消息统计信息?

我想获取和历史化“入队,出队大小”(以前在ActiveMQ上遇到过的术语)的队列指标。管理插件中提供的移动图表不足以......>

回答 1 投票 2

消息队列使用者应如何在微服务环境中模拟Identity Server 3中的用户?

我们有一个使用Identity Server 3的微服务环境。通过授权http标头中的承载令牌将身份提供给http微服务,其中令牌是JWT。那个JWT通常是...

回答 1 投票 0

如何通过JMS使用“ Other”(不是usr区域)文件夹创建MQRFH2标头

使用Spring的JmsTemplate message.setStringProperty(“ param”,“ value”)可以在MQRFH2.usr中设置值。我们如何在MQRFH2.other中设置值?

回答 1 投票 0

Actor Systems如何起到防止内存从队列溢出的作用,还可以防止线程在写队列时阻塞?

演员互相发送消息。如果队列有限,那么在尝试写/发送到完整队列时会发生什么?阻塞还是掉线?如果不受限制,则可能导致内存崩溃。如何...

回答 1 投票 0

Windows服务消息队列使用者应如何在微服务环境中模拟Identity Server 3中的用户?

我们有一个使用Identity Server 3的微服务环境。通过授权http标头中的承载令牌将身份提供给http微服务,其中令牌是JWT。那个JWT通常是...

回答 1 投票 0

如果在Rabbit MQ消息队列中使用相同的路由密钥将多个队列预订到同一交换,会发生什么

我有一个名为“ videoexchange”的通知交换,我有3个队列q1,q2和q3。所有3个队列q1,q2和q3都订阅了具有相同路由键“ * .encoding”的同一个交换“ videoexchange” ...

回答 1 投票 0

未创建多个队列-C

起初,我正在创建此程序来满足一个队列,并且一切正常。我目前正在尝试通过使用结构数组来创建多个队列,每个队列都是...

回答 1 投票 0

如何使用/不使用RabbitMQ改善大规模数据管道

我们有非常非常简单的数据管道,我们的问题是规模。发布者将消息发送到队列,而消费者需要使用它。顺序很重要(必须是FIFO),我们现在使用RabbitMQ,但是它的...

回答 1 投票 0

正在被覆盖的邮件-C

我具有以下两个功能,SendMessage和ReceiveMessage,顾名思义,它们将消息发送到队列并从队列接收消息。我的问题是,每条消息都是...

回答 1 投票 0

Azure服务总线队列分组消息

我有一个Web api应用程序,它执行不同类型的操作,而Domain实体称为Application。诸如“复制”,“更新”,“回收”,“还原”等操作。此操作必须为...

回答 2 投票 0

在FreeRTOS中使用流缓冲区时,可以使用互斥锁代替临界区吗?

我正在研究在FreeRTOS中使用流缓冲区将CAN帧从多个任务传输到ISR,ISR将这些帧在准备就绪后立即放入CAN发送缓冲区中。此处的手册说明了...

回答 1 投票 3

如何使用RabbitMQ管理插件将字节数组发布到队列?

如下所示,RabbitMQ管理GUI可以直接将消息发布到特定队列。此队列的使用者使用protobuf格式的消息,这意味着我应该发布...

回答 1 投票 0

在多个队列中发送和接收消息-C编程

我有一个任务,我必须创建多个队列。目前,我很困惑,因为我不了解如何将消息发送到特定队列以及如何发送/接收输入的...

回答 1 投票 2

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