1

我正在swing用 Java 构建一个接口，我构建了一个middleware不断读取串行端口并保存即将发生的内容的接口String，这就是我这样做的方式：

public class RFID {
  private static RFIDReader rReader;
  private static boolean state;

  public RFID(RFIDReader rReader) {
    this.rReader = rReader;
    this.state = true;
  }

  public void connect(String portName) throws Exception {
    CommPortIdentifier portIdentifier = CommPortIdentifier.getPortIdentifier(portName);
    if (portIdentifier.isCurrentlyOwned()) {
        System.out.println("Error: Port is currently in use");
    } else {
        CommPort commPort = portIdentifier.open(this.getClass().getName(), 2000);

        if (commPort instanceof SerialPort) {
            SerialPort serialPort = (SerialPort) commPort;
            serialPort.setSerialPortParams(9600, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);

            InputStream in = serialPort.getInputStream();
            OutputStream out = serialPort.getOutputStream();

            (new Thread(new SerialReader(in))).start();
            //(new Thread(new SerialWriter(out))).start();

        } else {
            System.out.println("Error: Only serial ports are handled by this example.");
        }
    }
}

public static class SerialReader implements Runnable {

    InputStream in;

    public SerialReader(InputStream in) {
        this.in = in;
    }

    public void run() {
        byte[] buffer = new byte[1024];
        int len = -1;
        String code;
        try {
            while (state == true && (len = this.in.read(buffer)) > -1) {
                code = new String(buffer, 0, len);
                if (code.length() > 1)
                    rReader.setCode(code);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

public void finish(){
    state = false;
}

public static class SerialWriter implements Runnable {

    OutputStream out;

    public SerialWriter(OutputStream out) {
        this.out = out;
    }

    public void run() {
        try {
            int c = 0;
            while ((c = System.in.read()) > -1) {
                this.out.write(c);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

因此，当我尝试打印code正在存储的内容时，它显示如下：

AC000F9
3
BB

实际上应该是这样的：

AC000F93BB

我在这里做错了什么？这种从byte[]to的转换String是不对的？

编辑： 我需要读取一个总共有 10 个字符的字符串。

4

1 回答 1

5

不要使用 anInputStream来阅读 - 使用 aReader的一些描述。如果您需要以 开头InputStream，请将其包装在InputStreamReader. 我会更改您的构造函数以接受 a Reader，并允许客户端传递他们想要的任何阅读器。这将使测试更容易（因为您可以只使用 a StringReader）。

编辑：注意 - 如果您确实需要从二进制文件创建阅读器InputStream，请明确选择Charset（编码）。所以使用InputStreamReader指定一个的构造函数重载。即使您想使用平台默认值，我也会明确说明您在做什么。

编辑：除了“字符串转换发生的位置”之外，还不清楚您希望阅读什么。您正在处理流式 API - 是什么决定了您在调用之前真正想阅读多少内容setCode？是一整条线吗？它是一些固定数量的字符吗？它是特定分隔符之前的字符吗？

编辑：现在我们知道得更多了，我建议你写一个这样的辅助方法：

// Assuming you now have a field of type Reader, called reader
private String readEntry() throws IOException {
    char[] buffer = new char[10];
    int index = 0;
    while (index < buffer.length) {
        int charsRead = reader.read(buffer, index, buffer.length - index);
        if (charsRead == -1) {
            throw new IOException("Couldn't read entry - end of data");
        }
        index += charsRead;
    }
    return new String(buffer);
}
于 2012-04-18T18:11:44.030 回答