我正在使用BLiP，我想在最后一次与用户交互的5分钟后安排3条消息，一个呼叫可以，其他人不能。
浏览 14提问于2020-01-28得票数 0
回答已采纳
我让一个调度器每分钟向队列发送一些具有相同ID的“信号”消息。同时，在5%的情况下，消息处理程序可以在5秒到15分钟的时间范围内使用消息。在这种情况下，我如何实现幂等消息处理，以便从调度器发送的第二条消息将被忽略？
我曾尝试采用消息重复检测，但这种方法不能很好地工作，因为它只使用消息发生时间戳
浏览 1提问于2013-11-05得票数 0
假设我有一个文件名列表(.zip)。我希望同时(并行)提取文件，对于每个提取的文件，并行地处理它们。我现在的代码是什么样子的： % ..所以，我的问题是，我只扫描一个进程Archive并发送多条消息。在这样做的时候，消息会被并发处理吗？内部的Erlang文件说，每个调度程序都有多个运行队列，所以我假设消息可以并发处理？或者，为了同时处理消息，我是否需要生成
浏览 0提问于2014-04-19得票数 1
回答已采纳
我们有一个这样的场景：
在几个节点上可能有许多工人(也称为消费者)，同时，webapp会向这些工人提交在线工作。我们需要均匀地处理这些工作，并知道是否有可用的工人来完成每一项工作。因此，我们希望使用Rabbitmq来调度作业，并设置每个作业消息ttl = 0，以便在没有工人执行每个作业时得到通知。但我们还希望Rabbitmq在工作节点崩溃时处理作业重新调度。但是，如果ttl设置为0，Rabbitmq
浏览 0提问于2016-04-25得票数 1
我一直在玩Actr ，这是一个简单的小演员系统。我想我的问题也适用于阿克卡。我有一个简单的代码，发送一个Actor数字1到10。Actor只是打印消息，而消息没有顺序。Actr将消息封装到一个可运行的文件中，并将其发送给ForkJoin执行器。当任务执行时，它将消息放到目标Actor的队列中，并对其进行处理。我对ForkJoinPool的理解是，任务被分发到多个线程。我增加了日志和
浏览 2提问于2021-12-15得票数 1
回答已采纳
为了防止并行计算中的某些问题，我们希望所有工作人员都可以类似地在queue1或queue2上工作，而不是混合处理它们(因为这将需要大量的锁和检查以及额外的db访问才能在队列上互操作)。第一部分：
因此，我们要做的是告诉message从queue1中选择尽可能多的在线工作人员(比如x)的消息，并让所有工作人员在(相同)队列的消息上工作。在确认这些消息</em
浏览 0提问于2019-05-18得票数 1
1回答
我有多达30个节点，每个节点能够发送高达1000条消息/秒的数据。每条消息可以具有256-512字节的数据。每个节点使用唯一的tcp端口进行通信。接收到的每个数据都经过预处理、插入数据库和后处理。将asyncio与推入队列的数据和使用此队列的工作线程一起使用。q.get() save_in_db(data)观察：-由于在接收数据包时没有进行任何处理，所有节点都
浏览 1提问于2021-05-16得票数 0
1回答
一个芹菜节拍，很多工人？
、、、、
我希望运行由多个工作进程共享的单个DatabaseScheduler-backed celerybeat实例。瑞迪斯是经纪人。是否只有一个工作人员收到计划任务，还是所有工作人员都收到计划任务？谢谢!
浏览 0提问于2015-03-12得票数 2
2回答
我想让一个从OMNET++中的三个不同节点接收消息的节点具有动画效果。现在，节点以顺序的方式发送。但是，我希望节点同时向根节点发送消息。根节点被输入门阵列占用。在Omnet中可以吗？
浏览 2提问于2012-03-26得票数 1
3回答
我有一个php进程producer-a，它将一个作业放在RabbitMQ a上--将处理推迟到第三方服务。第三方服务完成对a的处理，并将响应放置到队列b上。我面临的问题是，通过使用RMQ --我是异步地执行任务--但是我需要在仍然使用RMQ的同时序列化这个过程。问题是，流程B通过消息队列被推迟到第三方服务，我需要确保流程A在进程C从进程A获取作业之前将作业发送到进程B完成，从上面的时间线可以看出，流程C在进程A完成之前已经完成。更新：
我没有想过要陈述显而易见的事实，<
浏览 0提问于2015-02-16得票数 1
我想创建一个objective c应用程序来解释.aiml文件的列表，然后为它制作一个图形用户界面。我想要这样做，这样我就可以在应用程序中与aiml文件聊天。
有什么好办法吗？？示例代码？
浏览 0提问于2010-07-11得票数 1
回答已采纳
我遇到了一个奇怪的问题。我有一个云服务A，它将消息放入服务总线队列中，以供另一个云服务B读取。云服务B可能需要大约一秒钟的时间来处理它需要做的事情，然后它会将一条消息放回云服务A的队列中。例如，我生成一个在未来1到10秒之间的日期时间。当我在云服务A中收到消息时，我将ScheduledEnqueueTimeUtc属性与消息的EnqueuedTimeUtc属性进行了
浏览 1提问于2013-03-02得票数 6
回答已采纳
2回答
我想定期(每天)在我们的Web/Worker角色上完成某项任务。我的云服务中有多个实例，我希望每天只有一个实例完成这项任务(例如，Instance0可以在一天完成这项工作，第二天可以是Instance1完成这项工作，但0和1不会在同一天/期间尝试完成相同的工作)。Azure队列似乎是实现这一点的一种很好的方法，因为根据设计，只有一个实例会将消息出队(假设它在完成
浏览 1提问于2015-07-11得票数 0
2回答
我读了一篇关于使用消息传递进行进程间通信的文章。为了运行示例并看到它说的和我引用的：“应该同时编译和运行”。有人知道我到底该怎么做吗？
浏览 2提问于2015-11-20得票数 1
1回答
我有32个演员在任何时候运行，但只有24个线程。前24个参与者获得24个可用线程。剩下的8个线程只在24个参与者中的一个终止时才得到它们的执行线程。
浏览 2提问于2015-06-20得票数 0
1回答
根据我的理解，一个操作是由一个CPU操作的。而且，多处理系统具有多个CPU。也就是说，多处理系统可以同时处理多个任务。为什么具有多个CPU的多处理系统使用进程调度，并且使用一
浏览 1提问于2017-09-19得票数 0
我想用一个队列上的多个线程来模拟这个功能。如果我在启动发送器之前启动接收器，它会按预期工作，如下所示：[*] Rcvr2 Waiting for messages...但是，首先启动我的接收器会导致只有一个线程接收消息(启动的最后一个线程)：[*] Rcvr1 Waiting for messages发送的第一个<
浏览 0提问于2018-12-31得票数 2
1回答
我正在实现一个标准的MPI主/从系统:有一个主程序分配工作，还有一些奴隶要求块和处理数据。你有什么办法解决这个问题吗？
浏览 1提问于2012-11-02得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
