1回答
此表用作具有多个读取器和写入器的消息队列：id CHAR(36) PRIMARY KEY NOT NULL, message TEXT NOT NULL, 我尝试通过使用更新锁来防止重复读取消息：UPDATE MyQueue SET at=@nextDay WHERE at <= @today OR
浏览 0提问于2020-03-25得票数 1
2回答
队列作业在时间和内容上可能不同，这意味着系统需要保留相当多的作业。使用cronjob设置应用程序逻辑也会有点困难。centOS中的队列作业数量是否有限制，或者是否有任何其他的作业排队方法？
浏览 2提问于2010-03-25得票数 0
1回答
场景：
TL;DR -我需要一个队列系统，根据未来的时间戳而不是插入的顺序触发作业。我有一个条目的MySQL数据库，其中详细描述了需要执行的特定事件(主要包括一系列算术计算和基于时间戳的数据库插入/更新)。插入条目的时间和事件将“执行”的时间没有相关性，并由外部因素决定。此表是作业“队列”的一部分，该队列将包含设置为在未来几秒钟至几天内执行的任何位置的条
浏览 4提问于2014-04-01得票数 4
回答已采纳
1回答
我正在实现基于spring集成的应用程序，其中我需要动态地(基于消息params)向ActiveMQ队列发送消息(POJO)。使用spring集成概念来实现这一点的最佳方法是什么？例如，应该将请求消息(id:123，processor:ABC)发送到ABC.REQUEST队列，并从ABC.RESPONSE队列接收响应消息。类似地，请求消息(id:456，processor:XYZ)
浏览 4提问于2015-07-27得票数 1
回答已采纳
我所做的：
image: emqx/emqx:v4.0.0 - EMQX_NAME=emqx客户端的代码可以在中的"stdinpub“和"stdoutsub”文件夹中找到。，用qos=1发送第二条消息：
retain = falsepayload = "test2"
此消息</
浏览 8提问于2021-06-04得票数 1
1回答
SQS上的慢化消息
、、、、
我有一个消息传递用例问题。
我们在AWS中有一个队列，例如，该队列上的out-of-the-box-lambda-based-message-consumption和origQueue。现在，为了满足基于适度的消息消费的一个特殊特性(基于消息中的“isModerated”标志)，我正在考虑使用另一个并行队列(这将是上述队列的一个缓和版本)。在这个
浏览 2提问于2019-04-23得票数 0
回答已采纳
我在IBM softlayer中托管了我的Worklight服务器。是SoftLayer消息队列是基于JMS2.0API的消息队列还是不同。如果它是基于JMS的消息队列，则可以将其用于IBM Worklight Unified Push Notification。
浏览 0提问于2014-05-07得票数 0
包含上述数据的日志记录将被实时插入到表中，我的客户端代码应该查询这些记录并对它们进行分析。我现在遇到的问题是读取每个查询的唯一记录。Symbol_name <> @lastSeenSymbolName AND Status <> @lastSeenStatus;", APP_MAXIMUM_STRING_CHARS);
return TRUE;
MYSQL
浏览 1提问于2018-11-21得票数 1
回答已采纳
我有Azure，当一个或多个消息到达队列(peek-lock)连接器时，它使用处理来自基于服务总线会话的队列的消息。
有人能建议我如何使用从基于会话的队列中读取带有会话id的消息吗？
浏览 4提问于2020-09-10得票数 0
回答已采纳
1回答
有人能告诉我如何检查消息队列中是否有消息吗？消息队列是在基于linux的操作系统中用C语言实现的。我只想检查在特定时间消息队列中是否有任何消息。
浏览 3提问于2012-09-22得票数 5
回答已采纳
2回答
分布式原子计数器
、、
我有一个基于微服务架构的服务。该设计包括与队列通信的3个组件。系统组成部分：
微服务"A“获取请求并生成子请求。每个子请求都是写入服务"B“队列的队列消息。每一条产生多条消息来排队"B".Microservice "B“的传入消息都会得到一个任务来执行和执行它。当由服务"A“发出的所有子请求执行时--该服务将消息<
浏览 2提问于2020-04-23得票数 1
我有一个带有队列的JMS服务器。对于一个队列，我希望设置基于IP地址存储消息的访问权限。我尝试在上述队列上使用基于com.bea.contextelement.channel.RemoteAddress上下文过滤器的上下文策略。此设置只允许从特定计算机发送消息，但随后附加和运行在此队列上的MDB将被断开连接，消息不会被消耗和处理。
如何解决这个问题？
浏览 0提问于2019-01-23得票数 0
1回答
我正在探索基于不同技术( C、Java、Ruby和Python )的异构应用程序之间高级消息传递的ActiveMQ。在查看时，我无意中理解了在执行消息交换时混合协议的用例。我已经搜索了ActiveMQ文档，但是找不到任何这样的参考。发布后，本主题将这些消息存储在相应的队列(体育队列、金融队列和世界队列)下。在这种情况下，订阅到Sports队列<e
浏览 2提问于2016-01-21得票数 1
我当前的设置包括一个队列，称为"QONE“的InQueue。然后，QONE有另外6个队列，并向其发送消息。每个后续队列都有一个选择器，它接受基于正则表达式的消息。我能否在QONE上设置一个选择器来过滤掉不需要<e
浏览 2提问于2015-05-07得票数 3
回答已采纳
1回答
，蔚蓝存储队列消息可以退出队列的最大no是多少?是正确的，只有在出现异常时，消息才会移动到毒队列，而不是基于排队列计数?。注意:我们正在处理来自windows服务的消息。
浏览 4提问于2021-08-20得票数 1
回答已采纳
在Azure服务总线/队列中。我发现队列中有很多消息，基于队列长度不是0。但我无法从队列中接收或查看消息。
浏览 1提问于2014-07-01得票数 0
回答已采纳
我正在使用Lambda函数将消息推送到SQS队列。将消息放入SQS队列后，我需要触发其他Lambda函数来处理队列中的消息。
我认为我们可以使用SNS来实现这一点。我是AWS服务的新手，请在SNS的帮助下提出基于SQS队列消息触发Lambda函数的解决方案。
浏览 1提问于2016-12-15得票数 1
1回答
我是AMQP和RabbitMQ技术的新手。我曾经习惯于在mysql表中存储队列，但随着我的项目的成长，他们需要改变这种行为。安装和设置RabbitMQ是完全正常的。我的一个项目处理大量xml文件(每天处理数十亿行)。因此，我创建了虚拟生产者，将XML文件拆分成元素(1....)并将这些元素(每个xml文件数千个)与特定的路由关键字进行交换。这样就可以了。但这就是问题所在，因为我一次不能阅读超过一条消息。因此，我需要从数据库加载实际数据，将它们与XML元
浏览 2提问于2016-02-24得票数 0
我在一个生产系统上有一个Tibco EMS消息队列，它将消息从一个生产者路由到一个消费者应用程序。我已经设置了一个队列桥和选择器来将生产者队列上的消息路由到消费者队列
浏览 39提问于2016-09-27得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
