1回答
我使用ActiveMQ来收集来自队列中不同生产者的消息。我注意到，准备在代理队列中使用的消息有一个名为“时间戳”的字段。这是生产者向代理发送消息的时间，还是代理接收消息的时间？如果第一个情况是正确的，那么假设生产者P1在time t1发送消息，该消息到达time t2的代理，而另一个生产者P2在time t3发送消息，broker在time t4接收消息，其中包含t3 > t1和t2 > t4。这些消息将按照什么样的顺序排队并被消耗？因此，我想知道队列中消息的顺序是由代理接收这些消息的顺序决定的，还是由它们在生产者中“发送”的时间戳决定的。
如果我的问题有点混乱，请道歉，
谢谢你的
浏览 8提问于2022-06-07得票数 0
回答已采纳
假设我有m条消息在队列中，我有n条消息需要发布。如何以随机顺序插入队列中的n条消息，而不是附加到队列末尾？换句话说，我如何使用rabbitMQ进行混洗？
浏览 0提问于2016-04-19得票数 3
1回答
Oracle 10g中的触发器为常规表中的行子集生成向上插入和删除消息。这些消息由两个字段组成：
一个独特的行id一个非唯一的id.
在使用这些消息时，我希望在deque流程上强制执行一项遵守以下约束的命令：
必须以插入方式将属于同一id的order.Messages 消息排出队列，这种方式必须使任何其他去队列进程都不能用该id对潜在的后续消息(或消息)进行排队列。由于消息是使用触发器生成的，因此不能为此使用组。
我正在为AQ使用Oracle Java接口。关于如何实现这一点，有什么建议吗？
浏览 1提问于2009-11-19得票数 1
在AWS标准队列中，您可以设置一个重新驱动策略，如果消息未从队列中删除，则将导致消息重试。
在我的例子中，队列上有> 1,000,000条消息，需要几个小时来处理。当一个消息失败并被放回队列中时，它会被放在队列的末尾还是前面。当所有其他消息都已处理完毕时，这些消息是否会立即或两小时或三小时内重新尝试？
浏览 0提问于2019-09-04得票数 0
回答已采纳
我计划使用AWS FIFO SQS来记录我的数据存储中每个项目的当前状态。我将使用每个项目的唯一标识符作为messageGroupId，以确保对每个项的消息进行严格排序。
SQS是否确保如果属于特定组的消息在DLQ中，那么在DLQ消息被删除或重新驱动回主队列之前，来自该组的消息对使用者是不可见的吗？
例如，可以按顺序接收以下三条消息：
(groupIdA, M1)
(groupIdA, M2)
(groupIdA, M3)
我的计票器成功地使用了M1，但未能处理M2。它会尝试，直到maxReceive计数耗尽，消息被SQS推送到DLQ。现在，我仍然有另一条消息M3在等待被消耗。我希望确保M3只
浏览 4提问于2022-06-04得票数 0
回答已采纳
如果我需要确保另一条消息(具有相同的产品Id)不会同时被另一个消费者处理，我想知道处理来自队列的消息的最佳实践是什么。我的问题是，如果有人使用产品in下单和订购，而另一条消息带有相同的产品，我希望逐个处理它们，但不是并行处理。我正在考虑使用redis，我将保存正在处理的ids，并在处理结束后清除它们。但也许有一些更好的解决方案来解决这种情况。
浏览 2提问于2018-09-27得票数 1
我刚接触消息传递，对于MSMQ是否有可能为事务性队列提供无序消息，我还不太清楚。我认为这肯定是因为，如果一条消息没有被正确处理(因为我们将使用多个“竞争消费者”)，那么其他消费者可以继续处理消息，而失败的消息被放回队列中。在这件事上似乎找不到一个非黑即白的答案。
浏览 0提问于2009-11-04得票数 4
回答已采纳
1回答
我目前正在向类似于服务器的应用程序框架中添加JMS支持。JMS将由HornetQ (服务器类路径上的独立代理、hornetq )实现，但既没有JBoss、spring，也没有提供MDB的其他任何东西。
下一步是将消息侦听器添加到xa队列，该队列将允许对传入消息进行并行处理。有些消息会包含长时间运行的任务，因此基本思想是从onMessage方法生成工作线程。
在我穿越互联网的漫长旅途中，我遇到了，其中一位参与者提到他不会这么做，而是为任务使用额外的内部队列:然后(单线程)消息侦听器只会从入站队列中获取消息并为内部队列创建新消息，在内部队列的另一端，一些工作线程会为传入的消息进行竞争。入站消息一旦
浏览 1提问于2012-12-18得票数 6
回答已采纳
我目前正在为一个跟踪系统实现rabbitMQ，该系统有多个前端生产者在同一队列上写入。
基本上，我在队列中发送了两种类型的消息，因为跟踪工作流有两个步骤: impression/click => lead/sale。这很简单:用户点击一个横幅，然后在他被重定向到的网站上执行一个操作。此操作可能需要几秒钟到几天的时间来完成。我需要消费的销售线索或销售后，相应的解释或点击。
问题是我需要按时间顺序使用消息。虽然如果所有生产者都以相同的速度发送队列中的消息(即消息应该以FIFO的方式正确排序)，那么当其中一个生产者在队列中写入(由于某种原因)较慢时，我会遇到问题。
例如，如果我的领先操作发生在
浏览 0提问于2013-03-19得票数 3
回答已采纳
2回答
SNS的AWS常见问题说明：
问:信息是否会按正确的发布顺序传递给我？
Amazon服务将尝试按照发布者发布到主题的顺序传递来自发行者的消息。然而，网络问题可能会导致订户端出现无序消息.
它是否适用于SQS消费者，特别是FIFO SQS？我有一个用例，其中一个使用者需要维持消息发送的顺序。如果不是这样的话，我需要使用其他的东西。
浏览 0提问于2019-04-23得票数 2
回答已采纳
假设几个生产者发布到相同的交换E(扇出)。每个制片人都有自己的频道。队列Q绑定到exchange E。生产者P1向E发布消息M1，并接收来自E的确认A1。只有在确认A1之后，第二生产者P2才发布第二消息M2。Q: M1是第一个，M2是第二个，RabbitMQ保证消息的顺序吗？也就是说，订阅Q消费者总是会收到M1和之后的M2吗？
浏览 3提问于2016-02-29得票数 5
我正在调查，看看骆驼是否能满足以下要求。要求是:传入队列上消息的顺序应该与传出队列上的消息顺序相匹配。
我认为这个问题归结为Camel如何将消息从传入队列转发到传出队列的内部。
在简单的示例中，其中的路由如下所示：
from("incomingQueue").to("outgoingQueue);
incomingQueue有4条消息可以开始(按这个顺序到达)：message 1、message 2、message 3、message 4。
是否有保证或选择告诉骆驼以保持原始接收顺序的方式转发信息？因此，如果侦听器正在侦听传出队列，它将接收消息1，然后是消息2，然后是消
浏览 4提问于2014-08-28得票数 0
回答已采纳
1回答
@Async
public void scanFile() {
log.info("Start scanning");
String queueUrl = sqs.getQueueUrl("bucket-antivirus").getQueueUrl();
List<Message> messages = sqs.receiveMessage(new ReceiveMessageRequest()
.withQueueUrl(queueUrl)
.withWait
浏览 2提问于2018-07-16得票数 0
我有两个组件-一个基于云的CLS应用程序。另一个是普通的基于Java的管理员，它与MySQL对话。
考虑到SQS不是FIFO，而且我不确定我什么时候能在我的消费者端收到消息。此外，我可能会在同一数据上的前一条消息之前收到一条新消息，从而导致数据不一致
如果我想在这两个系统之间同步数据，SQS是一个好的服务吗？
在这样的同步场景中，SQS通常是一个好工具吗？
浏览 3提问于2016-09-26得票数 0
我有一个消息传递用例问题。
到目前为止，我们在AWS中有一个队列，例如，该队列上的和origQueue。
现在，为了满足基于优先级(高、中、低)的消息消耗(基于消息中设置的“优先级”号)的一个特殊特点，我认为有一组3条队列，其中每个队列属于不同的优先级级别。在最高优先级队列中，将继续发生。一个批处理过程将以5分钟的间隔继续运行。每条消息都可以从中、低优先级队列中提升一些消息。目前还没有考虑到这个批处理过程的逻辑，但是它可以是任何东西，比如取起10条中优先级消息和5条低优先级消息，这两条消息的使用时间都超过1小时，并将它们提升到高优先级队列，以便上述out-of-the-box-lambda-b
浏览 0提问于2019-04-25得票数 3
1回答
结合Oracle高级队列和JMS使用Apache有一个问题。
这是一个发布消息的应用程序。在Camel的帮助下，在Oracle高级队列中接收和排队消息。然后它们会被骆驼吃掉，并被转发到目标系统。对于消息传递失败的情况，高级队列中定义了重试计数，以便重复消息传递。
如果Camel现在将消息排出队列并将其发送到不可用的目标系统，则会抛出一个HttpOperationFailedException或NoSuchEndpointException。这些都会被捕获，并执行回滚。
此时，我们的期望是重试消息传递，就像Retry计数中定义的那样，然后移动到异常队列。然而，正在发生的是队列中的下一条消息是发送
浏览 4提问于2015-09-16得票数 7
回答已采纳
1回答
有人能向我解释消息队列是如何处理单个消息队列上阻塞的多个线程的吗？
我的情况是，有多个写入器阻塞一个完整的消息队列，每个发送消息的优先级等于线程优先级。我想确保他们以优先级顺序唤醒和发布，但是我的应用程序的行为就好像他们是以FIFO顺序(即他们阻塞的顺序)醒来一样。每个阻塞线程都使用具有系统级别范围的不同优先级的SCHED_FIFO策略进行调度。
我在互联网上到处搜索一些描述它应该如何工作的东西，我所能找到的只有POSIX手册页，它们描述了如果支持优先级调度的话，多个阻止程序会以优先级顺序唤醒。由于内核调度程序是一个优先级调度器，所以我认为线程会按优先级顺序唤醒并发送到队列，但是情况似乎并非如
浏览 3提问于2017-10-27得票数 4
是否可以在MSMQ消息队列上强制按顺序接收？也就是说，我们希望以与发送消息相同的顺序接收消息。
编辑:如果有帮助的话:事务性队列对我们来说很好。没有DTC会更好。
Edit2 -一些额外的上下文:当用户向我们的数据库提交新数据时(通过web界面)，我们的web应用程序将事件发布到服务总线上(在幕后使用MSMQ )。总线上的侦听器现在应该按顺序接收消息，因为这对于一致性很重要(person在创建之前不能重命名...)。总线专家只是为每个点对点连接和订阅管理创建队列，然而，他们说底层队列负责按顺序交付事件。
浏览 1提问于2013-07-01得票数 2
回答已采纳
我用皮卡为蟒蛇与RabbitMQ沟通。我有6个线程，它们使用和确认来自同一个队列的消息。对于每个线程，我使用不同的连接(和通道)。因此，我有几个问题非常接近对方：
如果连接到兔子将关闭在一个线程，我将进行重新连接，传递标签值将重置和重新连接后，它将从0开始？
在重新连接之后，我将以相同的顺序接收相同的未确认消息，或者它将开始在所有线程之间重新分发它们，还是从重新连接点开始？
这在我的应用程序中很重要，因为在消息接收和确认之间存在延迟，我希望在接下来的过程中避免重复。
浏览 3提问于2015-09-16得票数 3
回答已采纳
我有一个SQS的用例，在这里我将发送关于系统中特定对象的消息。每个对象最多每20秒有一条消息，其中有数十万(潜在的数百万)对象，这意味着我将每秒处理数万条(可能数十万条)消息。消息量不允许使用FIFO队列。
大多数情况下，我不关心即时消息。如果两个不同对象的消息以与发出的顺序不同的方式传递，那就好了。可能会出现的问题是，如果两个与同一对象有关的消息被按顺序传递，则可能会出现问题。
考虑到每个对象只会每20秒发生一次事件，并且每个对象都会有事件，我觉得如果两条消息分开20秒(它们之间可能有数百万条消息)不可能按顺序发送，我会觉得这是不可能的。尽管如此，我还没有找到任何关于SQS的订单过期交付的硬
浏览 0提问于2018-03-09得票数 1
我有一个FIFO队列和一个lambda轮询它。lambda对队列中的一个消息有此错误：
Runtime exited with error: signal: killed Runtime.ExitError
我知道这是因为达到了最大的记忆。
现在，在此错误之后发送到队列的任何msg都在队列中，错误的msg被困在飞行中，如AWS控制台上所看到的那样。
我所期望的:达到最大内存的 Msg应该已经退出，允许下一个Msg运行。
发生了什么： AWS控制台显示了1次航班消息，延迟后发送的新消息显示在“消息可用”下，直到我不得不清除队列才将其清空。
我想弄清楚，如果运行时被杀死了，msg是否会永久地保持在
浏览 11提问于2022-11-03得票数 1
我有工作线程，可以从不同的提供程序类接收消息。每个提供程序类都会添加/接收内部队列的消息。每个提供者只满足一个安慰队列，安慰使用者将消息添加到队列的提供者。
多个工作人员可以接收某个提供程序的消息，对它们进行处理，然后为消息发送一个ack (下面的message.commit()方法完成了ack)。
场景
provider1Worker2 Worker1从提取message2进行处理，以便在worker1完成之前完成处理，因此将ack发送回message2
问题
Would message2仍然坐在安慰队列上，等待message1被添加，或者message2会被弹出队列，尽管在接收到ack时，
浏览 4提问于2019-10-21得票数 2
回答已采纳
我已经配置了一个SQS队列，其中包含一个发布者和三个使用者。我想按顺序处理发布到队列中的所有消息。队列中发布的所有消息都属于同一组。
我已经阅读了SQS文档，并理解通过配置合适的可见性超时，我们可以确保在任何给定的时间只有一个使用者处理消息。在可见超时期间内，消息将不会传递给任何其他使用者。
这里我的问题是，当一个用户正在处理一条消息时，队列中的其他消息是否有可能被另一个使用者使用？
如果是，如何确保在给定时间只有一个使用者在使用队列中的消息？
浏览 4提问于2020-11-23得票数 1
回答已采纳
1回答
我编写了以下jQuery插件，它基本上只是一个简单的通知系统，用于向用户显示消息。如果您一次显示一条消息，则此功能非常有用。但是，如果您有多条消息要显示给用户，那么这些消息显然会一条接一条地显示。
我的问题是，根据这些代码，您如何建议我实现一个消息队列系统？我希望一次只显示一条消息，因此当单击close按钮或fadeOut完成时，下一条消息将触发并启动该过程。
我最初的想法是检查消息是否已经显示，然后可能将当前消息推送到一个数组中，然后在删除第一条消息时将其弹出，但我似乎无法理解这一点。
浏览 3提问于2011-04-26得票数 2
回答已采纳
4回答
在我的JavaEE web应用程序中，我需要严格按照到达的顺序处理传入的消息。我假设我的webapp容器(Tomcat6)保留了消息到达http端口时的顺序。
让我头疼的是我内部处理这些消息的方式。为了改善工作负载，我将每条消息的处理附加到一个ThreadPool，因为这里需要做很多事情，例如XML解析，有时使用外部web服务丰富数据。处理完成后，我将消息的java表示推入一个复杂的流处理引擎，即threadsafe。这里，在进入顺序是最高要求的地方检查不同的模式，例如，超过现象的阈值。
我的想法是将每个处理过的消息插入到一个具有它们在到达时收到的优先级ID的PriorityQueue中(在我
浏览 0提问于2012-03-20得票数 10
回答已采纳
1回答
我在我的项目中使用Oracle融合中间件12C的BPEL。即使BPEL成功地读取了消息，也需要将消息保留在队列中。
也就是说，一旦完成BPEL事务成功，消息就会从队列中删除。我们总是可以在队列中重新插入消息，但是消息的顺序会发生变化。
在weblogic中是否有任何可以帮助我实现这一点的配置？
浏览 1提问于2016-05-15得票数 1
回答已采纳
我想同时使用来自多个队列的jms消息。在长时间运行处理之后，所有消息都应该转到DB，我没有权利丢失它们。
问题:在处理另一条消息时，是否可以保存消息以供将来确认并调用oldMessage.acknowledge()？
我的第一个猜测是，这是不可能的，因为它在jms处理单元中很深，我必须在onMessage(...)方法中处理消息和确认。
第二种猜测是并发拆分onMessage()，并允许对许多消息进行长时间运行处理。但是这不是一个好的选择，因为我必须确保所有的消息都来了，，ordered，！
第二个问题:在并发处理过程中，有什么方法可以确保传入的订单吗？
浏览 4提问于2013-04-16得票数 1
回答已采纳
1回答
我是一个网络开发人员，最终在一些j2ee开发(新手)。我真的需要这个理论得到证实。
当用户点击“保存”按钮时，我获得了从我们的系统(生产者)向SOA Enterprice服务总线(使用者)传递消息的特权。信息不能丢失或不传递，必须遵守送货单。
环境：
JBossEAP5.1作为生产者。JNDI服务器是ESB (可能是 ESB作为消费者。)。
由于异步特性，我选择的武器是JMS，p2p。
当生产者发送消息时，可能会出现一些问题：
JNDI exceptionQueue管理器由于某种原因没有唤醒或配置错误，因此ESB出现故障。这应该会导致一些，从而导致exception.Network错误。
所以
浏览 5提问于2011-10-26得票数 0
我在使用AzureMessageQueue作为传输的azure工作者角色中托管了一个NServiceBus端点。我非常确定我将在azure中配置多个实例的情况下运行worker角色。我也有一些顺序很重要的信息。
这是我的问题。有没有办法通过这种类型的设置(向外扩展azure worker角色)来控制顺序？
我应该看一个传奇故事吗？我猜，像下面描述的技术(使用bus.send(object[]消息)重载)将在这个模型中工作，但只有在由于azure队列的大小限制而有少量消息的情况下，这才是理想的。
浏览 1提问于2012-11-16得票数 0
回答已采纳
我的问题是，我有一个先进先出队列，其中包含数以千计的消息，我只需要用MessageGroupId获取消息，这怎么可能呢？这意味着亚马逊为其属性提供了任何过滤器。因为它得到的所有消息都不是针对特定id的。谢谢，如果能帮到我的话我会很感激的。
浏览 3提问于2017-04-18得票数 1
4回答
我正在使用python中的boto3客户端。我正在将消息推送到sqs，但接收它们的顺序错误。我可以看到他们的发送时间是正确的。
队列是这样创建的：
boto_session = boto3.Session(region_name=..,aws_access_key_id=.., aws_secret_access_key=...)
sqs_client = boto_session.resource('sqs', endpoint_url=endpoint_url)
sqs_client.create_q
浏览 6提问于2016-10-31得票数 6
2回答
我正在研究一个能够处理来自RabbitMQ的消息的工作人员。
然而，我不知道如何做到这一点。
如果我收到一条消息，并且在处理错误时发生错误，我如何将消息放到队列的末尾？
我试图使用nack或拒绝，但消息总是重新放在第一个位置，其他消息保持冻结！
我不明白为什么要把这条信息放在第一个位置，我试图“播放”其他选项，如requeue或AllupTo，但它们似乎都不起作用。
提前谢谢你！
浏览 4提问于2016-12-29得票数 1
回答已采纳
我有一个进程，它读取来自SQS的消息并处理它。每条消息都有一个group_message_key，每条消息的处理相对较快，但是如果我使用不同的group_message_key读取消息，则会有额外的处理时间。因此，为了避免这些上下文切换，我尝试对消息进行分组。
我希望可以选择最初从通用队列中读取，其中所有消息都是排队的，并且只有在读取了第一条消息之后，才会查询消息队列，以便只使用特定的group_message_key传递消息。
我目前正在使用Amazon，但我根本不介意换到其他message，它可以提供我所缺少的特性(即:兔子，Kafka)。
我从来自许多不同进程的相同队列中并行读取，所以解
浏览 10提问于2021-12-19得票数 0
1回答
在要求后保持交货顺序
、、、、
我正在开发一个使用兔子MQ进行消息传递的应用程序。我使用显式ACK：
model.BasicConsume(queueName,false, consumer);
并在处理消息后执行ACK：
consumer.Received += (ch, ea) =>
{
try
{
var message = Encoding.UTF8.GetString(ea.Body);
浏览 2提问于2017-02-15得票数 3
1回答
我有一个发布端点'P‘和两个使用者'A'，'B’。
当'P‘发布消息'1’2‘'3’时，我预计消费者将使用'123‘顺序的消息。但实际上，消费顺序可能是'132‘、'312’等等。
我已经配置了与并发相关的设置，但它不起作用
问题：在A成功地使用消息之前，是否有一种配置可以阻止'B‘接收消息？
谢谢
浏览 3提问于2017-08-22得票数 0
回答已采纳
1回答
如何按组处理来自SQS队列的消息
、、、、
我目前有一个SQS队列来触发lambda函数，但是SQS对在役消息有120 k的限制，这意味着只有120 k的消息可以由lambda使用者处理。大多数情况下都很好。但是假设我有客户机A和B，如果A向队列发送500 k，在此之后B只发送1条消息，B需要等待队列中的所有消息来处理。为每个客户端创建一个队列是没有意义的(至少不是手动的)。例如，我如何能够以循环的方式处理来自客户端的消息，让每个人都有相同的时间来处理他们的任务？
我一直在研究Kinesis数据流，但不太确定这是否能解决我的问题。我是否需要创建一个SNS，将其重定向到一个负责循环消息的lambda到执行相同任务的队列，但这样我就可以避免
浏览 2提问于2022-03-11得票数 0
回答已采纳
1回答
我的场景:我有一个Azure存储队列，在这里消息可以随时传入。如果队列中有10个项，则必须按顺序处理它们。我正在使用c#和。
如果第一项在2秒后失败，它将在队列中保持不可见状态，持续28秒(默认情况下为30秒不可见)。
现在，我的工作人员将继续检查队列中的消息，并在什么时候处理它们。如果队列消息失败，它仍然是不可见的，因此在重新尝试第一条消息之前，将处理下一个队列项。
对于任何需要按顺序处理项目的队列的人来说，这似乎是一个非常基本的功能。
不，我不能将超时设置为更小的时间，因为任务会花费不同的时间。
浏览 0提问于2018-03-08得票数 0
想象一下订单的以下生命周期。
订单已付
批准命令
订单已完成
我们选择使用SQS来确保所有这些消息都按照它们产生的顺序进行处理，例如，避免将订单的状态更改为只在付款后才批准，而不是在完成之后。
但是，假设在尝试批准订单时出现了错误，在多次尝试之后，消息将被移动到死信队列中。
我们注意到的问题是后续的消息，即“订单完成”，它被处理，即使前面的消息是“已批准的”，它在死信队列中。
我们该怎么处理这事？
假设我们可以这样做，是否应该检查死信队列的内容是否具有与消费队列相同的MessageGroupID消息？
有没有我们缺少的机制？
浏览 1提问于2019-07-23得票数 4
回答已采纳
这是我的需求:我收到一个验证一些数据/记录的请求。对于每个请求，记录将被发送到SQS队列，以便由另一个服务/组件进一步处理。消息结构如下所示：
messageId: //a unique message id
requestId: //request id common between all messages/records for that request
record_body: {//key-value pairs}
一切都很好。现在，我想知道何时从队列中读取了具有相同请求id的所有消息(即，对于该请求id没有更多的消息)。我的想法是在每次读取时将每个消息/记录写入数据库，然后让另一个
浏览 0提问于2018-06-13得票数 0
4回答
我需要为新项目选择一个新的队列代理。
这一次，我需要一个支持发布/订阅的可伸缩队列，并且必须保持消息排序。
我读到亚历克西斯的评论:他写道：
事实上，我们认为RabbitMQ提供了比卡夫卡更强大的秩序
我在rabbitmq文档中阅读了消息排序部分：
“消息可以使用具有请求参数(basic.recover、basic.reject和basic.nack)的AMQP方法返回到队列，或者由于通道关闭，同时保存未确认的2.7.0版本和更高版本，如果队列有多个订阅者，单个使用者仍然可以观察消息的无序。这是由于其他可能请求消息的订阅者的行为。从队列的角度来看，消息总是以发布顺序保存。”
如
浏览 10提问于2014-01-26得票数 84
回答已采纳
1回答
跨队列的消息排序
、、
我在我的RabbitMQ设置中有一个场景，我很好奇如何解决这个问题。下图说明了它(为了简洁起见删除了交换和大多数队列)：
场景
生产者创建消息A(1)，它被顶级使用者接收，开始处理消息。
生产者创建消息A(2)，它被最底层的使用者接收(假设两个消费者都在循环交换中)。
底层使用者发布消息B(2)，该消息被放入消息B使用者的队列中
低速度的顶级消费者最终完成并发布它的信息B(1)。
问题
如果我们假设B用户不能被幂等，我们如何确保两个B消息的结果都以正确的顺序应用？
我曾想过使用应用于消息A的初始发布的时间戳，让使用者维护最后一次更改的时间戳，在此之前拒绝任何时
浏览 1提问于2015-04-09得票数 2
回答已采纳
当从蔚蓝队列中检索消息但未从其中删除消息时，消息的可见性超时过期，消息将(Re)添加到队列的端。
是否有一种方法可以将此类消息返回给队列的头？
浏览 2提问于2015-05-14得票数 2
回答已采纳
对于正常的SQS，假设可见性超时为30。一个工作人员使用一条消息，而该工作人员不会从SQS中删除该消息。现在，30岁以后，消息又变得可用了。
在SQS中，这个消息到底在哪里可用？它是在队列开始时可用，还是在队列结束时使用？
浏览 1提问于2022-05-17得票数 0
回答已采纳
1回答
我使用RabbitMQ将消息从服务器分发到多个客户端。每个客户端都有自己的队列。服务器向exchange发布了一条消息，并且存在多个绑定，这会导致分发到多个队列。
见下图。消息被发布到“公共Exchange”，其中有绑定到特定于用户的交换(例如，“用户1 Exchange")，最后一次绑定从用户特定的exchange到用户队列(例如，“用户1队列”)。
现在我的问题是，，我不希望某个客户端比其他客户机更早地收到消息，(例如，用户1的消息总是比用户2更早)
我的问题是:队列中的消息是否按确定的顺序可用？
编辑：我知道差异可能很小(如果有的话)。但我需要知道-客户都在问。在高峰期间，
浏览 3提问于2017-04-11得票数 0
回答已采纳
我已经在Azure queue中创建了一个队列，并在其中加入了两个项目。使用nodejs sdk，我创建了一个每5秒执行一次的计时器，并调用：
azure.createQueueService("precondevqueues", "<key>").getMessages(queueName, {numOfMessages : 1, visibilityTimeout: 1 }, callback)
我希望队列中的两个队列中的相同消息每隔5秒出现一次，但似乎并非如此。此调用的输出在两条消息之间交替。
情况不应该是这样，因为visibilityTime
浏览 2提问于2016-06-10得票数 1
我有一个客户端套接字列表，通常大小在2000左右。这些客户是动态的，他们来来往往。
我有一个由32个线程组成的固定线程池的ExecutorService来处理这些线程。此执行器服务负责解码和发送要发送给这2000客户端的消息。
我希望防止执行器服务的两个(或更多)线程同时处理同一个客户端。
一种方法可以是引入另一个簿记线程(因此我最终得到32 +1个线程)，它负责在完成与同一个客户端对应的前一条消息时调用ExecutorService.submit(mesage)。但我不确定这是否会引入瓶颈，这意味着这个新引入的簿记线程无法继续提交消息。
理想情况下，我不希望预先将线程分配给一组客户端，因为消
浏览 0提问于2018-08-14得票数 3
回答已采纳
1回答
我对Akka Actors和Actor Model有一点困惑。从执行元A发送到执行元B的消息是否保持顺序？如何在本地/网络环境中实现此目标？据我所知，网络引入了可变时延，如果M1的时延为1秒，M2的时延为0.5秒，消息M1和消息M2如何保持顺序？
浏览 8提问于2015-12-01得票数 0
来自Amazon页面：
Amazon不保证FIFO访问Amazon队列中的消息，这主要是因为Amazon的分布式特性。如果需要特定的消息排序，则应该设计应用程序来处理它。
我的问题是--如何设计应用程序？
浏览 1提问于2014-03-11得票数 9
我正在尝试实现一个应用程序(Java)，它将通过TIBCO EMS从其他不同的应用程序订阅不同的消息类型(XML)。这些消息类型中的每一种都有特定的用途。我认为我的应用程序中应该有多个具有多个订阅者的队列，然而，TIBCO的家伙坚持认为应该只有一个队列，所有这些消息都将在其中发布，并且我将有一个订阅者，然后订阅者应该根据收到的XML拥有不同任务的逻辑。
哪种方法更好？一个有多个队列和订阅者，还是一个队列和一个订阅者？请告诉我选择的原因。
谢谢!
-Naveen
浏览 0提问于2016-01-21得票数 0
我创建了一个Azure函数应用程序，它是从Azure服务总线队列触发的。服务总线中有两个队列，每个队列都有一个带有触发器的函数。函数应用程序是在Visual中使用C#开发的，并使用包部署发布。
我想要做的是，如果一个函数/触发器都有消息等待，则应该先处理另一个函数/触发器。(它们做的基本上是相同的事情，但是有一个队列用于处理优先级较高的消息，因为队列只是FIFO。)
我读过函数是的，但这并不是真正需要依赖的东西。
是否有任何方法可以显式地指示一个函数/触发器相对于另一个函数/触发器的优先级(甚至是扩展的首选项)？
浏览 5提问于2022-07-13得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
