我不想回答自己的问题，但是...我已经弄清楚了。我只是混淆了我的读写操作。此外，设备不喜欢我在命令末尾使用的 '\n'。它似乎更喜欢 '\r'。
最终我使用了安卓的bulkTransfer进行读写操作。我的写操作如下：
try {
device.getWriter().write(command + "\r");
device.getWriter().flush();
} catch (IOException e) {
throw new RuntimeException(e);
}
我的BufferedWriter覆盖写方法：
@Override
public void write(char[] buf, int offset, int count) throws IOException {
byte[] buffer = new String(buf, offset, count).getBytes(Charset.forName("US-ASCII"));
int byteCount = connection.bulkTransfer(endpoint, buffer, buffer.length, TIMEOUT);
}
这些读数相似：
char[] buffer = new char[BUF_SIZE];
try {
BufferedReader reader = device.getReader();
int readBytes = reader.read(buffer);
Log.d(TAG, "BYTES READ: " + readBytes);
} catch (IOException e) {
throw new RuntimeException(e);
}
String strBuf = new String(buffer).trim();
if (DEBUG) {
Log.d(TAG, "Read: " + strBuf);
}
并且：
@Override
public int read(char[] buf, int offset, int count) throws IOException {
byte[] buffer = new byte[count];
int byteCount = connection.bulkTransfer(endpoint, buffer, buffer.length, TIMEOUT);
if (byteCount < 0) {
throw new IOException();
}
char[] charBuffer = new String(buffer, Charset.forName("US-ASCII")).toCharArray();
System.arraycopy(charBuffer, 0, buf, offset, byteCount);
return byteCount;
}
这一切都是在一个线程中开始的，就像这样：
new Thread() {
@Override
public void run() {
String command = "go";
write(command);
while (true) {
String coords = read();
}
}
}.start();
显然，这只是通讯部分，我现在需要对其进行处理（将其放入服务中，使用处理程序向顶层UI活动报告）。但这部分已经想清楚了。
非常感谢那些正在开发rosjava（
http://code.google.com/p/rosjava/）的人们……他们已经组合了许多优秀的项目，他们的代码非常有帮助。
添加我的设备类以帮助澄清事情。
import com.google.common.base.Preconditions;
import android.hardware.usb.UsbConstants;
import android.hardware.usb.UsbDeviceConnection;
import android.hardware.usb.UsbEndpoint;
import android.hardware.usb.UsbInterface;
import android.util.Log;
import java.io.BufferedReader;
import java.io.BufferedWriter;
public class BKDevice {
private final UsbDeviceConnection usbDeviceConnection;
private final BufferedReader reader;
private final BufferedWriter writer;
public static final String TAG = "AcmDevice";
public BKDevice(UsbDeviceConnection usbDeviceConnection,
UsbInterface usbInterface) {
Preconditions.checkState(usbDeviceConnection.claimInterface(
usbInterface, true));
this.usbDeviceConnection = usbDeviceConnection;
UsbEndpoint epOut = null;
UsbEndpoint epIn = null;
for (int i = 0; i < usbInterface.getEndpointCount(); i++) {
UsbEndpoint ep = usbInterface.getEndpoint(i);
Log.d(TAG, "EP " + i + ": " + ep.getType());
if (ep.getType() == UsbConstants.USB_ENDPOINT_XFER_BULK) {
if (ep.getDirection() == UsbConstants.USB_DIR_OUT) {
epOut = ep;
} else if (ep.getDirection() == UsbConstants.USB_DIR_IN) {
epIn = ep;
}
}
}
if (epOut == null || epIn == null) {
throw new IllegalArgumentException("Not all endpoints found.");
}
BKReader acmReader = new BKReader(usbDeviceConnection, epIn);
BKWriter acmWriter = new BKWriter(usbDeviceConnection, epOut);
reader = new BufferedReader(acmReader);
writer = new BufferedWriter(acmWriter);
}
public BufferedReader getReader() {
return reader;
}
public BufferedWriter getWriter() {
return writer;
}
}
添加BKReader代码：
import android.hardware.usb.UsbDeviceConnection;
import android.hardware.usb.UsbEndpoint;
import android.util.Log;
import java.io.IOException;
import java.io.Reader;
import java.nio.charset.Charset;
public class BKReader extends Reader {
private static final int TIMEOUT = 1000;
private final UsbDeviceConnection connection;
private final UsbEndpoint endpoint;
public BKReader(UsbDeviceConnection connection, UsbEndpoint endpoint) {
this.connection = connection;
this.endpoint = endpoint;
}
@Override
public int read(char[] buf, int offset, int count) throws IOException {
byte[] buffer = new byte[count];
int byteCount = connection.bulkTransfer(endpoint, buffer, buffer.length, TIMEOUT);
if (byteCount < 0) {
throw new IOException();
}
char[] charBuffer = new String(buffer, Charset.forName("US-ASCII")).toCharArray();
System.arraycopy(charBuffer, 0, buf, offset, byteCount);
return byteCount;
}
@Override
public void close() throws IOException {
}
}
