Javascript - 在Websocket上使用Promise？

Question

我在纯Javascript中使用Websockets,我想在Websocket函数中实现Promises.我没有得到任何错误,但承诺不起作用.

使用以下代码,我可以成功连接到socketserver,但Promise似乎被跳过,因为警报的输出总是"失败".

有人知道这种情况下的问题是什么吗？Ps:我在最新的谷歌Chrome浏览器和最新的Mozilla Firefox浏览器中进行了测试,我省略了一些基本的检查/错误处理.

function Connect()
{
    server = new WebSocket('mysite:1234');

    server.onopen = (function()
    {
        return new Promise(function(resolve, reject) 
        {
            if (true)
            {
                resolve();
            }
            else
            {
                reject();
            }
        });
    }).then = (function()
    {
        alert('succeeed');
    }).catch = (function()
    {
        alert('failed');
    });
}

Answer 1

您尝试在新连接中使用promises似乎有点误导.您将希望返回一个承诺,connect()以便您可以使用它来了解服务器何时连接.

看起来你可能想要这样的东西:

function connect() {
    return new Promise(function(resolve, reject) {
        var server = new WebSocket('ws://mysite:1234');
        server.onopen = function() {
            resolve(server);
        };
        server.onerror = function(err) {
            reject(err);
        };

    });
}

然后,你会像这样使用它:

connect().then(function(server) {
    // server is ready here
}).catch(function(err) {
    // error here
});

或者async/await像这样:

async myMethod() {
  try {
      let server = await connect()
      // ... use server
  } catch (error) {
      console.log("ooops ", error)
  }
}

Answer 2

扩展@jfriend00 答案，因为他的答案每次connect调用该方法时都会尝试创建一个新连接，并且不考虑连接关闭的情况

function getSocket() {

  if (getSocket.server && getSocket.server.readyState < 2) {
    console.log("reusing the socket connection [state = " + getSocket.server.readyState + "]: " + getSocket.server.url);
    return Promise.resolve(getSocket.server);
  }

  return new Promise(function (resolve, reject) {

    getSocket.server = new WebSocket(SOCKET_URL);

    getSocket.server.onopen = function () {
      console.log("socket connection is opened [state = " + getSocket.server.readyState + "]: " + getSocket.server.url);
      resolve(getSocket.server);
    };

    getSocket.server.onerror = function (err) {
      console.error("socket connection error : ", err);
      reject(err);
    };
  });
}

并使用它

getSocket().then(function(server) {
  // do stuff
}).catch(function(err) {
    // error here
});

或使用异步/等待

const socket = await getSocket();

Answer 3

我面临着完全相同的问题，并创建了一个小型的websocket-promise库。它返回连接/断开连接和发送消息的承诺：

const WebSocketAsPromised = require('websocket-as-promised');
const wsp = new WebSocketAsPromised();

// connect
wsp.open('ws://echo.websocket.org')
  .then(() => console.log('Connected.')) 
  // send data and expect response message from server
  .then(() => wsp.sendRequest({foo: 'bar'}))
  .then(response => console.log('Response message received', response))
  // disconnect
  .then(() => wsp.close())
  .then(() => console.log('Disconnected.'));

关于消息，有两种选择：

1. 如果您发送数据并期望响应消息-您可以通过以下.sendRequest()方法使用Promise ：

   wsp.sendRequest({foo: 'bar'}); // returns promise
   // actually sends message with unique id: {id: 'xxxxx', foo: 'bar'}
   // promise waits response message with the same id: {id: 'xxxxx', response: 'ok'}
   

2. 如果您只想发送消息而不希望得到响应，请使用.send()方法：

   wsp.send(data); // returns undefined