WebSocket 握手期间出错：意外的响应代码：200 在 Jhipster 应用程序中

Question

我正在尝试在使用 Java spring 和 Angular 8 构建的现有 Jhipster 应用程序中连接到 websocket。在创建项目时，我没有选择 websocket 选项，现在需要实现项目中的 websockets。我从“https://www.jhipster.tech/using-websockets/”获得帮助并尝试实施相同的解决方案，但我收到握手失败消息。 我在 websockets 中使用 STOMP 和 sockJS。 请让我知道握手失败的原因。

这里是 websocket configuration.java 文件。

import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
import org.springframework.web.socket.server.support.DefaultHandshakeHandler;

import hr.nic.vc.security.AuthoritiesConstants;

import java.security.Principal;

import org.springframework.http.server.*;

import java.util.*;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.server.*;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.security.authentication.AnonymousAuthenticationToken;
import org.springframework.security.core.authority.SimpleGrantedAuthority;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.config.annotation.*;
import org.springframework.web.socket.server.HandshakeInterceptor;
import org.springframework.web.socket.server.support.DefaultHandshakeHandler;

@Configuration
@EnableWebSocketMessageBroker
public class WebsocketConfiguration implements WebSocketMessageBrokerConfigurer {

  @Override
  public void configureMessageBroker(MessageBrokerRegistry config)
  {
    config.enableSimpleBroker("/topic");
    //config.setApplicationDestinationPrefixes("/app");
  }

  @Override
  public void registerStompEndpoints(StompEndpointRegistry
   registry) {
    registry.addEndpoint("/websocket/blog").setHandshakeHandler(defaultHandshakeHandler())
        .setAllowedOrigins("*").withSockJS();
  }
  
  @Bean
  public HandshakeInterceptor httpSessionHandshakeInterceptor() {
      return new HandshakeInterceptor() {

          @Override
          public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Map<String, Object> attributes) throws Exception {
              if (request instanceof ServletServerHttpRequest) {
                  ServletServerHttpRequest servletRequest = (ServletServerHttpRequest) request;
                  attributes.put(IP_ADDRESS, servletRequest.getRemoteAddress());
              }
              return true;
          }

          @Override
          public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Exception exception) {

          }
      };
  }

  private DefaultHandshakeHandler defaultHandshakeHandler() {
      return new DefaultHandshakeHandler() {
          @Override
          protected Principal determineUser(ServerHttpRequest request, WebSocketHandler wsHandler, Map<String, Object> attributes) {
              Principal principal = request.getPrincipal();
              if (principal == null) {
                  Collection<SimpleGrantedAuthority> authorities = new ArrayList<>();
                  authorities.add(new SimpleGrantedAuthority(AuthoritiesConstants.ANONYMOUS));
                  principal = new AnonymousAuthenticationToken("WebsocketConfiguration", "anonymous", authorities);
              }
              return principal;
          }
      };
  }
  
}

这是 websocket 安全文件。

public class WebsocketSecurityConfiguration extends AbstractSecurityWebSocketMessageBrokerConfigurer {

    @Override
      protected void configureInbound(MessageSecurityMetadataSourceRegistry messages)
      {
        messages.nullDestMatcher().authenticated().simpDestMatchers("/topic/blog")
            .authenticated()
            // matches any destination that starts with /topic/
            // (i.e. cannot send messages directly to /topic/)
            // (i.e. can’t subscribe to /topic/messages/* to get messages which is sent to
            // /topic/messages-user)
            .simpDestMatchers("/topic/**").authenticated();
            // message types other than MESSAGE and SUBSCRIBE
            //.simpTypeMatchers(SimpMessageType.MESSAGE, SimpMessageType.SUBSCRIBE).denyAll()
            // catch all
            //.anyMessage().denyAll();
      }
    /**
     * Disables CSRF for Websockets.
     */
    @Override
    protected boolean sameOriginDisabled() {
        return true;
    }
}

这里是连接websocket认证后调用的connect方法。

connect():void {
    console.log("connect called"); //eslint-disable-line
    // build absolute path, websocket doesn't fail during deploying with a context path
    let url = '/websocket/blog';
    url = this.location.prepareExternalUrl(url);
    const authToken = this.authServerProvider.getToken();
    if (authToken) {
      url += '?access_token=' + authToken;
    }
    const socket = new SockJS(url);
    this.stompClient = Stomp.over(socket);
    const headers = {};
    this.stompClient.connect(headers, () => {
        console.log("this is inside stompclient connect connect"); //eslint-disable-line
      this.stompClient.subscribe('/topic/blog', data => {
          console.log("This inside subscription"); //eslint-disable-line
        this.listenerObserver.next(JSON.parse(data.body));
      });
    });
  }
}

授权令牌以正确的值传递。因此授权没有错误。 请让我知道是否需要其他任何内容。 我在这一点上卡了很长时间。

错误：

WebSocket connection to 'ws://localhost:8080/websocket/blog/587/mklduqvp/websocket?access_token=eyJhbGciOiJIUzUxMiJ9.eyJzdWIiOiJoYXJkZWVwc2h1a2xhMDhAbmljLmluIiwiYXV0aCI6IlJPTEVfRU1QTE9ZRUUiLCJleHAiOjE2MDUyNDUwNjd9.DJ2HITaVAiaphd2yg3yPAiLrLI4n8MjszjBasC3zOHrC-73mFdltDPEYHihY16VzPv0rh6EYLj84zCBv37TDNA' failed: Error during WebSocket handshake: Unexpected response code: 200

Answer 1

在你的 DefaultHandshakeHandler 中，你可以尝试注释 @Bean 并设置为 public。

@Bean
public DefaultHandshakeHandler defaultHandshakeHandler() {