嗨，我有这段代码
SendMessageToMyQueue();
UpdateStatusInDbThatMessageWasSent();
有时，在更新状态之前处理消息，这是我想要避免的。
我的问题是，如果我用这样的事务来包装这两行：
using(var tr = new TransactionScope())
{
SendMessageToMyQueue();
UpdateStatusInDbThatMessageWasSent();
tr.Compleate();
}
将保证在MyQueue上创建一个锁，并且在UpdateStatusInDbThatMessageWasSent更新
浏览 6提问于2017-12-08得票数 1
回答已采纳
我想学习更多关于编程消息传递应用程序和使用消息队列的知识。像qpid，亚马逊队列等的事情。你能告诉我一些应用程序(最好是C++，如果可能的话，开源)，这样我可以了解更多。
另外，您能告诉我决定是否不使用消息队列的一般指导原则吗？我对leanring很感兴趣，只是因为“酷”的因素，但我认为这对我未来可能是有益的。
浏览 0提问于2011-02-12得票数 2
回答已采纳
我想要创建一个使用者，它处理来自多个变量数目的消息，这些消息是动态连接或断开连接的。
我需要的是每个消费者首先优先处理每个源的N条消息。然后运行多个消费者来提高速度。
我一直在阅读、和以及许多其他文档的文档，而没有确定如何实现这一点。而且我也做了一些没有运气的测试。
有人能指点我怎么做或者在哪里读到吗？
-编辑--
QueueA-A3-A2-A1-┐
QueueB
QueueC-┘
所期望的效果是每个使用者获得每个队列的第一条消息。例如: A1、B1、C1、A2、B2、C2、A3、B3、C3等等。如果创建了一个新队列(QueueD)，消费者将以同样的方式开始接收来自它的消息。
提前感谢
浏览 1提问于2018-05-02得票数 4
我希望在需要发送消息时使用代码创建SQS，并在使用完所有消息后将其删除。我只想知道在使用Java代码创建SQS和向其发送消息之间是否需要一些延迟。谢谢。维伦德拉·阿加瓦尔
浏览 0提问于2019-01-25得票数 0
1回答
根据的说法
Synchronous queue subscribers must build in logic to process the message.
这是否意味着如果队列中有10条消息，只有一个订阅者得到第一条消息，并且在回复一些消息之后，第二条消息将去往另一个订阅者？
如果不是，有没有适合我上面提到的情况的消息传递软件或系统？
浏览 20提问于2018-09-05得票数 2
回答已采纳
目前，我对lambda函数有许多调用，这些调用是在SQS队列中出现消息时调用的。这些lambda函数将数据插入到数据库中。在处理完所有消息之后，我需要一种触发lambda函数的方法。我的想法是在数据库中发生所有n个insert操作之后创建一个Cloudwatch事件，但是我找不到显示这是可能的文档。这是解决这个问题的好办法吗？在数据库表上出现N个插入后，是否有可能创建Cloudwatch事件？
浏览 3提问于2022-04-03得票数 -1
我目前正在使用Apache Camel和ActiveMQ实现一个Java消息传递系统。我的目标是根据消息具有的几个属性动态设置消息的优先级。
我已经按照解释的配置了我的ActiveMQ。然后，我创建了以下方法，用于发送TextMessage
public void send(BaseMessage baseMessage, int jmsPriority) throws JsonProcessingException {
Map<String, Object> messageHeaders = new HashMap<>();
messageHeader
浏览 3提问于2021-02-16得票数 0
是否将 (YFilter)实现为python库，或者是否有类似的库来支持大量XML消息代理的过滤和转换。以便在Python语言中实现功能。
浏览 2提问于2016-04-01得票数 1
1回答
我在我的项目中使用Oracle融合中间件12C的BPEL。即使BPEL成功地读取了消息，也需要将消息保留在队列中。
也就是说，一旦完成BPEL事务成功，消息就会从队列中删除。我们总是可以在队列中重新插入消息，但是消息的顺序会发生变化。
在weblogic中是否有任何可以帮助我实现这一点的配置？
浏览 1提问于2016-05-15得票数 1
回答已采纳
1回答
我使用python发布和订阅消息队列。
publisher
rc = redis.Redis(host='127.0.0.1', port=6379)
rc.ping()
ps = rc.pubsub()
ps.subscribe('bdwaf')
r_str = "--8198b507-A--"
for i in range(0, 20000):
rc.publish('bdwaf', r_str)
用户
rc = redis.Redis(host='localhost', port=6379)
rc.p
浏览 3提问于2017-06-28得票数 1
1回答
在我的应用程序中，我们正在考虑创建多个私有队列来处理不同的任务，所以如果我有1000个私有队列来处理不同的消息，请任何人告诉我，如果我创建多个私有队列，是否会对msmsq处理产生影响
浏览 0提问于2013-02-21得票数 0
我目前正在使用AWS中的SQS。每60秒，我的应用程序从队列中取出所有消息并处理它们。考虑到我只能在一个请求中检索多达10条消息，所以我希望查询队列中的ApproximateNumberOfMessages。队列中消息的大致数量决定了我需要调用SQS多少次才能检索队列中的所有消息。
当我查询SQS的队列属性时，我得到：
{
'$metadata': {
httpStatusCode: 200,
requestId: '...',
extendedRequestId: undefined,
cfId: undefined,
浏览 8提问于2022-01-11得票数 1
回答已采纳
1回答
我认为这更像是一个“建筑设计”问题。
我有一个lambda生成器，它将将600条消息作为一个批处理(所以不是一个消息体为600条消息)，将其放入一个SQS队列(有多个生产者)。一种将接收单个消息并处理它们(在规模上)的消费者lambda。我想要做的是在每一批完成后运行另一个lambda。
最初的想法是创建一个“唯一批号”、一个“总批号”和一个“批次位置号”，并将其添加到每条消息的消息属性中。然后在消费者λ中检查这些，以确定批次是否完成。
但这是否意味着我需要在批号上使用FIFO队列和分区，并且每批只有一个lambda消费者。还是在DynamoDB中运行某种状态管理(这是一种模式吗？)请给我指点
浏览 5提问于2020-11-06得票数 1
回答已采纳
我编写了以下代码，以便将一些消息写入SQS队列并立即删除它们。但是，我在输出中看到，每条消息都会被即时删除。然而，我看到消息计数非常随机地出现。我的意思是，它最初显示1，然后再次显示2，尽管又删除了一个。我已经将可见性超时设置为50秒，就像在这个中提到的那样。作为程序的一部分，我尝试了相同的方法。
所以我的疑问是删除消息是否会立即发生。如果是这样，这将如何影响线程计数。请看下面的代码和输出。
__author__ = 'Dhanapathi.Marepalli'
import boto.sqs
conn = boto.sqs.connect_to_region("u
浏览 0提问于2015-11-02得票数 0
2回答
我有三个节点，每个节点都在一个控制台中。一个是服务器，另外两个是客户端。当客户端向服务器发送消息时，服务器必须向客户端发送另一条消息，但该消息仅出现在发送该消息的客户端的控制台中。
为什么消息没有出现在另一个节点上？谢谢。
浏览 0提问于2013-12-28得票数 0
1回答
当使用Websphere MQ (WMQ)时，这个问题主要集中在Websphere Application Server ( what )上，因为这是我最熟悉的。但是，我认为我所讨论的所有内容都适用于所有Java应用程序服务器，因为我坚持使用Java标准接口。我更希望得到与标准相关的解释，但对于WAS/WMQ的具体答案，我还是会非常兴奋。
JMS1.1定义了JMS与应用服务器接口的机制。粗略的过程是在某个时刻创建一个ConnectionConsumer来监视队列或主题。当消息出现时，JMS实现从ServerSessionPool获取一个ServerSessionPool对象，将消息加载到与Se
浏览 2提问于2012-08-31得票数 4
我们有一个使用MsmqBinding和WCF的WCF日志服务。问题是，我试图在远程计算机上使用它，而该消息似乎从未到达目标队列。以下是事实：
服务器配置
列表项目
目标机器名称: logserver.domain.ext
目标队列:私有$/logservice.svc(启用日志)
队列上的安全性:所有人:完全控制，网络服务:完全控制
IgnoreOSNameValidation注册表项: set
客户端配置
客户端点地址:logserver.domain.ext/私有/logservice.svc
观察行为
很好地创建了
浏览 3提问于2011-09-05得票数 1
回答已采纳
是否可以从RabbitMq管理控制台更改特定队列的节点名称？我试过了，但我认为这是我启动应用程序时创建的。我可以过后再换吗？我的队列在节点RabbitMQ1上，而我的连接在节点RabbitMQ2上，所以我不能从该队列读取消息。也许我可以改变我的连接节点？
浏览 19提问于2018-01-09得票数 0
回答已采纳
2回答
异步消息发送器
、、
我正在寻找一个可以从进程发送消息的库。它需要是异步的、可靠的和有序的。我不关心它是否会在队列已满时丢弃消息，但它已经能够报告这一点。它不能被阻塞。
应该可以将它插入到已经使用pthread的标准应用程序中。(将线程安全添加到需求)
我已经研究了一些可能的解决方案，可以解决这个问题。打开erlang端口并运行erlang vm来收集消息似乎很有希望，但我不确定端口本身是否可以开始发送数据？如果我能创建一个具有自己的发送者的嵌入式节点，那就太完美了。
当然，我可以用一个已知的键或者通过一个fifo来实现在shm中保持一个队列，但是这很容易出错……我宁愿重用一些现有的解决方案。
有人能想到做这件事的
浏览 1提问于2009-07-16得票数 0
回答已采纳
2回答
我使用boto3，AWS库连接到它们的SQS服务。我试图连接、读取和写入队列中的消息，但这似乎不起作用，而且文档也没有帮助
这是我的代码，有人能发现我做错了什么吗？
#Connect to a session
session = Session(aws_access_key_id=SQSAccessKey, aws_secret_access_key=SQSSecretKey,region_name=sqsRegion)
#Connect to a resource
sqs= session.resource('sqs')
queue = sqs.get_queue_by_
浏览 10提问于2016-02-19得票数 3
回答已采纳
1回答
我有一个Azure服务总线队列，其中包含用于数据库摄取作业的Rest请求。
为此，我需要创建任务工作人员来异步完成每个任务，如下图所示。
我想并行处理这些信息。芹菜对这个有用吗？有什么建议，我可以选择完成这一点吗？
提前谢谢。
浏览 4提问于2021-12-29得票数 0
可见性超时过期后，消息将传递给FIFO队列中的同一个使用者还是不同的使用者？
为了确保消息排序，必须在队列的顶部添加消息，以防可见性超时过期。这个假设正确吗？如果不是，在可见性超时过期时如何保持消息顺序？请给我看任何正式文件。我在官方文档里做了很多尝试来获取上面的信息，但是没有运气。
浏览 12提问于2022-05-03得票数 -3
2回答
我需要写一个排队系统，我想知道在MSMQ的Microsoft服务器周围有什么替代方案来排队消息？
我对MS-DTC和BizTalk略知一二，但这些选项的优缺点是什么，我是否遗漏了什么？
我需要按顺序传递消息，并且有可能需要水平扩展的能力。
我每小时要处理大约100,000条消息，每条消息不到256kb。
谢谢
浏览 1提问于2011-06-07得票数 2
回答已采纳
3回答
Java:跨多个服务器同步线程
、、、、
我有一个问题，我需要为Windows上的Java服务跨多个不同的服务器同步多个线程的处理。
在这个应用程序中，我有多个使用者线程从同一个JMS队列中提取消息。消息以3个或4个为一组进入，我需要确保每个组中的消息都是完全串行处理的。我需要某种同步机制来确保如果thread1拉出一条消息，然后thread2从该组中拉出下一条消息，thread2等待thread1完成处理，然后开始处理它的消息。
对线程的分布式同步机制有什么建议吗？任何类型的解决方案都是好的(JMS解决方案、分布式缓存等)
注意:我们使用的JMS提供者是ActiveMQ。
浏览 8提问于2009-04-03得票数 5
回答已采纳
当您在MQ队列上执行“正常”MQGET时，我的理解是过期的消息(过期时间已经过去的消息)将不会被检索。相反，它们将被丢弃并尝试队列中的下一条消息。
我的问题与相关的MQGET操作有关。由于它们专门寻找具有给定相关ID的消息，它们是否绕过会导致过期消息被丢弃的正常机制？
换句话说，既然他们在寻找一条特定的信息，他们会直接去寻找这个信息吗？
显然，如果该消息已过期，它将被丢弃，我的问题与队列中的消息有关。
浏览 0提问于2014-11-11得票数 1
回答已采纳
2回答
我在班上学习过消息队列系统，但我仍然不明白这些消息队列系统在实时场景中是如何工作的？有没有能帮助我全面了解的教程？有人能给我解释一下这些系统是怎么工作的吗？
浏览 0提问于2013-04-15得票数 8
回答已采纳
1回答
我们正在升级我们的基础架构，为此，我们将从Oracle 10g迁移到11g。
我们正在使用Oracle GoldenGate进行数据复制，据我们所知，它不支持复制AQ消息。
对于持久队列，我们提供了导入/导出选项。但是也有一些缓冲队列需要复制。
任何人都可以指导我们如何在这种情况下避免数据丢失。
感谢任何人的帮助。
浏览 0提问于2014-04-09得票数 5
7回答
我想设计一个简单的应用程序(没有j2ee和jms)，可以处理大量的消息(比如在交易系统中)
我已经创建了一个服务，它可以接收消息并将它们放在队列中，这样系统在超载时就不会卡住。
然后，我创建了一个包装队列的服务(QueueService)，并具有一个从队列中弹出消息的pop方法，如果没有消息返回null，则此方法被标记为"synchronized“以供下一步使用。
我创建了一个知道如何处理消息的类(MessageHandler)和另一个可以“侦听”新线程中的消息的类(MessageListener)。该线程有一个"while(true)“，并且一直试图弹出一条消息。
如果返回一
浏览 3提问于2009-11-23得票数 1
回答已采纳
我目前正在使用@Transactional注解将数据保存到数据库中，我想知道如何更改事务以使其影响其他资源，如消息队列。我没有设置beans或其他任何东西来处理数据库事务-我只添加了@Transactional注释，没有添加其他内容。
浏览 16提问于2018-08-02得票数 0
1回答
客户端同步中的竞争条件
、、、
我有一个web应用程序，其服务器为每个websocket连接创建一个客户端。客户端充当websocket连接和集线器的单个实例之间的中介。集线器维护一组注册客户端，并向客户端广播消息。这很好，但问题是，当服务器生成客户端在连接上接收到的初始状态包和客户机在集线器注册并开始接收广播事件之间，客户端可能会错过事件。
我的想法是在从db获取任何信息之前将客户机注册到集线器。这将确保客户机不会错过任何广播，尽管现在它可以接收已经应用于接收到的初始状态的消息。为了允许客户机忽略这些消息，我可以在初始状态包和广播事件中都包含一个单调的时间戳。
你能想出一个更优雅/更简单的解决方案吗？
浏览 0提问于2018-08-08得票数 3
我希望从队列中读取第一个MQ消息(不删除它)，并将此消息保存到我的数据库中。然后，如果一切都完成了，我需要永久地将此消息从MQ队列中删除。我所知道的就是删除队列中的第一条消息。但是，如何知道我保存到数据库中的同一条消息是否与我将从MQ中删除的消息相同？
谢谢你，迈克尔
编辑：现在试图在C#(控制台应用程序)中使用TransactionScope来处理操作：
using (TransactionScope scope = new TransactionScope){
//MQ Connection ( read message of queue)
Hashtable proper
浏览 2提问于2014-12-18得票数 0
回答已采纳
在AWS标准队列中，您可以设置一个重新驱动策略，如果消息未从队列中删除，则将导致消息重试。
在我的例子中，队列上有> 1,000,000条消息，需要几个小时来处理。当一个消息失败并被放回队列中时，它会被放在队列的末尾还是前面。当所有其他消息都已处理完毕时，这些消息是否会立即或两小时或三小时内重新尝试？
浏览 0提问于2019-09-04得票数 0
回答已采纳
在接收单个队列使用者和多个生产者时，是否可能出现消息顺序问题？producer1在2021-06-27 02:57:44.513上发布消息m1，在同一队列worker_consumer_queue上在2021-06-27 02:57:44.514上发布消息m2。连接到配置为单个使用者的队列的客户端代码应该首先按照m1的顺序接收消息，然后按照m2的顺序接收消息，对吗？有时接收消息的顺序不对。版本为ActiveMQ Artemis 2.17.0。尽管我提到了多个生产者，但使用属性blockOnDurableSend=false从同一个线程逐个发布消息。
我创建并关闭每个消息发布的生产者。在同一个J
浏览 3提问于2021-06-27得票数 0
回答已采纳
1回答
我使用.net C# (IBM版本9.1.5)从队列中提取消息。因此，我没有连接到队列和获取消息的问题。我读到过事务的概念。
我尝试了以下几点：
var getMessageOptions = new MQGetMessageOptions();
getMessageOptions = new MQGetMessageOptions();
getMessageOptions.Options += MQC.MQGMO_WAIT + MQC.MQGMO_SYNCPOINT;
getMessageOptions.WaitInterval = 20000; // 20 seconds wait
T
浏览 4提问于2020-05-19得票数 0
回答已采纳
我有一个实时聊天的应用程序。聊天是在客户端和服务器端(nodejs)使用Faye实现的。
现在，这个客户端聊天被用于rails应用程序，当我的页面重新加载/刷新时，我不想丢失在以下场景中可能发生的消息：
我重新加载页面
我从DB那里得到聊天记录
用户在聊天的另一边写5行
我呈现这一页
我丢失了5份最近的记录
我想听听你对解决这个问题的意见。我想到了一个类似于消息队列的消息队列，其中没有传递给客户端的消息将在那里等待，然后在页面通过javascript打开时被获取。
如果有人确认消息队列非常适合使用zeromq或在redis中实现简单队列，我还需要您的意见，因为我已经
浏览 2提问于2012-10-02得票数 1
回答已采纳
我创建了一个亚马逊SNS主题。我有一个Amazon队列订阅了这个主题。
我已经创建了一个默认的SQS队列(不是FIFO队列)。
我使用sqs-consumer API来长时间轮询SQS队列。
const app = Consumer.create({
queueUrl: 'https://sqs.us-east-2.amazonaws.com/xxxxxxxxxxxx/xxxxxxxxxxx',
handleMessage: async (message) => {
console.log(message);
},
sqs
浏览 0提问于2019-08-12得票数 3
回答已采纳
1回答
跟踪消息队列中的因果关系
、、、、
我正在开发一个系统，在这个系统中，我必须处理多条消息，但要保持这些消息的部分顺序。我的RabbitMQ队列有两种类型的消息: item create和item update。
假设我们有6条消息的队列：
CREATE1 CREATE2 UPDATE1 UPDATE2 UPDATE1 UPDATE1
如果我一个接一个地处理它们，那就很好了，但是速度很慢，因为我有很多信息
如果我将它们读入某个缓冲区，那么我可以并行地处理它们，但是我可以为尚未创建的第一项处理UPDATE1。更糟糕的是，上一次更新可能会在上一次更新之前处理，从而删除最新的项状态。
我可以在消息中创建一些额外的字段，或
浏览 1提问于2018-05-17得票数 1
全,
我正在寻找关于以下场景的建议：
我有一个组件运行在公司网络的一部分，它将消息发送到应用程序逻辑组件进行处理。这些组件可能驻留在同一服务器上，也可能驻留在同一网络(LAN或WAN)中的不同服务器上，或者驻留在云中的外部。应用程序服务器应该具有可伸缩性和弹性。
这些消息是相关的，因为它们到达的顺序很重要。它们带有客户端时间戳的时间戳。
我的想法是让客户端使用.NET basicHttpBinding (有些是基于WCF CF，它只有basic)来向应用服务器发送消息(这是因为我们可以保证端口80/443将为传出连接打开)。服务器接受它们，并将它们写入队列。如果需要，可以在多台机器上扩展此队列
浏览 0提问于2010-12-20得票数 0
回答已采纳
我正在尝试实现一个程序，其中一个父进程打开多个相互并行运行的子进程(通常在40个左右)。
现在，我希望能够使子进程与父进程对话，以提取只有父进程才有的一些信息。我的计划是使用，但我遇到了一些问题。这是我的基本设计：
1)父进程启动2)父进程打开多个子进程3)每个子进程向父进程发送多条消息。例如，特定的子节点可以向父节点发送20到100条消息。4)父母接收每条消息并向孩子发送一条“返回”消息，对于父母接收到的每条消息5)孩子接收来自父母的回复并执行一些动作
不幸的是，我还没能让它工作。我尝试过许多不同的方法，比如为每个孩子设置一个单独的队列，这会给我一个“警告: msg_get_queue()函
浏览 3提问于2010-07-22得票数 1
我计划为我们的系统实现一个message，并且大部分已经决定使用RabbitMQ。但是，我需要知道，使用RabbitMQ是可能的。
为对象O生成2条消息
1) A(创建O对象)，
B (更新同一个O对象).
在客户端(多个消费者)注册到队列以获取对象O的消息的，我希望B只在A被添加之后才被传递。
目标--为对象O处理创建，然后为该对象处理更新。
浏览 1提问于2015-11-18得票数 0
下面是一个场景：
2台机器：“机器A”和“机器B”。
让我们假设他们相应的IP地址是192.168.0.100 ( A)和192.168.0.200 ( B)。这两台机器都安装了MSMQ，安装在Windows 2008上。
A型机
配置了以下队列：transactional.，private$\aaa
该队列只有一个使用者，该队列包装了MSMQ事务中的每个Read操作，并且只从“当前”消息中读取(即不使用游标操作)。
B型机
有一个向FormatName:direct=os:192.168.0.100\private$\aaa发送消息的应用程序。每个Send消息都包装在MSMQ事务中，(C#中
浏览 4提问于2011-03-23得票数 1
回答已采纳
当我们使用System.Messaging远程发送消息时，它可以正常工作，即我可以在remore机器中看到队列中的消息。
但是，当我们尝试执行相同的任务时，即使用NServiceBus远程发送消息时，该消息没有出现在远程队列中，似乎该消息消失了
请注意，我们在客户端app.config文件中有以下配置：
<UnicastBusConfig>
<MessageEndpointMappings>
<add Messages="CCSMessage.ITaskCompleted, CCSMessage" Endpoint="transact
浏览 0提问于2010-09-22得票数 0
回答已采纳
我们有一个代表多个客户端的分布式应用程序。现在，当工作到达时，消息被放在单个队列中。消息是以FIFO顺序提取的，这在大多数情况下都工作得很好。
在某些情况下，我们将为单个客户端获取数千条消息，然后这些消息将占用队列中的前几个thousand+插槽。这意味着在处理这些消息之前，不能(或很少)为任何其他客户端执行任何工作-这会使较小的客户端处于饥饿状态。
我的想法是，在我们引用客户端列表之前，以及每次从队列中获取消息之前，我们都会查看消息，看看是哪个客户端提交了该消息。如果它是针对我们刚刚处理的同一客户端，我们将其推回，直到我们找到针对不同客户端的消息，或者迭代所有客户端，但找不到其他工作。
这是
浏览 0提问于2016-01-19得票数 1
请帮我开始
我一直在冲浪我的屁股洞周末，对不起我的法语，没有找到我想要的东西。
--这是我试图移动到消息队列的过程
每天晚上， pdf文件都会登陆到我们的ftp服务器上，大约45,000。为每个文件创建了一个记录在ms sql server中的一个队列表服务正在读取队列并处理磁盘上的文件。
--这就是我想要的pub/sub‘s和错误处理
，文件观察者写入事务中的队列，而不是数据库。我想这个更快。然后，我想订阅pdf队列，这样当一个新文件到达时，我就不必轮询数据库了。
一些问题的
如何使用transactions?How发布到队列中，如果处理message.What是打开/关闭队列连接的最佳方法
浏览 1提问于2012-02-26得票数 3
我是MassTransit的新手，所以如果这是个愚蠢的问题，请原谅我。
我只想知道一个人是如何处理不成功的赔偿的？所以所有的重试都失败了，即没有成功的补偿--我可以想象消息应该转到一个死信队列中，让我在以后的某个日期手动重试一次，可以再试一次吗？
任何帮助都将不胜感激。
浏览 1提问于2018-03-10得票数 0
回答已采纳
我现在有一个带有消息队列和on_message回调函数的paho-MQTT客户端脚本。
def on_message(self, client, _, message):
message = message.payload.decode()
self.messageQueue.put_nowait(message)
我需要对这些接收到的消息进行一些处理(我每3秒在队列中收到大约12条消息)
如何安全地处理这些消息？
浏览 4提问于2020-03-02得票数 0
我有一个消息队列，它没有Actor概念或任何东西，所以在应用程序启动时，我想启动messages使用者，然后继续从队列中获取消息。现在，Play框架为每个Web套接字连接创建一个Actor，我希望能够将持有特定ws端点的Web套接字连接的所有Actor分组，这样我就可以将从消息队列中收到的关于特定主题的所有消息广播到这些Actors组。
例如，以下端点将在每次客户端向以下任何一个端点发起请求时创建一个Actor。因此，让我们称它们为Foo演员和Bar Actors。
ws://localshost/foo
ws://localshost/bar
现在我要做的就是
伪码：
messages
浏览 1提问于2017-03-19得票数 1
我正在寻找关于Service最佳实践的权威文章。
特别是，我正在寻找以下主题(我知道答案，但必须找到支持知识的文档)：
同一数据库中的队列
消息
大小
系统，其中消息只是一个指针，数据从表中检索。
工具-审核Service应用程序
提亚
浏览 3提问于2013-04-05得票数 2
2回答
我正在尝试设计一个健壮的架构，但是我在解决消息传递问题上遇到了麻烦。让我试着解释一下 API将被聚集在ECS上，接收一堆请求。 工人也会被群集化，订阅相同的频道。(这就是问题所在，如果我们只与一个工人一起工作，就不会有任何问题) 如何处理多个workers，避免重复消息？什么是一个好的简单的方法，让许多工人保持忙碌？ 谢谢。 ?
浏览 20提问于2021-01-19得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
