在Embedded Jetty 9中註解的@WebSocket類中訪問HttpSession 9

Question

如何在Jetty 9中的帶註釋的@WebSocket類中訪問HttpSession對象？

我發現瞭如何使用它@ServerEndpoint註釋，就像在這裏做：在類波紋管HttpSession from @ServerEndpoint

使用@WebSocket註解一樣，我該怎麼辦呢？

@WebSocket 
public class AuctionWebSocket { 

    // NEED TO ACCESS HttpSession OBJECT INSIDE THESE METHODS: 

    @OnWebSocketConnect 
    public void onConnect(Session session) { 
     System.out.println("onConnect...");   
    } 

    @OnWebSocketMessage 
    public void onMessage(String message) {   
     System.out.println("Message: " + message); 
    }  

    @OnWebSocketClose 
    public void onClose(int statusCode, String reason) { 
     System.out.println("onClose...");   
    } 

    @OnWebSocketError 
    public void onError(Throwable t) { 
     System.out.println("onError...");   
    }  
} 

裏面的方法onConnect(Session session)，席力圖召session.getUpgradeRequest().getSession()它總是返回null。

有關的信息的緣故，這裏是我開始嵌入碼頭9：

public class Main { 

    public static void main(String[] args) throws Exception { 

     String webPort = System.getenv("PORT"); 
     if (webPort == null || webPort.isEmpty()) { 
      webPort = "8080"; 
     } 

     Server server = new Server(Integer.parseInt(webPort)); 

     ClassList classlist = org.eclipse.jetty.webapp.Configuration.ClassList.setServerDefault(server); 
     classlist.addBefore("org.eclipse.jetty.webapp.JettyWebXmlConfiguration", 
       "org.eclipse.jetty.annotations.AnnotationConfiguration"); 

     WebAppContext wac = new WebAppContext(); 
     String webappDirLocation = "./src/main/webapp/"; 

     wac.setAttribute("org.eclipse.jetty.server.webapp.ContainerIncludeJarPattern", ".*/classes/.*"); 
     wac.setDescriptor(webappDirLocation + "/WEB-INF/web.xml"); 
     wac.setBaseResource(new ResourceCollection(new String[]{webappDirLocation, "./target"})); 
     wac.setResourceAlias("/WEB-INF/classes/", "/classes/"); 
     wac.setContextPath("/"); 
     wac.setParentLoaderPriority(true); 

     /* 
     * WebSocket handler. 
     */ 
     WebSocketHandler wsh = new WebSocketHandler() { 

      @Override 
      public void configure(WebSocketServletFactory wssf) { 
       wssf.register(AuctionWebSocket.class); 
      } 
     }; 

     ContextHandler wsc = new ContextHandler(); 
     wsc.setContextPath("/auction-notifications"); 
     wsc.setHandler(wsh); 

     ContextHandlerCollection chc = new ContextHandlerCollection(); 
     chc.setHandlers(new Handler[]{wac, wsc}); 

     server.setHandler(chc); 

     server.start(); 
     server.join(); 
    } 

} 

讓我知道如果你需要更多的信息。

任何幫助將不勝感激。

在此先感謝。

Answer 1

你會想使用WebSocketCreator的概念。

首先你要定義你所選擇的WebSocketCreator在您在WebSocketServlet

public class MySessionSocketServlet extends WebSocketServlet 
{ 
    @Override 
    public void configure(WebSocketServletFactory factory) 
    { 
     factory.getPolicy().setIdleTimeout(30000); 
     factory.setCreator(new MySessionSocketCreator()); 
    } 
} 

下一頁配置WebSocketServletFactory，你會希望在升級過程中搶HttpSession並把它傳遞到WebSocket的對象，您正在創造。

public class MySessionSocketCreator implements WebSocketCreator 
{ 
    @Override 
    public Object createWebSocket(ServletUpgradeRequest req, ServletUpgradeResponse resp) 
    { 
     HttpSession httpSession = req.getSession(); 
     return new MySessionSocket(httpSession); 
    } 
} 

最後，剛在你自己的WebSocket的軌道，HttpSession的。

@WebSocket 
public class MySessionSocket 
{ 
    private HttpSession httpSession; 
    private Session wsSession; 

    public MySessionSocket(HttpSession httpSession) 
    { 
     this.httpSession = httpSession; 
    } 

    @OnWebSocketConnect 
    public void onOpen(Session wsSession) 
    { 
     this.wsSession = wsSession; 
    } 
} 

值得注意的是：在HttpSession可以屆滿，被清理和清理而WebSocket的是積極的。此外，此時的內容不保證與其他網絡操作的更改保持同步（這主要取決於您在服務器端使用的會話存儲/緩存技術）

還有一個注意事項：抗拒在您的套接字實例中存儲/跟蹤ServletUpgradeRequest對象的衝動，因爲此對象被Jetty正確地回收和清除。