我正在通过我的串行端口向设备发送（写入）字节。我正在使用 QSerialPort ( http://qt-project.org/wiki/QtSerialPort ) 模块来实例化设备 IO 支持。当我向我的 INSTEON 调制解调器（串行）发送消息时，设备在读取我的消息后会发回我的消息副本 + 0x06（ACK 字节），然后是状态消息。
我已经使用 DockLight ( http://www.docklight.de/ ) 测试了我的消息。我发送以下消息来查询设备的状态：
02 62 1D E9 4B 05 19 00
使用 Docklight，我收到响应：
02 62 1D E9 4B 05 19 00 06 02 50 20 CB CF 1E DA F7 21 00 FF
返回的消息正是我所期望的，即设备已打开。如果关闭，如果设备关闭，调制解调器将在最后一个字节位置发回 0x00。现在，我的问题 - 我必须没有正确设置我的函数来发送然后接收响应字节。我尝试了许多不同的示例和配置，目前我正在使用以下内容：
设置信号槽连接：
QObject::connect(&thread, SIGNAL(sendResponse(QByteArray)),
this, SLOT(handleResponse(QByteArray)));
QObject::connect(&thread, SIGNAL(error(QString)),
this, SLOT(processError(QString)));
QObject::connect(&thread, SIGNAL(timeout(QString)),
this, SLOT(processTimeout(QString)));
用于遍历设备 QList 的函数。如果设备是所需的类型（“Light”），那么我们将设备 ID 格式化为预期的 QByteArray 消息结构。将消息传递给线程以进行发送。（从 QSerialPortBlockingMaster示例修改的线程。
void Device::currentStatus(QList<Device *> * deviceList){
QString devID, updateQry;
int devStatus, updateStatus;
updateStatus=0;
QSqlQuery query;
for(int i=0; i<deviceList->size(); i++){
if(deviceList->at(i)->type == "Light"){
devStatus = deviceList->at(i)->status;
devID = deviceList->at(i)->deviceID;
QByteArray msg;
bool msgStatus;
msg.resize(8);
msg[0] = 0x02;
msg[1] = 0x62;
msg[2] = 0x00;
msg[3] = 0x00;
msg[4] = 0x00;
msg[5] = 0x05;
msg[6] = 0x19;
msg[7] = 0x00;
msg.replace(2, 3, QByteArray::fromHex( devID.toLocal8Bit() ) );
qDebug() << "Has device " << deviceList->at(i)->name << "Changed?";
//send(msg,&msgStatus, &updateStatus);
//msg.clear();
thread.setupPort("COM3",500,msg);
if(devStatus!=updateStatus){
qDebug() << deviceList->at(i)->name << " is now: " << updateStatus;
updateStatus = !updateStatus;
}
}
}
}
SetupThread用于设置局部线程变量并执行（运行）线程的函数。
void serialThread::setupPort(const QString &portName, int waitTimeout, const QByteArray &msg){
qDebug() << "Send Message " << msg.toHex();
QMutexLocker locker(&mutex);
this->portName = portName;
this->waitTimeout = waitTimeout;
this->msg = msg;
if(!isRunning())
start();
else
cond.wakeOne();
}
Run功能 - 处理发送和接收
void serialThread::run(){
bool currentPortNameChanged = false;
qDebug() << "Thread executed";
mutex.lock();
QString currentPortName;
if(currentPortName != portName){
currentPortName = portName;
currentPortNameChanged = true;
}
int currentWaitTimeout = waitTimeout;
QByteArray sendMsg = msg;
mutex.unlock();
QSerialPort serial;
while(!quit){
if(currentPortNameChanged){
serial.close();
serial.setPortName("COM3");
if (!serial.open(QIODevice::ReadWrite)) {
emit error(tr("Can't open %1, error code %2")
.arg(portName).arg(serial.error()));
return;
}
if (!serial.setBaudRate(QSerialPort::Baud19200)) {
emit error(tr("Can't set baud rate 9600 baud to port %1, error code %2")
.arg(portName).arg(serial.error()));
return;
}
if (!serial.setDataBits(QSerialPort::Data8)) {
emit error(tr("Can't set 8 data bits to port %1, error code %2")
.arg(portName).arg(serial.error()));
return;
}
if (!serial.setParity(QSerialPort::NoParity)) {
emit error(tr("Can't set no patity to port %1, error code %2")
.arg(portName).arg(serial.error()));
return;
}
if (!serial.setStopBits(QSerialPort::OneStop)) {
emit error(tr("Can't set 1 stop bit to port %1, error code %2")
.arg(portName).arg(serial.error()));
return;
}
if (!serial.setFlowControl(QSerialPort::NoFlowControl)) {
emit error(tr("Can't set no flow control to port %1, error code %2")
.arg(portName).arg(serial.error()));
return;
}
}
//write request
serial.write(msg);
if (serial.waitForBytesWritten(waitTimeout)) {
//! [8] //! [10]
// read response
if (serial.waitForReadyRead(currentWaitTimeout)) {
QByteArray responseData = serial.readAll();
while (serial.waitForReadyRead(10)){
responseData += serial.readAll();
}
QByteArray response = responseData;
//! [12]
emit this->sendResponse(response);
//! [10] //! [11] //! [12]
} else {
emit this->timeout(tr("Wait read response timeout %1")
.arg(QTime::currentTime().toString()));
}
//! [9] //! [11]
} else {
emit timeout(tr("Wait write request timeout %1")
.arg(QTime::currentTime().toString()));
}
mutex.lock();
cond.wait(&mutex);
if (currentPortName != portName) {
currentPortName = portName;
currentPortNameChanged = true;
} else {
currentPortNameChanged = false;
}
currentWaitTimeout = waitTimeout;
sendMsg = msg;
mutex.unlock();
}
serial.close();
}
handleResponse函数，接收响应信号的 SLOT
void Device::handleResponse(const QByteArray &msg){
qDebug() << "Read: " << msg.toHex();
}
我收到以下输出：
Has device "Living Room Light" Changed?
Send Message "02621de94b051900"
Has device "Bedroom Light" Changed?
Send Message "026220cbcf051900"
Thread executed
Read: "026220cbcf05190006"
Polling for changes...
Has device "Living Room Light" Changed?
Send Message "02621de94b051900"
Has device "Bedroom Light" Changed?
Send Message "026220cbcf051900"
Read: "025020cbcf1edaf721000002621de94b05190006"
Polling for changes...
Has device "Living Room Light" Changed?
Send Message "02621de94b051900"
Has device "Bedroom Light" Changed?
Send Message "026220cbcf051900"
Read: "02501de94b1edaf72100ff02621de94b05190006"
这里有两个问题。
我从未收到关于第二个设备（卧室灯）的任何回复，这是第二个发送的消息。似乎发送被阻止了，你会建议我如何格式化我的发送，以便在收到第一次发送的响应后发送？只有 1 个 COM 端口可用于发送/接收。我相信我应该向设备 1 发送消息，接收设备 1 响应，发送到设备 2，接收设备 2。我最终会看到大量设备的巨大交通拥堵并使用等待条件，即。在执行设备 2 的通信进程之前等待设备 1 的通信进程完成？
第一次读取包含接收的适当前半部分。
Read: "026220cbcf05190006"第二次接收包含第一个响应的第二半，然后是第二个响应的第一半：读取 2 -Read: "025020cbcf1edaf721000002621de94b05190006"适当的完整响应是02621DE94B05190006 025020CBCF1EDAF72100FF（注意20CBCF是完整响应示例中的设备 2 的 ID）
应该对我从串口接收数据的方式进行哪些更正？谢谢！