WebSocket連接

導入模塊

import webSocket from '@ohos.net.webSocket';

完整示例

import webSocket from '@ohos.net.webSocket';

var defaultIpAddress = "ws://";
let ws = webSocket.createWebSocket();
ws.on('open', (err, value) => {
    console.log("on open, status:" + value['status'] + ", message:" + value['message']);
    // 當收到on('open')事件時，可以通過send()方法與服務器進行通信
    ws.send("Hello, server!", (err, value) => {
        if (!err) {
            console.log("send success");
        } else {
            console.log("send fail, err:" + JSON.stringify(err));
        }
    });
});
ws.on('message', (err, value) => {
    console.log("on message, message:" + value);
    // 當收到服務器的`bye`消息時（此消息字段僅為示意，具體字段需要與服務器協(xié)商），主動斷開連接
    if (value === 'bye') {
        ws.close((err, value) => {
            if (!err) {
                console.log("close success");
            } else {
                console.log("close fail, err is " + JSON.stringify(err));
            }
        });
    }
});
ws.on('close', (err, value) => {
    console.log("on close, code is " + value.code + ", reason is " + value.reason);
});
ws.on('error', (err) => {
    console.log("on error, error:" + JSON.stringify(err));
});
ws.connect(defaultIpAddress, (err, value) => {
    if (!err) {
        console.log("connect success");
    } else {
        console.log("connect fail, err:" + JSON.stringify(err));
    }
});

webSocket.createWebSocket

createWebSocket(): WebSocket

創(chuàng)建一個WebSocket，里面包括建立連接、關閉連接、發(fā)送數(shù)據(jù)和訂閱/取消訂閱WebSocket連接的打開事件、接收到服務器消息事件、關閉事件和錯誤事件。

系統(tǒng)能力：SystemCapability.Communication.NetStack

返回值：

示例：

let ws = webSocket.createWebSocket();

WebSocket

在調用WebSocket的方法前，需要先通過webSocket.createWebSocket創(chuàng)建一個WebSocket。

connect

connect(url: string, callback: AsyncCallback<boolean>): void

根據(jù)URL地址，建立一個WebSocket連接，使用callback方式作為異步方法。

需要權限：ohos.permission.INTERNET

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

錯誤碼：

示例：

let ws = webSocket.createWebSocket();
let url = "ws://"
ws.connect(url, (err, value) => {
    if (!err) {
        console.log("connect success");
    } else {
        console.log("connect fail, err:" + JSON.stringify(err))
    }
});

connect

connect(url: string, options: WebSocketRequestOptions, callback: AsyncCallback<boolean>): void

根據(jù)URL地址和header，建立一個WebSocket連接，使用callback方式作為異步方法。

需要權限：ohos.permission.INTERNET

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

錯誤碼：

示例：

let ws = webSocket.createWebSocket();
let url = "ws://"
ws.connect(url, {
    header: {
        "key": "value",
        "key2": "value2"
    }
}, (err, value) => {
    if (!err) {
        console.log("connect success");
    } else {
        console.log("connect fail, err:" + JSON.stringify(err))
    }
});

connect

connect(url: string, options?: WebSocketRequestOptions): Promise<boolean>

根據(jù)URL地址和header，建立一個WebSocket連接，使用Promise方式作為異步方法。

需要權限：ohos.permission.INTERNET

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

返回值：

錯誤碼：

示例：

let ws = webSocket.createWebSocket();
let url = "ws://"
let promise = ws.connect(url);
promise.then((value) => {
    console.log("connect success")
}).catch((err) => {
    console.log("connect fail, error:" + JSON.stringify(err))
});

send

send(data: string | ArrayBuffer, callback: AsyncCallback<boolean>): void

通過WebSocket連接發(fā)送數(shù)據(jù)，使用callback方式作為異步方法。

需要權限：ohos.permission.INTERNET

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

錯誤碼：

示例：

let ws = webSocket.createWebSocket();
let url = "ws://"
ws.connect(url, (err, value) => {
    ws.send("Hello, server!", (err, value) => {
        if (!err) {
            console.log("send success");
        } else {
            console.log("send fail, err:" + JSON.stringify(err))
        }
    });
});

send

send(data: string | ArrayBuffer): Promise<boolean>

通過WebSocket連接發(fā)送數(shù)據(jù)，使用Promise方式作為異步方法。

需要權限：ohos.permission.INTERNET

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

返回值：

錯誤碼：

示例：

let ws = webSocket.createWebSocket();
let url = "ws://"
ws.connect(url, (err, value) => {
    let promise = ws.send("Hello, server!");
    promise.then((value) => {
        console.log("send success")
    }).catch((err) => {
        console.log("send fail, error:" + JSON.stringify(err))
    });
});

close

close(callback: AsyncCallback<boolean>): void

關閉WebSocket連接，使用callback方式作為異步方法。

