我想学习更多关于编程消息传递应用程序和使用消息队列的知识。像qpid，亚马逊队列等的事情。你能告诉我一些应用程序(最好是C++，如果可能的话，开源)，这样我可以了解更多。
另外，您能告诉我决定是否不使用消息队列的一般指导原则吗？我对leanring很感兴趣，只是因为“酷”的因素，但我认为这对我未来可能是有益的。
浏览 0提问于2011-02-12得票数 2
回答已采纳
1回答
根据的说法
Synchronous queue subscribers must build in logic to process the message.
这是否意味着如果队列中有10条消息，只有一个订阅者得到第一条消息，并且在回复一些消息之后，第二条消息将去往另一个订阅者？
如果不是，有没有适合我上面提到的情况的消息传递软件或系统？
浏览 20提问于2018-09-05得票数 2
回答已采纳
是否将 (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
我目前正在使用AWS中的SQS。每60秒，我的应用程序从队列中取出所有消息并处理它们。考虑到我只能在一个请求中检索多达10条消息，所以我希望查询队列中的ApproximateNumberOfMessages。队列中消息的大致数量决定了我需要调用SQS多少次才能检索队列中的所有消息。
当我查询SQS的队列属性时，我得到：
{
'$metadata': {
httpStatusCode: 200,
requestId: '...',
extendedRequestId: undefined,
cfId: undefined,
浏览 8提问于2022-01-11得票数 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
嗨，我有这段代码
SendMessageToMyQueue();
UpdateStatusInDbThatMessageWasSent();
有时，在更新状态之前处理消息，这是我想要避免的。
我的问题是，如果我用这样的事务来包装这两行：
using(var tr = new TransactionScope())
{
SendMessageToMyQueue();
UpdateStatusInDbThatMessageWasSent();
tr.Compleate();
}
将保证在MyQueue上创建一个锁，并且在UpdateStatusInDbThatMessageWasSent更新
浏览 6提问于2017-12-08得票数 1
回答已采纳
1回答
我有一个用java编写的应用程序，它使用mysql作为DB。我需要创建一个优惠券分发系统，其中我有100个优惠券存储在DB和第一100个客户谁登录应该得到这些优惠券。对于单个服务器，我认为这是非常直接的，但是如果我的应用服务器有多个与登录服务相平衡的负载实例，我该如何实现呢？更具体地说，我的问题是，在给定的时间，1000 s的用户可能试图登录，那么我如何保持FIFO的顺序呢？
浏览 0提问于2023-01-25得票数 0
我想要创建一个使用者，它处理来自多个变量数目的消息，这些消息是动态连接或断开连接的。
我需要的是每个消费者首先优先处理每个源的N条消息。然后运行多个消费者来提高速度。
我一直在阅读、和以及许多其他文档的文档，而没有确定如何实现这一点。而且我也做了一些没有运气的测试。
有人能指点我怎么做或者在哪里读到吗？
-编辑--
QueueA-A3-A2-A1-┐
QueueB
QueueC-┘
所期望的效果是每个使用者获得每个队列的第一条消息。例如: A1、B1、C1、A2、B2、C2、A3、B3、C3等等。如果创建了一个新队列(QueueD)，消费者将以同样的方式开始接收来自它的消息。
提前感谢
浏览 1提问于2018-05-02得票数 4
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
回答已采纳
2回答
我需要写一个排队系统，我想知道在MSMQ的Microsoft服务器周围有什么替代方案来排队消息？
我对MS-DTC和BizTalk略知一二，但这些选项的优缺点是什么，我是否遗漏了什么？
我需要按顺序传递消息，并且有可能需要水平扩展的能力。
我每小时要处理大约100,000条消息，每条消息不到256kb。
谢谢
浏览 1提问于2011-06-07得票数 2
回答已采纳
可见性超时过期后，消息将传递给FIFO队列中的同一个使用者还是不同的使用者？
为了确保消息排序，必须在队列的顶部添加消息，以防可见性超时过期。这个假设正确吗？如果不是，在可见性超时过期时如何保持消息顺序？请给我看任何正式文件。我在官方文档里做了很多尝试来获取上面的信息，但是没有运气。
浏览 12提问于2022-05-03得票数 -3
我能创造没有错误的优惠券。当我在字段中输入优惠券代码并单击submit按钮时，将得到以下错误。
An AJAX HTTP error occurred.
HTTP Result Code: 500
Debugging information follows.
Path: /system/ajax
StatusText: Service unavailable (with message)
ResponseText:
Drupal版本7.28
商业优惠券百分比7.x-1.0-beta7 7
dblog消息
// first error
Rules Warning:
Unable to get
浏览 0提问于2014-06-19得票数 1
回答已采纳
3回答
Java:跨多个服务器同步线程
、、、、
我有一个问题，我需要为Windows上的Java服务跨多个不同的服务器同步多个线程的处理。
在这个应用程序中，我有多个使用者线程从同一个JMS队列中提取消息。消息以3个或4个为一组进入，我需要确保每个组中的消息都是完全串行处理的。我需要某种同步机制来确保如果thread1拉出一条消息，然后thread2从该组中拉出下一条消息，thread2等待thread1完成处理，然后开始处理它的消息。
对线程的分布式同步机制有什么建议吗？任何类型的解决方案都是好的(JMS解决方案、分布式缓存等)
注意:我们使用的JMS提供者是ActiveMQ。
浏览 8提问于2009-04-03得票数 5
回答已采纳
1回答
我最近在一次面试中遇到了这个问题。假设您有3种优惠券：
免费托运(将分发给10%用户)一举得到(将分发给10%用户)平板10% (将分发到80%)
任务是找到一种分发优惠券的方法，这样在每次结帐时，用户都会得到一张优惠券，而这张优惠券应该是上述三张中的一张。您的系统中有多个用户，这种分发模式应该在系统中维护。
我没能解决这个问题。我认为我们需要为每个令牌指定一个优先级，并随机选择它们。
浏览 8提问于2022-11-15得票数 0
回答已采纳
当您在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
我目前正在使用@Transactional注解将数据保存到数据库中，我想知道如何更改事务以使其影响其他资源，如消息队列。我没有设置beans或其他任何东西来处理数据库事务-我只添加了@Transactional注释，没有添加其他内容。
浏览 16提问于2018-08-02得票数 0
我希望在需要发送消息时使用代码创建SQS，并在使用完所有消息后将其删除。我只想知道在使用Java代码创建SQS和向其发送消息之间是否需要一些延迟。谢谢。维伦德拉·阿加瓦尔
浏览 0提问于2019-01-25得票数 0
在AWS标准队列中，您可以设置一个重新驱动策略，如果消息未从队列中删除，则将导致消息重试。
在我的例子中，队列上有> 1,000,000条消息，需要几个小时来处理。当一个消息失败并被放回队列中时，它会被放在队列的末尾还是前面。当所有其他消息都已处理完毕时，这些消息是否会立即或两小时或三小时内重新尝试？
浏览 0提问于2019-09-04得票数 0
回答已采纳
我目前正在使用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
1回答
我认为这更像是一个“建筑设计”问题。
我有一个lambda生成器，它将将600条消息作为一个批处理(所以不是一个消息体为600条消息)，将其放入一个SQS队列(有多个生产者)。一种将接收单个消息并处理它们(在规模上)的消费者lambda。我想要做的是在每一批完成后运行另一个lambda。
最初的想法是创建一个“唯一批号”、一个“总批号”和一个“批次位置号”，并将其添加到每条消息的消息属性中。然后在消费者λ中检查这些，以确定批次是否完成。
但这是否意味着我需要在批号上使用FIFO队列和分区，并且每批只有一个lambda消费者。还是在DynamoDB中运行某种状态管理(这是一种模式吗？)请给我指点
浏览 5提问于2020-11-06得票数 1
回答已采纳
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
回答已采纳
目前，我对lambda函数有许多调用，这些调用是在SQS队列中出现消息时调用的。这些lambda函数将数据插入到数据库中。在处理完所有消息之后，我需要一种触发lambda函数的方法。我的想法是在数据库中发生所有n个insert操作之后创建一个Cloudwatch事件，但是我找不到显示这是可能的文档。这是解决这个问题的好办法吗？在数据库表上出现N个插入后，是否有可能创建Cloudwatch事件？
浏览 3提问于2022-04-03得票数 -1
我正在尝试实现一个程序，其中一个父进程打开多个相互并行运行的子进程(通常在40个左右)。
现在，我希望能够使子进程与父进程对话，以提取只有父进程才有的一些信息。我的计划是使用，但我遇到了一些问题。这是我的基本设计：
1)父进程启动2)父进程打开多个子进程3)每个子进程向父进程发送多条消息。例如，特定的子节点可以向父节点发送20到100条消息。4)父母接收每条消息并向孩子发送一条“返回”消息，对于父母接收到的每条消息5)孩子接收来自父母的回复并执行一些动作
不幸的是，我还没能让它工作。我尝试过许多不同的方法，比如为每个孩子设置一个单独的队列，这会给我一个“警告: msg_get_queue()函
浏览 3提问于2010-07-22得票数 1
下面是一个场景：
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
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
我是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
我们有一个使用MsmqBinding和WCF的WCF日志服务。问题是，我试图在远程计算机上使用它，而该消息似乎从未到达目标队列。以下是事实：
服务器配置
列表项目
目标机器名称: logserver.domain.ext
目标队列:私有$/logservice.svc(启用日志)
队列上的安全性:所有人:完全控制，网络服务:完全控制
IgnoreOSNameValidation注册表项: set
客户端配置
客户端点地址:logserver.domain.ext/私有/logservice.svc
观察行为
很好地创建了
浏览 3提问于2011-09-05得票数 1
回答已采纳
我正在寻找关于Service最佳实践的权威文章。
特别是，我正在寻找以下主题(我知道答案，但必须找到支持知识的文档)：
同一数据库中的队列
消息
大小
系统，其中消息只是一个指针，数据从表中检索。
工具-审核Service应用程序
提亚
浏览 3提问于2013-04-05得票数 2
2回答
我正在尝试设计一个健壮的架构，但是我在解决消息传递问题上遇到了麻烦。让我试着解释一下 API将被聚集在ECS上，接收一堆请求。 工人也会被群集化，订阅相同的频道。(这就是问题所在，如果我们只与一个工人一起工作，就不会有任何问题) 如何处理多个workers，避免重复消息？什么是一个好的简单的方法，让许多工人保持忙碌？ 谢谢。 ?
浏览 20提问于2021-01-19得票数 1
我刚开始使用RabbitMQ和Pika，所以如果答案是显而易见的，请原谅…
我们正在提供一些数据，并将结果传递到rabbitmq消息队列中。队列正在被一个将数据写入elasticsearch的进程消耗。
产生数据的速度比输入弹性搜索的速度快，因此队列会增长，几乎不会缩小。
我们正在使用pika，并收到警告：
UserWarning: Pika: Write buffer exceeded warning threshold at X bytes and an estimated X frames behind.
这会持续一段时间，直到Pika崩溃，并显示一条奇怪的错误消息：
NameError
浏览 1提问于2012-08-08得票数 2
回答已采纳
我运行一个优惠券网站，当我们启动我们的交易时，每秒钟能看到50-70个请求(我们每天多次发起20+交易)。当交易顺利进行时，我们的用户按下一个按钮来获取特定产品的优惠券，它通过ajax请求提供唯一的优惠券代码。每张优惠券只能兑换一次。
我的问题是，在这段时间流量这么大的情况下，同样的优惠券可以分发给多个用户。这是不好的，因为只有其中一个将能够实际赎回优惠券，留下一个糟糕的用户体验另一个。
我将所有优惠券信息存储在托管的node.js服务器上的内存中的对象中。我想这能让我快速处理这些请求。
我如何存储优惠券信息：
global.coupons = {};
//the number of cou
浏览 3提问于2015-04-17得票数 10
回答已采纳
2回答
异步消息发送器
、、
我正在寻找一个可以从进程发送消息的库。它需要是异步的、可靠的和有序的。我不关心它是否会在队列已满时丢弃消息，但它已经能够报告这一点。它不能被阻塞。
应该可以将它插入到已经使用pthread的标准应用程序中。(将线程安全添加到需求)
我已经研究了一些可能的解决方案，可以解决这个问题。打开erlang端口并运行erlang vm来收集消息似乎很有希望，但我不确定端口本身是否可以开始发送数据？如果我能创建一个具有自己的发送者的嵌入式节点，那就太完美了。
当然，我可以用一个已知的键或者通过一个fifo来实现在shm中保持一个队列，但是这很容易出错……我宁愿重用一些现有的解决方案。
有人能想到做这件事的
浏览 1提问于2009-07-16得票数 0
回答已采纳
1回答
在分布式系统环境下，我有一个关于数据共享的问题。通常我用的是情景A .我正在将消息从system推送到远程队列，如Amazon /SQS，并且我期望系统B在系统B启动和运行时接收消息。
我已经考虑过了，我带着一个我不确定是否足够好的替代方案。基本上，系统A现在将消息推送到本地队列，本地队列将消息推送给系统A。这方面的先决条件是系统A和B都已启动和运行，并且该队列仅针对系统A，即。没有系统C，D，E.它将消息推送到C、D、E上的相同(重复)本地队列中。
这是一个好的选择吗？
我还考虑将场景B作为场景A的备份计划，因为远程队列不可用，而且我不想丢失消息。在这种情况下，系统B将是一个远程队列。
浏览 1提问于2019-02-25得票数 0
回答已采纳
2回答
我试图了解分布式系统中队列的用例是什么。
以及它是如何扩展的，它如何确保它在系统中不是一个单一的故障点？
如有任何直接答复或对文件的引用，将不胜感激。
用例：
我知道队列是一个消息传递系统。它将相互沟通的系统解耦。但是，这是使用队列的唯一目的吗？
可伸缩性：
对于大量的数据，队列是如何扩展的？既读又写。
可靠性:如何使队列不成为系统中的单一故障点？队列是否进行复制，类似于数据存储？
我的问题没有指定给任何特定的队列服务器，比如Kafka或JMS。一般情况下。
浏览 2提问于2017-08-02得票数 5
1回答
在我的应用程序中，我们正在考虑创建多个私有队列来处理不同的任务，所以如果我有1000个私有队列来处理不同的消息，请任何人告诉我，如果我创建多个私有队列，是否会对msmsq处理产生影响
浏览 0提问于2013-02-21得票数 0
1回答
我配置了一个简单的SQS，我希望一次处理4消息。在我的测试中，它有2“可用”消息。当我收到消息时，它一次只产生1。我做错了什么？
sqs = boto3.client('sqs')
response = sqs.receive_message(
QueueUrl=queue_url,
MaxNumberOfMessages=4
)
浏览 2提问于2021-02-18得票数 3
回答已采纳
我正在建立一个数据库，其中一些表将在“使用它或失去它”场景自动应用程序流中填充。我的意思是，数据将通过Webhook ( RDBMS )进入，如果我的PayPal拒绝插入，那么数据将丢失，即没有操作员检查/更正数据并重试。
一个简单的解决方案是通过排除NOT NULL，甚至可能使字段基于文本来使DB字段尽可能简单。
一致性问题仍然存在。我如何确保这一点？我是否应该包括可能包含在数据库中的检查，并在出现问题时记录警告。
实际上，只有当WebHook服务发生变化时，事情才会崩溃，但我希望为这种情况做好准备。
更新：
我猜另一种方法是将所有传入的webhook消息逐字缓存到NoSQL存储中。抛开上面
浏览 0提问于2017-07-02得票数 1
2回答
我使用的是分布式jms队列，weblogic是我的应用服务器。在我的集群环境中部署了三个jms服务器。例如，生产者仅使用队列名称jndi查找'udq‘来发送消息。现在，我已经为每个jms服务器关联了一个使用者，并且我能够使用该消息，到目前为止没有问题。
这里有一个问题，我可以有一个消费者来消费来自3个jms服务器的消息吗？weblogic允许使用以下语法@对目标查找进行jndi命名
qsession1 = qcon1.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
qsession
浏览 1提问于2013-01-02得票数 1
1回答
图像处理系统.
用户将照片上传到S3。图像处理应用程序从S3获取照片并开始对其进行处理，并返回一个输出。
进程： over服务器向队列发送包含图像信息的消息，图像处理服务器获取该消息并开始对此映像进行处理。一旦图像处理完成，它就会将图像上传回S3，并将SQS消息返回到队列。图像处理引擎位于EC2服务器上。
下面是一个问题: was服务器如何从从图像处理服务器发送的队列中获取返回的SQS消息？
浏览 3提问于2012-11-27得票数 4
我希望从队列中读取第一个MQ消息(不删除它)，并将此消息保存到我的数据库中。然后，如果一切都完成了，我需要永久地将此消息从MQ队列中删除。我所知道的就是删除队列中的第一条消息。但是，如何知道我保存到数据库中的同一条消息是否与我将从MQ中删除的消息相同？
谢谢你，迈克尔
编辑：现在试图在C#(控制台应用程序)中使用TransactionScope来处理操作：
using (TransactionScope scope = new TransactionScope){
//MQ Connection ( read message of queue)
Hashtable proper
浏览 2提问于2014-12-18得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
