连接到websockets NodeJS Express服务器时出错

zengzsys  于 2023-08-04  发布在  Node.js
关注(0)|答案(2)|浏览(120)

我有一个配置了websockets的express服务器:

/tmp/ws-test $ cat httpServer.js
const express = require('express');
const WebSocket = require('ws');

const app = express();
const port = 8080;

app.get('/', function(req, res, next) {
  return res.send('Hello World!');
});

const wss = new WebSocket.Server({ server: app });

wss.on('connection', function connection(ws) {
  ws.on('message', function incoming(message) {
    console.log('received: %s', message);
  });
  ws.send('something from server');
});

app.listen(port, function(err) {
  if (err) {
    throw err;
  }
  console.log(`listening on port ${port}!`);
});

字符串
它按预期运行:

/tmp/ws-test $ node httpServer.js
listening on port 8080!


我有一个客户:

/tmp/ws-test $ cat client.js
const WebSocket = require('ws');

const ws = new WebSocket('ws://localhost:8080');

ws.on('open', function open() {
  ws.send('something from client');
});

ws.on('message', function incoming(data) {
  console.log(`received: ${data}`);
});


它的错误:

/tmp/ws-test $ node client.js
events.js:180
      throw er; // Unhandled 'error' event
      ^

Error: Unexpected server response: 200
    at ClientRequest.<anonymous> (/private/tmp/ws-test/node_modules/ws/lib/websocket.js:579:7)
    at ClientRequest.emit (events.js:203:13)
    at HTTPParser.parserOnIncomingClient [as onIncoming] (_http_client.js:575:27)
    at HTTPParser.parserOnHeadersComplete (_http_common.js:116:17)
    at Socket.socketOnData (_http_client.js:449:22)
    at Socket.emit (events.js:203:13)
    at addChunk (_stream_readable.js:295:12)
    at readableAddChunk (_stream_readable.js:276:11)
    at Socket.Readable.push (_stream_readable.js:210:10)
    at TCP.onStreamRead (internal/stream_base_commons.js:166:17)
Emitted 'error' event at:
    at abortHandshake (/private/tmp/ws-test/node_modules/ws/lib/websocket.js:697:15)
    at ClientRequest.<anonymous> (/private/tmp/ws-test/node_modules/ws/lib/websocket.js:579:7)
    [... lines matching original stack trace ...]
    at Socket.Readable.push (_stream_readable.js:210:10)


在客户端中,我还尝试使用http进行Web Socket连接。

const ws = new WebSocket('http://localhost:8080');


但它会抛出同样的错误。
为什么客户端在连接到服务器时出错?

zbsbpyhn

zbsbpyhn1#

您应该将http服务器示例传递给WebSocket.Server构造函数,而不是express应用程序的示例:

const express = require('express');
const WebSocket = require('ws');
const http = require('http');

const app = express();
const port = 8080;

const server = http.createServer(app);

app.get('/', function(req, res, next) {
    return res.send('Hello World!');
});

const wss = new WebSocket.Server({ server });

wss.on('connection', function connection(ws) {
    ws.on('message', function incoming(message) {
        console.log('received: %s', message);
    });
    ws.send('something from server');
});

server.listen(port, function(err) {
    if (err) {
        throw err;
    }
    console.log(`listening on port ${port}!`);
});

字符串

wvt8vs2t

wvt8vs2t2#

import express from "express";
import { WebSocketServer } from "ws";
import http from "http";

const app = express();
const port = 8080;

const server = http.createServer(app);

app.get('/', function(req, res, next) {
  return res.send('Hello World!');
});

const wss = new WebSocketServer({ server });

wss.on('connection', function connection(ws) {
  ws.on('message', function incoming(message) {
    console.log('received: %s', message);
});
ws.send('something from server');
});

server.listen(port, function(err) {
 if (err) {
    throw err;
 }
 console.log(`listening on port ${port}!`);
});

字符串

相关问题