如何在 Dropwizard 中使用 Quartz 调度程序进行 REST 调用？答案

【问题标题】：How to use Quartz scheduler for REST call in Dropwizard?如何在 Dropwizard 中使用 Quartz 调度程序进行 REST 调用？
【发布时间】：2018-06-19 11:30:19
【问题描述】：

我想使用 Dropwizard 后端发出定期 REST 请求。更具体地说，我想每分钟向外部 REST API 发出 GET 请求并处理结果。

我使用了quartz here，现在我尝试使用jersey 客户端发出REST 请求。我使用 guice 作为我的依赖注入。

我的应用类有以下方法

 @Override
  public void initialize(final Bootstrap<DockerwizardConfiguration> bootstrap) {
    Job everyJob = new EveryTestJob();
    bootstrap.addBundle(new JobsBundle(everyJob));
  }

  @Override
  public void run(final DockerwizardConfiguration configuration,
      final Environment environment) {
    Injector injector = Guice.createInjector(new AbstractModule() {
      @Override
      protected void configure() {
        bind(HelloWorldParameter.class)
            .annotatedWith(Names.named("helloWorldParameter"))
            .toInstance(configuration.getHelloWorldParameter());
      }
    });
    JerseyClientConfiguration conf = configuration.getJerseyClientConfiguration();
    conf.setChunkedEncodingEnabled(false);
    final Client client = new JerseyClientBuilder(environment).using(conf).build(getName());

    environment.jersey().register(new ExternalServiceResource(client)); // How should that be implented with guice
    environment.jersey().register(injector.getInstance(HelloWorldResource.class));


  }

而我的 EveryTestJob 类实现如下

@Every("1s")
public class EveryTestJob extends Job {

  @Override
  public void doJob(JobExecutionContext context) throws JobExecutionException {
    // logic run every time and time again
  }
}

我不确定如何组织它。

【问题讨论】：

代码中的一切看起来都很好，您遇到什么问题了吗？
我不知道如何将客户端对象注入到资源中，还是应该注入到EveryTestJob
所有进行rest调用所需的代码都应该在EveryTestJob中注入和处理
我认为EveryTestJob必须在initialize方法中用bootstrap Jobbundle实例化

标签： java jersey quartz-scheduler guice dropwizard

【解决方案1】：

我一直在尝试解决这个问题，这就是我发现的：

JobBundle 添加在任何资源之前，因此 JobExecutionContext 将不包括客户端 (https://www.dropwizard.io/0.9.2/docs/manual/internals.html)
尝试使用注射器，但也没有用 (https://github.com/HubSpot/dropwizard-guice)

最后我偶然发现了Jersey 2.0: Create repeating job，它展示了如何将客户端添加到上下文中！

这是我的解决方案：

在资源类中，

@Path("/myPath")
public class myResource {

    @Inject
    public myResource() {
        try {
            Scheduler scheduler = new StdSchedulerFactory().getScheduler();
            scheduler.getContext().put"myResource", this); // Inserts myResource into the context
        } catch (SchedulerException e) {
            // Handle exception
        }
    }

    // Other stuff for api
}

然后在作业类中（我使用的是 Dropwizard-jobs 2.0.1，其中 doJobs 不接受任何参数，因此我使用了 execute 代替），

@Every("10s")
public class myJob extends Job {

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        try {
            myResource res = (myResource) context.getScheduler().getContext().get("myResource");
            // Do stuff with your resource
        } catch (SchedulerException e) {
            // Handle exception
        }
    }
}

不确定您是否可以访问 ExternalServiceResource，但我希望这会有所帮助！

【讨论】：