@ohos.distributedsched.linkEnhance (Enhanced Connection)

The linkEnhance module delivers highly efficient Bluetooth connectivity and data transmission capabilities, significantly enhancing the cross-device connection stability. By employing a multi-channel merging algorithm, it not only increases the number of available cross-device connections but also strengthens cross-device data transmission capabilities, thereby improving the overall user experience.

NOTE

The initial APIs of this module are supported since API version 20. Newly added APIs will be marked with a superscript to indicate their earliest API version.

Modules to Import

import { linkEnhance } from '@kit.DistributedServiceKit';

linkEnhance.createServer

createServer(name: string): Server

Creates a Server object. After start() is called, the device can be connected to other devices as a server.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Parameters

Returns

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
const TAG = "testDemo";

linkEnhanceStart(name: string) {
  hilog.info(0x0000, TAG, 'start sever deviceId = ' + name);
  try {
    // Construct a Server object using the specified name.
    let server: linkEnhance.Server = linkEnhance.createServer(name);
  } catch (err) {
    hilog.info(0x0000, TAG, 'start sever errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

linkEnhance.createConnection

createConnection(deviceId: string, name: string): Connection

Creates a Connection object on the device that functions as the client. The device can then initiate connection requests to the device that functions as the server.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Parameters

Returns

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

On the device that functions as the client, call the createConnection() to create a Connection object.

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
const TAG = "testDemo";

linkEnhanceCreateConnection(peerDeviceId: string) {
  hilog.info(0x0000, TAG, 'connection sever deviceId = ' + peerDeviceId);
  try {
    let connection: linkEnhance.Connection = linkEnhance.createConnection(peerDeviceId, "demo");
  } catch (err) {
    hilog.info(0x0000, TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

Server

Represents a Server object, which provides methods for starting, stopping, and closing the server, and registering or unregistering event callbacks.

The following APIs are used on the server.

start()

start(): void

Starts the server so that it can be connected to the client.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
const TAG = "testDemo";

linkEnhanceStart(name: string) {
  hilog.info(0x0000, TAG, 'start sever deviceId = ' + name);
  try {
    let server: linkEnhance.Server = linkEnhance.createServer(name);
    server.start();
  } catch (err) {
    hilog.error(0x0000, TAG, 'start sever errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

stop()

stop(): void

Stops the server. After the server is stopped, you can call start to start it again.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
const TAG = "testDemo";

linkEnhanceStart(name: string) {
  hilog.info(0x0000, TAG, 'start sever deviceId = ' + name);
  try {
    let server: linkEnhance.Server = linkEnhance.createServer(name);
    server.start();
    server.stop();
   } catch (err) {
    hilog.error(0x0000, TAG, 'start sever errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

close()

close(): void

Destroys the Server object to release related resources. To interact with the peer device again, create a new Server object.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
const TAG = "testDemo";

linkEnhanceStart(name: string) {
  hilog.info(0x0000, TAG, 'start sever deviceId = ' + name);
  try {
    let server: linkEnhance.Server = linkEnhance.createServer(name);
    server.start();
    server.close();
  } catch (err) {
    hilog.error(0x0000, TAG, 'start sever errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

on(‘connectionAccepted’)

on(type: ‘connectionAccepted’, Callback<Connection>): void

Registers a callback listener for the connectionAccepted event. This API uses an asynchronous callback to return the result.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
const TAG = "testDemo";

linkEnhanceStart(name: string) {
  hilog.info(0x0000, TAG, 'start sever deviceId = ' + name);
  try {
    // Construct a Server object using the specified name.
    let server: linkEnhance.Server = linkEnhance.createServer(name);

    // Subscribe to the connectionAccepted event.
    server.on('connectionAccepted', (connection: linkEnhance.Connection): void => {
        hilog.info(0x0000, TAG, 'serverOnCallback = ' + JSON.stringify(connection));
    });
    // Start the server.
    server.start();
  } catch (err) {
    hilog.info(0x0000, TAG, 'start sever errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

off(‘connectionAccepted’)

off(type: ‘connectionAccepted’, Callback<Connection>): void

Unregisters the callback listener for the connectionAccepted event. This API uses an asynchronous callback to return the result.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
const TAG = "testDemo";

linkEnhanceStart(name: string) {
  hilog.info(0x0000, TAG, 'start sever deviceId = ' + name);
  try {
    // Construct a Server object using the specified name.
    let server: linkEnhance.Server = linkEnhance.createServer(name);
    server.on('connectionAccepted', (connection: linkEnhance.Connection): void => {
    hilog.info(0x0000, TAG, 'accpet new connection');
  });
  // Unsubscribe from the connectionAccepted event.
  server.off('connectionAccepted', (connection: linkEnhance.Connection): void => {
    hilog.info(0x0000, TAG, 'accpet new connection');
    });
  } catch (err) {
    hilog.error(0x0000, TAG, 'start sever errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

on(‘serverStopped’)

on(type: ‘serverStopped’, Callback<Connection>): void

Registers a callback listener for the serverStopped event. This API uses an asynchronous callback to return the result.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
const TAG = "testDemo";

linkEnhanceStart(name: string) {
  hilog.info(0x0000, TAG, 'start sever deviceId = ' + name);
  try {
    // Construct a Server object using the specified name.
    let server: linkEnhance.Server = linkEnhance.createServer(name);

    // Unsubscribe from the serverStopped event.
    server.on('serverStopped', (reason: number): void => {
      hilog.info(0x0000, TAG, 'serverStopped, reason= ' + reason);
    });
    // Start the server.
    server.start();
  } catch (err) {
    hilog.error(0x0000, TAG, 'start sever errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

off(‘serverStopped’)

off(type: ‘serverStopped’, Callback<Connection>): void

Unregisters the callback listener for the serverStopped event. This API uses an asynchronous callback to return the result.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
const TAG = "testDemo";

linkEnhanceStart(name: string) {
  hilog.info(0x0000, TAG, 'start sever deviceId = ' + name);
  try {
    // Construct a Server object using the specified name.
    let server: linkEnhance.Server = linkEnhance.createServer(name);
    server.on('serverStopped', (reason: number): void => {
      hilog.info(0x0000, TAG, 'serverStopped, reason= ' + reason);
    });
    // Unsubscribe from the serverStopped event.
    server.off('serverStopped', (reason: number): void => {
      hilog.info(0x0000, TAG, 'serverStopped, reason= ' + reason);
    });
  } catch (err) {
    hilog.info(0x0000, TAG, 'start sever errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
    }
}

ConnectResult

Represents the connection result, which is returned after the client calls connect().

System capability: SystemCapability.DistributedSched.AppCollaboration

Connection

Represents a Connection object, which provides methods for connecting to and disconnecting from a peer device, obtaining the device’s ID, sending data, and registering or unregistering event callbacks.

connect()

connect(void): void

Connects to the server from the client.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

After creating a Connection object, the application on the client device calls connect() to connect to the target device (that is, the server).

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';

const TAG = "testDemo";

linkEnhanceConnect(peerDeviceId: string) {
  hilog.info(0x0000, TAG, 'connection sever deviceId = ' + peerDeviceId);
  try {
    let connection: linkEnhance.Connection = linkEnhance.createConnection(peerDeviceId, "demo");
    // Subscribe to connection events.
    this.linkEnhanceRegisterConnectResult(connection);
    // Initiate a connection.
    connection.connect();
  } catch (err) {
    hilog.error(0x0000, TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}
linkEnhanceRegisterConnectResult(connection: linkEnhance.Connection) {
  connection.on('connectResult', (result: linkEnhance.ConnectResult): void => {
    hilog.info(0x0000, TAG, 'clientConnectResultCallback result = ' + result.success);
    try {
      if (result.success) {
        connection.on('dataReceived',(data: ArrayBuffer): void => {
          hilog.info(0x0000, TAG, 'receiveOnCallback data');
        });
      }
    } catch (err) {
      hilog.error(0x0000, TAG, 'connect state change on callback errCode: ' + (err as BusinessError).code + ', errMessage: ' +
      (err as BusinessError).message);
    }
  });
}

disconnect()

disconnect(): void

Disconnects from the peer device. The created Connection object remains valid after this API is called. You can call connect() to reconnect to the peer device if necessary.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';

const TAG = "testDemo";

linkEnhanceConnect(peerDeviceId: string) {
  hilog.info(0x0000, TAG, 'connection sever deviceId = ' + peerDeviceId);
  try {
    let connection: linkEnhance.Connection = linkEnhance.createConnection(peerDeviceId, "demo");
    connection.connect();
    connection.on('connectResult', (result: linkEnhance.ConnectResult): void => {
      hilog.info(0x0000, TAG, 'clientConnectResultCallback result = ' + result.success);
      if (result.success) {
        connection.disconnect();
      }
    });
    connection.disconnect();
  } catch (err) {
     hilog.error(0x0000, TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

close()

close(): void

Destroys the Connection object to release resources. If the device needs to interact with the peer device again, create a Connection object again and call connect() to initiate a connection.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';

const TAG = "testDemo";
linkEnhanceConnect(peerDeviceId: string) {
  hilog.info(0x0000, TAG, 'connection sever deviceId = ' + peerDeviceId);
  try {
    let connection: linkEnhance.Connection = linkEnhance.createConnection(peerDeviceId, "demo");
    connection.connect();
    connection.on('connectResult', (result: linkEnhance.ConnectResult): void => {
      hilog.info(0x0000, TAG, 'clientConnectResultCallback result = ' + result.success);
      if (result.success) {
        connection.close();
      }
    });
  } catch (err) {
    hilog.error(0x0000, TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

getPeerDeviceId()

getPeerDeviceId(): string

Obtains the device ID of the peer device. This API is called when the connection is established successfully either by initiating a connection or accepting an incoming connection.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Returns

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';

const TAG = "testDemo";
linkEnhanceConnect(peerDeviceId: string) {
  hilog.info(0x0000, TAG, 'connection sever deviceId = ' + peerDeviceId);
  try {
    let connection: linkEnhance.Connection = linkEnhance.createConnection(peerDeviceId, "demo");
    connection.getPeerDeviceId();
    hilog.info(0x0000, TAG, "peerDeviceId=%{public}s" + connection.getPeerDeviceId());
  } catch (err) {
    hilog.error(0x0000, TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

sendData()

sendData(data: ArrayBuffer): void

Sends data to the server after a connection is established successfully. When the server receives the connection callback, it can also send data to the client.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Parameters

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
const TAG = "testDemo";

linkEnhanceConnect(peerDeviceId: string) {
  hilog.info(0x0000, TAG, 'connection sever deviceId = ' + peerDeviceId);
  try {
    let connection: linkEnhance.Connection = linkEnhance.createConnection(peerDeviceId, "demo");
    connection.connect();
    connection.on('connectResult', (result: linkEnhance.ConnectResult): void => {
      hilog.info(0x0000, TAG, 'clientConnectResultCallback result = ' + result.success);
      if (result.success) {
        let len = 1;
        let arraybuffer = new ArrayBuffer(len); // Create the data to send.
        connection.sendData(arraybuffer);
        hilog.info(0x0000, TAG, "sendData data connection peerDeviceId=%{public}s" + connection.getPeerDeviceId());
      }
    });
  } catch (err) {
    hilog.error(0x0000, TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

on(‘connectResult’)

on(type: ‘connectResult’, callback: Callback<ConnectResult>): void

Registers a listener for the connectResult event. This API uses an asynchronous callback to return the result.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Parameters

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';

const TAG = "testDemo";
linkEnhanceConnect(peerDeviceId: string) {
  hilog.info(0x0000, TAG, 'connection sever deviceId = ' + peerDeviceId);
  try {
    let connection: linkEnhance.Connection = linkEnhance.createConnection(peerDeviceId, "demo");
    // Subscribe to the connectResult event.
    connection.on('connectResult', (result: linkEnhance.ConnectResult): void => {
        hilog.info(0x0000, TAG, 'clientConnectResultCallback result = ' + result.success);
    });

    // Initiate a connection.
    connection.connect();
  } catch (err) {
    hilog.error(0x0000, TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

off(‘connectResult’)

off(type: ‘connectResult’, callback: Callback<ConnectResult>): void

Unregisters the listener for the connectResult event.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Parameters

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
const TAG = "testDemo";
linkEnhanceConnect(peerDeviceId: string) {
  hilog.info(0x0000, TAG, 'connection sever deviceId = ' + peerDeviceId);
  try {
    let connection: linkEnhance.Connection = linkEnhance.createConnection(peerDeviceId, "demo");
    connection.on('connectResult', (result: linkEnhance.ConnectResult): void => {
      hilog.info(0x0000, TAG, 'clientConnectResultCallback result = ' + result.success);
    });
    // Unsubscribe from the connectResult event.
    connection.off('connectResult', (result: linkEnhance.ConnectResult): void => {
      hilog.info(0x0000, TAG, 'clientConnectResultCallback result = ' + result.success);
    });
  } catch (err) {
    hilog.error(0x0000, TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

on(‘disconnected’)

on(type: ‘disconnected’, callback: Callback<number>): void

Registers a listener for the disconnected event. This API uses an asynchronous callback to return the result.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Parameters

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
const TAG = "testDemo";
linkEnhanceConnect(peerDeviceId: string) {
  hilog.info(0x0000, TAG, 'connection sever deviceId = ' + peerDeviceId);
  try {
    let connection: linkEnhance.Connection = linkEnhance.createConnection(peerDeviceId, "demo");
    // Subscribe to the disconnected event.
    connection.on('disconnected', (number: number)=> {
        hilog.info(0x0000, TAG, 'connection disconnected reason = ' + number);
    });
  } catch (err) {
    hilog.info(0x0000, TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

off(‘disconnected’)

off(type: ‘disconnected’, callback: Callback<number>): void

Unregisters the listener for the disconnected event. This API uses an asynchronous callback to return the result.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Parameters

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
const TAG = "testDemo";

linkEnhanceConnect(peerDeviceId: string) {
  hilog.info(0x0000, TAG, 'connection sever deviceId = ' + peerDeviceId);
  try {
    let connection: linkEnhance.Connection = linkEnhance.createConnection(peerDeviceId, "demo");
    connection.on('disconnected', (number: number)=> {
        hilog.info(0x0000, TAG, 'connection disconnected reason = ' + number);
    });
    // Unsubscribe from the disconnected event.
    connection.off('disconnected', (number: number)=> {
        hilog.info(0x0000, TAG, 'connection disconnected reason = ' + number);
    });
  } catch (err) {
    hilog.error(0x0000, TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

on(‘dataReceived’)

on(type: ‘dataReceived’, Callback<ArrayBuffer>): void

Registers a listener for the dataReceived events. This API uses an asynchronous callback to return the result.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Parameters

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
const TAG = "testDemo";

linkEnhanceConnect(peerDeviceId: string) {
  hilog.info(0x0000, TAG, 'connection sever deviceId = ' + peerDeviceId);
  try {
    let connection: linkEnhance.Connection = linkEnhance.createConnection(peerDeviceId, "demo");
    connection.connect();
    connection.on('dataReceived', (data: ArrayBuffer)=> {
        hilog.info(0x0000, TAG, 'recv dataLen = ' + data.byteLength);
    });
  } catch (err) {
    hilog.error(0x0000, TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

off(‘dataReceived’)

on(type: ‘dataReceived’, Callback<ArrayBuffer>): void

Unregisters the listener for the dataReceived event.

Required permissions: ohos.permission.DISTRIBUTED_DATASYNC

System capability: SystemCapability.DistributedSched.AppCollaboration

Parameters

Error codes

For details about the error codes, see Enhanced Connection Error Codes.

Example

import { linkEnhance } from '@kit.DistributedServiceKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
const TAG = "testDemo";

linkEnhanceConnect(peerDeviceId: string) {
  hilog.info(0x0000, TAG, 'connection sever deviceId = ' + peerDeviceId);
  try {
    let connection: linkEnhance.Connection = linkEnhance.createConnection(peerDeviceId, "demo");
    connection.connect();
    connection.off('dataReceived', (data: ArrayBuffer)=> {
        hilog.info(0x0000, TAG, 'recv dataLen = ' + data.byteLength);
    });
    connection.disconnect();
  } catch (err) {
    hilog.error(0x0000, TAG, 'errCode: ' + (err as BusinessError).code + ', errMessage: ' +
    (err as BusinessError).message);
  }
}

你可能感兴趣的鸿蒙文章

harmony 鸿蒙Distributed Service Kit (Distributed Management Service)

harmony 鸿蒙DeviceManager

harmony 鸿蒙oh_device_manager_err_code.h

harmony 鸿蒙oh_device_manager.h

harmony 鸿蒙Device Management Error Codes

harmony 鸿蒙Screen Hopping Error Codes

harmony 鸿蒙Link Enhancement Error Codes

harmony 鸿蒙@ohos.distributedHardware.deviceManager (Device Management) (System API)

harmony 鸿蒙@ohos.cooperate (Screen Hopping) (System API)

harmony 鸿蒙@ohos.distributedsched.abilityConnectionManager (Cross-Device Connection Management) (System API)