需要權限：ohos.permission.INTERNET

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

錯誤碼：

示例：

let ws = webSocket.createWebSocket();
let url = "ws://"
ws.close((err, value) => {
    if (!err) {
        console.log("close success")
    } else {
        console.log("close fail, err is " + JSON.stringify(err))
    }
});

close

close(options: WebSocketCloseOptions, callback: AsyncCallback<boolean>): void

根據(jù)可選參數(shù)code和reason，關閉WebSocket連接，使用callback方式作為異步方法。

需要權限：ohos.permission.INTERNET

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

錯誤碼：

示例：

let ws = webSocket.createWebSocket();
let url = "ws://"
ws.close({
    code: 1000,
    reason: "your reason"
}, (err, value) => {
    if (!err) {
        console.log("close success")
    } else {
        console.log("close fail, err is " + JSON.stringify(err))
    }
});

close

close(options?: WebSocketCloseOptions): Promise<boolean>

根據(jù)可選參數(shù)code和reason，關閉WebSocket連接，使用Promise方式作為異步方法。

需要權限：ohos.permission.INTERNET

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

返回值：

錯誤碼：

示例：

let ws = webSocket.createWebSocket();
let url = "ws://"
let promise = ws.close({
    code: 1000,
    reason: "your reason"
});
promise.then((value) => {
    console.log("close success")
}).catch((err) => {
    console.log("close fail, err is " + JSON.stringify(err))
});

on('open')

on(type: 'open', callback: AsyncCallback<Object>): void

訂閱WebSocket的打開事件，使用callback方式作為異步方法。

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

示例：

let ws = webSocket.createWebSocket();
ws.on('open', (err, value) => {
    console.log("on open, status:" + value['status'] + ", message:" + value['message']);
});

off('open')

off(type: 'open', callback?: AsyncCallback<Object>): void

取消訂閱WebSocket的打開事件，使用callback方式作為異步方法。

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

示例：

let ws = webSocket.createWebSocket();
let callback1 = (err, value) => {
    console.log("on open, status:" + value['status'] + ", message:" + value['message']);
}
ws.on('open', callback1);
// 可以指定傳入on中的callback取消一個訂閱，也可以不指定callback清空所有訂閱
ws.off('open', callback1);

on('message')

on(type: 'message', callback: AsyncCallback<string | ArrayBuffer>): void

訂閱WebSocket的接收到服務器消息事件，使用callback方式作為異步方法。每個消息最大長度為4K，超過4K自動分片。

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

示例：

let ws = webSocket.createWebSocket();
ws.on('message', (err, value) => {
    console.log("on message, message:" + value);
});

off('message')

off(type: 'message', callback?: AsyncCallback<string | ArrayBuffer>): void

取消訂閱WebSocket的接收到服務器消息事件，使用callback方式作為異步方法。每個消息最大長度為4K，超過4K自動分片。

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

示例：

let ws = webSocket.createWebSocket();
ws.off('message');

on('close')

on(type: 'close', callback: AsyncCallback<{ code: number, reason: string }>): void

訂閱WebSocket的關閉事件，使用callback方式作為異步方法。

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

示例：

let ws = webSocket.createWebSocket();
ws.on('close', (err, value) => {
    console.log("on close, code is " + value.code + ", reason is " + value.reason);
});

off('close')

off(type: 'close', callback?: AsyncCallback<{ code: number, reason: string }>): void

取消訂閱WebSocket的關閉事件，使用callback方式作為異步方法。

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

示例：

let ws = webSocket.createWebSocket();
ws.off('close');

on('error')

on(type: 'error', callback: ErrorCallback): void

訂閱WebSocket的Error事件，使用callback方式作為異步方法。

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

示例：

let ws = webSocket.createWebSocket();
ws.on('error', (err) => {
    console.log("on error, error:" + JSON.stringify(err))
});

off('error')

off(type: 'error', callback?: ErrorCallback): void

取消訂閱WebSocket的Error事件，使用callback方式作為異步方法。

系統(tǒng)能力：SystemCapability.Communication.NetStack

參數(shù)：

示例：

let ws = webSocket.createWebSocket();
ws.off('error');

WebSocketRequestOptions

建立WebSocket連接時，可選參數(shù)的類型和說明。

系統(tǒng)能力：以下各項對應的系統(tǒng)能力均為SystemCapability.Communication.NetStack。

WebSocketCloseOptions

關閉WebSocket連接時，可選參數(shù)的類型和說明。

系統(tǒng)能力：以下各項對應的系統(tǒng)能力均為SystemCapability.Communication.NetStack。

close錯誤碼說明

發(fā)送給服務端的錯誤碼可以自行定義，下面的列表僅供參考。

系統(tǒng)能力：以下各項對應的系統(tǒng)能力均為SystemCapability.Communication.NetStack。