我正在开发服务器端Web服务代码。我正在使用JAX-RS作为开发框架。
到目前为止,我已经创建了将请求的数据响应到客户端的模型类和资源类。
示例资源方法...
@GET
@Path("/{userId}")
@Produces(MediaType.APPLICATION_JSON)
public User getUserDetails(@PathParam("userId") long id) {
..
// some code here //
..
}
基本上,服务器响应数据或做一些操作取决于客户端调用的URI。
我想从服务器启动的那一刻起每两分钟向第三方服务器发出 Http POST 请求。但我不知道我应该在哪里编写该代码(正如我所说,方法执行取决于调用的 URI)。
那么,我应该在哪里编写服务器启动时开始执行并在服务器停止时结束的代码。
如何每隔两分钟发送一次Http请求?
你应该能够结合使用Quartz和ServletContextListener来做到这一点。
您需要创建一个作业、触发器和调度程序,以使代码每两分钟运行一次,以及一个实现 ServletContextListener 接口的侦听器类。
您的代码如下所示:
工作类别:
package com.example;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
public class ExampleJob implements Job
{
public void execute(JobExecutionContext context) throws JobExecutionException {
// Code to make POST call here
}
ServletContextListener
package com.example;
public class ExampleListener implements javax.servlet.ServletContextListener {
public void contextInitialized(ServletContext context) {
JobDetail job = JobBuilder.newJob(ExampleJob.class)
.withIdentity("exampleJob", "group").build();
// Trigger
Trigger trigger = TriggerBuilder
.newTrigger()
.withIdentity("exampleTrigger", "group")
.withSchedule(
SimpleScheduleBuilder.simpleSchedule()
.withIntervalInSeconds(120).repeatForever())
.build();
// Scheduler
Scheduler scheduler = new StdSchedulerFactory().getScheduler();
scheduler.start();
scheduler.scheduleJob(job, trigger);
}
}
并在 web 中添加此内容.xml:
<listener>
<listener-class>com.example.ExampleListener</listener-class>
</listener>
或者,如果您使用的是 Servlet 容器 3.x,则可以跳过 Web.xml 修改,方法是使用 @WebListener
注释侦听器类