文档中心

场景介绍

批量传输主要应用在传输和接收大量数据同时又没有带宽和间隔时间要求的情况下，例如传输文件、图像等场景，打印机和扫描仪等设备属于这种类型的设备。

环境准备

环境要求

开发工具及配置：

DevEco Studio作为驱动开发工具，是进行驱动开发必备条件之一，开发者可以使用该工具进行开发、调试、打包等操作。请下载安装该工具，并参考DevEco Studio使用指南中的创建工程及运行进行基本的操作验证，保证DevEco Studio可正常运行。
SDK版本配置：

扩展外设管理提供的ArkTS接口，所需SDK版本为API 16及以上才可使用。
HDC配置：

HDC（HarmonyOS Device Connector）是为开发人员提供的用于调试的命令行工具，通过该工具可以在Windows/Linux/Mac系统上与真实设备或者模拟器进行交互，详细参考HDC配置。

搭建环境

在PC上安装DevEco Studio，要求版本在4.1及以上。
将public-SDK更新到API 16或以上。
PC安装HDC工具，通过该工具可以在Windows/Linux/Mac系统上与真实设备或者模拟器进行交互。
用USB线缆将搭载HarmonyOS的设备连接到PC。

开发指导

接口说明

展开

接口名	描述
bulkTransfer(pipe: USBDevicePipe, endpoint: USBEndpoint, buffer: Uint8Array, timeout ?: number): Promise<number>	批量传输。

更多关于设备管理和传输模式的详细接口介绍，请查阅@ohos.usbManager。

开发步骤

主机（Host）连接设备（Device），通过bulkTransfer接口进行数据传输。以下步骤描述了如何使用批量传输方式来传输数据：

说明

以下示例代码只是使用批量传输方式来传输数据的必要流程，需要放入具体的方法中执行。在实际调用时，设备开发者需要遵循设备相关协议进行调用，确保数据的正确传输和设备的兼容性。

导入模块。

收起
自动换行
深色代码主题
复制
// 导入usbManager模块
import { usbManager } from '@kit.BasicServicesKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { JSON } from '@kit.ArkTS';
Index.ets

获取设备列表。

说明

批量传输只能在传输类型为2的端点上进行，若不匹配会返回IO错误。

收起
自动换行
深色代码主题
复制
// 获取设备列表。
let deviceList: usbManager.USBDevice[] = [];
try {
  deviceList = usbManager.getDevices();
} catch (error) {
    console.error(`USB getDevices failed: ${error}`);
    this.logInfo_ += '\n[ERROR] USB getDevices failed: ' + JSON.stringify(error);
}

console.info(`deviceList: ${deviceList}`);
this.logInfo_ += '\n[INFO] deviceList: ' + JSON.stringify(deviceList);
if (deviceList === undefined || deviceList.length === 0) {
  console.error('deviceList is empty');
  this.logInfo_ += '\n[ERROR] deviceList is empty';
  return;
}
/*
  deviceList结构示例
  [
    {
      name: '1-1',
      serial: '',
      manufacturerName: '',
      productName: '',
      version: '',
      vendorId: 7531,
      productId: 2,
      clazz: 9,
      subClass: 0,
      protocol: 1,
      devAddress: 1,
      busNum: 1,
      configs: [
        {
          id: 1,
          attributes: 224,
          isRemoteWakeup: true,
          isSelfPowered: true,
          maxPower: 0,
          name: '1-1',
          interfaces: [
            {
              id: 0,
              protocol: 0,
              clazz: 9,
              subClass: 0,
              alternateSetting: 0,
              name: '1-1',
              endpoints: [
                {
                  address: 129,
                  attributes: 3,
                  interval: 12,
                  maxPacketSize: 4,
                  direction: 128,
                  number: 1,
                  type: 3,
                  interfaceId: 0,
                }
              ]
            }
          ]
        }
      ]
    }
  ]
 */
this.deviceList_ = deviceList;
Index.ets

获取设备操作权限。

收起
自动换行
深色代码主题
复制
if (this.deviceList_ === undefined || this.deviceList_.length === 0) {
  console.error('deviceList is empty');
  this.logInfo_ += '\n[ERROR] deviceList is empty';
  return;
}
let deviceList: usbManager.USBDevice[] = this.deviceList_;
let deviceName: string = deviceList[0].name;
// 申请操作指定的device的操作权限。
usbManager.requestRight(deviceName).then((hasRight: boolean) => {
  console.info('usb device request right result: ' + hasRight);
  this.logInfo_ += '\n[INFO] usb device request right result: ' + JSON.stringify(hasRight);
}).catch((error: BusinessError) => {
  console.error(`usb device request right failed : ${error}`);
  this.logInfo_ += '\n[ERROR] usb device request right failed: ' + JSON.stringify(error);
});
Index.ets

打开设备。

