我目前正在研究使用 JMS(即 Spring 框架 JMS 和 Active MQ)在服务器和客户端之间发送带有负载的消息的应用程序的带宽限制功能(不要问我为什么,这不是我的决定)。
我发现了很多限制传入 JMS 消息的方法(但没有一个是基于实际带宽负载的),但是我没有找到任何可能的方法来限制传出消息流。所以我决定自己写漏桶算法。
有什么方法可以获取JMS消息的大小吗?除了Java中的“sizeof”实现之外(在Java中,确定对象大小的最佳方法是什么?)
我认为没有比测量其序列化大小更好的替代方法来确定 JMS 消息大小。
但是如果您愿意,您可以添加一些优化。消息有多种类型(例如 MapMessage、ObjectMessage、TextMessage)。
短信的大小是指其文本的长度。 Map消息的大小是其所有字段的总大小。这些字段是原语或java.util.Date,因此测量它们不是问题。 对象消息包含可序列化的对象,因此您可以通过写入 ByteOutputStream 来测量其大小。
我认为,如果您使用大多数 JMS 提供程序的隐藏功能来发送延迟消息,那么使用 JMS 实现漏桶可能会得到简化。您可以在将消息放入队列时对其进行测量,并决定希望订阅者何时接收它。 请阅读此处了解如何发送延迟消息的详细信息:http://alexradzin.blogspot.com/2010/10/send-delayed-jms-messages.html
由于JMS消息在发送过程中是序列化的,因此获取消息大小的最佳方式是通过ObjectOutputStream。
private int getMessageSizeInBytes(MessageWrapper message) throws IOException {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
ObjectOutputStream oos = new ObjectOutputStream(baos);
oos.writeObject(message);
oos.close();
return baos.size();
}
除了 @AlexR 之前的评论之外,BytesMessage 还有一个 getBodyLength() 方法
http://download.oracle.com/javaee/1.4/api/javax/jms/BytesMessage.html#getBodyLength
并且您可以通过捕获使用 Session.createMessage() 创建的一些对象(即没有有效负载的 JMS 消息类型)来估计传输中的典型标头大小。我想我会倾向于直接使用 byte[] 中的有效负载,使用 BytesMessage,并在带宽至关重要的情况下通过 ZipOutputStream 进行压缩。此外,JMS 允许提示抑制消息时间戳和消息 ID,这可能有助于减少消息大小,例如
虽然提供商不需要支持它,
如果JMS提供者接受这个提示,这些消息必须将消息ID设置为null;如果提供者忽略提示,则消息 ID 必须设置为其正常的唯一值
我曾经在 WebSphere MQ 上使用带宽非常有限的 JMS,通过这种方式可以使消息大小相当小 - 尽管在这种情况下本机线框格式也针对大小进行了优化