WebSocket server.run()不允许以下代码启动

vd8tlhqk  于 2023-08-05  发布在  其他
关注(0)|答案(1)|浏览(67)

我有以下来自GitHub的Web Socket服务器代码:

public class WebsocketServer extends WebSocketServer {

    private static int PORT = 2005;

    private Set<WebSocket> conns;

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

    @Override
    public void onOpen(WebSocket conn, ClientHandshake handshake) {
        conns.add(conn);
        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("Received: " + message);

        for (WebSocket sock : conns) {
            sock.send(messageToSend);
        }
    }

    @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 void main(String[] args) throws IOException, InterruptedException {
        WebsocketServer server = new WebsocketServer();
        server.run();

        BufferedReader sysin = new BufferedReader(new InputStreamReader(System.in));
        while (true) {
            String in = sysin.readLine();
            server.sendToAll(in);
            if (in.equals("exit")) {
                server.stop();
                break;
            } else if (in.equals("restart")) {
                server.stop();
                server.start();
                break;
            }
        }

    }

    public void sendToAll(String text) {
        Collection<WebSocket> con = connections();
        synchronized (con) {
            for (WebSocket c : con) {
                c.send(text);
            }
        }
    }
}

字符串
代码工作fine, but all code that come after server.run();不会启动/工作!在该部分中,我需要从Java控制台向客户机发送消息。
我做错了什么?

**注意:**我的客户端使用JavaScript,可以连接到服务器。

uqcuzwp8

uqcuzwp81#

你需要start()Runnable类,不要直接run()

server.start();

字符串
代替了

server.run();

相关问题