收起
自动换行
深色代码主题
复制
if (this.deviceList_ === undefined || this.deviceList_.length === 0) {
  console.error('deviceList_ is empty');
  this.logInfo_ += '\n[ERROR] deviceList is empty';
  return;
}
let deviceList: usbManager.USBDevice[] = this.deviceList_;
try {
  if (!usbManager.hasRight(deviceList[0]?.name)) {
    console.error('permission denied');
    this.logInfo_ += '\n[ERROR] permission denied';
    return;
  }
  // 打开设备，获取数据传输通道。
  let pipe: usbManager.USBDevicePipe = usbManager.connectDevice(deviceList[0]);
  if (!deviceList?.[0]?.configs?.[0]?.interfaces?.[0]) {
    console.error('invalid interface');
    this.logInfo_ += '\n[ERROR] invalid interface';
    return;
  }
  let interface1: usbManager.USBInterface = deviceList?.[0]?.configs?.[0]?.interfaces?.[0];
  /*
    打开对应接口，在设备信息（deviceList）中选取对应的interface。
    interface1为设备配置中的一个接口。
   */
  usbManager.claimInterface(pipe, interface1, true);
  this.pipe_ = pipe;
  this.interface_ = interface1;
  console.info('open device success');
  this.logInfo_ += '\n[INFO] open device success';
} catch (error) {
  console.error(`USB hasRight failed: ${error}`);
  this.logInfo_ += '\n[ERROR] USB hasRight failed: ' + JSON.stringify(error);
}
Index.ets

数据传输。

说明

在数据传输前建议先获取interface所属endpoint的type，通过type判断interface是否支持所需的传输类型。

若调用传输接口失败，请先确认设备interface是否支持模式切换。若alternateSetting支持切换设置，可在传输前调用usbManager.setInterface重新设置interface，使端点和传输类型匹配，保证端点正常通信。

收起
自动换行
深色代码主题
复制
if (this.pipe_ === undefined || this.interface_ === undefined) {
  console.error('pipe_ or interface_ is null');
  this.logInfo_ += '\n[ERROR] pipe_ or interface_ is null';
  return;
}
let pipe: usbManager.USBDevicePipe = this.pipe_;
let interface1: usbManager.USBInterface = this.interface_;
/*
读取数据，在device信息中选取对应数据接收的endpoint来做数据传输
（endpoint.direction == 0x80）；dataUint8Array是要读取的数据，类型为Uint8Array。
 */
let inEndpoint: usbManager.USBEndpoint = interface1.endpoints?.[1];
let outEndpoint: usbManager.USBEndpoint = interface1.endpoints?.[0];
let dataUint8Array: Uint8Array = new Uint8Array(1024);
if (inEndpoint !== undefined && inEndpoint.direction === 0x80) {
  usbManager.bulkTransfer(pipe, inEndpoint, dataUint8Array, 15000).then((dataLength: number) => {
    if (dataLength >= 0) {
      console.info(`usb readData result Length : ${dataLength}`);
      this.logInfo_ += '\n[INFO] usb readData result Length: ' + JSON.stringify(dataLength);
    } else {
      console.error('usb readData failed');
      this.logInfo_ += '\n[ERROR] usb readData failed';
    }
  }).catch((error: BusinessError) => {
    console.error(`usb readData error : ${error}`);
    this.logInfo_ += '\n[ERROR] usb readData error: ' + JSON.stringify(error);
  });
}

// 发送数据，在device信息中选取对应数据发送的endpoint来做数据传输。（endpoint.direction == 0）
if (outEndpoint !== undefined && outEndpoint.direction === 0) {
  usbManager.bulkTransfer(pipe, outEndpoint, dataUint8Array, 15000).then((dataLength: number) => {
    if (dataLength >= 0) {
      console.info(`usb writeData result write length : ${dataLength}`);
      this.logInfo_ += '\n[INFO] usb writeData result write length: ' + JSON.stringify(dataLength);
    } else {
      console.error('usb writeData failed');
      this.logInfo_ += '\n[ERROR] usb writeData failed';
    }
  }).catch((error: BusinessError) => {
    console.error(`usb writeData error : ${error}`);
    this.logInfo_ += '\n[ERROR] usb writeData error: ' + JSON.stringify(error);
  });
}
Index.ets

释放接口，关闭设备。

收起
自动换行
深色代码主题
复制
if (this.pipe_ === undefined || this.interface_ === undefined) {
  console.error('pipe_ or interface_ is null');
  this.logInfo_ += '\n[ERROR] pipe_ or interface_ is null';
  return;
}
let pipe: usbManager.USBDevicePipe = this.pipe_;
let interface1: usbManager.USBInterface = this.interface_;
try {
  usbManager.releaseInterface(pipe, interface1);
  usbManager.closePipe(pipe);
} catch (error) {
  console.error(`failed: ${error}`);
  this.logInfo_ += '\n[ERROR] failed: ' + JSON.stringify(error);
}

this.pipe_ = undefined;
this.interface_ = undefined;
console.info('close device success');
this.logInfo_ += '\n[INFO] close device success';
Index.ets