【发布时间】:2015-08-20 14:44:08
【问题描述】:
我正在为网站开发通知服务。我希望能够实时接收通知,因此我使用 Java AsyncResponse 来完成此操作。我遇到了一个问题,在某些情况下,我的 ajax 调用的后端直到调用后 20 秒才运行。为了测试它,我启动了 3 个页面,然后尝试添加新通知。如果我等待的时间足够长,则没有问题,但如果我不等待,则不是每个页面都会更新,因为不是每个页面都在轮询。是我做错了什么导致了问题,还是我可以做些什么来确定导致问题的原因?谢谢!
Java 代码:
@Path("/demo0825/notifications")
@Consumes(MediaType.APPLICATION_JSON)
@Produces(MediaType.APPLICATION_JSON)
public class NotificationsResource {
@Singleton
@Startup
public static class Storage{
public static ArrayList<AsyncResponse> arList = new ArrayList<>();
private static final Object lock = new Object();
}
@GET
@Path("/poll")
public void pollNotifications(@Suspended AsyncResponse ar){
Date dateobj = new Date();
synchronized (Storage.lock) {
Storage.arList.add(ar);
}
}
@POST
public final Response addNotification(Notification pData) throws Exception {
try (NotificationDataAccess dataAccess = new NotificationDataAccess()) {
dataAccess.add(pData);
synchronized (Storage.lock) {
for (AsyncResponse ar : Storage.arList) {
ar.resume(pData);
}
Storage.arList.clear();
}
return Response.ok().build();
}
}
Javascript 代码:
pollNotifications = function(){
console.log("here");
$.ajax({
url: "/atrt_ent/rest/demo0825/notifications/poll",
contentType: 'application/json',
type: "GET",
success: function(data){
console.log(data);
...
}
},
complete: function(){
console.log("here");
pollNotifications();
}
});
}
pollNotifications();
我正在使用 chrome 并显示时间戳,以便在调用 ajax 时记录第一个 console.log("here"),然后我可以使用调试语句查看 java 代码中的日期。我也在没有锁的情况下这样做了,并且得到了相同的结果。
【问题讨论】:
-
我不是 Java 开发人员或其他任何语言,但是,我的猜测是
synchronized (Storage.lock) {说“不要让其他任何人访问此属性”,意思是,只有一个请求可以访问它在任何给定时间。因此,如果您打开了三个选项卡,则每个选项卡都必须等待前一个选项卡的请求完成,然后它的请求才能访问该属性。 -
我敢打赌,您描述的 20 秒是 RESTful 服务中的暂停超时。尝试设置一个超时处理程序,看看它是否被调用。 docs.oracle.com/javaee/7/api/javax/ws/rs/container/…
-
我实际上更新了它,以便我在锁之外进行日期检查并且它不会改变任何东西。这也是我想过的。
-
@Gimby 感谢您的建议,因为它正好是 20 秒,但是当我添加
ar.setTimeoutHandler((asyncResp) -> asyncResp.resume(Response.status(Response.Status.REQUEST_TIMEOUT).build()));时,处理程序中的代码从未调用过。 -
@Gimby 我在该代码上添加了一个调试中断,该代码不会受到影响,并且行为没有任何变化。
标签: javascript java ajax rest glassfish