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

Question

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

我使用Hibernate Envers在审核表中保存了一些信息。当存在请求时(来自我的REST控制器(时，这很好，因为需要记录用户，因此在这种情况下始终可以找到用户。

但是，我也与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$1.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

我想忽略这种情况，因为在这种情况下我的意图是用"系统"之类的东西填充"用户"信息。表明此更改不是用户直接进行的(因为没有用户设想(。

我的代码在下面。

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());