Apache ActiveMQ Artemis消息大小配置
我正在试用ActiveMQ Artemis进行消息传递设计。我期待消息与嵌入的文件内容（字节）。我不希望它们大于10MB。但是，我想知道在Artemis中是否有一种可配置的方法来处理这个问题。它是否支持默认的最大消息大小？我试着寻找答案，但没有找到任何答案。另外，我的生产者和消费者都是。NET AMQP实现。
共有1个答案
ActiveMQ Artemis本身并不限制消息的大小。它支持任意大的消息。但是，您将受到以下几件事的约束：
- 代理的堆空间：如果客户端在一个块中发送消息，这导致代理超出了可用的堆空间，那么发送消息将失败。代理不能控制AMQP客户端如何发送消息。我相信AMQP支持分块发送消息，但我不能百分之百肯定这一点。
- 代理的磁盘空间：代理认为“大”的AMQP消息（即不能放入单个日记文件中的消息）将直接存储在
data/largemessages目录中的磁盘上。ActiveMQ Artemis日记文件大小由broker.xml中的journal-file-size配置参数控制。默认journal-file-size为10MB。默认情况下，当磁盘空间利用率达到90%时，代理将停止向生产者提供信用。这由broker.xml中的max-disk-usage配置参数控制。
-
是否有一种方法可以强制TextInputLayout错误消息使用一行？ 我尝试将放置在TextInputLayout上，其error_apperation样式包含： 但它不起作用。然而，改变颜色是有效的。我不明白，mErrorView只是一个文本视图，它应该可以工作。
-
我想知道Kafka中信息的压缩大小。 我使用kafka 1.1.0和java kafka connect 1.1.0从我的制作人向主题发送消息。 如果消息对我的制作人来说太大，我会得到一个 消息序列化时为xxx字节，大于使用max.request配置的最大请求大小。大小配置。 设置最大请求。将大小设置为合适的值将导致来自代理的错误消息作为消息。代理配置中的max.bytes也必须相应地进行调整。不
-
如何获得Kafka单张唱片的大小？ 有一些关于我为什么需要这个的说明。 这似乎不是在ConsumerRecord或RecordMetadata类上公开的serializedValueSize。我并不真正理解这个属性的价值，因为它与对消费者有用的消息的大小不匹配。serializedValueSize用于什么？ 最大Poll.Records 在对poll（）的单个调用中返回的最大记录数。 这并不存在
-
我目前使用的是Kafka0.9.0.1。根据我找到的一些来源，设置消息大小的方法是修改中的以下键值。 message.max.bytes replica.fetch.max.bytes fetch.message.max.bytes 我的文件实际上有这些设置。 其他可能相关的设置如下。 但是，当我试图发送具有4到6 MB大小的有效负载的消息时，使用者永远不会得到任何消息。生产者似乎在发送消息时没有
-
设置节点允许的消息大小上限。大于此限制的接收和发送消息都将被拒绝。 Whisper中的消息大小不能超过底层P2P协议的10Mb上限。 调用： web3.shh.setMaxMessageSize(size, [callback]) 参数： size：Number - 字节为单位的消息大小 callback：Function - 可选的回调函数，其第一个参数为错误对象，第二个参数为返回结果 返回值
-
在Log4J2中，当大小超过指定阈值时，我希望修剪写入控制台附加器的消息的结尾。 知道吗？