2015-01-08 52 views

回答

0

简而言之:

与RabbitMQ的,你可以发送缓冲区,您可以创建缓冲区根据您的喜好,例如:

byte[] messageBodyBytes = ByteBuffer.allocate(4).putInt(yourint).array(); 
channel.basicPublish(exchangeName, routingKey, null, messageBodyBytes); 

,如果你要发送一个Java类,可以序列它使用JSON格式。

长:

您sholud读到这里的AMQP协议规范:https://www.rabbitmq.com/resources/specs/amqp0-9-1.pdf

+0

这是什么原因,它被设计为只使用字节[]。 –

1

你需要序列化/反序列化要发送的数据。也许使用JSON或XML或其他适合您应用程序的格式

0

您可以对任何实现了Serializable接口的Java对象进行序列化。