1. package org.usb4java.javax.examples;
    3. import java.util.List;
    5. import javax.usb.UsbConfiguration;
    6. import javax.usb.UsbDevice;
    7. import javax.usb.UsbDeviceDescriptor;
    8. import javax.usb.UsbEndpoint;
    9. import javax.usb.UsbHostManager;
    10. import javax.usb.UsbHub;
    11. import javax.usb.UsbInterface;
    12. import javax.usb.UsbPipe;
    14. public class UsbUtil {
    16.     public static final String vIdStr = "1A86";
    17.     public static final String pIdStr = "E010";
    19.     private static final short VENDOR_ID = (short) Integer.parseInt(vIdStr, 16);
    20.     private static final short PRODUCT_ID = (short) Integer.parseInt(pIdStr, 16);
    21. //    private static final short VENDOR_ID = (short)0x8888;
    22. //    private static final short PRODUCT_ID = (short)0x0006;
    24.     public static void main(String[] args) {
    25.         try {
    26.             UsbPipe sendUsbPipe = new UsbUtil().useUsb();
    28.             if (sendUsbPipe != null) {
    29.                 //    绿灯亮
    30.                 String sendData = "55AA000400000000000000030D0A";
    31.                 sendMassge(sendUsbPipe, Test.hexTobytes(sendData));
    32.             }
    34.         } catch (Exception e) {
    35.             e.printStackTrace();
    36.         }
    37.     }
    39.     public UsbPipe useUsb() throws Exception {
    40.         UsbInterface iface = linkDevice();
    41.         if (iface == null) {
    42.             return null;
    43.         }
    44.         UsbEndpoint receivedUsbEndpoint, sendUsbEndpoint;
    46.         sendUsbEndpoint = (UsbEndpoint) iface.getUsbEndpoints().get(0);
    47.         if (!sendUsbEndpoint.getUsbEndpointDescriptor().toString().contains("OUT")) {
    48.             receivedUsbEndpoint = sendUsbEndpoint;
    49.             sendUsbEndpoint = (UsbEndpoint) iface.getUsbEndpoints().get(1);
    50.         } else {
    51.             receivedUsbEndpoint = (UsbEndpoint) iface.getUsbEndpoints().get(1);
    52.         }
    54.         //发送：
    55.         UsbPipe sendUsbPipe = sendUsbEndpoint.getUsbPipe();
    56.         sendUsbPipe.open();
    58.         //接收
    59.         final UsbPipe receivedUsbPipe = receivedUsbEndpoint.getUsbPipe();
    60.         receivedUsbPipe.open();
    62.         new Thread(new Runnable() {
    63.             @Override
    64.             public void run() {
    65.                 try {
    66.                     receivedMassge(receivedUsbPipe);
    67.                 } catch (Exception e) {
    68.                     e.printStackTrace();
    69.                 }
    70.             }
    71.         }).start();
    72.         return sendUsbPipe;
    73.     }
    75.     public UsbInterface linkDevice() throws Exception {
    77.         UsbDevice device = null;
    78.         if (device == null) {
    79.             device = findDevice(UsbHostManager.getUsbServices()
    80.                     .getRootUsbHub());
    81.         }
    82.         if (device == null) {
    83.             System.out.println("设备未找到！");
    84.             return null;
    85.         }
    86.         UsbConfiguration configuration = device.getActiveUsbConfiguration();
    87.         UsbInterface iface = null;
    88.         if (configuration.getUsbInterfaces().size() > 0) {
    89.             iface = (UsbInterface) configuration.getUsbInterfaces().get(0);
    90.         } else {
    91.             return null;
    92.         }
    93.         iface.claim();
    94.         return iface;
    95.     }
    97.     public void receivedMassge(UsbPipe usbPipe) throws Exception {
    98.         byte[] b = new byte[64];
    99.         int length = 0;
    100.         while (true) {
    101.             //阻塞
    102.             length = usbPipe.syncSubmit(b);
    103.             System.out.println("接收长度：" + length);
    104.             for (int i = 0; i < length; i++) {
    105. //                System.out.print(Byte.toUnsignedInt(b[i])+" ");
    106.             }
    107.         }
    108.     }
    110.     public static void sendMassge(UsbPipe usbPipe, byte[] buff) throws Exception {
    111.         //阻塞
    112.         usbPipe.syncSubmit(buff);
    113.         //非阻塞
    114.         //usbPipe.asyncSubmit(buff);
    115.     }
    117.     public UsbDevice findDevice(UsbHub hub) {
    118.         UsbDevice device = null;
    119.         List list = hub.getAttachedUsbDevices();
    120.         for (int i = 0; i < list.size(); i++) {
    121.             device = (UsbDevice) list.get(i);
    122.             UsbDeviceDescriptor desc = device.getUsbDeviceDescriptor();
    123.             if (desc.idVendor() == VENDOR_ID && desc.idProduct() == PRODUCT_ID) {
    124.                 return device;
    125.             }
    126.             if (device.isUsbHub()) {
    127.                 device = findDevice((UsbHub) device);
    128.                 if (device != null) {
    129.                     return device;
    130.                 }
    131.             }
    132.         }
    133.         return null;
    134.     }
    135. }

    pom

    1.   <dependencies>
    2.     <dependency>
    3.       <groupId>org.usb4java</groupId>
    4.       <artifactId>usb4java-javax</artifactId>
    5.       <version>1.3.0</version>
    6.     </dependency>
    7.   </dependencies>