如何在RabbitMQ中发送ArrayList？Java项目批量传递需求咨询

可以，但需要注意序列化方式和消息大小限制这两个核心问题，下面是具体实现思路和注意事项：

核心实现思路 #

RabbitMQ本身仅传递字节流，因此你需要将ArrayList序列化为字节数组发送，接收端再反序列化为原ArrayList对象。常用的序列化方案有以下两种：

1. JSON序列化（推荐） #

使用Jackson或Gson这类JSON库将ArrayList转为JSON字符串，再转换为字节数组发送；接收端反向解析即可。这种方式兼容性强，无需让对象实现特定接口。

示例代码片段：

// 发送端：将ArrayList转为JSON字节数组
ObjectMapper objectMapper = new ObjectMapper();
List<YourObject> dataList = new ArrayList<>();
// 填充1000条业务数据
byte[] messageBytes = objectMapper.writeValueAsBytes(dataList);
channel.basicPublish(exchangeName, routingKey, null, messageBytes);

// 接收端：解析JSON字节数组为ArrayList
byte[] receivedBytes = delivery.getBody();
List<YourObject> receivedList = objectMapper.readValue(receivedBytes, new TypeReference<List<YourObject>>(){});

2. Java原生序列化 #

让你的业务对象类实现Serializable接口，直接将ArrayList序列化为字节流。这种方式仅适合纯Java环境，且对象结构变更时容易出现兼容性问题。

示例代码片段：

// 发送端
ByteArrayOutputStream bos = new ByteArrayOutputStream();
ObjectOutputStream oos = new ObjectOutputStream(bos);
oos.writeObject(dataList);
byte[] messageBytes = bos.toByteArray();
channel.basicPublish(exchangeName, routingKey, null, messageBytes);

// 接收端
ByteArrayInputStream bis = new ByteArrayInputStream(delivery.getBody());
ObjectInputStream ois = new ObjectInputStream(bis);
List<YourObject> receivedList = (List<YourObject>) ois.readObject();

关键注意事项 #

• 消息大小限制：RabbitMQ默认最大消息大小为128MB。1000条普通业务对象的ArrayList通常远低于这个阈值，但如果单个对象包含大体积数据（如嵌套大量字段、二进制文件），可能会超出限制。此时可选择：
  • 将数据拆分为多个小消息分批发送
  • 修改RabbitMQ配置文件rabbitmq.conf中的rabbitmq_server.max_message_size参数调整上限（不建议设置过大，会影响Broker性能）
• 序列化兼容性：确保发送端与接收端使用相同的序列化方案，且业务对象的字段名称、类型完全匹配
• 性能考量：大消息会增加网络传输时间与Broker内存占用，若后续数据量持续增长，建议采用批量发送或分块处理的方式

内容的提问来源于stack exchange，提问作者Srif Techman