org.springframework.web.socket.handler.WebSocketHandlerDecorator.afterConnectionEstablished()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(2.9k)|赞(0)|评价(0)|浏览(119)

本文整理了Java中org.springframework.web.socket.handler.WebSocketHandlerDecorator.afterConnectionEstablished()方法的一些代码示例,展示了WebSocketHandlerDecorator.afterConnectionEstablished()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WebSocketHandlerDecorator.afterConnectionEstablished()方法的具体详情如下:
包路径:org.springframework.web.socket.handler.WebSocketHandlerDecorator
类名称:WebSocketHandlerDecorator
方法名:afterConnectionEstablished

WebSocketHandlerDecorator.afterConnectionEstablished介绍

暂无

代码示例

代码示例来源:origin: spring-projects/spring-framework

  1. @Override
  2. public void afterConnectionEstablished(WebSocketSession session) throws Exception {
  3. if (logger.isDebugEnabled()) {
  4. logger.debug("New " + session);
  5. }
  6. super.afterConnectionEstablished(session);
  7. }

代码示例来源:origin: spring-projects/spring-framework

  1. @Override
  2. public void afterConnectionEstablished(WebSocketSession session) throws Exception {
  3. session.getAttributes().put("decorated", true);
  4. super.afterConnectionEstablished(session);
  5. }
  6. }

代码示例来源:origin: spring-projects/spring-session

  1. @Override
  2. public void afterConnectionEstablished(WebSocketSession wsSession)
  3. throws Exception {
  4. super.afterConnectionEstablished(wsSession);
  5. publishEvent(new SessionConnectEvent(this, wsSession));
  6. }

代码示例来源:origin: spring-projects/spring-integration

  1. @Override
  2. public void afterConnectionEstablished(WebSocketSession session) throws Exception {
  3. super.afterConnectionEstablished(session);
  4. applicationEventPublisher.publishEvent(session);
  5. }

代码示例来源:origin: org.springframework/spring-websocket

  1. @Override
  2. public void afterConnectionEstablished(WebSocketSession session) throws Exception {
  3. if (logger.isDebugEnabled()) {
  4. logger.debug("New " + session);
  5. }
  6. super.afterConnectionEstablished(session);
  7. }

代码示例来源:origin: apache/servicemix-bundles

  1. @Override
  2. public void afterConnectionEstablished(WebSocketSession session) throws Exception {
  3. if (logger.isDebugEnabled()) {
  4. logger.debug("New " + session);
  5. }
  6. super.afterConnectionEstablished(session);
  7. }

代码示例来源:origin: lcw2004/one

  1. @Override
  2. public void afterConnectionEstablished(final WebSocketSession session) throws Exception {
  3. String principalId = (String) session.getAttributes().get("principalId");
  4. String sessionId = session.getId();
  5. // 客户端与服务器端建立连接后,此处记录谁上线了
  6. logger.info("WebSocket Online, Principal Id[{}], Session Id[{}]", principalId, sessionId);
  7. SocketSessionRegistry.registerSessionId(principalId, sessionId);
  8. super.afterConnectionEstablished(session);
  9. }

代码示例来源:origin: ch.rasc/wampspring

  1. @Override
  2. public void afterConnectionEstablished(WebSocketSession webSocketSession)
  3. throws Exception {
  4. super.afterConnectionEstablished(webSocketSession);
  5. Principal principal = webSocketSession.getPrincipal();
  6. if (principal != null) {
  7. SimpMessageHeaderAccessor accessor = SimpMessageHeaderAccessor
  8. .create(SimpMessageType.MESSAGE);
  9. accessor.setSessionId(webSocketSession.getId());
  10. publishEvent(new SessionConnectedEvent(this, MessageBuilder.createMessage(
  11. new byte[0], accessor.getMessageHeaders()), principal));
  12. }
  13. }

相关文章