# @ohos.net.webSocket (WebSocket连接)
> **说明:**
>
> 本模块首批接口从API version 6开始支持。后续版本的新增接口,采用上角标单独标记接口的起始版本。
给第三方应用提供webSocket客户端和服务端服务器,实现客户端与服务端的双向连接,目前服务端仅支持智慧屏使用。
客户端:使用WebSocket建立服务器与客户端的双向连接,需要先通过[createWebSocket](#websocketcreatewebsocket6)方法创建[WebSocket](#websocket6)对象,然后通过[connect](#connect6)方法连接到服务器。当连接成功后,客户端会收到[open](#onopen6)事件的回调,之后客户端就可以通过[send](#send6)方法与服务器进行通信。当服务器发信息给客户端时,客户端会收到[message](#onmessage6)事件的回调。当客户端想要取消此连接时,通过调用[close](#close6)方法主动断开连接后,客户端会收到[close](#onclose6)事件的回调。若在上述任一过程中发生错误,客户端会收到[error](#onerror6)事件的回调。
服务端:(目前服务端仅支持智慧屏使用)使用WebSocket建立服务器与客户端的双向连接,需要先通过[createWebSocketServer](#websocketcreatewebsocketserver19)方法创建[WebSocketServer](#websocketserver19)对象,然后通过[start](#start19)方法启动服务器,监听客户端的申请建链的消息。当连接成功后,服务端会收到[connect](#onconnect19)事件的回调,之后服务端可以通过[send](#send19)方法与客户端进行通信,或者通过[listAllConnections](#listallconnections19)方法列举出当前与服务端建链的所有客户端信息。当客户端给服务端发消息时,服务端会收到[messageReceive](#onmessagereceive19)事件回调。当服务端想断开与某个客户端的连接时,可以通过调用[close](#close19)方法主动断开与某个客户端的连接,之后服务端会收到[close](#onclose19)事件的回调。当服务端想停止service时,可以调用[stop](#stop19)方法。若在上述任一过程中发生错误,服务端会收到[error](#onerror19)事件的回调。
## 导入模块
```ts
import { webSocket } from '@kit.NetworkKit';
```
## 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事件获得该接口的执行结果。
**需要权限**:ohos.permission.INTERNET
**原子化服务API:** 从API version 11开始,该接口支持在原子化服务中使用。
**系统能力**:SystemCapability.Communication.NetStack
**注意:** URL地址长度不能超过1024个字符,否则会连接失败。从API15开始,URL地址长度限制由1024修改为2048。
**参数:**
| 参数名 | 类型 | 必填 | 说明 |
| -------- | ------------------------ | ---- | ---------------------------- |
| url | string | 是 | 建立WebSocket连接的URL地址。 |
| callback | AsyncCallback\ | 是 | 回调函数。true:连接请求创建成功;false:连接请求创建失败。 |
**错误码:**
以下错误码的详细介绍参见[webSocket错误码](errorcode-net-webSocket.md)和[通用错误码](../errorcode-universal.md)。
| 错误码ID | 错误信息 |
| --------------------- | ------------------------------------------ |
| 401 | Parameter error. |
| 201 | Permission denied. |
| 2302001 | Websocket url error. |
| 2302002 | Websocket certificate file does not exist. |
| 2302003 | Websocket connection already exists. |
| 2302998 | It is not allowed to access this domain. |
| 2302999 | Internal error. |
**示例:**
```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.info("connect success")
} else {
console.error(`connect fail. Code: ${err.code}, message: ${err.message}`)
}
});
```
### connect6+
connect(url: string, options: WebSocketRequestOptions, callback: AsyncCallback\): void
根据URL地址,建立一个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\ | 是 | 回调函数。true:连接请求创建成功;false:连接请求创建失败。 |
**错误码:**
以下错误码的详细介绍参见[webSocket错误码](errorcode-net-webSocket.md)和[通用错误码](../errorcode-universal.md)。
| 错误码ID | 错误信息 |
| --------------------- | ------------------------------------------ |
| 401 | Parameter error. |
| 201 | Permission denied. |
| 2302001 | Websocket url error. |
| 2302002 | Websocket certificate file does not exist. |
| 2302003 | Websocket connection already exists. |
| 2302998 | It is not allowed to access this domain. |
| 2302999 | Internal error. |
**示例:**
```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.info("connect success")
} else {
console.error(`connect fail. Code: ${err.code}, message: ${err.message}`)
}
});
```
### 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\ | 回调函数。true:连接请求创建成功;false:连接请求创建失败。 |
**错误码:**
以下错误码的详细介绍参见[webSocket错误码](errorcode-net-webSocket.md)和[通用错误码](../errorcode-universal.md)。
| 错误码ID | 错误信息 |
| --------------------- | ------------------------------------------ |
| 401 | Parameter error. |
| 201 | Permission denied. |
| 2302001 | Websocket url error. |
| 2302002 | Websocket certificate file does not exist. |
| 2302003 | Websocket connection already exists. |
| 2302998 | It is not allowed to access this domain. |
| 2302999 | Internal error. |
**示例:**
```ts
import { webSocket } from '@kit.NetworkKit';
let ws = webSocket.createWebSocket();
let url = "ws://"
let promise = ws.connect(url);
promise.then((value: boolean) => {
console.info("connect success")
}).catch((err:string) => {
console.error("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\ | 是 | 回调函数。true:发送请求创建成功;false:发送请求创建失败。 |
**错误码:**
以下错误码的详细介绍参见[通用错误码](../errorcode-universal.md)。
| 错误码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.info("connect success")
} else {
console.error(`connect fail. Code: ${err.code}, message: ${err.message}`)
}
});
ws.on('open', (err: BusinessError, value: Object) => {
console.info("on open, status:" + (value as OutValue).status + ", message:" + (value as OutValue).message)
ws.send("Hello, server!", (err: BusinessError, value: boolean) => {
if (!err) {
console.info("send success")
} else {
console.error(`send fail. Code: ${err.code}, message: ${err.message}`)
}
});
});
```
> **说明:**
>
> 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形式返回发送数据的结果。true:发送请求创建成功;false:发送请求创建失败。 |
**错误码:**
以下错误码的详细介绍参见[通用错误码](../errorcode-universal.md)。
| 错误码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.info("connect success")
} else {
console.error("connect fail. Code: ${err.code}, message: ${err.message}")
}
});
ws.on('open', (err: BusinessError, value: Object) => {
console.info("on open, status:" + (value as OutValue).status + ", message:" + (value as OutValue).message)
let promise = ws.send("Hello, server!");
promise.then((value: boolean) => {
console.info("send success")
}).catch((err:string) => {
console.error("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\ | 是 | 回调函数。true:关闭请求创建成功;false:关闭请求创建失败。 |
**错误码:**
以下错误码的详细介绍参见[通用错误码](../errorcode-universal.md)。
| 错误码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.info("close success")
} else {
console.error(`close fail. Code: ${err.code}, message: ${err.message}`)
}
});
```
### close6+
close(options: WebSocketCloseOptions, callback: AsyncCallback\): void
根据参数options,关闭WebSocket连接,使用callback方式作为异步方法。
**需要权限**:ohos.permission.INTERNET
**原子化服务API:** 从API version 11开始,该接口支持在原子化服务中使用。
**系统能力**:SystemCapability.Communication.NetStack
**参数:**
| 参数名 | 类型 | 必填 | 说明 |
| -------- | ------------------------ | ---- | ----------------------------------------------------- |
| options | WebSocketCloseOptions | 是 | 参考[WebSocketCloseOptions](#websocketcloseoptions)。 |
| callback | AsyncCallback\ | 是 | 回调函数。true:关闭请求创建成功;false:关闭请求创建失败。 |
**错误码:**
以下错误码的详细介绍参见[通用错误码](../errorcode-universal.md)。
| 错误码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.info("close success")
} else {
console.error(`close fail. Code: ${err.code}, message: ${err.message}`)
}
});
```
### 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形式返回关闭连接的结果。true:关闭请求创建成功;false:关闭请求创建失败。 |
**错误码:**
以下错误码的详细介绍参见[通用错误码](../errorcode-universal.md)。
| 错误码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.info("close success")
}).catch((err:string) => {
console.error("close fail, error:" + JSON.stringify(err))
});
```
### on('open')6+
on(type: 'open', callback: AsyncCallback\