@Autowired在可运行单元内不起作用

Question

我有一个可运行的任务，我试图自动连接字段，但当我这样做时，任务不会运行。当我自动连接runnable外部的字段时，它工作正常。为什么会发生这种情况？还有没有其他更简单的方法可以在runnable中获取自动安装字段的新实例，而不是在内部自动安装它？

这是我的可运行方法”

Runnable task = new Runnable() {

                @Autowired
                ICruxPanelClientService CruxPanelClientService;

                public void run (){
            CruxPanelClientService.setCruxWebServiceBaseURL("http://10.41.181.23:8080");
            CronCruxModel m = new CronCruxModel();
            m = model1.get(model_var);
            System.out.println("EXECUTING");
            System.out.println(m.getService_status() + " ---------EXEexecution");
            System.out.println(m.getCat_name() + "Executing Name ");
        //  time = m.getService_time();
            UpdateCategoryRequest updateCategoryRequest = new UpdateCategoryRequest();
            CategoryModel categoryModel = new CategoryModel();
            categoryModel.setColor(m.getCat_color());
            categoryModel.setIcon(m.getCat_icon());
            categoryModel.setIconWhite(m.getCat_icon_white());
            categoryModel.setName(m.getCat_name());
            categoryModel.setId(m.getCat_id());
            categoryModel.setKey(m.getCat_catkey());
            categoryModel.setIndexOrder(m.getCat_indexOrder());
            updateCategoryRequest.setCategory(categoryModel);
            CruxPanelClientService.updateCategory(updateCategoryRequest);
            GetServiceDataIdByCategoryIdRequest request1 = new GetServiceDataIdByCategoryIdRequest();    
            request1.setId(m.getCat_id());
            GetServiceDataIdByCategoryIdResponse response1 = CruxPanelClientService.getServiceDataIdByCategoryId(request1);
            ArrayList<ServiceModel> service = new ArrayList<ServiceModel>();
            service = response1.getServiceModels();

            JSONArray json = new JSONArray();
            if(m.getService_order_succ_msg()==null)
            {
                json = new JSONArray();
            }
            else {

                 json = new JSONArray(m.getService_order_succ_msg());
            }
            String message = m.getService_order_succ_msg();

            for (int j=0;j<service.size();j++)
            {   
                UpdateServiceMasterRequest req = new UpdateServiceMasterRequest();
                ServiceModel s = new ServiceModel();
                s=service.get(j);
                ;
                JSONObject obj = new JSONObject();

                if(json.length()==0 ) 
                {
                    String ms = null;
                    s.setOrderSuccessMessage(ms);
                    req.setServiceModel(s);

                }

                else {

                    String message1 = json.get(j).toString();

                    if(message1.equals(null) || message1.equals("")) {
                        String ms = null;
                        s.setOrderSuccessMessage(ms);
                        req.setServiceModel(s);

                    }
                    else {
                        s.setOrderSuccessMessage(message1);

                        req.setServiceModel(s);

                    }
                }
                CruxPanelClientService.updateServiceMaster(req);

            }
            m.setService_status("executed");
            UpdateCronCruxRequest q = new UpdateCronCruxRequest();
            q.setCronCruxModel(m);
            CruxPanelClientService.updateCronCrux(q);

                }
            };`

Answer 1

Spring不@autowire任何东西进入非托管实例（您使用new创建的实例，与Spring创建和管理的实例相反）。

这给你留下了以下选择:

• @autowire外部的依赖项，并将其传递给Runnable（或使其可由Running访问）
• 创建一个新的类子类Runnable，并在需要的地方创建@autowire
• 不需要注入依赖项，而是在需要时查找它（applicationContext.getBean（..））

使用线程时要小心作用域和延迟初始化，因为一些Spring作用域（例如“请求”或“会话”作用域）是线程本地绑定的（例如，在新线程中使用延迟请求作用域依赖项时，该依赖项在执行时不再与当前请求关联）。

Answer 2

@Autowire不能用于匿名类（因为您调用了new，而不是Spring），您可以在外部类中自动连接一个字段，然后在Runnable中使用该字段。

或者使Runnable成为一个完整的类（不是匿名的）并使其成为bean（并自动装配，例如使用id）

Answer 3

问题是Spring不能控制可运行文件的创建。有几种可能的解决方案：

1. 将可运行的创建放在一些服务、存储库、控制器、组件或spring曾经处理过的内容中：

示例:

@Service
public class SomeService {

    @Autowired
    private ICruxPanelClientService cruxPanelClientService;

    public Runnable newRunnable() {

        return new Runnable() {

            public void run() {
                cruxPanelClientService <- will be visible here and injected
            }
        }
    }

}

示例:

@Configuration
public class Runnableconfiguration {

    @Bean
    @Scope("prototype")
    public Runnable newRunnbale(final ICruxPanelClientService cruxPanelClientService) {
        return new Runnable() {
            public void run() {
                cruxPanelClientService <- will be visible here
            }
        }
    }
}