java - Jersey 2.0 : Create repeating job

Question

在我们的 REST-Service 中，我们希望实现一个每 10 秒检查一次的作业。所以我们认为我们可以使用 Quartz 来制作一个涵盖此内容的作业。但问题是，我们需要注入(inject)一个单例，因为它在作业中使用，而作业似乎不在我们的服务上下文中，因此注入(inject)的类始终为 null (NullPointerException)。

那么有没有另一种可能的解决方案可以在不使用 Quartz 的情况下完成这样的工作？已经尝试编写我们自己的 JobFactory 将作业与 BeanManager 连接起来，但它根本不起作用。

这是不起作用的作业的代码:

@Stateless
public class GCEStatusJob  implements Job, Serializable{

    private Logger log = LoggerFactory.getLogger(GCEStatusJob.class);

    @Inject
    SharedMemory sharedMemory;

    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        GoogleComputeEngineFactory googleComputeEngineFactory = new GoogleComputeEngineFactory();

        List<HeartbeatModel> heartbeatList = new ArrayList<>(sharedMemory.getAllHeartbeats());
        List<GCE> gceList = googleComputeEngineFactory.listGCEs();
        List<String> ipAddressList = gceList.stream().map(GCE::getIp).collect(Collectors.toList());

        for(HeartbeatModel heartbeat : heartbeatList){
            if(ipAddressList.contains(heartbeat.getIpAddress())){
                long systemTime = System.currentTimeMillis();

                if(systemTime-heartbeat.getSystemTime()>10000){
                    log.info("Compute Engine mit IP "+heartbeat.getIpAddress()+" antwortet nicht mehr. Wird neu gestartet!");
                    String name = gceList.stream().filter((i) -> i.getIp().equals(heartbeat.getIpAddress())).findFirst().get().getName();
                googleComputeEngineFactory.resetGCE(name);
                }
            }
        }
    }
}

SharedMemory 始终为空。

Answer 1

我使用了Scheduler上下文映射来实现这一点。你可以试试这个。

在 REST API 中，当我们创建 Scheduler 时，我们可以使用上下文映射将参数传递给 Job

@Path("job")
public class RESTApi {
    private String _userID;

    public String get_userID() {
        return _userID;
    }

    public void set_userID(String _userID) {
        this._userID = _userID;
    }
    @GET
    @Path("/start/{userId}")
    public void startJob(@PathParam("userId") String userID) {
        _userID = userID;
        try {
            SimpleTrigger trigger = new SimpleTrigger();
            trigger.setName("updateTrigger");
            trigger.setStartTime(new Date(System.currentTimeMillis() + 1000));
            trigger.setRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY);
            trigger.setRepeatInterval(1000);
            JobDetail job = new JobDetail();
            job.setName("updateJob");
            job.setJobClass(GCEStatusJob.class);
            Scheduler scheduler = new StdSchedulerFactory().getScheduler();
            scheduler.getContext().put("apiClass", this);
            scheduler.start();
            scheduler.scheduleJob(job, trigger);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

作业实现

public class GCEStatusJob implements Job {
    @Override
    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        RESTApi apiClass;
        try {
            apiClass = ((RESTApi) arg0.getScheduler().getContext().get("apiClass"));
            System.out.println("User name is" + apiClass.get_userID());
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
    }

}

如果我的理解有误，请纠正我。