如何在流程中提交或刷新其余响应

Question

我对java和jersey都是新手。现在，我想使用 jersey 来实现 REST 服务，并在发送响应后进行额外处理（具体来说，休眠固定的秒数，然后在同一 servlet 上下文中触发不同的 REST 请求，因此它与 REST 代理不同）。我已经用谷歌搜索了一段时间，但似乎所有人都想当然地认为在方法结束时隐式刷新响应。以下是我正在努力处理的启用了 JAXB 的当前代码。

@Path("/chat")
public class LoadSimulator {

    @Context private UriInfo uriInfo;

    @Path("/outbound/{senderAddress}/requests")
    @POST
    @Consumes({MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML})
    @Produces({MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML})
    public Response createOutboundSMSMessage(OutboundSMSMessageRequest inSmsReq, @PathParam("senderAddress") String senderAddress) throws JAXBException {
        String requestId = UUID.randomUUID().toString();
        URI uri = uriInfo.getAbsolutePathBuilder().path(requestId).build();

        ObjectFactory factory = new ObjectFactory();
        ResourceReference resourceReference = new ResourceReference();
        resourceReference.setResourceURL(uri.toString());
        JAXBElement<ResourceReference> inSmsResponse = factory.createResourceReference(resourceReference);
                return Response.created(uri).entity(inSmsResponse).build();
             //// want to flush or commit the response explicitly like:
              //        out.flush();
            //        out.close();
            //// Then sleep for a few second and fire a new REST request
            //        sleep(5);
            //          ....   
            // ClientConfig config = new DefaultClientConfig();
            // String response = r.path("translate").queryParams(params).get(String.class);



    }
}

Answer 1

如果你能做你想做的事，你就会耗尽服务器上的资源，因为每个请求都需要 X 秒，并且在盒子哭叔叔之前你有有限数量的可用线程。

不评论为什么你想要这样做；如果您为 LoadSimulator 使用了 @Singleton 注释，您可以在 @PostConstruct public void init()< 中设置一个监听（并发）队列的线程。 /code> - 当您的 servlet 启动时被调用。

@Singleton
@Path("/chat")
public class LoadSimulator {
    private Thread restCaller;
    private ConcurrentLinkedQueue<MyInfo> queue = new ConcurrentLinkedQueue<MyInfo>();

    ...
    @PostConstruct public void init()
    {
        restCaller = new Thread(new MyRunnable(queue));
        restCaller.start();
    }
    ...

然后，在 REST 调用中，您可以将进行第二个 REST 调用所需的任何信息放入该队列中，并让上述线程将其拉出并进行查询。