没有STOMP的Spring 4 webSocketjs

Question

我试图在不使用socketjs库的情况下测试websocket，而且我不想添加任何stomp连接。

我下面的例子stackoverflow问题：WebSocket与Sockjs

因此，如果没有践踏服务器，我已经成功地通过ocketjs库与url连接：ws://localhost:8080/greeting/741/0tb5jpyi/websocket

现在我想删除socketjs库以允许原始websocket连接（可能是android、ios等设备）

删除参数时：。使用SockJS（），我无法通过websocket进行连接。

我尝试了以下URL，但不起作用：

ws://localhost:8080/greeting/394/0d7xi9e1/websocket not worked
ws://localhost:8080/greeting/websocket not worked
ws://localhost:8080/greeting/ not worked 

我应该使用哪个URL进行连接？

Answer 1

我在客户端也面临同样的情况，客户端不能连接到服务器。

使我工作的是将下面的setAllowedOriginates（“*”）添加到自定义处理程序。

registry.addHandler(webSocketHandler, "/app").setAllowedOrigins("*");

Answer 2

您应该使用ws://localhost:8080/greeting：

new WebSocket('ws://localhost:8080/greeting')

Answer 3

在我的项目中，我使用WebSocket时没有跺脚。

下面的配置适用于Spring-start。

在pom中添加Spring Bootwebsocket依赖项。xml

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
    <version>${spring-boot.version}</version>
</dependency>

然后添加一个类（这里WebSocketServerConfiguration.java），它配置您的webSocketServerC：

@Configuration
@EnableWebSocket
public class WebSocketServerConfiguration implements WebSocketConfigurer {

    @Autowired
    protected MyWebSocketHandler webSocketHandler;

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(webSocketHandler, "/as");
    }
}

最后，您可以编写您的WebsocketHandler。Spring为WebSocketHandler提供了不同的抽象类（在主包中：org.springframework.web.socket.handler）。我的websocket配置时没有STOMP，我的客户端也没有使用socket。js。因此，MyWebSocketHandler扩展了TextWebSocketHandler，并覆盖了错误、打开和关闭连接以及接收到的文本的方法。

@Component
public class MyWebSocketHandler extends TextWebSocketHandler {
    ...

    @Override
    public void handleTransportError(WebSocketSession session, Throwable throwable) throws Exception {
        LOG.error("error occured at sender " + session, throwable);
        ...
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
        LOG.info(String.format("Session %s closed because of %s", session.getId(), status.getReason()));

        ...
    }

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        LOG.info("Connected ... " + session.getId());

        ...
    }

    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage jsonTextMessage) throws Exception {
        LOG.debug("message received: " + jsonTextMessage.getPayload());
        ...
    }
}