"Error creating bean with name 'scopedTarget.get'" 收到 RabbitMQ 消息时

Question

当我没有请求范围时，我在忽略 @Scope 时遇到了一些问题。我可以解释。

我正在使用 Hibernate Envers 在审计中保存用户的一些信息 table。这在存在请求（来自我的 Rest Controller）时效果很好，因为用户需要登录，所以在这种情况下总能找到用户。

但是，我也在使用 RabbitMQ。当我收到一些需要对数据库执行某些操作的消息时（例如，插入一个实体），我的代码尝试从应用程序上下文加载 User bean。 User Bean 与 @Scope 请求绑定，而 Spring 找不到线程绑定请求。

因此，我收到错误消息：

Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'scopedTarget.get': Scope 'request' is not active for the current thread; consider defining a scoped proxy for this bean if you intend to refer to it from a singleton; nested exception is java.lang.IllegalStateException: No thread-bound request found: Are you referring to request attributes outside of an actual web request, or processing a request outside of the originally receiving thread? If you are actually operating within a web request and still receive this message, your code is probably running outside of DispatcherServlet/DispatcherPortlet: In this case, use RequestContextListener or RequestContextFilter to expose the current request.
        at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:355)
        at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:197)
        at org.springframework.aop.target.SimpleBeanTargetSource.getTarget(SimpleBeanTargetSource.java:35)
        at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.getTarget(CglibAopProxy.java:705)
        at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:655)
        at com.domain.config.UserConfiguration$User$$EnhancerBySpringCGLIB$$c7e6e64e.getUserId(<generated>)
        at com.domain.audit.RevisionEntityListener.newRevision(RevisionEntityListener.java:28)
        at org.hibernate.envers.internal.revisioninfo.DefaultRevisionInfoGenerator.generate(DefaultRevisionInfoGenerator.java:93)
        at org.hibernate.envers.internal.synchronization.AuditProcess.getCurrentRevisionData(AuditProcess.java:114)
        at org.hibernate.envers.internal.synchronization.AuditProcess.executeInSession(AuditProcess.java:96)
        at org.hibernate.envers.internal.synchronization.AuditProcess.doBeforeTransactionCompletion(AuditProcess.java:153)
        at org.hibernate.envers.internal.synchronization.AuditProcessManager.doBeforeTransactionCompletion(AuditProcessManager.java:46)
        at org.hibernate.engine.spi.ActionQueue$BeforeTransactionCompletionProcessQueue.beforeTransactionCompletion(ActionQueue.java:928)
        ... 38 common frames omitted
Caused by: java.lang.IllegalStateException: No thread-bound request found: Are you referring to request attributes outside of an actual web request, or processing a request outside of the originally receiving thread? If you are actually operating within a web request and still receive this message, your code is probably running outside of DispatcherServlet/DispatcherPortlet: In this case, use RequestContextListener or RequestContextFilter to expose the current request.
        at org.springframework.web.context.request.RequestContextHolder.currentRequestAttributes(RequestContextHolder.java:131)
        at org.springframework.web.context.request.AbstractRequestAttributesScope.get(AbstractRequestAttributesScope.java:41)
        at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:340)
        ... 50 common frames omitted

我想忽略这种情况，因为在这种情况下我的意图是用 "system" 之类的东西填充 "user" 信息。表明此更改不是由用户直接进行的（因为没有涉及用户）。

我的代码如下。

RevisionEntityListener（Hibernate Envers）：

@Component
public class RevisionEntityListener implements RevisionListener, ApplicationContextAware {

    private static ApplicationContext applicationContext;

    @Override
    public void newRevision(Object revisionEntity) {

        RevEntity revEntity = (RevEntity) revisionEntity;

        User user = applicationContext.getBean(User .class);
        revEntity.setUserId(user.getUserId());
        // code
    }

    private static void setStaticApplicationContext(ApplicationContext context) {
        applicationContext = context;
    }

    @Override
    public void setApplicationContext(ApplicationContext applicationContext)
            throws BeansException {
        setStaticApplicationContext(applicationContext);
    }

}

我的UserConfiguration:

@Configuration
public class UserConfiguration {

    @Autowired
    private OAuth2ClientContext context;

    @Bean
    @Scope(proxyMode = ScopedProxyMode.TARGET_CLASS, scopeName = "request")
    public User get() {
        User user = null;
        try {

            String token = context.getAccessToken().getValue();
            // code
        return user;
    }

    @Getter
    @Setter
    @ToString
    public static class User {
        private Long userId;
        // all user information
    }

}

Answer 1

我不知道这是否是最佳选择，但我创建了一个 if 来查看 SecurityContextHolder.getContext().getAuthentication() 是否存在：

User user;
if (SecurityContextHolder.getContext().getAuthentication() != null) {
    user = applicationContext.getBean(User .class);
} else {
    user = createSystemUser();
}
revEntity.setUserId(user.getUserId());

"Error creating bean with name 'scopedTarget.get'" 收到 RabbitMQ 消息时

"Error creating bean with name 'scopedTarget.get'" when receiving a RabbitMQ message

java

spring

scope

hibernate-envers

spring-bean