无法将客户端 (Javascript) 连接到现有的套接字服务器

Question

我有一个侦听端口 6868 的现有套接字服务器。它写在 Java.

我需要将客户端连接到服务器。客户端在我的 React 应用程序的 Java 脚本中编码。

我已经尝试了几乎所有我在 Internet 上找到的教程组合，但我仍然无法让客户端连接。

import * as io from "socket.io-client";

export default () => {
  // eslint-disable-next-line no-restricted-globals
  self.onmessage = (message) => {
    const data = message.data;
      try {
      var socket = io("http://localhost:6868/");
    } catch (error) {
      console.log("do nothing: " + error);
    }
  };
};

无论如何，我都会得到同样的错误：ReferenceError: socket_io_client__WEBPACK_IMPORTED_MODULE_0___default is not defined。

这是我在 package.json 中看到的版本："socket.io-client": "^4.4.0"

我用这个命令安装它：npm i socket.io-client

Answer 1

原来 socket.io 不能用于连接到我在 Java 中的 ServerSocket。为了解决这个问题，我将 ServerSocket 更改为 WebSocketServer.

以下是使 Java WebSocket 与 JavaScript 客户端连接所需的所有代码：

WebsocketServer.java

import org.java_websocket.WebSocket;
import org.java_websocket.handshake.ClientHandshake;
import org.java_websocket.server.WebSocketServer;

import java.net.InetSocketAddress;
import java.util.HashSet;
import java.util.Set;

public class WebsocketServer extends WebSocketServer {

    private static int TCP_PORT = 6868;

    private static Set<WebSocket> conns;


    public WebsocketServer() {
        super(new InetSocketAddress(TCP_PORT));
        conns = new HashSet<>();
    }

    @Override
    public void onOpen(WebSocket conn, ClientHandshake handshake) {
        conns.add(conn);
        conn.send("hello!!");
        System.out.println("New connection from " + conn.getRemoteSocketAddress().getAddress().getHostAddress());
    }

    @Override
    public void onClose(WebSocket conn, int code, String reason, boolean remote) {
        conns.remove(conn);
        System.out.println("Closed connection to " + conn.getRemoteSocketAddress().getAddress().getHostAddress());
    }

    @Override
    public void onMessage(WebSocket conn, String message) {
        System.out.println("Message from client: " + message);
        for (WebSocket sock : conns) {
            sock.send("SENDING BACK" + message);
        }
    }

    @Override
    public void onError(WebSocket conn, Exception ex) {
        //ex.printStackTrace();
        if (conn != null) {
            conns.remove(conn);
            // do some thing if required
        }
        System.out.println("ERROR from " + conn.getRemoteSocketAddress().getAddress().getHostAddress());
    }

    public static Set<WebSocket> getConns() {
        return conns;
    }
}

并使用 new WebsocketServer().start();

从 main() 启动服务器

client.js

    var connection = new WebSocket("ws://127.0.0.1:6868");

    connection.onopen = function () {
      console.log("Connected!");
      connection.send("Ping"); // Send the message 'Ping' to the server
    };

    // Log errors
    connection.onerror = function (error) {
      console.log("WebSocket Error " + error);
    };

    // Log messages from the server
    connection.onmessage = function (e) {
      console.log("Server: " + e.data);
    };

以及 Java Web 套接字的依赖项：

    <dependency>
        <groupId>
            org.java-websocket
        </groupId>
        <artifactId>
            Java-WebSocket
        </artifactId>
        <version>
            1.3.0
        </version>
    </dependency>

无法将客户端 (Javascript) 连接到现有的套接字服务器

Can't connect client (Javascript) to existing socket server

javascript

socket.io

reactjs