活动 MQ 消息大小或对对象的引用
我想通过ActiveMQ传递一条大消息。还有两个消费者/生产者。第一个是基于Spring MVC构建的，第二个使用Apache camel从队列中获取消息。问题是，我试图推送一条包含大约10 mb数据的短信，但ActiveMQ代理拒绝了它，并显示错误消息。
org.springframework.web.util.NestedServletException：
请求处理失败；嵌套异常是Java . lang . illegalstateexception:
表格太大：10037142
我知道有机会使用对存储在FS中的对象的引用，但我没有找到任何可以解决此问题的库。
共有1个答案
我认为这个错误是在生产者客户端，但你可以确认这一点，并取决于客户端应用程序类型，如果它是基于spring boot或jetty，tomcat有不同的方法来解决这一限制，这里的解决方案的例子取决于您的配置表单过大异常和Spring Boot Rest服务表单过大。你也可以使用博客消息，http://activemq.apache.org/blob-messages.html
-
如何配置我的以丢弃未使用的消息？ 我不希望我的客户端在订阅服务器队列时收到服务器发送的所有旧消息。 这是我目前的经纪人： 目前，我的服务器首先启动并发送大约10条消息。之后，我的客户机订阅队列，并接收在没有客户机订阅时发送的所有10条消息。我不想要这种行为。 解决 然后我发出这样一条信息: 解决方案2 我创建了一个主题而不是队列。 http://Java sample approach . com
-
我正在尝试建立一个简单的 ActiveMQ 代理网络。我有2台机器，比如A和B。 在A的< code>activemq.xml文件中，我放置了networkConnector，它具有指向机器b的URI。在A的日志中，显示它连接到了b 我有一个向A发送消息的应用程序。在ActiveMQ的网络控制台的网络选项卡中，我可以看到我的消息正在排队和出队（我认为这意味着消息被转发到机器B）。 我的问题是消息在
-
我正在使用apache camel（Fuse 2.10.x)和soap over http和soap over JMS。JMS消息由对象消息转换为字节消息格式，这就造成了消息读取的问题。 我正在JBoss5.0GA环境中使用用于websphere MQ的JNDI连接。 我们遇到了IBM属性的另一个问题，通过删除属性解决了这个问题。我们还有camel header属性来设置消息
-
在 http://activemq.apache.org/message-groups.html 中，据说消息组提供了跨多个使用者的消息处理的负载平衡。 虽然我读了整篇文章，但我不明白消息组和负载平衡之间的关系。毕竟，在消息组之前就已经有了负载平衡:消息代理根据消费者的确认速度来分发消息。因此，如果消息组涉及负载平衡，就粒度而言，它是一个更大的负载平衡。 正确吗？ 如有任何意见或见解，我们将不胜感
-
要求：一个activemq队列应该在一台机器（比如machine1)中运行。该队列应该从machine1和另一台机器（比如machine2)中访问。监听器将只在machine1中运行。因此，我发送到machine1和machine2的所有消息都应该进入machine1中可用的队列，并且应该被同一台机器(machine1)中可用的监听器接收。 问题：我发送到machine1和machine2的所有消
-
我对Kafka2.6.0中的消息大小配置有点困惑。但让我们讲一个故事： 我们正在使用由3个节点组成的Kafka集群。到目前为止，消息的标准配置。“zstd压缩”被激活。 相关的代理配置很简单： 此时，生产者配置也很简单： 现在我们想把一个8Mbyte的消息放到一个特定的主题中。这些数据的压缩大小只有200 KB。 如果我将这些数据放入主题中，会出现以下错误： 所以我改变了生产者配置如下： 现在制作