1回答
我正在设计一个单进程多线程嵌入式Linux应用程序.该设计包括客户机-服务器子系统，其中工作线程接收POSIX消息队列上其他线程发布的消息。
我需要队列显示非阻塞发送和阻塞接收语义。我可以想出几种实现上述功能的方法：-创建两个单独的消息队列描述，用于为了发送和接收访问队列，即两次调用mq_open。随后将设置用于通过队列发送的描述的O_NONBLOCK标志。
指定阻塞行为并使用mq_timedsend代替mq_send
指定阻塞行为并在mq_getattr之前调用mq_send以避免在发送时阻塞
第一种解决方案可能是首选的解决方案，但要使其工作，必须保证每次对mq_open的调
浏览 12提问于2020-02-27得票数 3
回答已采纳
6回答
我在一个数据处理应用程序中工作，其中的并发是通过将多个工作单元放在一个消息队列上来实现的，多个消息驱动bean (MDB)实例监听该消息队列。除了以这种方式实现并发之外，我们没有任何特定的理由来使用消息传递基础设施和MDB。
这让我思考为什么使用多个线程不能达到同样的效果。
因此，我的问题是，在什么情况下可以使用异步消息传递(例如JMS)作为多线程的替代方案来实现并发？使用一种方法比使用另一种方法有哪些优点/缺点？
浏览 0提问于2009-10-20得票数 6
回答已采纳
我想使用create_workqueue()创建一个新的工作队列
我正在读的一本关于内核开发的书的作者说：“这个函数创建所有的工作线程(系统中的每个处理器一个)，并为它们处理工作做好准备。”
我的代码显示在这个问题的末尾，创建了一个内核，并在两个队列上调度工作。一个是默认工作队列，另一个使用自定义工作队列。它们应该由不同的工作线程来处理。
但是，我在结果(如下所示)中看到，这两个进程都由同一个进程(PID 42501)处理，该进程是我的虚拟机中的线程kworker2。
运行结果：
#include <linux/workqueue.h>
#include "
浏览 7提问于2017-01-18得票数 3
2回答
我需要在C++上构建类似客户端-服务器的应用程序。目标是跟踪具有多个线程的多个进程(跟踪函数执行)，并将这些数据收集到除以线程id的文件中。
目前，我已经在POSIX消息队列(服务器侦听队列并从生产者收集数据)上实现了这一点，但它的运行速度非常慢。关于在Linux平台(C++语言)上实现的任何其他想法。对于这项任务，最好的沟通方式是什么？顺便说一句，一个线程范围内的数据顺序对我来说非常敏感。
浏览 1提问于2015-11-11得票数 0
1回答
我正在使用运行Linux的嵌入式设备进行编程，其中内存较少，只有64 is的闪存。我计划使用队列进行线程通信。
在其中，我遇到了使用POSIX队列或只使用简单队列的问题。
实际上，我需要的是我不希望队列是优先级驱动的。我想知道POSIX队列的利弊，然后我会有一个很好的图片
我想知道对我的情况使用POSIX队列或简单队列的最佳优化方式是什么？
第一个线程执行HTTP POST，第二个线程执行HTTP GET。这两个线程需要在数据写入或获取时进行通信。
我看到POSIX队列使用Linux内核，在这种情况下，它比使用自己的数据结构队列有更多的开销？
换句话说，轻量级IPC，类似于用于线程通信的单向管
浏览 0提问于2017-06-19得票数 1
1回答
我在线程中创建一个队列，它将一直运行。这个线程正在维护这个队列，并在一定时间内从队列中获取消息。我的问题是如何在另一个类或servlet中访问这个队列？？并将消息插入到此队列中。让这个队列保持静态？我需要考虑多线程吗？
浏览 3提问于2014-09-29得票数 0
回答已采纳
我有一个要求，消费者需要首先使用队列中的高优先级消息。
有人能在这样的开源队列中工作吗？
此外，如果它支持批量获取消息将是好的？
浏览 1提问于2014-07-17得票数 1
回答已采纳
2回答
我有多个源将原始数据推送到S3。我已经在我的S3桶上配置了一个SQS事件通知。问题在于滞后和局限。
我预计在不久的将来会有更多的消息来源，而且由于我们在一次投票中只能从SQS获得10条消息，我认为在不久的将来，当有更多的源将数据推送到S3时，SQS将充满数千条消息，我将无法更快地处理它们。
我正在考虑通过将消息从我的主SQS队列扩展到更多的SQS队列，从而使我的处理层能够轮询多个队列，例如:5个队列，并处理更多的消息。可能的方法应该是什么？
浏览 0提问于2019-01-29得票数 6
回答已采纳
1回答
我在Ubuntu上使用单独的线程调用pygame.event.get()很长时间了，没有任何问题。然而，MacOS抛出了一个异常'NSInternalInconsistencyException', reason: 'nextEventMatchingMask should only be called from the Main Thread!'；并且在正常执行几秒钟后，Windows报告窗口是(Not answering)的，我假设这有相同的解释，这意味着Linux与其他OSes不同的是，Linux对这种软件设计是有容忍度的。
有没有办法在单独的线程中清空事
浏览 0提问于2017-10-23得票数 5
我们正在使用TIBCO JMS 4.3.3和相同版本的.Net TIBCO.EMS.dll for .net 2.0我们在队列中卡住消息方面遇到了巨大的问题。我们正在使用一个队列中的消息，该队列从主题桥接而来。我们的应用程序创建了多个具有长期会话的消费者--每个长期会话都有一个消费者。会话和使用者是在主线程中创建的，但是使用者本身使用的是在单独线程上使用带有超时的接收()方法的消息。每个使用者都有自己的线程，它在线程中工作。在每次成功接收时，我们都会在一个会话上调用Commit，该会话创建了接收消息的消费者(很抱歉使用了难看的措辞)。
问题是，当这个队列被大量填充(由主题中的桥)时，许多消息都
浏览 3提问于2010-11-17得票数 1
回答已采纳
1回答
因此，我有一个源源不断运行的python脚本，可以发送消息。它获取消息的内容，并在几个API上运行搜索，然后用该搜索的结果进行答复。目前，我使用的是异步/等待，它目前正在工作，但是如果它已经在处理一个消息时收到了一个消息，那么它将等待使用它当前正在搜索的消息完成，然后才开始它收到的消息。
我希望将其设置为一次可以处理多个消息，因为大多数等待都在等待API响应。是我应该在这里使用的多处理功能，如果是的话，是否有一种方法可以让多处理函数处于空闲状态，直到消息被添加，然后将消息发送到多处理函数。我似乎应该使用队列，但大多数文档都说，一旦没有更多的工作要处理，队列就会关闭。需要做的一件事是，如果我有一
浏览 2提问于2017-07-14得票数 0
回答已采纳
在Linux中，msgsnd可以从用户空间发送消息。但是，如果发送的消息数量达到最大消息数，msgsnd将阻塞，是否有方法更改最大值？谢谢
浏览 0提问于2020-06-15得票数 0
在ActiveMQ Artemis 2.15.0版本中，我们可以自动创建队列。默认情况下，自动删除设置为true (未更改)。我们时不时地看到下面的日志。从日志消息看，服务器似乎试图删除自动创建的队列，但失败了，因为它有1条消息。我的问题是，当队列中有消息时，为什么broker会尝试删除队列？ 2020-10-22 02:48:23,599 ERROR [org.apache.activemq.artemis.core.server] AMQ224065: Failed to remove auto-created queue test:
ActiveMQIllegalStateExcep
浏览 18提问于2020-10-27得票数 1
回答已采纳
1回答
我们是后端处理器，使用JMS MQ进行编程。我们有两个队列。一个用于获取消息，另一个用于发送消息。所有的银行用户都会通过他们的IB、MB等将消息放到Q1。我们从Q1接收消息并对其进行处理，然后将消息发送到Q2。
目前我们不使用多线程来实现这一点。我们是否能够使用多线程或单线程就足以做到这一点。因为我们一个接一个地从Q1获取消息并对其进行处理。
如果问题不能理解，请回复给我。请谁来帮帮我。
浏览 8提问于2017-01-25得票数 5
1回答
MSMQ和WCF的新特性。我希望能够以高速率处理传入的MSMQ消息。我想让它成为多线程的(和事务性的)。做这件事的最好方法是什么？任何例子，代码片段，理论都是非常受欢迎的。另外，WCF如何知道MSMQ中是否有消息？或者，我是否必须创建一个Windows服务来轮询MSMQ，然后在新线程上启动它以查找找到的消息，并调用WCF服务并将消息传递给它？最好的方法是什么？
非常感谢
浏览 2提问于2012-04-21得票数 1
回答已采纳
我使用的是xms.net 8.0.0.8，我想在web应用程序中启动多线程xms监听器。
我使用新的线程t=new Thread ()开始处理消息代码...
但是有些地方出了问题，线程卡住了，无法读取消息?如果有人有多线程的xms示例，web应用程序可以分享或告诉我错误?或者这是xms中多线程的错误吗？
public void ProcessMessage()
{
try
{
ConnectionFactory = WsHelper.CreateConnectionFactoryWMQ();
Connec
浏览 3提问于2018-04-03得票数 0
我在linux上有一个java应用程序，它打开UDP套接字并等待消息。
在繁重的负载下几个小时后，会出现数据包丢失，即内核接收到数据包，但我的应用程序没有收到数据包(我们在sniffer中看到丢失的数据包，在netstat中看到UDP数据包丢失，在应用程序日志中看不到这些数据包)。
我们尝试扩大套接字缓冲区，但这并不管用--我们开始丢失数据包的时间比之前晚，但仅此而已。
对于调试，我想知道OS udp缓冲区在任何给定时刻有多满。我搜索过了，但什么也没找到。你能帮帮我吗?
另外，各位，我知道UDP是不可靠的。然而，我的计算机接收所有UDP消息，而我的应用程序无法使用其中的一些消息。我想最大限度地
浏览 3提问于2010-02-18得票数 56
回答已采纳
1回答
消息队列是否锁定
、、
我正在尝试在Linux中使用消息队列，是否可以执行以下操作
进程%1具有名为one的消息队列
生产者1&2向没有锁机制的生产者发送消息，可以吗？
浏览 1提问于2012-05-16得票数 0
回答已采纳
1回答
我在进程A中使用boost进程间消息队列编写了IPC机制。这基本上是用进程A接收和发送数据。使用boost消息队列的原因是考虑到windows和linux的兼容性。
但是进程B是linux唯一的版本，它使用posix消息队列实现。此场景是否存在兼容性问题？进程A打开boost消息队列并等待进程B使用posix消息队列发送数据(如果它们使用相同的队列名称)？
浏览 13提问于2020-08-07得票数 1
我有一个spring引导应用程序，它从一个云消息队列中提取消息并将其放回一个云数据库。我意识到我的程序是单线程的(我没有使用请求映射，只是拉、处理、放到db)。我想让Spring处理并发的事情。因此，我可以创建一个dispatcher函数，它用@RequestMapping调用应用程序中的控制器？
@RestController
@RequestMapping("/test")
public class GatewayController {
@RequestMapping("/service")
public void InvokeService(..
浏览 0提问于2019-08-07得票数 0
回答已采纳
在嵌入式Linux环境、System消息队列或Posix消息队列中应该使用什么？在项目中普遍使用的是什么？
浏览 5提问于2014-01-23得票数 4
回答已采纳
2回答
在iTron中，有较轻版本的消息队列称为数据队列。它们非常容易用于快速消息传输。Linux中是否存在任何等价的同步原语？
数据队列的定义:它是一个单词消息()的队列。
浏览 2提问于2009-04-10得票数 1
回答已采纳
2回答
我需要一个关于我的WCF服务队列设计的建议。所以，我有一个wcf服务和很多客户端。客户端生成消息并将其放入队列中，以便我的服务进行处理。服务异步处理它们，客户端在将消息放入队列时不需要回调或响应。
我的服务需要将消息从队列中出队，以便使用多线程进行处理。但如果我的服务将停止或失败，或服务器立即关闭-此服务必须重新处理消息，这不会继续处理。
因此，我考虑msmq队列实现。Msmq让我做了很好的队列，但是如何实现这个要求:重新处理消息，没有处理到最后？
也许有人会给我另一个好的建议。谢谢你的帮助。
浏览 1提问于2011-04-13得票数 2
回答已采纳
1回答
用线程访问数据库
、、
我正在开发一个程序(使用运行在Linux机器上的C++ )，它使用SQLite作为后端。
它有两个线程，执行以下任务：
线程1
等待一段数据到达(在本例中，通过无线电模块)
立即将其插入数据库。
返回到等待新数据
重要的是，这个线程在尽可能长的时间内“监听”，并且不会被阻止，等待插入数据库。
线程2
每隔2分钟，在数据库上运行一个SELECT以查找未处理的数据。
处理数据
更新使用标志获取的行，以显示它们已被处理。
关键是确保Thread 1始终可以插入到数据库中，即使这意味着Thread 2无法选择或更新(因为这可能
浏览 0提问于2016-09-07得票数 1
在下面的示例中，我将最大和核心池大小设置为1。但是没有处理任何消息。当我启用调试日志时，我能够看到从SQS中提取的消息，但我猜它没有被处理/删除。但是，当我将核心和最大池大小增加到2时，消息似乎会被处理。
编辑
我相信Spring可能会为接收者分配一个线程，用于从队列中读取数据，因此它无法将线程分配给正在处理消息的侦听器。当我将核心池大小增加到2时，我看到消息正在从队列中读取。当我添加另一个侦听器(对于死信队列)时，我遇到了同样的问题--2个线程不够，因为消息没有被处理。当我将核心池大小增加到3时，它开始处理消息。在本例中，我假设分配了一个线程来读取队列中的消息，每个线程分配了两个侦听器。
@
浏览 1提问于2018-04-27得票数 13
回答已采纳
5回答
我正在研究一个用于嵌入式Linux进程间通信的消息队列。我想知道为什么我不使用Linux提供的消息队列，如下所示：
msgctl，msgget msgrcv，msgsnd。
而不是创建共享内存，并与信号量同步？
在商业嵌入式产品上直接使用这组函数有什么缺点？
浏览 13提问于2012-03-05得票数 14
回答已采纳
我知道核心数据使NSManagedObjectId成为它的主键。
现在，在这样的场景中，msgId对于消息记录来说是独一无二的。
Thread A试图将带有msgId 1001的消息插入上下文中。在插入之前，thread A尝试使用msgId键和值1001查找消息。没有找到任何内容，因此它执行insert操作。
同时，Thread B对msgId 1001的消息也做了同样的事情。
所以，时间
Thread A：查找->插入->保存
Thread B：查找->插入->保存
线程A和线程B都有自己的上下文，它们会查找、插入和保存，因此使用msgId 1001的消息可能被插入
浏览 3提问于2013-05-02得票数 1
回答已采纳
1回答
我正在尝试弄清楚WSMQ是如何处理消息侦听器和线程的。如果我有一个消息监听器的实例，并且有许多队列，那么每个监听器是否为每个队列创建一个新线程？或者会有一个线程给监听器吗？任何见解都会有很大的帮助，谢谢。
浏览 2提问于2009-10-06得票数 2
环境: Windows或Linux ActiveMQ-artemis版本: any
地址的属性中有两个属性。例如，如下所示。地址属性中的“消息计数”和“消息数量”有什么区别？
如果我想知道某个主题中有多少条消息，即使没有使用者订阅它，我还应该监视哪一个或哪些其他属性？
浏览 5提问于2022-07-16得票数 0
回答已采纳
由于我对多线程设计不太了解，英语也不是我的母语，所以我不知道如何准确地描述我的问题。假设我在学校有一个迷你程序，负责分析运行时提要。提要是具有以下格式的连续消息列表：
{"type": "A", "data": [...]} // message for doing task type A
{"type": "B", "data": [...]} // message for doing task type B
{"type": "C", "data"
浏览 2提问于2022-06-18得票数 0
例如，如果项目需要日志系统，而不是直接写入日志文件或将日志文件包装在监视器对象中，我们可以启动一个专用的日志线程，这是唯一将记录日志的线程。
如果其他线程想要写日志，它会向这个专用线程发送一条消息。然后，日志线程可以顺序地将日志从其消息队列写入日志文件。
我认为这是一个比多线程设计更好的设计，在多线程设计中，每个写日志的例程都应该使用某种同步方案。
我说的对吗？您能提供更多的方法/示例来将多线程问题转变为简单的单线程问题吗？
浏览 0提问于2012-10-09得票数 0
回答已采纳
ObjectiveC古鲁的问题w/一些WinAPI背景：
在ObjectiveC中是否支持COM样的公寓线程模型？
类A是single-threaded：--A类的所有对象都是在一个特定线程中创建的，所有消息处理程序都在该线程中调用
类B是B类的multi-threaded：对象，可以在任何调用线程中创建，所有消息处理程序只能在用于创建对象的原始线程中调用。
类C是C类的free-threaded：对象，可以在任何调用线程中创建，消息处理程序可以在任何线程中调用
我的想法是:由于ObjectiveC是关于消息的，所以COM+就像多线程一样可以很容易地实现。还是不想？
谢谢
浏览 4提问于2012-07-11得票数 0
回答已采纳
我得到了一个队列，里面有很多消息。
我请求每次读取/事务200条消息：
using (var connection = _configuration.ConnectionFactory.OpenConnection())
{
using (var transaction = connection.BeginTransaction())
{
using (var command = connection.CreateCommand())
{
command.Transaction = transaction;
浏览 0提问于2013-03-04得票数 0
回答已采纳
nodejs是如何工作的？我读了很多次nodejs的官方文件，我不明白这到底是什么意思，
我理解的是，每当nodejs程序启动时，事件循环也会启动。
官方文件上说
事件循环允许Node.js执行非阻塞I/O操作--尽管JavaScript是单线程的--只要有可能就将操作卸载到系统内核。
事件循环有5个阶段，
TimersPending CallbacksIdle-Prepare (不知道它的is)PollCheckClose回调是什么)
在Windows和Unix/Linux实现之间有一个细微的差异，
我曾多次观看以上视频，很难理解他的演示，在这段视频中，伯特是windows操作系统中n
浏览 5提问于2022-04-11得票数 0
在Linux中，消息队列是IPC的一种形式。但是，我不明白它们与文件有何不同。进程可以直接写入文件，而不是写入消息队列，对吗？使用消息队列有什么好处？
此外，与消息队列的写入和读取相关的优先级的重要性是什么？
浏览 4提问于2022-02-28得票数 0
回答已采纳
1回答
我目前正在用消息填充队列系统。当新消息开始传入时，应该有一个单独的线程打印队列。问题是我的程序不能工作。
private static void pData(IWebDriver driver)
{
Queue<string> messageToSend = new Queue<string>();
Thread printThread = new Thread(new ParameterizedThreadStart(PrintQueueMessages));
printThread.Start(messageToSend);
wh
浏览 3提问于2021-02-25得票数 1
4回答
如何判断一个线程是否有消息队列？
、、、、
有没有办法从threadId中找出一个线程是否有消息队列？
基本上，有一些windows api只有在线程具有消息queue.window时才起作用。
浏览 0提问于2009-11-24得票数 2
回答已采纳
是否有一个(Linux)命令将所有消息从Websphere MQ6中的一个队列移动到另一个队列？
我有一个队列，它有一个定义的回退队列，但是我想知道一旦纠正了阻止消息被处理的错误，如何将所有消息传输回原始队列。
有没有GUI工具可以做到这一点？IBM Websphere MQ Explorer6似乎没有这个选项...
浏览 0提问于2010-06-28得票数 2
回答已采纳
我对基于Ubuntu/Linux的操作系统完全陌生，现在我正在使用Ubuntu 19.10，所以为了缩短时间，我需要开发一个通过消息队列与其他应用程序对话的应用程序，Linux/Ubuntu是否提供了内置消息队列？我曾在Windows中使用MSMQ开发类似的应用程序。
谢谢你的进阶。
浏览 0提问于2020-02-18得票数 0
是否有一个使用c++11的并发原语的不错的wait_any实现？
或如何在c++11的互斥体、condition_variable、.中实现？
实现它的一般思想和算法是什么，不仅是c++11，还有本地的Linux系统调用和线程？
wait_any正在等待向量/数组中的任何期货都可用，或者多个condition_variables中的任何一个等待信号，等等.
浏览 2提问于2017-04-06得票数 1
回答已采纳
2回答
我想用Java编写一个聊天应用程序，使用Swing作为接口。
我想出了一个主意(在的帮助下)，但我不确定这是否是最好的方法。
Blockinqueue线程中有两个main队列，一个用于传入消息，另一个用于传出消息。
有四个线程，两个用于传出，两个用于传入消息，一个用于处理GUI和套接字。
传出消息的线程：
ActionListener (Swing)：是在用户单击GUI中的“发送”时触发的。线程将新消息添加到传出队列并在其上触发notifyAll()。
socketOutgoing：可以访问套接字。使用wait()在传出队列中休眠，直到通知为止。通过套接字在传出队列中发送新消息，然后再
浏览 1提问于2014-01-21得票数 2
回答已采纳
我有一个经过训练的机器学习模型，名为model.h5。我正在使用Keras将模型加载为 >>> from keras.models import load_model
>>> model=load_model("model.h5") 但是会打印以下错误消息。 Segmentation fault: 11 然后弹出一个窗口，上面写着 Python quit unexpectedly while using the libhdf5.103.dylib plug-in. 在我的Linux机器上，代码正在工作，模型正在加载，但在我的Mac上，出现了
浏览 16提问于2019-02-25得票数 0
2回答
iOS中的线程通信？
、、、、
有人能给我解释一下如何在swift3 iOS中管理线程通信吗？我做了一些研究，我找到了管理线程的gcd，但我需要一些其他的东西，我需要通知(发送消息或其他东西)线程x线程y已经完成，或者一般情况下通知线程的状态，有没有像java中的线程通信的等价物？( notify ()，notifyAll()，wait())但是在iOS中？谢谢
浏览 20提问于2017-07-18得票数 1
回答已采纳
3回答
MSMQ并发处理设计问题
、、、
我有一个用C#编写的windows服务，它从MSMQ读取数据，并根据消息的类型将它们分配给在工作线程中处理该消息的代理。应用程序在没有代理的情况下启动，并在运行时消息到达MSMQ时动态创建
以下是它的工作原理的基本数字：
如果代理工作线程正忙于工作，则将消息排入其本地队列。到目前一切尚好。但是如果由于某种原因停止了服务，本地队列内容就会丢失。
我正在尝试找出处理这种情况的最好方法。现在本地队列是一个System.Concurrent.ConcurrentQueue。我可能会使用Sql Ce db或其他持久性存储，但我担心性能问题。我考虑的另一件事是仅当代理准备好处理消息时才从MSMQ
浏览 1提问于2012-07-18得票数 6
2回答
我在python中使用了一个队列，它的工作方式类似于一个通道。也就是说，无论何时进行插入，其他线程都在等待并获取插入的值。这个值就是收益。
@classsynchronized('mutex')
def send(self, message):
# This might raise Full
if not self._is_closed:
self._queue.put(message)
return True
return False
@classsynchronized('mutex')
def
浏览 1提问于2013-06-07得票数 2
回答已采纳
2回答
根据RabbitMQ关于的文档
当消息被请求时，如果可能的话，它将被放置到其队列中的原始位置。如果没有(由于多个使用者共享队列时来自其他使用者的并发传递和确认)，该消息将被请求到更接近队列头的位置。
因此，对于单个客户端使用者，如果服务器队列最初是
尾巴c b a
并且客户端使用者使用头消息("a")，服务器队列应该变成：
尾c b头
然后，如果客户端使用者插入处理过的消息，则应该在服务器队列的首端请求消息(按照文档的“原始位置”)，服务器队列应该变成：
尾巴c b a
最后，客户端使用者应该再次使用相同的头消息("a")。
但这
浏览 0提问于2019-01-15得票数 1
回答已采纳
1回答
我想知道如何在linux操作系统上配置posix队列。我知道如何在sysctl.conf和代码中编辑
mq_open(**,**,**);
还有其他方法可以配置每个队列的消息数量和队列数量吗？
浏览 1提问于2014-03-14得票数 1
回答已采纳
我使用的是RabbitMQ Server2.3.1。
在一个通道中有5-6个队列。
该队列由java bean组成。
并且有相同数量的scala参与者聚集在特定的队列中。所有这些参与者都试图通过处理rabbitmq连接和通道的公共队列管理器来获取队列消息。
此队列管理器中只有一个连接和通道。
昨天，我只在一个bean中做了一些更改。
当我开始使用消息时，它会给出异常“本地类不兼容”。我知道这个错误应该出现，但事实是，即使其他队列中有消息，其他参与者也会进入等待状态。
将4-5个队列绑定到单个通道是一种好的做法吗？或者，当一个队列对象被强制转换为异常时，在具有4-5个队列绑定的通道中发生异常时，
浏览 0提问于2011-04-12得票数 1
回答已采纳
1回答
我有一个SQS队列，它包含大量消息(通常是数千条消息)。目前，我有多个侦听器(由从同一个源创建的线程创建)，每个侦听器侦听队列并接收消息。一旦侦听器收到来自队列的消息，侦听器就会从队列中删除消息。只有在从队列中删除消息后才会处理该消息。我的能见度超时为30秒。
我不会使用任何锁或任何东西来处理副本，因为在收到消息后，我会立即从队列中删除消息。到目前为止，我还没见过一件诡计的事，但我只是担心它可能会发生。
现在，问题是，哪一种方法更好:以这种方式拥有多个侦听器或在单个线程中侦听队列，然后旋转新线程来处理接收到的每条消息？
浏览 3提问于2017-06-30得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
