//连接失败
client.on('connectFailed', function(error) {
console.log('Connect Error, ' + error.toString());
//开始连接
client.on('connect', function(connection) {
console.log('开始连接'+url);
connection.on('error', function(error) {
console.log("连接错误 " + error.toString());
connection.on('close', function() {
console.log('连接关闭');
connection.on('message', function (message) {
connection.resolveFunc(message)
if (connection.connected) {
console.log('websocket连接已建立')
resolve(connection)
client.connect(url)
发送消息并获得结果
let send=function (conn,msg) {
return new Promise((resolve => {
conn.sendUTF(msg)
conn.resolveFunc=resolve
let close=function(conn){
conn.close()
module.exports={
connect:connect,
send:send,
close:close
const util=require('./AsyncWebsocketUtil')
async function main() {
let conn=await util.connect('wss://api.yourhost.pr/ws')
let respMsg=await util.send(conn,'1')
console.log(respMsg)
main()
