javax.servlet.http.HttpServletRequest#upgrade()源码实例Demo

下面列出了javax.servlet.http.HttpServletRequest#upgrade() 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

@Override
protected void handleSuccess(HttpServletRequest request, HttpServletResponse response,
		UpgradeInfo upgradeInfo, TyrusUpgradeResponse upgradeResponse) throws IOException, ServletException {

	TyrusHttpUpgradeHandler handler = request.upgrade(TyrusHttpUpgradeHandler.class);
	Writer servletWriter = newServletWriter(handler);
	handler.preInit(upgradeInfo, servletWriter, request.getUserPrincipal() != null);

	response.setStatus(upgradeResponse.getStatus());
	upgradeResponse.getHeaders().forEach((key, value) -> response.addHeader(key, Utils.getHeaderFromList(value)));
	response.flushBuffer();
}
 
@Override
protected void handleSuccess(HttpServletRequest request, HttpServletResponse response,
		UpgradeInfo upgradeInfo, TyrusUpgradeResponse upgradeResponse) throws IOException, ServletException {

	TyrusHttpUpgradeHandler handler = request.upgrade(TyrusHttpUpgradeHandler.class);
	Writer servletWriter = newServletWriter(handler);
	handler.preInit(upgradeInfo, servletWriter, request.getUserPrincipal() != null);

	response.setStatus(upgradeResponse.getStatus());
	upgradeResponse.getHeaders().forEach((key, value) -> response.addHeader(key, Utils.getHeaderFromList(value)));
	response.flushBuffer();
}
 
@Override
protected void handleSuccess(HttpServletRequest request, HttpServletResponse response,
		UpgradeInfo upgradeInfo, TyrusUpgradeResponse upgradeResponse) throws IOException, ServletException {

	TyrusHttpUpgradeHandler handler = request.upgrade(TyrusHttpUpgradeHandler.class);
	Writer servletWriter = servletWriterHelper.newInstance(handler);
	handler.preInit(upgradeInfo, servletWriter, request.getUserPrincipal() != null);

	response.setStatus(upgradeResponse.getStatus());
	for (Map.Entry<String, List<String>> entry : upgradeResponse.getHeaders().entrySet()) {
		response.addHeader(entry.getKey(), Utils.getHeaderFromList(entry.getValue()));
	}
	response.flushBuffer();
}
 
源代码4 项目: haven-platform   文件: ProxyServlet.java
private void doUpgrade(String id, HttpServletRequest request, HttpServletResponse response) throws Exception {
    // currently we not support tcp upgrade (but websockets doing in WsProxy)
    // we can send error for docker clients (it accept only 400, 404 & 500 codes),
    // but sending 500 does not interrupt docker client, and its hangs
    request.upgrade(ImmediateCloseConnection.class);
    log.debug("{}: close upgraded connection", id);
}
 
源代码5 项目: sample.daytrader7   文件: PingUpgradeServlet.java
@Override
protected void doPost(final HttpServletRequest req, final HttpServletResponse res) throws ServletException, IOException {
  
    if (Log.doTrace()) {
        Log.trace("PingUpgradeServlet:doPost");
    }
    
    if ("echo".equals(req.getHeader("Upgrade"))) {
        
        if (Log.doTrace()) {
            Log.trace("PingUpgradeServlet:doPost -- found echo, doing upgrade");
        }
        
        res.setStatus(101);
        res.setHeader("Upgrade", "echo");
        res.setHeader("Connection", "Upgrade");

        req.upgrade(Handler.class);          
      
    } else {
        
        if (Log.doTrace()) {
            Log.trace("PingUpgradeServlet:doPost -- did not find echo, no upgrade");
        }
        
        res.getWriter().println("No upgrade: " + req.getHeader("Upgrade"));
    }
}
 
源代码6 项目: Tomcat8-Source-Read   文件: TestUpgrade.java
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
        throws ServletException, IOException {

    req.upgrade(upgradeHandlerClass);
}
 
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
        throws ServletException, IOException {

    req.upgrade(upgradeHandlerClass);
}
 
源代码8 项目: quarkus-http   文件: AsyncUpgradeServlet.java
@Override
protected void doGet(final HttpServletRequest req, final HttpServletResponse resp) throws ServletException, IOException {
    req.upgrade(Handler.class);
}
 
源代码9 项目: quarkus-http   文件: UpgradeServlet.java
@Override
protected void doGet(final HttpServletRequest req, final HttpServletResponse resp) throws ServletException, IOException {
    req.upgrade(Handler.class);
}