Wie man die Session-Id im Frühjahr WebSocketStompClient?

How to get session id in Java Spring WebSocketStompClient?

Habe ich WebSocketStompClient und StompSessionHandlerAdapter, welche Instanzen Verbindung in Ordnung zu websocket auf meinem server. WebSocketStompClient verwenden SockJsClient.

Aber ich weiß nicht, wie get session id des websocket-Verbindung. In den code mit stomp session-handler auf client-Seite

   private class ProducerStompSessionHandler extends StompSessionHandlerAdapter {
            ...
            @Override
            public void afterConnected(StompSession session, StompHeaders  connectedHeaders) {
            ...
            }

stomp-Sitzung enthält eine session-id, die verschiedene session-id auf dem server.
Also aus dieser ids:

DEBUG ... Processing SockJS open frame in WebSocketClientSockJsSession[id='d6aaeacf90b84278b358528e7d96454a...

DEBUG ... DefaultStompSession - Connection established in session id=42e95c88-cbc9-642d-2ff9-e5c98fb85754

Muss ich zuerst die session-id, von WebSocketClientSockJsSession.
Aber ich habe nicht gefunden in WebSocketStompClient oder SockJsClient jede Methode, um etwas abrufen, wie session-id...

InformationsquelleAutor Irina | 2017-02-15

To get session id, die Sie brauchen, um zu definieren, Ihre eigenen interceptor als unten, und legen Sie die session-id als benutzerdefiniertes Attribut.

public class HttpHandshakeInterceptor implements HandshakeInterceptor {

    @Override
    public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler,
            Map attributes) throws Exception {
        if (request instanceof ServletServerHttpRequest) {
            ServletServerHttpRequest servletRequest = (ServletServerHttpRequest) request;
            HttpSession session = servletRequest.getServletRequest().getSession();
            attributes.put("sessionId", session.getId());
        }
        return true;
    }

Jetzt können Sie die gleiche session-id in der controller-Klasse.

@MessageMapping("/message")
public void processMessageFromClient(@Payload String message, SimpMessageHeaderAccessor  headerAccessor) throws Exception {
        String sessionId = headerAccessor.getSessionAttributes().get("sessionId").toString();

    }

Danke!!! Aufgrund der server arbeitet mit javascript-client zu senden ich session-id, um java-client seine Anfrage.
Statt zu schreiben Ihre eigenen Abfangjäger könnten Sie machen verwenden der built-in HttpSessionHandshakeInterceptor.
funktioniert wie ein Charme!

InformationsquelleAutor Dhiraj Ray

5

Können Sie @Header annotation zugreifen sessionId:
```
@MessageMapping("/login")
public void login(@Header("simpSessionId") String sessionId) {
    System.out.println(sessionId);
}
```
Und es funktioniert gut für mich ohne jede benutzerdefinierte Abfangjäger
- Es funktionierte aber die jsessionid auf der client-Seite und die sessionid erhalten stimmt nicht überein.
InformationsquelleAutor Arseniy

Es ist ein Weg, zu extrahieren, sockjs sessionId per Reflection API:

public void afterConnected(StompSession session, StompHeaders connectedHeaders) {
    //we need another sessionId!
    System.out.println("New session established : " + session.getSessionId());
    DefaultStompSession defaultStompSession =
            (DefaultStompSession) session;
    Field fieldConnection = ReflectionUtils.findField(DefaultStompSession.class, "connection");
    fieldConnection.setAccessible(true);

    String sockjsSessionId = "";
    try {
        TcpConnection<byte[]> connection = (TcpConnection<byte[]>) fieldConnection.get(defaultStompSession);
        try {
            Class adapter = Class.forName("org.springframework.web.socket.messaging.WebSocketStompClient$WebSocketTcpConnectionHandlerAdapter");
            Field fieldSession = ReflectionUtils.findField(adapter, "session");
            fieldSession.setAccessible(true);
            WebSocketClientSockJsSession sockjsSession = (WebSocketClientSockJsSession) fieldSession.get(connection);
            sockjsSessionId = sockjsSession.getId(); //gotcha!
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    } catch (IllegalAccessException e) {
        e.printStackTrace();
    }

    if (StringUtils.isBlank(sockjsSessionId)) {
        throw new IllegalStateException("couldn't extract sock.js session id");
    }

    String subscribeLink = "/topic/auth-user" + sockjsSessionId;
    session.subscribe(subscribeLink, this);
    System.out.println("Subscribed to " + subscribeLink);
    String sendLink = "/app/user";
    session.send(sendLink, getSampleMessage());
    System.out.println("Message sent to websocket server");
}