牛仔消息队列设计
是一种用于实现分布式系统之间异步通信的解决方案。它可以帮助开发人员在不同的组件或服务之间传递消息，实现解耦、提高系统的可伸缩性和可靠性。
牛仔消息队列设计的主要特点包括：
- 异步通信：消息队列采用异步通信方式，发送方将消息发送到队列中后即可继续处理其他任务，而不需要等待接收方的响应。这种方式可以提高系统的响应速度和吞吐量。
- 解耦：消息队列将发送方和接收方解耦，使它们可以独立演化。发送方只需要将消息发送到队列中，而不需要关心具体的接收方是谁，接收方也只需要从队列中获取消息进行处理，而不需要关心消息的来源。
- 可靠性：消息队列通常会提供持久化机制，确保消息在发送和接收过程中不会丢失。即使在发送方发送消息后，接收方暂时不可用，消息也会被保存在队列中，待接收方恢复后再进行处理。
- 扩展性：由于消息队列的解耦特性，可以方便地增加新的发送方或接收方，而不会对现有系统造成影响。同时，消息队列可以根据实际需求进行水平扩展，以应对高并发的消息处理需求。
牛仔消息队列设计可以应用于各种场景，包括但不限于：
- 异步任务处理：将耗时的任务放入消息队列中，由后台的工作线程进行处理，提高系统的响应速度。
- 事件驱动架构：通过消息队列传递事件消息，不同组件之间可以实现松耦合的交互，提高系统的可维护性和可扩展性。
- 日志处理：将系统产生的日志消息发送到消息队列中，再由专门的日志处理组件进行处理和存储，方便后续的日志分析和监控。
- 消息通知：将用户的操作请求放入消息队列中，再由相应的通知服务进行处理，实现实时的消息推送功能。
腾讯云提供了一款适用于牛仔消息队列设计的产品，即腾讯云消息队列 CMQ。CMQ 提供高可用、高可靠、高性能的消息队列服务，支持消息的持久化存储、消息的顺序消费、消息的定时投递等特性。您可以通过以下链接了解更多关于腾讯云消息队列 CMQ 的信息：https://cloud.tencent.com/product/cmq
相关·内容
我有两个正在运行的牛仔服务器实例，它们连接到RabbitMQ。我使用gen_bunny作为RabbitMQ客户端连接到RabbitMQ。
如果使用bunnyc: rabbitMQ ()，我可以使用来自bunnyc的消息。但是，为此，我需要显式地触发此方法。我想要的是在牛仔上绑定一个事件，这样一旦队列中有消息，它就应该自动通知牛仔。
是否可以使用gen_bunny或其他erlang客户端？
浏览 5提问于2013-05-30得票数 0
回答已采纳
我正在尝试集成websocket聊天使用ERlang，牛仔，Websocket和gen_bunny。
我能够让他们独立工作。
浏览器->牛仔websocket聊天(作品) Erlang和RabbitMQ AMQP (作品)
在将它们集成在一起时，我能够将消息从浏览器传递给牛仔，并将其传递给RabbitMQ，然后再从RabbitMQ获取。
我甚至可以将消息回复给发送它的用户。但是，我希望将消息广播给所有已连接的用户。
根据我的理解，Erlang将为每个用户创建一个单独的进程。那么，在我从RabbitMQ得到响应后，如何将其广播给所有连接的用户？？
浏览 1提问于2013-05-01得票数 4
回答已采纳
我有牛仔休息处理程序，这应该产卵夫妇gen_servers。在我的牛仔处理程序中发送/处理消息的最佳方式是什么？是否只有一种可能使用"!“将消息从gen_server发送到处理程序？操作员？
浏览 0提问于2013-06-05得票数 0
我的问题是，我有一个先进先出队列，其中包含数以千计的消息，我只需要用MessageGroupId获取消息，这怎么可能呢？这意味着亚马逊为其属性提供了任何过滤器。因为它得到的所有消息都不是针对特定id的。谢谢，如果能帮到我的话我会很感激的。
浏览 3提问于2017-04-18得票数 1
我有一个Erlang服务器，有许多IoT摄像头，连接到使用TCP，并用它们的序列号注册自己。
同一服务器还运行一个为API提供服务的web服务(牛仔)。
我想要创建一个API，它将从IoT相机获取一张照片。
我正在考虑将IoT进程建模为gen_server，并使用IoT序列号使用全局名称注册。
当收到牛仔的请求时，我会做一个gen_server:call()，然后等待照片被下载。
我的问题是，如果没有注册设备，gen_server:call()将导致进程崩溃。我宁愿只返回一个错误消息，而不是崩溃，所以我考虑使用try...catch。
有更好的方法吗？还是一种更好的建模IoT流程的方法？
浏览 1提问于2017-09-15得票数 1
回答已采纳
1回答
我有一个牛仔websocket服务器。许多客户端通过websocket发送消息。我需要对消息进行处理。我可以在websocket_handle中做到这一点，但是因为它是实时的，所以我想避免它，而我想将消息发送到一个全局进程，在那里可以完成所有的处理。
因为每个牛仔都有自己的进程，所以如何运行一个每个用户都可以发送消息的进程，并在该进程中进行处理。
浏览 0提问于2013-06-04得票数 1
回答已采纳
我使用RabbitMQ和C#作为消息代理框架。在我的场景中，有许多消费者可以从不同的队列中消费。从使用者的角度来看，几个队列形成了一个逻辑组。
例如: Queue1，Queue2，Queue3。
Consumer1将希望接收来自Queue1、Queue3的第一条消息，并且只有在不可用的情况下尝试从Queue2接收消息。
Consumer2将希望接收来自Queue2、Queue3的第一条消息，并且只有在不可用的情况下尝试从Queue1接收消息。
下面是一个可能的设置，每个消费者都关心队列的子集。Consumer2对所有队列感兴趣，在优先级为1,2，因此消费者维护优先级逻辑。请注意，这是一个与这里
浏览 4提问于2016-03-31得票数 0
1回答
我有一个用牛仔编写的web服务，我计划使用RabbitMQ作为DB层。所以我的牛仔服务将是生产者之一，它向队列写入数据，消费者向数据库写入数据。还有更多的异步任务将来自另一个服务(不是牛仔)。
现在的问题是这些消费者应该去哪里。这些应该是单独的erlang应用程序的一部分，还是应该为所有消费者创建单独的Erlang应用程序。任何建议都将不胜感激。
浏览 15提问于2016-09-23得票数 1
回答已采纳
我们有一个系统，多个使用者从队列中获取消息(目前是用数据库实现的)。这些消息有一个order字段。一个特定顺序的所有消息都应该同步处理。这意味着同一顺序的2条消息永远不应该由不同的消费者同时处理。他们应该在order字段上有一个“锁”。
我们过去只处理少数几条消息，但经过几次扩展之后，我们目前正在处理大约400条消息/S，其中有10位用户。我们几乎达到了我们的数据库的最大能力，并希望进一步扩展。
这就是为什么我们希望用消息队列来实现这个系统的原因。但是，消息队列的设计并不是为了将特定用户的消息锁定在特定字段上。
有多个使用者的队列解决方案的最佳设计是什么，其中使用者可以根据队列中的某个字段值锁
浏览 0提问于2019-09-13得票数 1
回答已采纳
通过阅读许多JavaScript事件循环教程，我看到了用于标识队列存储消息的不同术语，这些消息可以在调用堆栈为空时由事件循环获取：
队列
消息队列
事件队列
我找不到标准术语来识别这一点。
就连MDN似乎也在上感到困惑，因为它首先将其称为队列，然后表示消息队列，但在标记中我看到了事件队列。
循环的这一部分是在某个细节中定义的，还是仅仅是一个没有“固定”名称的实现细节？
浏览 0提问于2018-04-09得票数 15
在AWS标准队列中，您可以设置一个重新驱动策略，如果消息未从队列中删除，则将导致消息重试。
在我的例子中，队列上有> 1,000,000条消息，需要几个小时来处理。当一个消息失败并被放回队列中时，它会被放在队列的末尾还是前面。当所有其他消息都已处理完毕时，这些消息是否会立即或两小时或三小时内重新尝试？
浏览 0提问于2019-09-04得票数 0
回答已采纳
我需要将消息发送到不同的队列管理器(不同的QM名称、主机端口对)。
处理这种情况的最佳方法是什么？我需要为每个队列管理器创建单独的ConnectionFactory吗？
用例:向分布式代理(FTE代理)发送命令消息的Java服务。但是，这些代理可以监听不同队列管理器上的不同队列。
浏览 1提问于2015-09-02得票数 1
无论何时从消息队列中读取消息，内核都会删除消息。
同样的信息能读两遍吗？
如何在同一个进程或两个不同的进程中读取相同的消息两次？
浏览 0提问于2015-07-21得票数 0
在团队和/或大型项目中工作时，我是敏捷方法的主要倡导者。
然而，我发现对于较小的项目，当我单独工作时，我通常会从项目开始编写单元测试，广泛地记录，重构。随着时间的流逝，我停下来，因为我觉得我在浪费时间。我发现带有敏捷旋转的牛仔编码(经常测试，编写人类可读的代码)对我来说在小型的单独项目上工作得非常好，我不希望其他人不得不与之合作。
其他人也有同感吗？或者你认为一个人永远不应该固执己见(明白了吗？牛仔)？
所以真正的问题是:有没有专门为单独项目量身定做的敏捷方法？(除了我上面的“敏捷牛仔”方法)
浏览 3提问于2009-08-21得票数 6
回答已采纳
我创建了一个天蓝色的web作业，它在服务总线队列消息上触发。当我运行web作业时，它处理来自服务总线队列的消息，因此我的简单问题如下；
是否有一种方法可以使web作业在传递到队列的新消息上触发，而不对其进行处理，从而使消息完整并从队列中删除？
我目前正在使用"Servicebustrigger“来触发函数类中的队列。
public void Processservicebus([ServiceBusTrigger("%Values:QueueName%", AutoCompleteMessages = false, Connection = "ServiceBu
浏览 5提问于2022-09-02得票数 0
我想在牛仔中创建一个websocket应用程序，它从另一个牛仔处理程序那里获取数据。假设我想结合牛仔的Echo_get示例：
使用websocket示例
在这种情况下，GET对Echo的请求应该通过websocket处理程序向该示例中的html页面发送一个"push“。
最简单的方法是什么？我能用一些简单的方式使用“管道”操作员吗？我是否需要创建和中间gen_something来在它们之间传递消息？我希望得到一个示例代码的答案，它显示了处理程序的胶水代码--我真的不知道从哪里开始将这两个处理程序连接起来。
浏览 2提问于2014-12-30得票数 4
回答已采纳
1回答
我正在设计一个单进程多线程嵌入式Linux应用程序.该设计包括客户机-服务器子系统，其中工作线程接收POSIX消息队列上其他线程发布的消息。
我需要队列显示非阻塞发送和阻塞接收语义。我可以想出几种实现上述功能的方法：-创建两个单独的消息队列描述，用于为了发送和接收访问队列，即两次调用mq_open。随后将设置用于通过队列发送的描述的O_NONBLOCK标志。
指定阻塞行为并使用mq_timedsend代替mq_send
指定阻塞行为并在mq_getattr之前调用mq_send以避免在发送时阻塞
第一种解决方案可能是首选的解决方案，但要使其工作，必须保证每次对mq_open的调
浏览 12提问于2020-02-27得票数 3
回答已采纳
当我阅读https://github.com/rabbitmq/internals/blob/master/variable_queue.md时，variable_queue将消息保存在四个队列数据结构上，但我总是感到困惑，为什么要这样设计？谁能给我一个更直观的解释？ 谢谢。
浏览 12提问于2021-04-22得票数 0
1回答
我们一直使用RabbitMQ作为经纪人。它位于用Go与NGINX编写的客户端和API服务器之间。到目前为止，我们已经成功地使用了它。我们正在使用的消息大小已经增加到了20 we。发送此大消息始终会导致以下错误：
=ERROR REPORT==== 20--2018年10月-2018年：：11:17:59节点“兔子@pc11213”节点上的进程<0.21106.0>中带有退出值的错误：{{ node，{badmatch，{more，<<8001224 bytes>>，{http_req，#Port<0.99287>，ranch_tcp，备存，&l
浏览 0提问于2018-10-22得票数 1
1回答
我的应用程序正在使用发布到主题的消息。我有3台服务器运行我的应用程序代码。在当前的实现中，消息被分发给所有正在运行的VM，即消息的副本被每个使用者接收。
我的要求是每个消费者都应该接收不同的消息，也就是说，没有两个消费者应该得到相同的消息。
下面是我正在使用的库：
春季jms 4.2.7
JavaJMS2.0
tibco jms 8.0
野蝇群作为服务器
目前，我有以下配置：
TibjmsConnectionFactory factory = new TibjmsConnectionFactory("server-url");
factory.setUs
浏览 2提问于2018-12-07得票数 3
2回答
一个标准窗口的队列可以容纳多少条消息？当队列溢出时会发生什么？
GetMessage及其相关文档对此只字不提，而且PeekMessage只给出了某些消息类别的是/否，而不是消息计数。
说，队列是使用内存映射文件实现的，并且没有消息计数限制，但该页是关于WinCE的。这也适用于桌面Win32吗？
浏览 1提问于2008-09-23得票数 13
回答已采纳
我正在尝试获取具有特定关联id的消息，就像rabbitmq文档中所解释的那样。但是，我发现不相关的消息被出队了。我不希望它发生。在收到消息并知道这不是我要找的消息后，我如何告诉rabbitmq不要出队。请帮帮我。
`
.
.
replyQueueName = channel.queueDeclare().getQueue();
consumer = new QueueingConsumer(channel);
channel.basicConsume(replyQueueName, false, consumer);
while (true) {
QueueingCon
浏览 2提问于2016-02-11得票数 4
1回答
我们正在使用microservices和AWS构建一个用于消息传递的应用程序。
在“最终目的地”微服务处理之前，我们需要由多个微服务处理单个消息。
例如：
微服务A生成消息
消息必须由微服务B进行验证。
验证的消息必须使用microservice C进行转换。
转换后的消息必须应用到使用microservice D的数据存储中
是否有动态地(在消息创建时)指定消息队列上侦听器之间的消息流的模式？
浏览 1提问于2018-08-22得票数 1
回答已采纳
我们有一个要求，我们需要使用SQS从头到尾一次处理一条消息(不是严格的顺序)。有没有什么办法可以在SQS中将maxConcurrentConsumer设置为1？
我正在查看文档，但找不到要设置的此属性。在Amazon控制台上，我在配置队列菜单中看不到此属性。在消息检索时，我们可以指定我们希望在一次轮询中读取多少消息，但由于AWS自动伸缩功能可以创建多个消费者(实际上是Springboot微服务)，因此我们不能通过将此限制设置为1来依赖它。
附注:我们不能控制消息发送者，它可以向SQS发送许多消息。
浏览 16提问于2016-09-01得票数 1
回答已采纳
我试图找出在什么条件下，我希望为2个端点应用程序实现一个远程队列，而不是一个本地队列。
考虑一下这个场景: App A on Server A需要通过MQServer1将消息发送到服务器B上的App B。
看起来，最简单的配置是在MQServer1上创建一个本地队列，并配置AppA将消息放入本地队列，同时配置AppB以从同一个本地队列获取消息。AppA和AppB都会连接到同一个队列管理器，但是执行不同的命令。
什么样的情况需要安装另一个MQ服务器(例如MQServer2)并在MQServer1上配置一个远程队列，而后者则通过一个通道将来自AppA的消息发送到MQServer2上的本地队列以供A
浏览 1提问于2015-07-09得票数 3
我有一个ActiveMQ设置，一个生活在一个数据中心的源代理将到达特定主题的所有消息转发给另一个数据中心的目标代理。使用者应用程序只使用来自目标代理的消息。(这种设置主要是为了确保在两个数据中心之间快速高效地转发消息。)
用于转发的配置如下所示：
<networkConnectors>
<networkConnector name="Q:DontForwardQueueMessages"
uri="static:(tcp://destination-broker.example.com:61616)"
duplex="
浏览 3提问于2015-08-05得票数 0
回答已采纳
1回答
Tibco将消息存储在数据文件或数据库中。我需要浏览发布到主题或队列中的旧消息。EMS是否提供了用于搜索旧的/消耗的消息的API？假设我有一个主题complexEvent.topic at time --发布者向complexEvent.topic发布一条消息，而在时间t2中，消费者使用该消息。比方说，在离开t2 2个小时后，我需要查看t1和t1+ 10 (分钟)之间发布的所有消息，以主题complexEvent.topic为主题。我怎样才能搜索旧消息？
浏览 3提问于2014-03-06得票数 1
回答已采纳
我们是一个使用相同的WebSphere MQ队列来写入和读取消息的开发人员团队。因为我们使用相同的队列，一些消息由另一台机器的读取器接收。是否有一种方法可以过滤由发送方的Environment.MachineName从队列中读取的消息？
这就是我通过使用MQMessage.GroupId所做的努力。
将GroupId设置为PUT的消息。
将MQGetMessageOptions.MatchOptions = MQC.MQMO_MATCH_GROUP_ID设置为GET，并设置消息上的GroupId。
基本上，我试图为使用队列的每个工作站创建一个组。不幸的是，这是行不通的，没有消息
浏览 1提问于2014-06-10得票数 0
我需要查看消息队列而不删除它们。如果消息队列项符合某些条件，我将继续删除它。怎么做？下面是我知道的APIs -但似乎都不支持窥视。
mq_close() --关闭消息queuemq_getattr() -获取消息queuemq_notify()的当前属性-当队列变为nonemptymq_open()时通知调用进程-打开或创建消息queuemq_receive() -接收来自queuemq_send()的消息-将消息放入消息queuemq_setattr() -设置消息队列的标志
有没有办法在不删除的情况下偷看一条信息？
浏览 1提问于2011-09-13得票数 14
回答已采纳
3回答
在工作中，我们正在讨论是否为PHP应用程序实现消息队列。目前我们看的是阿帕奇的ActiveMQ。我们不完全清楚的一件事是，是否可以基于到达队列的消息来触发进程。
到目前为止，我们找到的文献似乎表明，消息队列是一种基于拉入的机制:该进程定期运行(作为守护进程或cron)，并从队列中拉出其传入消息。有没有可能把它变成一个推送机制？也就是说，有没有办法让消息队列在消息到达时实际启动HTTP请求(或进程)？我们找到的一种选择是发布/订阅模型，但这需要在无限循环中运行我们的PHP应用程序来维护到ActiveMQ实例的开放(TCP)连接，这感觉有点笨拙。
任何意见都将非常感谢。
浏览 0提问于2010-11-23得票数 1
回答已采纳
1回答
我是Apache活动消息队列的新手。在读取(消费)来自MQ的消息时，脱队列计数增加，从MQ存储中删除消息。在这里，我想扫描消息而不删除MQ和去队列计数中的消息。意思是，我只想扫描消息并将其存储在本地，或者在输出时打印出来。
有人能对此提出建议吗？我想用java实现它。
浏览 4提问于2016-01-06得票数 1
回答已采纳
1回答
根据documentation，服务总线触发器提供了几个元数据属性。这些属性可以用作其他绑定中的绑定表达式的一部分，也可以用作代码中的参数。这些属性是Message类的成员。示例： [FunctionName("ServiceBusQueueTriggerCSharp")]
public static void Run(
[ServiceBusTrigger("myqueue", Connection = "ServiceBusConnection")]
string myQueueIt
浏览 17提问于2021-09-01得票数 0
回答已采纳
1回答
我正在尝试做一个RestApi (asp.net核心)，它通过RabbitMq调用后端(C#)。为了处理许多请求，我需要异步调用后端。
对我来说，来自rabbitmq的示例代码似乎并不是线程安全的，因为它将消息排出队列，直到返回具有正确关联id的消息为止。所有其他人都将被忽视。(链接： )
while(true)
{
var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
if(ea.BasicProperties.CorrelationId == corrId)
{
r
浏览 6提问于2017-02-16得票数 10
由于某些原因，我们不允许在LOB中使用多个队列。
因此，我们设置了一个非常大的预取数，并且该单个队列的使用者将负责根据某些消息属性向内存队列中的其他队列分配。其他后台任务将从内存队列中获取消息并处理它。
为了避免消息丢失，在后台任务处理完消息之前，是否可以手动修改消息？
浏览 1提问于2022-02-23得票数 0
1回答
可以暂停的维持秩序队列
、、、、
我目前正在开发一个使用RabbitMQ向员工传递消息的软件。基本上，这是一个非常简单的任务，因为您可以使用单个队列直接交换，所有工作人员都使用该队列。工作完成了。
但现在，事情开始变得复杂起来。如果有两个额外的要求，这使我认为：
消息并不都是相等的，即消息有一个“标志”，用于对消息进行分组。现在，第一个要求是所有具有相同“标志”的消息都按顺序处理。
希望使用特定标志“暂停”所有消息的处理。
第一个问题很容易解决:您只需确保具有相同标志的消息始终由同一个工作器处理，并将其预取设置为1，以确保可以使用x-consistent-hash交换。
第二个问题也很容易解决:您只需为每个标志
浏览 2提问于2014-12-17得票数 0
1回答
我有一个系统，在这个系统中，我发布了针对特定消费者的共享主题的更新。我注意到由于SQS消费者缺乏选择性侦听，消息被卡在队列中，因此消息被劫持。
示例：
给定:消息{目的: A，有效载荷: 1234}
给予: ConsumerA，& ConsumerB
我预计Message将由ConsumerA处理。然而，它却不断被消费者B所劫持。它接收消息，然后拒绝处理它，因为目标字段不匹配，导致可见性超时过期，并且消息被放回队列中。但是由于SQS的性质，ConsumerB有同样的机会再次选择消息。
我的问题是，用什么模式来解决这类问题？我正在考虑为每个消费者创建一个队列，但它有特定于系统im工作的缺
浏览 2提问于2022-10-19得票数 0
1回答
1)我有兴趣了解是否有可能保留使用Spring Integration交付的消息。我已经在使用mongo持久化存储(ConfigurableMongoDbMessageStore)，但是只有失败的消息保留在集合中。理想情况下，我希望所有消息都保留列出并重试的功能。
我会使用"status“或类似的字段来标识排队、成功或失败的消息。不确定这个字段是否已经存在，但我猜一定有类似的东西存在。
2)此外，当消息失败并被替换时，消息中有更多的数据。这些数据是序列化的，所以我很好奇如何提取原始消息并重试。
3)目标是在webapp中创建一个接口，所有排队的消息都可以在其中看到并重试。不仅是失败的消
浏览 1提问于2014-07-28得票数 0
我正在使用Twilio到 4.2应用程序。我是散装寄出的，一次大约1000件，零星地收到。
目前，当我收到文本时，我将其保存到DB (to、from、body)，然后将该记录传递给ActiveJob工作人员，以便稍后处理。为了发送消息，我目前将Twilio保存到另一个DB，并将该记录传递给另一个ActiveJob工作人员。因为我经常分批做这件事，所以我有两个工人。第一个传出消息工作者只发送一条消息。第二个查询DB并查找应该接收消息的所有用户，为应该发送的每个消息创建一个DB记录，然后将该记录传递给第一个传出消息工作者。所以第二个基本上是为第一个要处理的工作创造了一堆工作。
现在，我让工作人员在
浏览 0提问于2015-02-07得票数 0
回答已采纳
我试图从Java获取特定Websphere MQ队列的使用者数量？在将消息放入队列之前，我需要知道是否有人会使用这些消息。
浏览 0提问于2014-05-07得票数 5
回答已采纳
1回答
是否可以巧妙地使用PostMessage、GetMessage等对消息进行排队(假设发送方和接收方消息循环都进行了协作)，或者我是否需要自己的解决方案？
如果你想知道它的用例，它是图标加载。您总是希望首先加载最近请求的图标。:)
浏览 8提问于2012-07-10得票数 0
回答已采纳
我有一个Camel路由，它从一个ActiveMQ JMS队列中读取，进行一些处理，并将结果传递到一个远程目的地。如果此进程的通信部分失败，我希望无限期地重试(直到目标“向上”)。我可以通过创建路由transacted和设置redeliveryPolicy来处理这个问题。在Camel (通过camel.processor.RedeliveryPolicy重新尝试路由的失败部分)和ActiveMQConnectionFactory (通过org.apache.activemq.RedeliveryPolicy重新尝试整个路由)中都设置了重发。
我还有一个要求，就是我们应该能够从JMS中删除一个条目
浏览 2提问于2017-05-19得票数 2
我在AWS中有一个死信队列，几天前我有大约30k条消息在里面。今天，我对使用此队列的服务进行了一些更改，现在我看到队列中有33K个消息，我只想查看今天的消息，这可能吗？
通常我会右击“查看/删除消息”，然后单击“开始拉取”，但我不会在顶部看到今天的消息，而且我可以拉取的量是有限制的……
有什么建议吗？
浏览 17提问于2020-01-09得票数 0
3回答
MSMQ并发处理设计问题
、、、
我有一个用C#编写的windows服务，它从MSMQ读取数据，并根据消息的类型将它们分配给在工作线程中处理该消息的代理。应用程序在没有代理的情况下启动，并在运行时消息到达MSMQ时动态创建
以下是它的工作原理的基本数字：
如果代理工作线程正忙于工作，则将消息排入其本地队列。到目前一切尚好。但是如果由于某种原因停止了服务，本地队列内容就会丢失。
我正在尝试找出处理这种情况的最好方法。现在本地队列是一个System.Concurrent.ConcurrentQueue。我可能会使用Sql Ce db或其他持久性存储，但我担心性能问题。我考虑的另一件事是仅当代理准备好处理消息时才从MSMQ
浏览 1提问于2012-07-18得票数 6
我想用C制作我自己的消息调度员.例如，我想向MyButton或MyWindow结构发送消息。这些结构有自己的处理程序。
有什么大师的建议吗？
PS:用于嵌入式应用程序(使用微控制器)
PPS:多亏了肖恩--这就是我所需要的。我对肖恩建议的简单解释是：
typedef void (*MyHandler)(size_t param);
MyHandler Handlers[32];
void RegisterHandlers(size_t id, MyHandler handler) {
Handlers[id] = handler;
}
void SendMessage(size_t
浏览 0提问于2012-10-15得票数 0
回答已采纳
从中，我知道SNS对SQS有重试策略，但它们是否保证至少有一条消息传递给SQS？
请给出正式的引文。
浏览 0提问于2018-04-06得票数 4
回答已采纳
我有7个用于处理IBM Websphere消息队列的windows服务，通过使用每个服务，我可以获得消息和计数。因此，现在我需要一个windows服务来处理它们服务的所有队列，并检索消息计数。现在，我使用INI File读取MQ详细信息，从而分别连接到这些消息队列。我需要一种方法来连接所有的队列并检索队列深度，这样我就可以通过邮件获得队列的深度。
请在这方面帮助我..。
浏览 27提问于2016-09-16得票数 0
有没有人在PHP中想出了一种优雅的方法来认识到SQS刚刚从队列中向您发送了与之前发送的消息相同的消息？如果SQS从未收到请求者发送的'deletemessage‘请求，这可能会发生，因为原始SQS队列可能已经关闭，因此它的替换将重新发送与Amazon文档相同的消息。会非常感谢PHP中的任何指针、代码示例等等。
浏览 1提问于2014-05-22得票数 1
回答已采纳
我在里面有个队列和留言。另外，我在不同的过程中有两个使用者。我一个接一个地接收消息，并决定此消息不是我的，并使用requeue标志拒绝它。在文档中，我发现了下一个短语“服务器不能在当前通道的上下文中将消息传递给同一个客户端”。这是否意味着被拒绝的消息应该传递给另一个消费者？
浏览 1提问于2018-07-02得票数 0
回答已采纳
我想知道是否有一种方法可以在不让邮件被标记为在“慰藉”中被重新传递的情况下破解一条消息。
情况:有一个由多个订阅者服务的保证队列，我们希望另一个订阅服务器处理特定的消息。这是个非常棘手的案子。
有没有人知道这件事或者以前试过这个？
浏览 4提问于2015-12-04得票数 1
回答已采纳
我正在尝试同步我拥有的三个微服务。
为了做到这一点，我实现了RabbitMQ。现在似乎一切正常，但我不确定我是否在遵循最佳实践，我找不到参考资料来查找它，也许有人能帮我做这件事？
简要介绍我要做的事情：我有一个服务应该更新另外两个，每个服务都应该接收发送的消息。我有两种类型的消息(保存和删除资源)。*在出现错误时，队列应恢复并重新发送消息。
我正在做的事情：，我已经设置了一个交换，我的每个使用者连接到两个不同的队列，每种类型的消息(保存/删除)一个。我已经使用了一个直接的交换来过滤以后的消息，即使目前我不需要过滤它们。
每个队列都是命名的，交换和消息都是持久的，我正在添加我使用过的消息。
问题
浏览 4提问于2016-07-11得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
