0回答
HornetQ持久性未删除文件
、、、、
在我的应用程序中，我注意到HornetQ 2.4.1已经堆积了大量的消息日志文件(有时多达数千个)。我通过JMS队列使用HornetQ，我们使用Wildfly8.2。通常，在启动服务器实例时，HornetQ会有3个消息日志和一个锁文件。
消息日志文件堆积导致重新启动服务器时出现问题，我们将看到以下日志：
HQ221014: 54% loaded
删除文件时，服务器加载正常。我已经尝试了一些，似乎这些文件中的消息已经被处理过了，但我不确定为什么随着时间的推移，它们会继续堆积。
编辑1:我找到了，它表明我们没有确认消息。然而，当我们像这样创建会话时，connection.createSession
浏览 4提问于2017-12-12得票数 6
回答已采纳
卡夫卡中的demo.incoming话题堆积如山。
我正在使用。每秒大约有70个请求通过Scrapy Cluster REST api (Producer)提交给Kafka。蜘蛛可以非常快地完成爬行，因为redis中的队列保持在一个非常低的数字，大多数时间少于10个。但demo.incoming中的消息数量每秒都在堆积。这是我用来查看Kafka中demo.incoming主题消息数的命令
kafka-run-class.sh kafka.tools.GetOffsetShell \
--broker-list localhost:9092,kafka-statefulset-2:9092,ka
浏览 1提问于2019-07-07得票数 1
出于故障排除的目的，我希望获得将消息发送到特定队列或交换的生产者的列表。我在rabbitmq控制台中看不到任何获取上述详细信息的选项。一些生产者正在堆积一个零散的队列，我正在尝试找出生产者在队列中堆积消息的IP。
有人能在这方面给我指点一下吗？
浏览 0提问于2018-11-02得票数 0
我们正在使用Solace JS API进行开发。在web应用程序中，我们订阅了一个主题并使用了消息平面缓冲(大约700kb)。为了测试，在使用之后，我们只打印"message recieved“。我们似乎不能更快地消费，消息堆积如山。当我们使用字符串测试ex。"Hello World“我们可以消费一切，不会堆积。因此，当消息大小较大时，似乎存在消耗缓慢的问题。
有什么想法或建议来处理这个问题吗？我们使用的是Solace JS API网站上提供的示例。
浏览 0提问于2017-07-29得票数 0
2回答
我有一个基于氮气的网络应用程序的登录页面。如果用户身份验证失败，我会向用户闪现一条消息，让他们知道。但是，如果用户继续提供错误的凭据，这些闪存消息会不断堆积。有没有办法在发布新的消息之前先清除闪现的消息？
浏览 2提问于2010-01-07得票数 4
回答已采纳
我有一个由于某种原因而停止处理消息的活动应用程序。现在，重启后有300万条消息堆积起来。看起来大概需要60个小时才能处理。我只想清除所有的消息。简单地运行"DELETE FROM ACTIVEMQ_MSGS“类型的命令来删除消息有多安全或危险？
浏览 0提问于2013-05-17得票数 1
回答已采纳
我们在生产系统中有一个队列管理器，它有大约10个集群主题和50个订阅。所有队列管理器都在IBM MQ集群拓扑中，数据在NAS (共享存储)中，因此所有队列管理器都启用了MI (多实例)。我们有大量的发布-订阅消息流。但我们有时会看到消息在队列管理器中的SYSTEM.INTER.QMGR.PUBS中堆积起来，其中定义了主题和订阅，为了再次获得消息流，我们必须重新启动队列管理器。我正在尝试理解我们可能会遇到这个问题的情况。我读过的很少，比如如果目标订阅队列上没有消费者，消息可能会堆积在这个系统队列中。但是在我们的例子中，当我们看到这个积压时，所有的集群传输和其他订阅队列都是空的。有没有人看到类似的
浏览 1提问于2016-03-12得票数 1
在maximo v7.5中，我尝试使用外部系统>企业服务上传数据，但新数据没有反映在maximo中，日志或文件管理中也没有错误，也没有消息堆积在队列中。实际上，每次我尝试时，都会出现入站事务成功的消息。
浏览 24提问于2020-04-22得票数 0
我让这些应用程序服务器运行Tomcat，将消息排队到本地嵌入式代理。这些消息被转发到独立的代理。有另一台机器连接到使用消息的独立代理。嵌入式代理和独立代理是持久的。
我有一个队列，它在嵌入式代理中比转发到独立代理的消息增长更快。我可以清楚地看到调度计数小于入队计数。我看到在嵌入式代理上只有一个消费者连接到独立代理上的这个队列，许多消费者连接到独立代理。
独立代理中的队列大小几乎为0，CPU大约有95%处于空闲状态，这意味着独立代理不会耗尽资源，消息也不会堆积在独立代理上，而是会堆积在嵌入式代理中。
是否有一个配置参数可以使独立代理增加从嵌入式代理读取的线程/使用者的数量？或者让嵌入式代理更快地
浏览 0提问于2012-09-18得票数 1
我想知道是否有一种方法可以在发送消息之前检查消费者是否正在运行？我正在使用最新的php STOMP，并且正在努力查看是否有一种方法可以在发送消息和让消息在队列中堆积之前检测到它是否正在运行。
谢谢，史蒂夫
浏览 0提问于2011-02-04得票数 3
回答已采纳
我有3个消费者订阅了一个卡夫卡主题。生产者向主题发布1条消息。
我如何确保信息在内部复制卡夫卡，然后被所有三个消费者消费？
一种方法是不提交消息，但随后消息将继续堆积在主题中。
浏览 1提问于2018-09-14得票数 1
回答已采纳
我使用Spring AMQP连接并向RabbitMQ发送消息。我知道，当连接中断时，存在处理发送重试的底层机制。我想知道当消息和整个应用程序被卡住一段时间后会发生什么，例如连接在一定时间内没有重新建立，消息在应用程序中不断堆积？
浏览 0提问于2015-04-14得票数 0
我不想使用消息过期，因为它依赖于发送应用程序，也不想使用pub/sub，因为如果应用程序不接收消息，它将填满文件系统等。我不希望消息堆积在队列中，因为应用程序关闭。
这种设置是必需的，这样就不会因为这个队列和使用它的应用程序而出现任何中断。有什么建议吗？
浏览 0提问于2020-03-20得票数 0
我正在使用QuickFIX/J来实现一个非常简单的应用程序，它可以跟踪TradeCaptureReport消息。基本上，应用程序只将通过public void fromApp(Message message, SessionID session)接收的所有消息存储到数据库中。
假设由于某种原因，数据库暂时关闭。解决这种情况的最佳办法是什么？
只需从public void fromApp(Message message, SessionID session)中抛出一个public void fromApp(Message message, SessionID session)。这将防止从队列
浏览 0提问于2016-01-31得票数 1
回答已采纳
我正在读关于SQS和消息队列的文章，我想知道当有一个快速的生产者和缓慢的消费者时会发生什么。会发生什么？消息堆积存储在哪里？它是否在内存堆栈上，最终发生堆栈溢出，服务器崩溃？这就是内存被用作有限队列的问题吗？
浏览 2提问于2020-01-13得票数 0
当我的拉取客户端关闭时，有没有办法管理推送服务器上的队列堆积？
我想在这种情况下实现一个封顶的FIFO消息队列。
(我使用的是Node.js)
谢谢！
浏览 4提问于2014-01-28得票数 1
我在我的项目中使用的是烧瓶引导，唯一的奇怪之处是每条闪存消息都显示在它们自己的块中，所以当一个页面显示3条消息时，它们“堆积”得很快。而且总是呈橙色，不管我给了他们什么颜色。是否有一种方法可以覆盖该行为，并将闪存消息合并到一个使用类别颜色正确的块中？
浏览 0提问于2015-05-07得票数 0
回答已采纳
我再cmq的广州节点创建了一个topic(ID为： topic-71efzxh6)， 同时对这个topic创建了一个订阅者，指定同样为广州节点的queue(ID为： subsc-lw3u5gq9)，我向topic发送消息， 消息无法到达订阅queue。
在topic中显示有消息堆积，查看topic的订阅者queue，显示有待投递消息，不知道为啥会出现这种情况？
看官方文档说明，向topic发送消息应该会立即投递到订阅者的啊？
浏览 562提问于2019-05-23
我是Active MQ的新手，但有时队列没有被处理并不断堆积，清除是一种好的做法吗?是否有其他解决方案可以阻止我保留所有消息以供清除之外的重新处理？我真的不想失去排队，这是可能的吗？
浏览 0提问于2017-10-10得票数 0
1回答
好吧，我有一个简单的PHP，它与ok相呼应。它在9292端口上，当我把index.php放在浏览器上时，我可以看到"OK“消息。所以我想从netcat收到它的输出。
nc xx.xxx.xxx.xx 9292
堆积如山。我做错什么了？
浏览 1提问于2015-04-28得票数 0
回答已采纳
我正在寻找一个如何使用Spring jms实现以下内容的示例。 我的应用程序从队列接收消息，经过一些处理后，将结果发送到web服务。该web服务现在支持批量消息，我们想开始使用它。The Client AcknowledgmentMode似乎是其中的一部分，但我还不明白我们如何防止消息堆积在应用程序的内存中。如果批量api请求或导致该请求的任何消息的任何处理失败，则必须回滚所有jms消息。
浏览 15提问于2019-10-07得票数 0
1回答
我的要求是设置EMS设置如下..这可行吗? 1.父EMS队列。2. Tibco BW发动机听取了儿童EMS的发言。
EMS队列将每分钟接收数千条消息。父队列必须堆积消息并将有限的消息传递给子队列，例如1000是限制。也就是说，子队列应该有1000条消息，其余的消息应该在父队列中。一旦Tibco BW使用了子队列中的一千条消息，则父队列将向子队列发送下一千条消息。这能办到吗？
浏览 6提问于2015-02-24得票数 1
回答已采纳
1回答
我通过SSH连接到服务器，有时它会冻结几分钟，然后抛出“管道破裂”消息并返回到我的控制台。当我再次登录并执行一个who时，我仍然可以看到用户已经登录，并且这些都在不断地堆积。我该怎么杀他们？我每次都是以根登录。
浏览 0提问于2011-12-27得票数 2
回答已采纳
1回答
public void onGuildMessageReceived(GuildMessageReceivedEvent e)
{
String message = e.getMessage().getContentRaw();
if(message.equalsIgnoreCase("!hi")) {
e.getChannel().sendMessage("Hi").queue();
}
if(messa
浏览 9提问于2020-09-01得票数 0
在WSO2 ESB4.9.0中，当批量消息出现在队列中时，我们面临着MQ代理的问题。
代理调用的后端服务每秒只能处理50个请求，超过这个数后，我们的后端服务将失败。
这里的问题是，当消息在队列上堆积(1000条消息)时，代理从队列中读取所有消息，并发送到后端服务&后端服务失败。
我们可以在代理上设置什么设置来控制代理服务读取的消息吗？
这里的主要问题是代理非常快地从队列中读取消息，并泛洪后端服务。后端服务失败，因为它们不能处理更高的负载
浏览 0提问于2016-07-06得票数 1
我正在向远程(场外) MQ服务器发送一条消息。收信人说他们没有收到我发送的信息，但是看起来我这边的情况很好。例如，如果我停止XMITQ，我发送的消息就会在那里堆积，直到我重新启动它。如果出现网络问题(例如，如果有人在我的终端上更改了防火墙/路由器设置)，我发送的消息会发生什么变化？我认为它最终会出现在死信队列中，但那里什么也没有。MQ消息消失似乎是没有意义的。
浏览 3提问于2014-12-02得票数 0
回答已采纳
1回答
我的要求是在java桌面应用程序中创建动态时间序列堆积面积图。像这样的例子，但我想要堆积面积图。我发现了很多堆积面积图的例子，但它们都是基于静态数据的。
浏览 1提问于2013-05-27得票数 3
回答已采纳
我需要安排延迟消息，所以我声明了一个带有x死信交换和x死信路由密钥的延迟队列DELAY_STAT，它将路由到默认的交换到我的目标队列统计数据。
当我需要为队列STAT安排延迟消息时，我会在到期时将消息发布到DELAY_STAT，当到达消息ttl时，它将是一个死信，然后路由到STAT，以便可以使用它。
但是我遇到了一个问题，据说
当设置每条消息时，TTL过期消息可以排在未过期消息的后面，直到后者被使用或过期为止。
这意味着如果B更早地发送，一些短延迟消息A将被长延迟消息B所堆积。
浏览 1提问于2018-06-22得票数 0
我们使用的是hornetq-core 2.2.21。最后，在阅读了一条非跨国消息之后，该消息仍然处于队列中，尽管它确认会话是使用
sessionFactory.createSession(true, true, 0)
定位器设置：
val transConf = new TransportConfiguration(classOf[NettyConnectorFactory].getName,map)
val locator = HornetQClient.createServerLocatorWithoutHA(transConf)
locator.setBlockOnDurableSen
浏览 1提问于2013-12-17得票数 1
回答已采纳
我有一个Gmail过滤器，它将标签(‘OTP’)应用于某些传入的消息。它们堆积在一起，我只想保存几天。
我可以手动删除它们，方法是执行搜索(例如，'older_than:2d label:OTP -label:GST')，然后删除结果，但是我想使用一个过滤器来自动化这个过程。
下面的示例显示了一个突出显示的消息线程“SMS转发器”，该线程共有21条单独消息，其中只有7条符合我的删除标准，其余14条将保留。
📷
浏览 0提问于2021-09-10得票数 1
2回答
如何停止gem创建的cron作业
、、、、
我正在使用“任何时候”gem，并通过执行以下操作使其正常工作：
whenever --set environment=production --update-crontab theCronJob
我使用的时间间隔是2分钟，因为我还在尝试弄清楚。但是，现在我每隔2分钟就会在我的终端窗口中收到一条您有邮件的消息。我猜cron会运行并让我知道这一点。如何停止我的cron运行？这些消息开始堆积起来。
谢谢
浏览 0提问于2011-12-16得票数 15
回答已采纳
image.png
看控制台是有堆积的，实际是重试的导致的堆积，但是用go写的rocketmq exporter采集不到这个堆积数，只能采集normal的topic,不能采集到retry和死信的
image.png
浏览 367提问于2020-01-06
这里有一个快速的问题，我们看到如果我们将一条消息( modifyAckDeadline(0) )复制，并且它被发送到队列的最前面是很棒的，但是我们是否也必须在NACK之后确认这条消息呢?我们会问，因为我们在订阅指数备份中启用了0-600秒，我们看到了很多重复的消息，例如: 10条消息在10分钟后堆积到200条消息。因此，我们认为原始消息始终保持不变，直到达到指数后退的最大重试乘以消息的NACKs次数。
如果我们是对的，解决方案是简单的NACK ->，然后ACK原始消息或ACK然后NACK
确认截止日期= 600秒
已启用排序键
浏览 1提问于2022-01-04得票数 0
回答已采纳
我有一个web应用程序通过rebus发送消息来开始在远程机器上长时间运行的作业。我正在使用MSMQ传输。远程工作者可以并行处理5个操作。因此，如果远程工作人员很忙，一些消息可能会堆积在队列中，直到工作人员可以处理它们。同时，用户可能决定取消挂起的操作(或正在执行的操作)。在使用rebus (或任何总线)时，处理此特定场景的最佳策略是什么？
浏览 0提问于2015-09-17得票数 3
下面是我的整个HTML和CSS：
我在白手起家地聊一聊。我有一个包含div的可滚动div，每个消息都包含一个div。有点像
<div>
(undefined number of divs pertaining to the same class)
</div>
我想动画的消息，以使他们成为可见/无形的同时滚动，理想情况下，不允许一个消息可以看到部分。信息要么应该被看到，要么不应该被看到，而不是一半--就像现在一样。
因为它是聊天，消息会堆积起来，所以滚动顶()会增加，每条消息的高度也是可变的，这取决于它有多少文本，所以我不知道该如何做。
浏览 3提问于2014-07-07得票数 1
回答已采纳
12回答
显示的错误消息是：
注册表中没有找到指定的目标组件- nb-base/8.0.1.0.201408251540。安装程序可以继续，好像指定了目标组件一样。单击“是”继续，单击“否”退出安装程序。
我已经多次尝试卸载我的NetBeans8.0.2，但是失败了。在谷歌找到了一个解决方案之后。我想我应该加入堆积如山的行列。
浏览 18提问于2017-02-23得票数 12
我的应用程序每秒收到大约2000条字符串消息，每条消息大约有300个字符长。
我需要将所有消息存储在DB中。我正在使用2008和.NET。
我正在考虑将所有数据保存在内存中，直到达到一定的限制(例如，10000条消息=5秒)，然后一次把它全部写下来。
这样，数据将被写入硬盘驱动器每5秒，而不是每秒钟。
我的方法够好吗？为了取得以下结果，我应该使用什么方法？
消息没有堆积在内存中。
)硬盘不会自杀:)
注意:没有必要解析字符串，唯一的办法是按照它们到达的顺序来存储它们。
浏览 7提问于2011-09-30得票数 2
回答已采纳
3回答
不支持直通，已禁用总帐
、、、
我尝试使用selenium和webdriver_manager.chrome爬行特定的站点，我的代码完全爬行了该站点的元素。但是在爬网之后，控制台窗口中会出现以下错误消息。
ERROR:gpu_init.cc(426) Passthrough is not supported, GL is disabled
当我第一次发现它的时候，我没有勾选chrome的硬件硬件堆积，也没有解决这个问题。
浏览 1提问于2021-05-12得票数 21
我已经多次提到这是一个最佳实践，即应该为每个消息类型配置一个分发服务器进程，但从来没有解释过为什么会这样。由于增加分发者的数量增加了部署的复杂性，我想知道它背后的原因。我的猜测是，如果给定消息类型的所有可用订阅者都很忙，分发服务器可能会等待一个订阅者被释放，而其他类型的消息可能有空闲的订阅者堆积在分发服务器的工作队列中。这是准确的吗？还有其他原因吗？
浏览 3提问于2011-04-28得票数 2
回答已采纳
在微服务架构中，假设有一个业务场景，其中用户购买了将在两年后过期的东西，系统需要提前一点通知用户。 在这种情况下，我们应该如何处理这种情况，以便即使有许多用户需要通知，也可以及时通知用户？ 例如，使用消息队列的延迟队列将导致当有许多用户时消息堆积；使用定时任务时，太多的用户将使服务器CPU过载。 有什么好方法可以做到这一点吗？
浏览 64提问于2021-04-16得票数 0
3回答
我继承了一个从MSMQ中提取消息的应用程序，它对消息进行一些处理，然后根据消息中的内容向数据库添加一些数据。消息正被我无法控制的第三方应用程序推入队列。
我对MSMQ知之甚少，尽管我对如何使用这些API有基本的了解。
无论如何，我注意到这些消息从来没有被删除过，我们的客户端绝对不会明确地删除它们，我可以在计算机管理中查看这些消息，并将消息返回到服务器上一次重新启动时。
这是错的吗？，当队列达到最大大小时，消息会自动被删除吗?或者它们会永远堆积在那里，慢慢地占用更多的内存吗？
浏览 7提问于2009-05-11得票数 2
回答已采纳
我在WebLogic中配置了一个JMS服务器、一个JMS队列和一个连接工厂。我的应用程序侦听此weblogic上配置的MQ队列，以使用这些消息并将其转换并发送到下游应用程序。我的问题是，上游应用程序向weblogic队列注入了太多消息，而我的应用程序无法以相同的速度使用这些消息。这是在堆积消息队列。
是否有一种方法可以控制从上游应用程序到我的应用程序weblogic队列的消息，以便我的应用程序可以在将任何新消息放入队列之前对现有消息进行处理？
我在weblogic中看到了这么多设置，但我不确定要使用哪一种设置
Weblogic 12.1.1 4 Java 1.8
浏览 4提问于2022-10-12得票数 0
3回答
我正在构建一个工具来使用Kafka中的数据，并将它们插入到MongoDB中，并进行一些操作。
现在我要做的是：
// Poll during X ms
ConsumerRecords<String, String> records = consumer.poll(Duration.of(100, ChronoUnit.MILLIS));
// For each record, insert it into Mongo
for (ConsumerRecord<String, String> record : records) {
System.out.printl
浏览 1提问于2018-12-13得票数 0
我们使用的是。
应用场景:服务器通过websocket向客户端高速推送消息。
最近我们遇到了一个问题，客户端无法处理来自socket.io服务器的所有事件消息。websocket消息开始堆积，客户端变成了unresponsive.In Chrome开发工具，我们可以看到客户端的内存逐渐增加。
使用wireshark分析tcpdump表明，发生了大量重新传输，客户端无法应对。
我们计划在服务器side.Is有一个节流机制，有什么事件/回调可以用来检测慢速客户端，这样我们就可以开始在服务器端对这个特定的websocket进行节流？
浏览 5提问于2015-03-05得票数 1
我有一个系统正在处理来自MSMQ队列的消息(使用多个进程进行处理)。
每个消息处理都意味着读取一些行，并进行3次更新和1次插入。我使用这个系统每秒处理大约60条消息。
令我困惑的是，无论出于什么原因，当队列中的消息堆积起来，并且系统正在以最快的速度处理消息时，CPU使用率呈现出一个周期，峰值为95%-100%，谷值为50%-45%。即使我添加了更多的进程来进行处理，这种行为仍然存在。
当工作负载意味着行插入和更新(我在考虑缓存刷新等)时，SQL Server会显示出这种行为吗？也许这与主机有关(这是在Hyper-V上运行的，而不是在真正的硬件上运行)？
下面是一个perfmon运行的链接：
浏览 0提问于2011-10-11得票数 0
回答已采纳
我在MQ集群基础结构中看到一个问题，其中消息堆积在SYSTEM.INTER.QMGR.PUBS中，它存在于队列管理器中
定义了集群主题。
Infocenter说：“在发布/订阅集群中，这些发布是针对远程队列上的SYSTEM.INTER.QMGR.PUBS队列的
托管订阅的管理人员。“
我想知道消息流是如何与队列管理器中的SYSTEM.INTER.QMGR. PUBS队列工作的，主题和订阅定义为
聚类主题与局部假设
本地主题和本地订阅
如果主题是定义在队列管理器的本地的，那么这里有人能帮助理解消息是否流经SYSTEM.INTER.QMGR.PUBS队列吗？
浏览 2提问于2016-04-01得票数 0
我正在使用ws Node.js包创建到每秒发送数百条消息的服务器的简单WebSocket客户端连接。即使使用仅对传入消息执行console.logs的简单onMessage处理程序，客户端也无法跟上。我的理解是，这被称为背压，传入的消息可能会开始堆积在客户端的网络缓冲区中，或者服务器可能会一起限制连接或断开所有连接。
如何从客户端监控背压或网络缓冲区？我已经找到了几篇从服务器的角度讨论这个问题的文章，但我无法控制服务器，需要知道我的客户端到底有多慢？
浏览 4提问于2020-05-25得票数 3
我在找伪码或真码。
我的目标是在两个边界之间的任意时间显示一个模态消息框(如“保持在顶部”和“不可规避”)，比如t_in_minutes_minimum和t_in_minutes_maximum，它们的内容总是相同的。
如果我不点击up，信息不应该堆积如山，而是关闭自己在一段时间后。
有办法和报警器联系吗？
如何在应用程序之外显示模态消息？
一段时间后，我怎样才能让我的信息在没有敲击的情况下自动关闭呢？
PS:我试了很多次。
浏览 5提问于2017-01-20得票数 0
回答已采纳
嗨，我看不到任何关于collapse_key实现的解释。我想我知道它是做什么的，但不知道它是如何做到的！
我有一个C2DM框架设置和发送4种类型的消息到许多手机。
非常基本的字符串消息看起来像这样：
type:name:uuid
type:name:uuid:number
type:uuid:id
如果手机关机了，那么等待手机在线时，许多邮件就会堆积如山。据我所知，我的系统工作正常，但是collapse_key将在这里为我做什么呢？
addEncodedParameter(sb，"collapse_key"，"no_ide_what_to_put_here")；
浏览 0提问于2011-04-12得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
