Java 中 RabbitMQ 怎么使用 RabbitTemplate 的 convertAndSend 异步将实体对象序列化并发布-java教程-PHP中文网

rabbittemplate 的 convertandsend 默认对业务代码表现为异步发送，需配置 jackson2jsonmessageconverter 实现 json 序列化，实体类须有无参构造及 getter/setter，消费者端需使用相同 converter 以确保反序列化成功，并建议开启 confirm/return 机制保障可靠性。

java 中 rabbitmq 怎么使用 rabbittemplate 的 convertandsend 异步将实体对象序列化并发布

RabbitTemplate 的 convertAndSend 默认就是异步发送的（底层基于 Spring AMQP 封装的 RabbitMQ Java Client，实际调用是同步 I/O，但对业务代码而言无阻塞等待逻辑），关键在于配置好序列化器，让实体对象能被自动转成字节并正确送达队列。

确保使用 Jackson2JsonMessageConverter

默认的 SimpleMessageConverter 只支持 String、byte[]、Serializable，不推荐直接序列化自定义实体类。应显式配置 Jackson2JsonMessageConverter，它能把 Java 对象转为 JSON 字符串再封装成 Message：

在配置类中注入 converter 并绑定到 RabbitTemplate：

@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
    RabbitTemplate template = new RabbitTemplate(connectionFactory);
    template.setMessageConverter(new Jackson2JsonMessageConverter());
    return template;
}

实体类需有无参构造函数，字段用 public 或配 getter/setter；如需控制字段忽略或重命名，加 @JsonIgnore 或 @JsonProperty
发送时无需手动序列化，直接传对象即可：

rabbitTemplate.convertAndSend("exchange.name", "routing.key", new User("Alice", 28));

注意消息体编码与消费者兼容性

JSON 序列化后消息 body 是 UTF-8 字节数组，contentType 自动设为 application/json。消费者端也必须用相同的 converter 才能反序列化成功：

Docker Container Cleaner

CLI工具，用于清理已停止的Docker容器、未使用的镜像、卷和网络，释放磁盘空间。

下载

消费者 RabbitListener 或 MessageListener 需同样配置 Jackson2JsonMessageConverter
若消费者是其他语言（如 Python），需确认其能解析标准 JSON，并注意时间类型（LocalDateTime 默认转为 ISO 格式字符串）、枚举序列化方式等
避免在实体中放不可序列化的字段（如 ThreadLocal、InputStream），否则会抛 NotSerializableException

处理异常与可靠性保障

convertAndSend 不会抛出网络异常（失败由 confirm 或 return 机制捕获），但序列化失败会立即报错：

若对象含非标准类型（如 JPA 代理、Hibernate lazy 对象），先调用 initialize 或转为 DTO 再发
开启 publisher confirms 和 mandatory 以捕获路由失败：

rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
    if (!ack) log.error("消息未确认: {}", cause);
});
rabbitTemplate.setMandatory(true); // 路由不到队列时触发 ReturnCallback

配合 @EnableRabbit 和 @RabbitListener 实现自动重试、死信等高级能力

可选：自定义序列化行为

如需修改 JSON 输出格式（如日期格式、缩进、空值处理），可定制 ObjectMapper：

ObjectMapper objectMapper = new ObjectMapper();
objectMapper.registerModule(new JavaTimeModule()); // 支持 LocalDateTime
objectMapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
Jackson2JsonMessageConverter converter = new Jackson2JsonMessageConverter(objectMapper);