我正在测试我的 Arduino UNO 的串行传输速度。根据我的要求，我必须将 3KB/s 从主机 PC 传输到 Arduino。我编写了一个非常简单的程序，它回复结果，Serial.available()然后在 Arduino IDE 的串行监视器中对其进行测试。我已经开始发送字符，直到达到最大值，即 63 个字节。我对此感到非常惊讶，因为我在某处读到 Arduino 有一个 128 字节的串行缓冲区。
无论如何，我已经制定了一个非常简单的协议，它以 48 字节数据包（实际上是 49 字节，因为标题字符）传输数据。主机发送一个d字符，然后发送 48 个字节的数据。为了测试传输的有效性，我发送了一个从 0 到 47 的简单字节序列，该序列在 Arduino 端得到验证。如果验证失败，UNO 将开始闪烁 PIN13 上的板载 LED。一旦发送了字节，主机就会等待一个简单k字符的确认。一旦完成处理实际数据包，Arduino 就会发送此信息。
主机程序测量传输的数据包数量并在 1 秒后显示。波特率为 9600，PC 成功传输约 16 个数据包/秒（约 800 字节/秒），这还不错。我试图通过将双方的波特率提高到 57600 来改善这一点；但是，发送的数据包数量只增加了一点。我不知道问题是什么。也许我已经达到了 USB 串行转换器的某种限制？
这是我的代码。
PC（Java，我使用jSSC进行串口通信）
package hu.inagy.tapduino.server;
import jssc.SerialPort;
import jssc.SerialPortException;
/**
* Test Arduino communication.
*/
public class App
{
private static void testComm(SerialPort port) throws SerialPortException {
long runningSeconds = 0;
long time = System.currentTimeMillis();
long numberOfPackets = 0;
boolean packetSent = false;
while (runningSeconds < 10) {
long currentTime = System.currentTimeMillis();
if (currentTime - time > 1000) {
runningSeconds++;
time = currentTime;
System.out.println(numberOfPackets + " packets/s");
numberOfPackets = 0;
}
if (!packetSent) {
packetSent = true;
port.writeByte((byte) 'd');
for (int i = 0; i < 48; i++) {
port.writeByte((byte) i);
}
} else {
byte[] received = port.readBytes();
if (received != null) {
if (received.length > 1) {
throw new IllegalStateException("One byte expected, instead got: " + received.length);
}
char cmd = (char) received[0];
if ('k' != cmd) {
throw new IllegalStateException("Expected response 'k', instead got: " + cmd);
}
packetSent = false;
numberOfPackets++;
}
}
}
}
public static void main(String[] args)
{
SerialPort port = new SerialPort("COM7");
try {
if (!port.openPort()) {
throw new IllegalStateException("Failed to open port.");
}
port.setParams(57600, 8, 1, 0);
} catch (SerialPortException e) {
throw new IllegalStateException("Exception while setting up port.", e);
}
try {
// Wait 1.5sec for Arduino to boot successfully.
Thread.sleep(1500);
} catch (InterruptedException e) {
throw new IllegalStateException("Interrupt while waiting?", e);
}
try {
testComm(port);
} catch (SerialPortException exc) {
throw new IllegalStateException("Failure while testing communication.", exc);
} finally {
try {
if (!port.closePort()) {
throw new IllegalStateException("Failed to close port.");
}
} catch (SerialPortException e) {
throw new IllegalStateException("Exception while closing port.", e);
}
}
}
}
阿杜诺
void setup() {
pinMode(13, OUTPUT);
Serial.begin(57600);
}
boolean error = false;
void loop() {
if (error) {
digitalWrite(13, HIGH);
delay(1000);
digitalWrite(13, LOW);
delay(1000);
} else {
while (Serial.available()<49);
char cmd = Serial.read();
if ('d'!=cmd) {
error=true;
return;
}
for (int i=0; i<48; i++) {
int r = Serial.read();
if (r!=i) {
error=true;
return;
}
}
Serial.write('k');
}
}