# @ohos.net.webSocket (WebSocket连接)
> **说明:**
>
> 本模块首批接口从API version 6开始支持。后续版本的新增接口,采用上角标单独标记接口的起始版本。
使用WebSocket建立服务器与客户端的双向连接,需要先通过[createWebSocket](#websocketcreatewebsocket6)方法创建[WebSocket](#websocket6)对象,然后通过[connect](#connect6)方法连接到服务器。
当连接成功后,客户端会收到[open](#onopen6)事件的回调,之后客户端就可以通过[send](#send6)方法与服务器进行通信。
当服务器发信息给客户端时,客户端会收到[message](#onmessage6)事件的回调。当客户端不要此连接时,可以通过调用[close](#close6)方法主动断开连接,之后客户端会收到[close](#onclose6)事件的回调。
若在上述任一过程中发生错误,客户端会收到[error](#onerror6)事件的回调。
## 导入模块
```ts
import { webSocket } from '@kit.NetworkKit';
```
## 完整示例
```ts
import { webSocket } from '@kit.NetworkKit';
import { BusinessError } from '@kit.BasicServicesKit';
let defaultIpAddress = "ws://";
let ws = webSocket.createWebSocket();
ws.on('open', (err:BusinessError, value: Object) => {
if (err != undefined) {
console.log(JSON.stringify(err));
return;
}
// 当收到on('open')事件时,可以通过send()方法与服务器进行通信
ws.send("Hello, server!", (err: BusinessError, value: boolean) => {
if (!err) {
console.log("send success");
} else {
console.log("send fail, err:" + JSON.stringify(err));
}
});
});
ws.on('message',(error: BusinessError, value: string | ArrayBuffer) => {
console.log("on message, message:" + value);
// 当收到服务器的`bye`消息时(此消息字段仅为示意,具体字段需要与服务器协商),主动断开连接
if (value === 'bye') {
ws.close((err: BusinessError, value: boolean) => {
if (!err) {
console.log("close success");
} else {
console.log("close fail, err is " + JSON.stringify(err));
}
});
}
});
ws.on('close', (err: BusinessError, value: webSocket.CloseResult) => {
console.log("on close, code is " + value.code + ", reason is " + value.reason);
});
ws.on('error', (err: BusinessError) => {
console.log("on error, error:" + JSON.stringify(err));
});
ws.connect(defaultIpAddress, {
header:{
name1: 'value1',
name2: 'value2',
name3: 'value3'
},
proxy: {
host: '192.168.0.150',
port: 8888,
exclusionList: []
},
protocol: 'my-protocol',
}, (err: BusinessError, value: boolean) => {
if (!err) {
console.log("connect success");
} else {
console.log("connect fail, err:" + JSON.stringify(err));
}
ws.close((err: BusinessError) => {
if (!err) {
console.log("close success");
} else {
console.log("close fail, err is " + JSON.stringify(err));
}
});
});
```
## webSocket.createWebSocket6+
createWebSocket(): WebSocket
创建一个WebSocket,里面包括建立连接、关闭连接、发送数据和订阅/取消订阅WebSocket连接的打开事件、接收到服务器消息事件、关闭事件和错误事件。
**原子化服务API:** 从API version 11开始,该接口支持在原子化服务中使用。
**系统能力**:SystemCapability.Communication.NetStack
**返回值:**
| 类型 | 说明 |
| :---------------------------------- | :----------------------------------------------------------- |
| [WebSocket](#websocket6) | 返回一个WebSocket对象,里面包括connect、send、close、on和off方法。 |
**示例:**
```ts
let ws: webSocket.WebSocket = webSocket.createWebSocket();
```
## WebSocket6+
在调用WebSocket的方法前,需要先通过[webSocket.createWebSocket](#websocketcreatewebsocket6)创建一个WebSocket。
### connect6+
connect(url: string, callback: AsyncCallback\): void
根据URL地址,建立一个WebSocket连接,使用callback方式作为异步方法。
> **说明:**
> 可通过监听error事件获得该接口的执行结果,错误发生时会得到错误码:200。
**需要权限**:ohos.permission.INTERNET
**原子化服务API:** 从API version 11开始,该接口支持在原子化服务中使用。
**系统能力**:SystemCapability.Communication.NetStack
**注意:**URL地址长度不能超过1024个字符,否则会连接失败。
**参数:**
| 参数名 | 类型 | 必填 | 说明 |
| -------- | ------------------------ | ---- | ---------------------------- |
| url | string | 是 | 建立WebSocket连接的URL地址。 |
| callback | AsyncCallback\ | 是 | 回调函数。 |
**错误码:**
| 错误码ID | 错误信息 |
| --------------------- | ------------------------------------------ |
| 401 | Parameter error. |
| 201 | Permission denied. |
| 230200112+ | Websocket url error. |
| 230200212+ | Websocket certificate file does not exist. |
| 230200312+ | Websocket connection already exists. |
| 230299812+ | It is not allowed to access this domain. |
| 230299910+ | Websocket other unknown error. |
> **错误码说明:**
> 以上错误码的详细介绍参见[webSocket错误码](errorcode-net-webSocket.md)。
**示例:**
```ts
import { webSocket } from '@kit.NetworkKit';
import { BusinessError } from '@kit.BasicServicesKit';
let ws = webSocket.createWebSocket();
let url = "ws://";
ws.connect(url, (err: BusinessError, value: boolean) => {
if (!err) {
console.log("connect success");
} else {
console.log("connect fail, err:" + JSON.stringify(err));
}
});
```
### connect6+
connect(url: string, options: WebSocketRequestOptions, callback: AsyncCallback\): void
根据URL地址和header,建立一个WebSocket连接,使用callback方式作为异步方法。
> **说明:**
> 可通过监听error事件获得该接口的执行结果,错误发生时会得到错误码:200。
**需要权限**:ohos.permission.INTERNET
**原子化服务API:** 从API version 11开始,该接口支持在原子化服务中使用。
**系统能力**:SystemCapability.Communication.NetStack
**注意:**URL地址长度不能超过1024个字符,否则会连接失败。
**参数:**
| 参数名 | 类型 | 必填 | 说明 |
| -------- | ------------------------ | ---- | ------------------------------------------------------- |
| url | string | 是 | 建立WebSocket连接的URL地址。 |
| options | WebSocketRequestOptions | 是 | 参考[WebSocketRequestOptions](#websocketrequestoptions)。 |
| callback | AsyncCallback\ | 是 | 回调函数。 |
**错误码:**
| 错误码ID | 错误信息 |
| --------------------- | ------------------------------------------ |
| 401 | Parameter error. |
| 201 | Permission denied. |
| 230200112+ | Websocket url error. |
| 230200212+ | Websocket certificate file does not exist. |
| 230200312+ | Websocket connection already exists. |
| 230299812+ | It is not allowed to access this domain. |
| 230299910+ | Websocket other unknown error. |
> **错误码说明:**
> 以上错误码的详细介绍参见[webSocket错误码](errorcode-net-webSocket.md)。
**示例:**
```ts
import { webSocket } from '@kit.NetworkKit';
import { BusinessError } from '@kit.BasicServicesKit';
let ws = webSocket.createWebSocket();
let options: webSocket.WebSocketRequestOptions | undefined;
if (options !=undefined) {
options.header = {
name1: "value1",
name2: "value2",
name3: "value3"
};
options.caPath = "";
}
let url = "ws://"
ws.connect(url, options, (err: BusinessError, value: Object) => {
if (!err) {
console.log("connect success");
} else {
console.log("connect fail, err:" + JSON.stringify(err))
}
});
```
### connect6+
connect(url: string, options?: WebSocketRequestOptions): Promise\
根据URL地址和header,建立一个WebSocket连接,使用Promise方式作为异步方法。
> **说明:**
> 可通过监听error事件获得该接口的执行结果,错误发生时会得到错误码:200。
**需要权限**:ohos.permission.INTERNET
**原子化服务API:** 从API version 11开始,该接口支持在原子化服务中使用。
**系统能力**:SystemCapability.Communication.NetStack
**注意:**URL地址长度不能超过1024个字符,否则会连接失败。
**参数:**
| 参数名 | 类型 | 必填 | 说明 |
| ------- | ----------------------- | ---- | ------------------------------------------------------- |
| url | string | 是 | 建立WebSocket连接的URL地址。 |
| options | WebSocketRequestOptions | 否 | 参考[WebSocketRequestOptions](#websocketrequestoptions)。 |
**返回值:**
| 类型 | 说明 |
| :----------------- | :-------------------------------- |
| Promise\ | 以Promise形式返回建立连接的结果。 |
**错误码:**
| 错误码ID | 错误信息 |
| --------------------- | ------------------------------------------ |
| 401 | Parameter error. |
| 201 | Permission denied. |
| 230200112+ | Websocket url error. |
| 230200212+ | Websocket certificate file does not exist. |
| 230200312+ | Websocket connection already exists. |
| 230299812+ | It is not allowed to access this domain. |
| 230299910+ | Websocket other unknown error. |
> **错误码说明:**
> 以上错误码的详细介绍参见[webSocket错误码](errorcode-net-webSocket.md)。
**示例:**
```ts
import { webSocket } from '@kit.NetworkKit';
let ws = webSocket.createWebSocket();
let url = "ws://"
let promise = ws.connect(url);
promise.then((value: boolean) => {
console.log("connect success")
}).catch((err:string) => {
console.log("connect fail, error:" + JSON.stringify(err))
});
```
### send6+
send(data: string | ArrayBuffer, callback: AsyncCallback\): void
通过WebSocket连接发送数据,使用callback方式作为异步方法。
**需要权限**:ohos.permission.INTERNET
**原子化服务API:** 从API version 11开始,该接口支持在原子化服务中使用。
**系统能力**:SystemCapability.Communication.NetStack
**参数:**
| 参数名 | 类型 | 必填 | 说明 |
| -------- | ------------------------ | ---- | ------------ |
| data | string \| ArrayBuffer | 是 | 发送的数据。
API 6及更早版本仅支持string类型。API 8起同时支持string和ArrayBuffer类型。 |
| callback | AsyncCallback\ | 是 | 回调函数。 |
**错误码:**
| 错误码ID | 错误信息 |
| ------- | ----------------------- |
| 401 | Parameter error. |
| 201 | Permission denied. |
**示例:**
```ts
import { webSocket } from '@kit.NetworkKit';
import { BusinessError } from '@kit.BasicServicesKit';
let ws = webSocket.createWebSocket();
let url = "ws://"
class OutValue {
status: number = 0
message: string = ""
}
ws.connect(url, (err: BusinessError, value: boolean) => {
if (!err) {
console.log("connect success");
} else {
console.log("connect fail, err:" + JSON.stringify(err))
}
});
ws.on('open', (err: BusinessError, value: Object) => {
console.log("on open, status:" + (value as OutValue).status + ", message:" + (value as OutValue).message);
ws.send("Hello, server!", (err: BusinessError, value: boolean) => {
if (!err) {
console.log("send success");
} else {
console.log("send fail, err:" + JSON.stringify(err))
}
});
});
```
> **说明**
>
> send接口必须在监听到open事件后才可以调用。
### send6+
send(data: string | ArrayBuffer): Promise\
通过WebSocket连接发送数据,使用Promise方式作为异步方法。
**需要权限**:ohos.permission.INTERNET
**原子化服务API:** 从API version 11开始,该接口支持在原子化服务中使用。
**系统能力**:SystemCapability.Communication.NetStack
**参数:**
| 参数名 | 类型 | 必填 | 说明 |
| ------ | ------ | ---- | ------------ |
| data | string \| ArrayBuffer | 是 | 发送的数据。
API 6及更早版本仅支持string类型。API 8起同时支持string和ArrayBuffer类型。 |
**返回值:**
| 类型 | 说明 |
| :----------------- | :-------------------------------- |
| Promise\ | 以Promise形式返回发送数据的结果。 |
**错误码:**
| 错误码ID | 错误信息 |
| ------- | ----------------------- |
| 401 | Parameter error. |
| 201 | Permission denied. |
**示例:**
```ts
import { webSocket } from '@kit.NetworkKit';
import { BusinessError } from '@kit.BasicServicesKit';
let ws = webSocket.createWebSocket();
let url = "ws://"
class OutValue {
status: number = 0
message: string = ""
}
ws.connect(url, (err: BusinessError, value: boolean) => {
if (!err) {
console.log("connect success");
} else {
console.log("connect fail, err:" + JSON.stringify(err))
}
});
ws.on('open', (err: BusinessError, value: Object) => {
console.log("on open, status:" + (value as OutValue).status + ", message:" + (value as OutValue).message);
let promise = ws.send("Hello, server!");
promise.then((value: boolean) => {
console.log("send success")
}).catch((err:string) => {
console.log("send fail, error:" + JSON.stringify(err))
});
});
```
> **说明**
>
> send接口必须在监听到open事件后才可以调用。
### close6+
close(callback: AsyncCallback\): void
关闭WebSocket连接,使用callback方式作为异步方法。
**需要权限**:ohos.permission.INTERNET
**原子化服务API:** 从API version 11开始,该接口支持在原子化服务中使用。
**系统能力**:SystemCapability.Communication.NetStack
**参数:**
| 参数名 | 类型 | 必填 | 说明 |
| -------- | ------------------------ | ---- | ---------- |
| callback | AsyncCallback\ | 是 | 回调函数。 |
**错误码:**
| 错误码ID | 错误信息 |
| ------- | ----------------------- |
| 401 | Parameter error. |
| 201 | Permission denied. |
**示例:**
```ts
import { webSocket } from '@kit.NetworkKit';
import { BusinessError } from '@kit.BasicServicesKit';
let ws = webSocket.createWebSocket();
ws.close((err: BusinessError) => {
if (!err) {
console.log("close success")
} else {
console.log("close fail, err is " + JSON.stringify(err))
}
});
```
### close6+
close(options: WebSocketCloseOptions, callback: AsyncCallback\): void
根据可选参数code和reason,关闭WebSocket连接,使用callback方式作为异步方法。
**需要权限**:ohos.permission.INTERNET
**原子化服务API:** 从API version 11开始,该接口支持在原子化服务中使用。
**系统能力**:SystemCapability.Communication.NetStack
**参数:**
| 参数名 | 类型 | 必填 | 说明 |
| -------- | ------------------------ | ---- | ----------------------------------------------------- |
| options | WebSocketCloseOptions | 是 | 参考[WebSocketCloseOptions](#websocketcloseoptions)。 |
| callback | AsyncCallback\ | 是 | 回调函数。 |
**错误码:**
| 错误码ID | 错误信息 |
| ------- | ----------------------- |
| 401 | Parameter error. |
| 201 | Permission denied. |
**示例:**
```ts
import { webSocket } from '@kit.NetworkKit';
import { BusinessError } from '@kit.BasicServicesKit';
let ws = webSocket.createWebSocket();
let options: webSocket.WebSocketCloseOptions | undefined;
if (options != undefined) {
options.code = 1000
options.reason = "your reason"
}
ws.close(options, (err: BusinessError) => {
if (!err) {
console.log("close success")
} else {
console.log("close fail, err is " + JSON.stringify(err))
}
});
```
### close6+
close(options?: WebSocketCloseOptions): Promise\
根据可选参数code和reason,关闭WebSocket连接,使用Promise方式作为异步方法。
**需要权限**:ohos.permission.INTERNET
**原子化服务API:** 从API version 11开始,该接口支持在原子化服务中使用。
**系统能力**:SystemCapability.Communication.NetStack
**参数:**
| 参数名 | 类型 | 必填 | 说明 |
| ------- | --------------------- | ---- | ----------------------------------------------------- |
| options | WebSocketCloseOptions | 否 | 参考[WebSocketCloseOptions](#websocketcloseoptions)。 |
**返回值:**
| 类型 | 说明 |
| :----------------- | :-------------------------------- |
| Promise\ | 以Promise形式返回关闭连接的结果。 |
**错误码:**
| 错误码ID | 错误信息 |
| ------- | ----------------------- |
| 401 | Parameter error. |
| 201 | Permission denied. |
**示例:**
```ts
import { webSocket } from '@kit.NetworkKit';
let ws = webSocket.createWebSocket();
let options: webSocket.WebSocketCloseOptions | undefined;
if (options != undefined) {
options.code = 1000
options.reason = "your reason"
}
let promise = ws.close();
promise.then((value: boolean) => {
console.log("close success")
}).catch((err:string) => {
console.log("close fail, err is " + JSON.stringify(err))
});
```
### on('open')6+
on(type: 'open', callback: AsyncCallback\