响应式AMQP后台线程调用Spring Boot JPA结合Hibernate Envers报错如何解决

错误栈已经明确指向com.my.package.revision.AuditRevisionListener第10行空指针，并非事务没有在Service内正常完成，问题核心是：
你自定义的Envers审计监听器中大概率是从Spring Security上下文、或者Servlet请求上下文里读取操作人等审计字段，而你用Schedulers.boundedElastic()调度的后台线程没有绑定这些上下文，读取内容为空直接使用就触发了空指针，导致事务提交前的Envers回调失败。关闭Envers后不会触发这个回调，所以逻辑可以正常运行。

方案1：添加空值兜底逻辑 #

直接修改你的AuditRevisionListener，加空判断给审计字段设置默认值，适配无请求上下文的后台任务场景：

// 示例代码，对应你的AuditRevisionListener实现
@Override
public void newRevision(Object revisionEntity) {
  AuditRevisionEntity rev = (AuditRevisionEntity) revisionEntity;
  Authentication auth = SecurityContextHolder.getContext().getAuthentication();
  // 加空判断，后台任务没有用户上下文时用系统账号兜底
  if (auth != null && auth.isAuthenticated()) {
    rev.setOperator(auth.getName());
  } else {
    rev.setOperator("system-consumer");
  }
  // 剩余原有逻辑
}

方案2：手动传播上下文到异步线程 #

如果后台任务的操作人需要继承消息触发来源的上下文，可以在调度任务前先把当前上下文取出来，传到后台线程中绑定：

// 在SubscriptionReceiveController的flatMap逻辑中修改
receiver.receiveMessages().flatMap(message -> {
  // 先在当前调用线程拿到上下文
  SecurityContext securityContext = SecurityContextHolder.getContext();
  MyObject object;
  try {
    object = mapper.readValue(message.getBody().toString(), MyClass.class);
  } catch (JsonProcessingException e) {
    throw new JsonProcessingRuntimeException("Failed to convert message to object", e);
  }

  Mono<MyObject> blockingWrapper = Mono.fromCallable(() -> {
    try {
      // 给后台线程绑定上下文
      SecurityContextHolder.setContext(securityContext);
      return myService.updateMyObject(object.getId());
    } finally {
      // 线程用完必须清空上下文，避免线程复用导致的上下文污染
      SecurityContextHolder.clearContext();
    }
  });
  return blockingWrapper.subscribeOn(Schedulers.boundedElastic());
})

1. 改用Spring Cloud Azure官方注解消费：不需要自己手动维护响应式流订阅和线程调度，Spring会自动处理消息转换、上下文传播、并发控制：

@ServiceBusListener(
  destinationName = "你的服务总线主题/队列名",
  subscriptionName = "你的订阅名（如果是主题模式）",
  concurrency = "你想要的并发消费数"
)
public void consumeMessage(MyObject object) {
  myService.updateMyObject(object.getId());
  // 剩余其他处理逻辑
}

2. 用@Async注解封装异步逻辑：把JPA写入方法标记为@Async，Spring会自动管理异步线程池、事务绑定、上下文传播，不需要你手动写Mono包装和调度逻辑。

另外你当前把阻塞JPA操作放在boundedElastic调度器的做法是正确的，不要改成其他响应式调度器，避免阻塞事件循环线程。

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