1回答
消息队列是否锁定
、、
我正在尝试在Linux中使用消息队列，是否可以执行以下操作
进程%1具有名为one的消息队列
生产者1&2向没有锁机制的生产者发送消息，可以吗？
浏览 1提问于2012-05-16得票数 0
回答已采纳
1回答
分布式事件节流的只读队列？
、、、、
我正在寻找一种在集群范围内限制各种进程的方法。这需要某种集中式的控制，可以处理任意数量的事件消费者。我的想法涉及到一个只读队列，它以一定的速率生成令牌，没有积压(因此错过的事件就会被丢弃)。例如，假设我有一些web API需要限制到每小时10,000条消息，但可以从集群中的任意数量的服务器调用。我将配置一个队列，使其以10k消息/小时的速度生成令牌，并且所有服务器都连接到该队列并在继续之前检索令牌。这将引入延迟元素(第一次请求后3600/10000秒)，但无论消费者数量如何，都是平滑和可预测的。我不想积压，因为我不想在一段安静的时间后出现匆忙-目标不只是限制每小时的事件总数，而是将它们均匀地分
浏览 1提问于2014-01-21得票数 3
5回答
我正在研究一个用于嵌入式Linux进程间通信的消息队列。我想知道为什么我不使用Linux提供的消息队列，如下所示：
msgctl，msgget msgrcv，msgsnd。
而不是创建共享内存，并与信号量同步？
在商业嵌入式产品上直接使用这组函数有什么缺点？
浏览 13提问于2012-03-05得票数 14
回答已采纳
在Linux中，msgsnd可以从用户空间发送消息。但是，如果发送的消息数量达到最大消息数，msgsnd将阻塞，是否有方法更改最大值？谢谢
浏览 0提问于2020-06-15得票数 0
2回答
消息总线的最佳容器
、、、、
我正在C++中设计我自己的消息总线，它将作为基于组件的游戏的后端。消息总线将具有以下特性：
经常迭代，从第一个元素开始，最后一个元素结束。
在随机地点很少移除元件
理论上无限元素数
理论上，消息类型的数量是无限的。
需要尽可能快地跑
所有元素都将包含一个指向消息处理程序的指针。
螺纹安全
我的问题是：
储存这些资料的最佳容器是什么？这并不局限于标准的C++，因此boost容器是适用的，只要容器在Windows和Linux之间是跨平台的。
浏览 1提问于2013-10-23得票数 2
回答已采纳
1回答
ESB/消息队列快速启动
、、、
我需要实现一个演示系统，以证明概念。基本上，系统描述可以简化为两个模块：
模块1发送请求
模块2捡起它们，处理并发送回响应。
(注意：模块驻留在同一个intranet中，所以我可能希望协议比http更快。我想到了以下几种选择：
消息队列
ESB
理想情况下，系统应该是(但不限于)基于java的，在Linux上运行，并且能够扩展linearly.However，性能超出了POC的范围。我在看和。我的想法是在java中实现这些模块。该架构将是消息驱动的。模块将通过消息队列或服务总线进行通信。
“使用者”将请求作为消息发送到消息队列，“生产者”根据特定的订阅主题
浏览 3提问于2013-04-17得票数 1
回答已采纳
3回答
假设您在系统中有一个实体，例如，" Person“，您希望处理修改各种Person实体的事件。重要的是：
同一人的threads/processes事件按FIFO顺序处理，多人事件流由不同的threads/processes并行处理。
我们有一个使用共享数据库和锁解决这个问题的实现。线程竞争获取一个人的锁，然后在获取锁后按顺序处理事件。我们希望移动到消息队列，以避免轮询和锁定，我们认为这将减少DB的负载，并简化消费者代码的实现。
我已经对ActiveMQ、RabbitMQ和HornetQ做了一些研究，但我没有看到实现这一点的明显方法。
ActiveMQ支持用户订阅通配符，但我看不到将每
浏览 7提问于2011-04-15得票数 8
回答已采纳
1回答
我在进程A中使用boost进程间消息队列编写了IPC机制。这基本上是用进程A接收和发送数据。使用boost消息队列的原因是考虑到windows和linux的兼容性。
但是进程B是linux唯一的版本，它使用posix消息队列实现。此场景是否存在兼容性问题？进程A打开boost消息队列并等待进程B使用posix消息队列发送数据(如果它们使用相同的队列名称)？
浏览 13提问于2020-08-07得票数 1
在嵌入式Linux环境、System消息队列或Posix消息队列中应该使用什么？在项目中普遍使用的是什么？
浏览 5提问于2014-01-23得票数 4
回答已采纳
2回答
在iTron中，有较轻版本的消息队列称为数据队列。它们非常容易用于快速消息传输。Linux中是否存在任何等价的同步原语？
数据队列的定义:它是一个单词消息()的队列。
浏览 2提问于2009-04-10得票数 1
回答已采纳
假设我正在创建一组产品，它们共享大部分代码，但不是全部代码(例如:具有多个前端的应用程序:命令行、Windows/MAC/Linux、移动(最低限度) GUI、web等)。
此外，让我们说，共享的代码不能很容易地分开和‘库’。
我正在考虑为不同的产品(例如分支: CLI、Windows、Linux )或代码中的编译标志(例如#if (FRONT_END == CLI) #elif (FRONT_END == WEB) ...)使用mercurial命名分支。
我对这两种方法都不满意。以下是我的不满：
命名分支机构：
如果我更改了一段共享代码，则需要将其与所有分支合并。是否有hg命令自动完成
浏览 0提问于2011-01-07得票数 1
1回答
我正在设计一个单进程多线程嵌入式Linux应用程序.该设计包括客户机-服务器子系统，其中工作线程接收POSIX消息队列上其他线程发布的消息。
我需要队列显示非阻塞发送和阻塞接收语义。我可以想出几种实现上述功能的方法：-创建两个单独的消息队列描述，用于为了发送和接收访问队列，即两次调用mq_open。随后将设置用于通过队列发送的描述的O_NONBLOCK标志。
指定阻塞行为并使用mq_timedsend代替mq_send
指定阻塞行为并在mq_getattr之前调用mq_send以避免在发送时阻塞
第一种解决方案可能是首选的解决方案，但要使其工作，必须保证每次对mq_open的调
浏览 12提问于2020-02-27得票数 3
回答已采纳
我在OpenShift上运行了一个MQTV3.6.10实例，并启用了RabbitMQ插件。我有多个Spring Boot应用程序，使用来自RabbitMQ队列的消息。所有消费者都使用MqttDefaultFilePersistence。将持久化数据写入到持久化卷上的目录/tmp/mqtt，配额为100M。这是我为连接到RabbitMQ队列而编写的代码：
MqttConnectOptions options = new MqttConnectOptions();
options.setUserName(username);
options.setPassword(pass
浏览 1提问于2017-11-24得票数 0
环境: Windows或Linux ActiveMQ-artemis版本: any
地址的属性中有两个属性。例如，如下所示。地址属性中的“消息计数”和“消息数量”有什么区别？
如果我想知道某个主题中有多少条消息，即使没有使用者订阅它，我还应该监视哪一个或哪些其他属性？
浏览 5提问于2022-07-16得票数 0
回答已采纳
我正在尝试接收来自队列的消息，并尝试了不同的方法，并面临性能问题。以下是每种运行类型的度量标准：
接收模式= peek和lock；1000条消息花了2.5分钟，因为我必须逐一完成每条消息
接收模式=接收和删除；1000条消息平均花费1.5分钟。
接收模式=接收和删除(预取计数为100)；1000条消息花费了3秒，但我最终丢失了执行结束时缓冲区中的100条消息
接收模式= peek和lock (预取计数为100)；1000消息花费了2分钟，因为我必须再次完成每条消息。只有当有一种方法在批处理中完成时，它才会是一个问题解决者。
以下是我的代码供参考：
ServiceBusS
浏览 4提问于2021-08-25得票数 1
回答已采纳
如果消息发送到SQS，我正在尝试触发警报。但是，我看到CloudWatch指标表明有一条消息，但没有触发警报。
警报当前也处于INSUFFICIENT_DATA状态。为了测试，我通过boto3客户端发送了一条消息。
下面是我的SQS和CloudWatch报警的CloudFormation模板
QueueMessageAlarm:
Type: AWS::CloudWatch::Alarm
Condition: AlarmsEnabled
Properties:
AlarmDescription: "Alarm if queue message is greater than 0
浏览 70提问于2018-12-14得票数 0
回答已采纳
3回答
在CMS上进行并发仲裁
、、、
我正在建立一个自定义的CMS，允许用户发布消息到它。消息很短，就像推文一样。
问题是这些消息是由真正的版主主持的。并且有多个版主同时处理消息流。我担心的是，如果这些版主都在处理同一条消息，那该怎么办呢？这既是低效的，也是不一致的。因为一条消息可以被一个版主拒绝，然后由另一个版主传递。
因此，我希望建立某种机制，以便CMS可以将这些消息分发给不同的版主，并避免重复。CMS期望在短时间内处理大量的消息。因此，这个问题变得更加严重。
任何想法都是值得欣赏的。干杯。
浏览 2提问于2010-08-21得票数 0
在Linux中，消息队列是IPC的一种形式。但是，我不明白它们与文件有何不同。进程可以直接写入文件，而不是写入消息队列，对吗？使用消息队列有什么好处？
此外，与消息队列的写入和读取相关的优先级的重要性是什么？
浏览 4提问于2022-02-28得票数 0
回答已采纳
是否有一个(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
3回答
我有一个用Node.js编写的服务和用Ruby编写的工作人员的多个前端。现在的问题是如何使这些沟通？我需要维护动态的工作人员池来处理负载(当负载增加时会产生更多的工作人员)，并且消息相当大~2-3M，因为我通过Node.js前端将用户上传的图像发送给工作人员。因为我想要很好的缩放，所以我考虑了一些排队解决方案，但是我没有找到任何现有的解决方案(或误解的指南)来提供：
后备机制。到目前为止，我发现的解决方案只有单一的故障点消息代理，没有办法提供退路。
序列化。因此，当代理失败时，任务不会丢失。
传递大信息的能力。
用于Ruby和Node.js的Easy
一些用于跟踪队列大小的
浏览 2提问于2012-04-16得票数 0
回答已采纳
我正在使用SQS和lambda来处理一些特定的请求。每个请求可以包含来自1条消息的消息，最多可包含数十万条消息。唯一的问题是，小请求有时必须等待队列中已经存在的大型请求(因为所有并发的lambda都已被占用，而且我不想增加lambda的并发性)。所以我想有两个队列，一个用于小请求，一个用于大请求，这样小请求可以被更快地处理。但是，挑战是如何为每个队列分配lambda并发数。现在，我将lambda并发设置为30，但是如果出现一个大请求，那么所有的30个lambda都会很忙。有没有办法告诉lambda根据触发它的SQS队列部分使用并发lambda (假设20用于大请求，10用于小请求)？或者是否有
浏览 0提问于2019-02-18得票数 2
回答已采纳
2回答
我正在使用Microsoft Azure ServiceBus处理队列消息，使用WCF进行订阅。我正在尝试实现重试逻辑。我使用Peak/Lock查看消息，然后必须对消息进行一些本地处理。如果该处理失败，我将解锁该消息，以便可以再次尝试处理它。问题是我需要构建一个在两次处理尝试之间有一个延迟。目前，它被弹回队列，然后几乎立即被处理。两次尝试之间需要大约2分钟。
浏览 1提问于2013-06-03得票数 1
1回答
对于不一致地支持优先级消息的面向消息的中间件(例如AMQP)，当队列只有FIFO语义时，实现优先级消耗的最佳方式是什么？一般的用例是这样的系统:当队列中存在大量积压的消息时，消费者在接收较低优先级的消息之前接收较高优先级的消息。
浏览 1提问于2009-07-16得票数 9
回答已采纳
我在ActiveMQ中使用camel路由，以便从websphere MQ队列读取消息并将消息转发到wmq队列，它工作得很好，但似乎wmq read操作太频繁(每1秒)。如何定义读取间隔值？例如，每10秒读取一次消息？
谢谢你尼古拉斯
浏览 2提问于2015-04-16得票数 2
1回答
我想知道如何在linux操作系统上配置posix队列。我知道如何在sysctl.conf和代码中编辑
mq_open(**,**,**);
还有其他方法可以配置每个队列的消息数量和队列数量吗？
浏览 1提问于2014-03-14得票数 1
回答已采纳
1回答
我在非根系统中使用POSIX消息队列。我在断开连接和清洁方面遇到了重大问题。我看不到打开的消息队列，然后编写一个例程来清除它们。
我想知道这两种可能中的一种：
在本地、$PWD或其他地方创建POSIX
从Linux获得替代消息队列库，而不是标准消息队列库。
浏览 7提问于2014-04-03得票数 1
我使用以下代码将消息发布到RabbitMQ队列：
ConnectionFactory factory = new ConnectionFactory {
HostName = hostName,
Port = port,
UserName = userName,
Password = password,
VirtualHost = "/",
Protocol = Protocols.DefaultProtocol
};
connection = factory.CreateConnection();
channel = conne
浏览 1提问于2015-02-25得票数 1
回答已采纳
2回答
我有多个源将原始数据推送到S3。我已经在我的S3桶上配置了一个SQS事件通知。问题在于滞后和局限。
我预计在不久的将来会有更多的消息来源，而且由于我们在一次投票中只能从SQS获得10条消息，我认为在不久的将来，当有更多的源将数据推送到S3时，SQS将充满数千条消息，我将无法更快地处理它们。
我正在考虑通过将消息从我的主SQS队列扩展到更多的SQS队列，从而使我的处理层能够轮询多个队列，例如:5个队列，并处理更多的消息。可能的方法应该是什么？
浏览 0提问于2019-01-29得票数 6
回答已采纳
1回答
我正在研究一种方法，要求我向SQS发送一条消息。我不希望它成为一条新消息，因为它将重置代码所需的approximateRecieveCount参数。
请注意，I不能将NACK发送到队列中，因为我将它作为一批10条消息读取，因此我希望在某些情况下手动将其发送回单个消息，而不是批处理.。
我试图使用的代码
我试过设置JMSMessageId，但根据文档，这是不可能的-
发送消息后，Amazon为每条消息设置以下标题和属性：
JMSMessageID
JMS_SQS_SequenceNumber (只适用于FIFO队列)
我现在使用的代码是
defaultJmsTemplate.send(
浏览 2提问于2020-04-13得票数 1
我们将在我们的项目中使用rabbitmq，但是面对一个问题，我们希望在我们的dev机器上进行调试，所以响应消息必须发送到最初发送请求消息的机器。我们将如何实现这一目标，在框架中是否有一个现有的解决方案？
我们考虑了几种解决办法。例如为每台机器声明一组队列，队列名按机器名前缀。那可行吗？
浏览 1提问于2013-12-27得票数 1
回答已采纳
有没有办法将JMS消息队列配置为自动丢弃所有收到的消息？(换句话说:对于发送者来说，消息必须看起来是正常到达的，但队列应该静默地丢弃它。也就是说，队列的行为应该类似于"/dev/null")如果有必要的话，我对IBM MQ最感兴趣，但是，如果JMS规范提供了这种可能性，那就更好了。
由于我已经尝试了搜索，但没有找到这样的可能性，我怀疑答案是“不”。因此，确认是这种情况(我没有遗漏任何东西)的答案对我也是有效的。
用例:测试将消息发送到真实JMS队列的系统，该队列(在测试设置中)不会被任何其他程序读出。(我不想模拟JMS队列，以使测试环境尽可能接近生产环境。出于同样的原因，例如为
浏览 0提问于2017-10-11得票数 1
我们知道，消息消费成功后，该消息会被activemq删除。我想永远存储数据库中的消息。如何配置activemq？
浏览 0提问于2013-04-22得票数 0
我试过了saveqmgr和dmpmqcfg。我无法得到预期的产出。
dmpmqcfg -m qm.apple -t all -a -x all -o setmqaut
我正在使用MQ_7.5版本。哪个命令用于在linux中对MQ消息队列进行备份
浏览 2提问于2017-01-07得票数 1
回答已采纳
如果基于Solaris的MQ管理器向中间的Windows MQ manager发送消息，然后将消息发送给Linux管理器，那么是否需要将CCSID全部更改为相同？我不这么认为，但我被逼着这么做.
当客户端通过Windows上的中间MQ管理器从Solaris上的应用程序发送消息时，我遇到了一个问题，但是基于Linux的最终目的地应用程序接收到了带有CR/LF行结束字符的消息，它无法处理。接收端组应该编写一个转换退出程序吗？还是MCA？
浏览 10提问于2017-08-08得票数 3
回答已采纳
我有一个单节点ActiveMQ实例，其中有两个相互竞争的使用者连接到一个主题。主题订阅按照JMS 2.0规范进行共享。共享订阅不保证只有一个订阅者(使用相同的订阅名称)获得消息。但我注意到的是，它不能保证只有在第一条消息被确认的情况下才会传递第二条消息。在第一消费者花费时间确认消息的情况下，甚至在消费者将第一消息的确认发送到代理之前，第二消息就被传递给自由消费者。这是一种标准行为吗？有没有办法在确认第一条消息之前阻止代理传递第二条消息？
浏览 54提问于2021-03-11得票数 0
我在Linux操作系统中使用HornetQ和JBoss6，谁能告诉我如何控制JMS队列删除消息或改变消息的顺序，MessageConsumers与队列连接的详细信息？
哪种方法最适合这样的需求？任何建议都是值得感谢的。
谢谢。
浏览 2提问于2011-06-07得票数 3
回答已采纳
2回答
在Linux中，如果我有两个使用C程序的进程，它们可以相互通信(通过shm、套接字、管道等)，我如何测量这两个进程在C中通信所用的时间？
也就是说，给定进程A和B，A发送消息，B读取消息，MB是某种用于通信的消息箱，我希望测量A将消息放入MB和B从MB检索消息所用的时间。
浏览 6提问于2013-06-17得票数 2
回答已采纳
1回答
我正在研究将现有消息队列(Mosquitto )移动到云(Amazon )的可行性。
我们现有的服务使用子队列的概念，这样用户就不会收到不适合他们的消息。例如：
/MyQueueName/user1 1/
/MyQueueName/user2 2/
/MyQueueName/user3 3/
等。
在用户计算机上运行的应用程序订阅与他们自己的userid相关的子队列。然后他们只接收与他们相关的信息。
SQS似乎没有创建子队列的能力，也没有过滤消息属性的灵活性。我可以允许将所有消息发送到所有计算机，然后只有在内容相关的情况下才会对其采取行动，但这似乎是浪费，特别是考虑到我们目前正在20,000+
浏览 4提问于2015-10-20得票数 2
回答已采纳
4回答
使用Linux消息队列
、、、
我必须创建单个服务器进程A和多个客户端进程(Es)。所有用户都应该使用Linux消息队列进行数据传递。信息将向两个方向流动。同时，多个客户端进程(Es)也可能已注册到服务器进程A。
目前，我只使用一个命名消息队列，它由Server Process A创建和打开，并由客户端进程(Es)使用/打开(仅)。这适用于两个流程场景(即一个服务器进程A和一个客户机进程B)，但不适用于多个客户端进程(Es)和一个服务器进程。
我在这里面临的问题是设计/逻辑。如何从其他客户端进程(Es)解除服务器进程A上的多路复用消息，以及从服务器进程A返回到相应的客户端进程，或者可能它可以发送回所有客户端进程(Es)，但必
浏览 3提问于2013-04-23得票数 2
回答已采纳
3回答
我正在尝试使用消息队列在Linux中两个不相关的进程之间进行通信。我知道使用公共键值将允许我们在两个不相关的进程中打开相同的消息队列。但问题是，有时对应于消息队列的键值可能已被某些系统实用程序使用。因此，我使用IPC_CREAT | IPC_EXEL标志来确保强制创建新的消息队列。
如果msgget()返回错误，我会递增键值并重新尝试创建一个新的消息队列，直到成功为止。现在，问题是我如何将这个成功的键值传递给另一个想要在同一消息队列上操作的无关进程。
我是不是遗漏了什么？以前有没有人遇到过类似的问题？
浏览 0提问于2009-11-06得票数 2
1回答
向线程发送消息的最佳方式
、、、
将消息发送到在c#/.net中的while(1)循环中运行的线程(而不是进程)，最有效和最快的方法是什么：
使用同步队列的(例如在)Running中，在线程上下文中使用系统winforms的Application.Run的消息循环)，并且在运行application.run之前订阅一个在线程上下文中捕获消息的事件。使用套接字或命名管道向线程发送消息。
在Linux中，我习惯于使用unix域套接字来做这件事，那么在windows中做这件事的等效方法是什么？共享内存文件？命名管道？你认为如何？
浏览 9提问于2009-12-20得票数 16
回答已采纳
我当时正在研究linux，偶然发现了这个ipcs命令。
从手册页：
ipcs - provide information on ipc facilities
ipc在手册页中没有解释，但它很可能代表进程间的通信。这从它所列出的信息的上下文中也是有意义的:共享内存段、消息队列和信号量数组。
我想知道，由于linux/unix中的所有内容都是一个“文件”，或者至少是一个类似文件的对象，那么ipcs中列出的元素中的“文件”在哪里呢？
为什么mkfifo创建的命名管道没有在ipcs中列出？据我所知，fifos是队列。mkfifo创建的命名管道与ipcmk创建的消息队列有何不同？
浏览 0提问于2013-04-22得票数 2
回答已采纳
我已经建立了一个rabbit集群，每当数据库中发生变化时，我都会将消息发布到扇出交换中。
对于使用这些更新的一些微服务，我将专用队列绑定到此交换，并且我最初还为外部客户端设置了一个专用队列，以便它们可以将其与自己的rabbit基础设施联合起来，并使用每个消息的副本。
现在我想知道，允许exchange联合而不是为每个新的外部消费者创建一个新的专用队列是否是一个更好的方法，因为会有越来越多的用户到来。
好处和坏处是什么？
谢谢
浏览 4提问于2017-03-28得票数 0
基本上，我想创建一个客户端可以偶尔订阅的数据缓冲区，获取最后一段时间的所有数据，继续监听它的实时数据，然后在一段时间后取消订阅，然后重复。
我在考虑使用一个过期的TTL rabbitmq队列。这个想法是让客户偶尔订阅和取消订阅它。当客户端订阅队列时，它应该获取队列上的所有可用消息。然后客户端将保持在通道上，以将实时数据推送到它们。
这是一个好方法吗？我知道怎么在rabbitmq上发布/订阅。我如何让它在每次客户端订阅时都将所有数据推入队列？
浏览 0提问于2013-03-21得票数 0
回答已采纳
2回答
我们使用豆茎上的工作层发送网络钩子。我们需要使用指数退避，以防止任何错误时，接触第三方。然而，我不清楚这将如何运作。
如果作业失败了，并且调用了一个ChangeMessageVisibility来延长时间，那么我有两个选择：
返回一个成功的200。然后SQS会将它从队列中移除--不太好。
返回错误代码。那么SQS会将消息可见性覆盖到默认值吗？
来自
工作环境层中的web应用程序只应在本地主机上侦听。当工作者环境层中的web应用程序返回一个200 OK响应以确认它已经接收并成功处理了该请求时，守护进程将向SQS队列发送一个DeleteMessage调用，以便将消息从队列中删除。
浏览 3提问于2015-07-06得票数 6
1回答
我目前有一个应用程序向SNS主题发送消息。有三个SQS队列订阅了这个主题。由于成本原因，我试图从我的体系结构中消除SNS的使用。我的应用程序本身是否有可能在不使用SNS的情况下对SQS执行SNS和扇出消息的操作？如果有什么缺点，那是什么呢？
浏览 2提问于2022-04-26得票数 0
回答已采纳
1回答
我的用例需要我重播在一个目的地发送到另一个目的地(一个或多个)的消息。
可以有四种可能的组合：
主题->主题(CompositeTopic)
主题->队列(CompositeTopic，VirtualTopic)
队列->主题(CompositeQueue，MirroredQueue)
队列->队列(CompositeQueue)
是否有其他方法来重播其他消息，然后列出其中一个？
在主题->队列CompositeTopic或VirtualTopic的情况下使用哪一个？什么时候为什么?
在队列->主题CompositeQueue
浏览 5提问于2014-09-25得票数 1
回答已采纳
1回答
我目前正在使用RabbitMQ () at 通过GitHub API导入关于GitHub repos的元信息。根据GitHub恢复的次数，一个任务可以花几秒钟的时间查看，最多几分钟。我创建了如下新消息/任务：
queue.publish( msg, :persistent => true )
其中一名工人将收到消息并执行任务。工作人员在Memcached中设置他的状态(运行，完成)。这样我就知道什么时候完成任务了！
我想在这个过程中摆脱Memcached。我想从RabbitMQ获得一个msg的状态。像这样的东西是理想的：
status = queue.publish( msg, :per
浏览 2提问于2014-09-14得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
