\u6211\u5c06\u8be6\u7ec6\u4ecb\u7ecd Qt \u7684\u7f51\u7edc\u7f16\u7a0b，\u91cd\u70b9\u5c55\u793a\u5982\u4f55\u4f7f\u7528 Qt \u63d0\u4f9b\u7684\u7f51\u7edc\u6a21\u5757（QtNetwork）\u5b9e\u73b0 TCP \u5ba2\u6237\u7aef\u548c\u670d\u52a1\u5668，\u4e0e\u524d\u6587\u7684 ReferenceClass\u3001PointerClass\u3001SerialPort \u548c ModbusTCPDebugger \u96c6\u6210，\u66ff\u4ee3\u539f\u6709\u7684 WinSock2 \u5b9e\u73b0\u3002\u540c\u65f6，\u6211\u5c06\u6269\u5c55 Qt GUI（\u57fa\u4e8e\u524d\u6587 DebugWindow），\u6dfb\u52a0\u7f51\u7edc\u72b6\u6001\u76d1\u63a7\u3001\u6570\u636e\u53d1\u9001\/\u63a5\u6536\u5c55\u793a，\u5e76\u652f\u6301 Modbus TCP \u529f\u80fd\u7801（0x01\u30010x03\u30010x06）\u548c TCP-to-RTU \u8f6c\u6362\u3002\u4ee3\u7801\u5c06\u4f7f\u7528 std::string\u3001std::vector\u3001C \u98ce\u683c\u6570\u7ec4\u548c\u8fed\u4ee3\u5668，\u4fdd\u6301\u4e0e\u524d\u6587\u7684\u517c\u5bb9\u6027，\u5e76\u63d0\u4f9b Linux \u9002\u914d\u8bf4\u660e\u3002Demo \u5c06\u901a\u8fc7 main \u51fd\u6570\u5b9e\u4f8b\u5316\u7c7b\u5e76\u542f\u52a8 GUI，\u5c55\u793a\u7f51\u7edc\u901a\u4fe1\u3002<\/p>\n
1. Qt \u7f51\u7edc\u7f16\u7a0b\u6982\u8ff0<\/p>\n
Qt \u7684 QtNetwork \u6a21\u5757\u63d0\u4f9b\u8de8\u5e73\u53f0\u7684\u7f51\u7edc\u7f16\u7a0b\u63a5\u53e3，\u652f\u6301 TCP\u3001UDP\u3001HTTP\u3001SSL \u7b49\u534f\u8bae\u3002\u4e3b\u8981\u7c7b\u5305\u62ec：<\/p>\n
QTcpSocket：\u5b9e\u73b0 TCP \u5ba2\u6237\u7aef，\u53d1\u9001\u548c\u63a5\u6536\u6570\u636e\u3002<\/p>\n<\/li>\n
QTcpServer：\u5b9e\u73b0 TCP \u670d\u52a1\u5668，\u76d1\u542c\u8fde\u63a5\u5e76\u5904\u7406\u5ba2\u6237\u7aef\u3002<\/p>\n<\/li>\n
QNetworkAccessManager：\u7528\u4e8e HTTP \u8bf7\u6c42（\u672c\u4f8b\u4e0d\u91cd\u70b9）\u3002<\/p>\n<\/li>\n
QAbstractSocket：\u63d0\u4f9b\u5f02\u6b65\u4fe1\u53f7（\u5982 connected\u3001readyRead）\u3002<\/p>\n<\/li>\n
\u7279\u70b9：<\/p>\n
\u8de8\u5e73\u53f0：\u65e0\u9700\u533a\u5206 Windows\/Linux\u3002<\/p>\n<\/li>\n
\u5f02\u6b65：\u57fa\u4e8e\u4fe1\u53f7\u4e0e\u69fd，\u907f\u514d\u963b\u585e\u3002<\/p>\n<\/li>\n
\u96c6\u6210\u6027：\u4e0e Qt GUI \u548c\u4e8b\u4ef6\u5faa\u73af\u65e0\u7f1d\u7ed3\u5408\u3002<\/p>\n<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n
2. \u8bbe\u8ba1\u76ee\u6807<\/p>\n
\u66ff\u6362 WinSock2：\u5c06 ModbusTCPDebugger \u548c PointerClass \u7684\u7f51\u7edc\u90e8\u5206\u6539\u4e3a QtNetwork\u3002<\/p>\n<\/li>\n
GUI \u589e\u5f3a：<\/p>\n
\u663e\u793a\u7f51\u7edc\u72b6\u6001（\u8fde\u63a5\/\u65ad\u5f00）\u3002<\/p>\n<\/li>\n
\u5c55\u793a Modbus \u6570\u636e（HEX \u548c\u89e3\u6790\u503c）\u3002<\/p>\n<\/li>\n
\u652f\u6301\u53d1\u9001 Modbus \u8bf7\u6c42\u548c\u4e32\u53e3\u547d\u4ee4\u3002<\/p>\n<\/li>\n
\u5b9e\u65f6\u66f4\u65b0\u5bc4\u5b58\u5668\/\u7ebf\u5708\u8868\u683c\u548c\u56fe\u8868\u3002<\/p>\n<\/li>\n<\/ul>\n<\/li>\n
\u529f\u80fd：<\/p>\n
TCP \u5ba2\u6237\u7aef：PointerClass \u4f7f\u7528 QTcpSocket \u53d1\u9001 Modbus \u8bf7\u6c42\u3002<\/p>\n<\/li>\n
TCP \u670d\u52a1\u5668：ModbusTCPDebugger \u4f7f\u7528 QTcpServer \u5904\u7406\u5ba2\u6237\u7aef\u8fde\u63a5\u3002<\/p>\n<\/li>\n
\u5f02\u6b65 I\/O：\u5229\u7528 Qt \u4fe1\u53f7\u4e0e\u69fd\u5904\u7406\u6570\u636e\u3002<\/p>\n<\/li>\n
TCP-to-RTU：\u96c6\u6210 ModbusConverter\u3002<\/p>\n<\/li>\n<\/ul>\n<\/li>\n
\u573a\u666f：\u8c03\u8bd5\u5de5\u5177\u901a\u8fc7 TCP \u4e0e Modbus \u8bbe\u5907\u901a\u4fe1，\u901a\u8fc7\u4e32\u53e3\u4e0e RTU \u8bbe\u5907\u4ea4\u4e92，GUI \u663e\u793a\u6570\u636e\u3002<\/p>\n<\/li>\n<\/ul>\n
3. \u524d\u7f6e\u7c7b\u8c03\u6574<\/p>\n
\u4ee5\u4e0b\u662f SerialPort（\u4fdd\u6301\u4e0d\u53d8）\u3001ModbusConverter（\u524d\u6587\u5b9a\u4e49）\u3001ReferenceClass \u548c PointerClass \u7684\u8c03\u6574，\u4ee5\u53ca\u91cd\u5199\u7684 ModbusTCPDebugger\u3002<\/p>\n
SerialPort（\u7b80\u8981\u8bf4\u660e）<\/p>\n
\u4f7f\u7528\u524d\u6587\u7684\u5f02\u6b65 SerialPort \u7c7b，\u652f\u6301 asyncRead \u548c write，\u65e0\u9700\u4fee\u6539\u3002<\/p>\n
ModbusConverter（\u7b80\u8981\u8bf4\u660e）<\/p>\n
\u4fdd\u6301\u524d\u6587\u7684 TCP-to-RTU \u8f6c\u6362\u51fd\u6570，\u5305\u62ec CRC \u8ba1\u7b97\u548c\u9a8c\u8bc1\u3002<\/p>\n
ReferenceClass（\u8c03\u6574）<\/p>\n
cpp<\/p>\n<\/p>\n
#include <string>
\n#include <vector>
\n#include <functional>
\n#include <QObject>
\n#include "SerialPort.h"<\/p>\n
class ReferenceClass : public QObject {
\n Q_OBJECT
\nprivate:
\n std::vector<int>& data;
\n std::string& buffer;
\n SerialPort& serial;<\/p>\n
public:
\n ReferenceClass(std::vector<int>& d, std::string& b, SerialPort& s, QObject* parent = nullptr)
\n : QObject(parent), data(d), buffer(b), serial(s) {
\n if (data.empty()) {
\n throw std::runtime_error("ReferenceClass: Data vector cannot be empty");
\n }
\n }<\/p>\n
void asyncReadFromSerial(std::function<void(const std::vector<uint8_t>&)> callback) {
\n serial.asyncRead(data, [this, callback](const std::vector<uint8_t>& serialData) {
\n std::string str(serialData.begin(), serialData.end());
\n buffer += str;
\n std::string num;
\n for (char c : str) {
\n if (c == ' ') {
\n if (!num.empty()) data.push_back(std::stoi(num));
\n num.clear();
\n } else {
\n num += c;
\n }
\n }
\n if (!num.empty()) data.push_back(std::stoi(num));
\n callback(serialData);
\n emit dataUpdated();
\n });
\n }<\/p>\n
void writeToSerial(const std::string& command) {
\n std::vector<uint8_t> data(command.begin(), command.end());
\n serial.write(data);
\n buffer += "Sent: " + command;
\n emit dataUpdated();
\n }<\/p>\n
const std::vector<int>& getData() const { return data; }
\n const std::string& getBuffer() const { return buffer; }<\/p>\n
signals:
\n void dataUpdated();
\n};<\/p>\n
\u8c03\u6574：<\/p>\n
\u7ee7\u627f QObject \u4ee5\u652f\u6301\u4fe1\u53f7\u4e0e\u69fd\u3002<\/p>\n<\/li>\n
\u6dfb\u52a0 dataUpdated \u4fe1\u53f7，\u901a\u77e5 GUI \u6570\u636e\u53d8\u5316\u3002<\/p>\n<\/li>\n<\/ul>\n
PointerClass（\u8c03\u6574）<\/p>\n
cpp<\/p>\n<\/p>\n
#include <memory>
\n#include <string>
\n#include <vector>
\n#include <QObject>
\n#include <QTcpSocket>
\n#include <QHostAddress><\/p>\n
class PointerClass : public QObject {
\n Q_OBJECT
\nprivate:
\n std::vector<int>* data;
\n std::string* buffer;
\n std::unique_ptr<int[]> dynamicArray;
\n size_t arraySize;
\n QTcpSocket* tcpSocket;
\n uint16_t transactionId;<\/p>\n
public:
\n PointerClass(std::vector<int>* d, std::string* b, size_t size, const std::string& host, int port, QObject* parent = nullptr)
\n : QObject(parent), data(d), buffer(b), arraySize(size), tcpSocket(new QTcpSocket(this)), transactionId(0) {
\n if (!data || !buffer) {
\n throw std::runtime_error("PointerClass: Null pointer provided");
\n }
\n dynamicArray = std::unique_ptr<int[]>(new int[size]);
\n for (size_t i = 0; i < size; ++i) {
\n dynamicArray[i] = static_cast<int>(i);
\n }
\n tcpSocket->connectToHost(QString::fromStdString(host), port);
\n connect(tcpSocket, &QTcpSocket::connected, this, &PointerClass::onConnected);
\n connect(tcpSocket, &QTcpSocket::readyRead, this, &PointerClass::onReadyRead);
\n connect(tcpSocket, &QTcpSocket::disconnected, this, &PointerClass::onDisconnected);
\n }<\/p>\n
void asyncModbusRequest(uint16_t functionCode, uint16_t startAddr, uint16_t countOrValue,
\n std::function<void(const std::vector<uint8_t>&)> callback) {
\n if (tcpSocket->state() != QAbstractSocket::ConnectedState) {
\n emit errorOccurred("Not connected");
\n return;
\n }
\n std::vector<uint8_t> frame = createModbusFrame(functionCode, startAddr, countOrValue);
\n tcpSocket->write(QByteArray(reinterpret_cast<const char*>(frame.data()), frame.size()));
\n *buffer += "Sent Modbus: ";
\n for (auto it = frame.begin(); it != frame.end(); ++it) {
\n *buffer += std::to_string(static_cast<unsigned int>(*it) & 0xFF) + " ";
\n }
\n \/\/ \u5b58\u50a8\u56de\u8c03
\n connect(this, &PointerClass::responseReceived, this, [=](const std::vector<uint8_t>& data) {
\n callback(data);
\n emit dataUpdated();
\n }, Qt::SingleShotConnection);
\n }<\/p>\n
void updateDynamicArray(size_t index, int value) {
\n if (index >= arraySize) {
\n throw std::out_of_range("Dynamic array index out of range");
\n }
\n dynamicArray[index] = value;
\n }<\/p>\n
std::vector<int> parseModbusResponse(const std::vector<uint8_t>& response) {
\n std::vector<int> values;
\n if (response.size() >= 9) {
\n uint8_t functionCode = response[7];
\n if (functionCode == 0x03) {
\n for (size_t i = 0; i < response[8] \/ 2; ++i) {
\n values.push_back((response[9 + 2 * i] << 8) | response[9 + 2 * i + 1]);
\n data->push_back(values.back());
\n }
\n } else if (functionCode == 0x01) {
\n for (size_t i = 0; i < response[8]; ++i) {
\n uint8_t byte = response[9 + i];
\n for (size_t j = 0; j < 8; ++j) {
\n values.push_back((byte >> j) & 1);
\n data->push_back(values.back());
\n }
\n }
\n } else if (functionCode == 0x06) {
\n values.push_back((response[10] << 8) | response[11]);
\n data->push_back(values.back());
\n }
\n }
\n return values;
\n }<\/p>\n
const std::vector<int>& getData() const { return *data; }
\n const std::string& getBuffer() const { return *buffer; }<\/p>\n
signals:
\n void dataUpdated();
\n void responseReceived(const std::vector<uint8_t>& data);
\n void errorOccurred(const QString& error);
\n void connectionStateChanged(bool connected);<\/p>\n
private slots:
\n void onConnected() {
\n emit connectionStateChanged(true);
\n }<\/p>\n
void onDisconnected() {
\n emit connectionStateChanged(false);
\n }<\/p>\n
void onReadyRead() {
\n QByteArray response = tcpSocket->readAll();
\n std::vector<uint8_t> data(response.begin(), response.end());
\n emit responseReceived(data);
\n }<\/p>\n
private:
\n std::vector<uint8_t> createModbusFrame(uint16_t functionCode, uint16_t startAddr, uint16_t countOrValue) {
\n std::vector<uint8_t> frame(12);
\n transactionId++;
\n frame[0] = (transactionId >> 8) & 0xFF;
\n frame[1] = transactionId & 0xFF;
\n frame[2] = 0x00;
\n frame[3] = 0x00;
\n frame[4] = 0x00;
\n frame[5] = 0x06;
\n frame[6] = 0x01;
\n frame[7] = functionCode;
\n frame[8] = (startAddr >> 8) & 0xFF;
\n frame[9] = startAddr & 0xFF;
\n frame[10] = (countOrValue >> 8) & 0xFF;
\n frame[11] = countOrValue & 0xFF;
\n return frame;
\n }
\n};<\/p>\n
\u8c03\u6574：<\/p>\n
\u4f7f\u7528 QTcpSocket \u66ff\u6362 WinSock2\u3002<\/p>\n<\/li>\n
\u7ee7\u627f QObject，\u6dfb\u52a0\u4fe1\u53f7（\u5982 dataUpdated\u3001responseReceived）\u3002<\/p>\n<\/li>\n
\u5f02\u6b65\u8bf7\u6c42\u901a\u8fc7\u4fe1\u53f7\u4e0e\u69fd\u5904\u7406\u54cd\u5e94\u3002<\/p>\n<\/li>\n<\/ul>\n
ModbusTCPDebugger（\u91cd\u5199）<\/p>\n
cpp<\/p>\n<\/p>\n
#include <QObject>
\n#include <QTcpServer>
\n#include <QTcpSocket>
\n#include <string>
\n#include <vector>
\n#include <fstream>
\n#include <mutex>
\n#include <QThreadPool>
\n#include <QRunnable><\/p>\n
class ModbusTCPDebugger : public QObject {
\n Q_OBJECT
\nprivate:
\n QTcpServer* server;
\n std::vector<bool> coils = std::vector<bool>(100, false);
\n std::vector<uint16_t> registers = {0x1234, 0x5678, 0x9ABC, 0xDEF0};
\n std::mutex dataMutex;
\n std::ofstream logFile;
\n QThreadPool* threadPool;<\/p>\n
public:
\n ModbusTCPDebugger(const std::string& host, int port, QObject* parent = nullptr)
\n : QObject(parent), server(new QTcpServer(this)), logFile("modbus_log.txt", std::ios::app), threadPool(new QThreadPool(this)) {
\n threadPool->setMaxThreadCount(4);
\n if (!server->listen(QHostAddress(QString::fromStdString(host)), port)) {
\n throw std::runtime_error("Server failed to listen");
\n }
\n connect(server, &QTcpServer::newConnection, this, &ModbusTCPDebugger::handleNewConnection);
\n }<\/p>\n
private slots:
\n void handleNewConnection() {
\n QTcpSocket* clientSocket = server->nextPendingConnection();
\n connect(clientSocket, &QTcpSocket::readyRead, this, [=]() {
\n class ClientTask : public QRunnable {
\n QTcpSocket* socket;
\n ModbusTCPDebugger* debugger;
\n public:
\n ClientTask(QTcpSocket* s, ModbusTCPDebugger* d) : socket(s), debugger(d) {}
\n void run() override {
\n QByteArray data = socket->readAll();
\n std::vector<uint8_t> buffer(data.begin(), data.end());
\n debugger->logData("Received: ", buffer);
\n std::vector<uint8_t> response;
\n {
\n std::lock_guard<std::mutex> lock(debugger->dataMutex);
\n response = debugger->processModbusFrame(buffer);
\n }
\n if (!response.empty()) {
\n socket->write(QByteArray(reinterpret_cast<const char*>(response.data()), response.size()));
\n debugger->logData("Sent: ", response);
\n }
\n }
\n };
\n threadPool->start(new ClientTask(clientSocket, this));
\n });
\n connect(clientSocket, &QTcpSocket::disconnected, clientSocket, &QTcpSocket::deleteLater);
\n }<\/p>\n
private:
\n std::vector<uint8_t> processModbusFrame(const std::vector<uint8_t>& frame) {
\n if (frame.size() < 8) return {};
\n uint16_t transactionId = (frame[0] << 8) | frame[1];
\n uint16_t protocolId = (frame[2] << 8) | frame[3];
\n uint16_t length = (frame[4] << 8) | frame[5];
\n uint8_t unitId = frame[6];
\n uint8_t functionCode = frame[7];<\/p>\n
if (protocolId != 0x0000 || length != frame.size() – 6) return {};<\/p>\n
if (functionCode == 0x01 && frame.size() >= 12) { \/\/ \u8bfb\u7ebf\u5708
\n uint16_t startAddr = (frame[8] << 8) | frame[9];
\n uint16_t count = (frame[10] << 8) | frame[11];
\n if (startAddr + count <= coils.size()) {
\n size_t byteCount = (count + 7) \/ 8;
\n std::vector<uint8_t> response(9 + byteCount);
\n response[0] = frame[0]; response[1] = frame[1];
\n response[2] = 0x00; response[3] = 0x00;
\n response[4] = 0x00; response[5] = 3 + byteCount;
\n response[6] = unitId; response[7] = functionCode;
\n response[8] = byteCount;
\n for (size_t i = 0; i < byteCount; ++i) {
\n uint8_t byte = 0;
\n for (size_t j = 0; j < 8 && (i * 8 + j) < count; ++j) {
\n byte |= (coils[startAddr + i * 8 + j] ? 1 : 0) << j;
\n }
\n response[9 + i] = byte;
\n }
\n return response;
\n }
\n } else if (functionCode == 0x03 && frame.size() >= 12) { \/\/ \u8bfb\u5bc4\u5b58\u5668
\n uint16_t startAddr = (frame[8] << 8) | frame[9];
\n uint16_t count = (frame[10] << 8) | frame[11];
\n if (startAddr + count <= registers.size()) {
\n std::vector<uint8_t> response(9 + 2 * count);
\n response[0] = frame[0]; response[1] = frame[1];
\n response[2] = 0x00; response[3] = 0x00;
\n response[4] = 0x00; response[5] = 3 + 2 * count;
\n response[6] = unitId; response[7] = functionCode;
\n response[8] = 2 * count;
\n for (size_t i = 0; i < count; ++i) {
\n response[9 + 2 * i] = (registers[startAddr + i] >> 8) & 0xFF;
\n response[9 + 2 * i + 1] = registers[startAddr + i] & 0xFF;
\n }
\n return response;
\n }
\n } else if (functionCode == 0x06 && frame.size() >= 12) { \/\/ \u5199\u5bc4\u5b58\u5668
\n uint16_t addr = (frame[8] << 8) | frame[9];
\n uint16_t value = (frame[10] << 8) | frame[11];
\n if (addr < registers.size()) {
\n registers[addr] = value;
\n return frame;
\n }
\n }
\n std::vector<uint8_t> response(9);
\n response[0] = frame[0]; response[1] = frame[1];
\n response[2] = 0x00; response[3] = 0x00;
\n response[4] = 0x00; response[5] = 0x03;
\n response[6] = unitId; response[7] = functionCode | 0x80;
\n response[8] = 0x02;
\n return response;
\n }<\/p>\n
void logData(const std::string& prefix, const std::vector<uint8_t>& data) {
\n std::lock_guard<std::mutex> lock(dataMutex);
\n logFile << prefix;
\n for (auto it = data.begin(); it != data.end(); ++it) {
\n logFile << std::hex << std::setw(2) << std::setfill('0') << (static_cast<unsigned int>(*it) & 0xFF) << " ";
\n }
\n logFile << std::dec << "\\\\n";
\n logFile.flush();
\n }
\n};<\/p>\n
\u91cd\u5199：<\/p>\n
\u4f7f\u7528 QTcpServer \u548c QTcpSocket\u3002<\/p>\n<\/li>\n
QThreadPool \u5904\u7406\u5ba2\u6237\u7aef\u4efb\u52a1\u3002<\/p>\n<\/li>\n
\u7ebf\u7a0b\u5b89\u5168\u901a\u8fc7 std::mutex \u4fdd\u8bc1\u3002<\/p>\n<\/li>\n<\/ul>\n
4. \u6269\u5c55\u7684 Qt GUI<\/p>\n
cpp<\/p>\n<\/p>\n
#include <QApplication>
\n#include <QMainWindow>
\n#include <QWidget>
\n#include <QVBoxLayout>
\n#include <QHBoxLayout>
\n#include <QTextEdit>
\n#include <QLineEdit>
\n#include <QPushButton>
\n#include <QTableWidget>
\n#include <QComboBox>
\n#include <QTimer>
\n#include <QLabel>
\n#include <QtCharts\/QChart>
\n#include <QtCharts\/QChartView>
\n#include <QtCharts\/QLineSeries>
\n#include "ReferenceClass.h"
\n#include "PointerClass.h"
\n#include "ModbusTCPDebugger.h"
\n#include "ModbusConverter.h"<\/p>\n
class DebugWindow : public QMainWindow {
\n Q_OBJECT
\nprivate:
\n ReferenceClass* refClass;
\n PointerClass* ptrClass;
\n QTextEdit* logText;
\n QLineEdit* commandInput;
\n QComboBox* commandType;
\n QTableWidget* dataTable;
\n QChart* chart;
\n QChartView* chartView;
\n QLineSeries* regSeries;
\n QTimer* updateTimer;
\n QLabel* statusLabel;
\n std::vector<int> lastRegValues;<\/p>\n
public:
\n DebugWindow(ReferenceClass* ref, PointerClass* ptr, QWidget* parent = nullptr)
\n : QMainWindow(parent), refClass(ref), ptrClass(ptr) {
\n setWindowTitle("Qt Network Debug Tool");
\n resize(900, 700);
\n QWidget* centralWidget = new QWidget(this);
\n setCentralWidget(centralWidget);
\n QVBoxLayout* mainLayout = new QVBoxLayout(centralWidget);<\/p>\n
\/\/ \u72b6\u6001\u6807\u7b7e
\n statusLabel = new QLabel("Disconnected", this);
\n mainLayout->addWidget(statusLabel);<\/p>\n
\/\/ \u65e5\u5fd7\u533a\u57df
\n logText = new QTextEdit(this);
\n logText->setReadOnly(true);
\n mainLayout->addWidget(logText);<\/p>\n
\/\/ \u6570\u636e\u8868\u683c
\n dataTable = new QTableWidget(10, 3, this);
\n dataTable->setHorizontalHeaderLabels({"Address", "Register", "Coil"});
\n mainLayout->addWidget(dataTable);<\/p>\n
\/\/ \u56fe\u8868
\n chart = new QtCharts::QChart;
\n regSeries = new QtCharts::QLineSeries;
\n chart->addSeries(regSeries);
\n chart->createDefaultAxes();
\n chart->setTitle("Register Values");
\n chartView = new QtCharts::QChartView(chart);
\n chartView->setRenderHint(QPainter::Antialiasing);
\n mainLayout->addWidget(chartView);<\/p>\n
\/\/ \u547d\u4ee4\u8f93\u5165
\n QHBoxLayout* inputLayout = new QHBoxLayout;
\n commandType = new QComboBox(this);
\n commandType->addItems({"Serial", "Modbus Read Coils (0x01)", "Modbus Read Registers (0x03)", "Modbus Write Register (0x06)"});
\n commandInput = new QLineEdit(this);
\n QPushButton* sendButton = new QPushButton("Send", this);
\n inputLayout->addWidget(commandType);
\n inputLayout->addWidget(commandInput);
\n inputLayout->addWidget(sendButton);
\n mainLayout->addLayout(inputLayout);<\/p>\n
\/\/ \u5b9a\u65f6\u5668
\n updateTimer = new QTimer(this);
\n updateTimer->start(500);<\/p>\n
\/\/ \u4fe1\u53f7\u4e0e\u69fd
\n connect(sendButton, &QPushButton::clicked, this, &DebugWindow::sendCommand);
\n connect(updateTimer, &QTimer::timeout, this, &DebugWindow::updateUI);
\n connect(refClass, &ReferenceClass::dataUpdated, this, &DebugWindow::updateUI);
\n connect(ptrClass, &PointerClass::dataUpdated, this, &DebugWindow::updateUI);
\n connect(ptrClass, &PointerClass::connectionStateChanged, this, &DebugWindow::updateStatus);
\n connect(ptrClass, &PointerClass::errorOccurred, this, &DebugWindow::showError);<\/p>\n
\/\/ \u521d\u59cb\u8bf7\u6c42
\n refClass->asyncReadFromSerial([this](const std::vector<uint8_t>& data) {
\n logText->append("Serial: " + QString::fromStdString(formatData(data)));
\n });
\n ptrClass->asyncModbusRequest(0x03, 0, 4, [this](const std::vector<uint8_t>& data) {
\n logText->append("Modbus: " + QString::fromStdString(formatData(data)));
\n });
\n }<\/p>\n
private slots:
\n void sendCommand() {
\n std::string cmd = commandInput->text().toStdString();
\n std::stringstream ss(cmd);
\n std::string type = commandType->currentText().toStdString();
\n if (type == "Serial") {
\n refClass->writeToSerial(cmd + "\\\\n");
\n logText->append("Sent Serial: " + QString::fromStdString(cmd));
\n } else if (type == "Modbus Read Coils (0x01)") {
\n int start, count;
\n ss >> start >> count;
\n ptrClass->asyncModbusRequest(0x01, start, count, [this](const std::vector<uint8_t>& data) {
\n logText->append("Modbus Coils: " + QString::fromStdString(formatData(data)));
\n });
\n } else if (type == "Modbus Read Registers (0x03)") {
\n int start, count;
\n ss >> start >> count;
\n ptrClass->asyncModbusRequest(0x03, start, count, [this](const std::vector<uint8_t>& data) {
\n logText->append("Modbus Registers: " + QString::fromStdString(formatData(data)));
\n });
\n } else if (type == "Modbus Write Register (0x06)") {
\n int addr, value;
\n ss >> addr >> value;
\n ptrClass->asyncModbusRequest(0x06, addr, value, [this](const std::vector<uint8_t>& data) {
\n logText->append("Modbus Write: " + QString::fromStdString(formatData(data)));
\n });
\n \/\/ TCP-to-RTU \u793a\u4f8b
\n std::vector<uint8_t> tcpFrame = ptrClass->createModbusFrame(0x06, addr, value);
\n std::vector<uint8_t> rtuFrame = ModbusConverter::tcpToRtu(tcpFrame);
\n refClass->writeToSerial(std::string(rtuFrame.begin(), rtuFrame.end()));
\n }
\n commandInput->clear();
\n }<\/p>\n
void updateUI() {
\n updateTable();
\n updateChart(ptrClass->getData());
\n }<\/p>\n
void updateStatus(bool connected) {
\n statusLabel->setText(connected ? "Connected" : "Disconnected");
\n statusLabel->setStyleSheet(connected ? "color: green" : "color: red");
\n }<\/p>\n
void showError(const QString& error) {
\n logText->append("Error: " + error);
\n }<\/p>\n
private:
\n void updateTable() {
\n const auto& data = ptrClass->getData();
\n for (size_t i = 0; i < std::min<size_t>(data.size(), 10); ++i) {
\n dataTable->setItem(i, 0, new QTableWidgetItem(QString::number(i)));
\n dataTable->setItem(i, 1, new QTableWidgetItem(QString::number(data[i])));
\n ptrClass->asyncModbusRequest(0x01, i, 1, [this, i](const std::vector<uint8_t>& data) {
\n auto values = ptrClass->parseModbusResponse(data);
\n if (!values.empty()) {
\n dataTable->setItem(i, 2, new QTableWidgetItem(QString::number(values[0])));
\n }
\n });
\n }
\n }<\/p>\n
void updateChart(const std::vector<int>& values) {
\n if (values == lastRegValues) return;
\n lastRegValues = values;
\n regSeries->clear();
\n for (size_t i = 0; i < values.size(); ++i) {
\n regSeries->append(i, values[i]);
\n }
\n chart->axes(Qt::Horizontal)->first()->setRange(0, values.size());
\n chart->axes(Qt::Vertical)->first()->setRange(0, *std::max_element(values.begin(), values.end()) + 100);
\n }<\/p>\n
std::string formatData(const std::vector<uint8_t>& data) {
\n std::stringstream ss;
\n for (auto byte : data) {
\n ss << std::hex << std::setw(2) << std::setfill('0') << (static_cast<unsigned int>(byte) & 0xFF) << " ";
\n }
\n return ss.str();
\n }
\n};<\/p>\n
5. Main \u51fd\u6570<\/p>\n
cpp<\/p>\n<\/p>\n
#include <QApplication>
\n#include "ReferenceClass.h"
\n#include "PointerClass.h"
\n#include "ModbusTCPDebugger.h"
\n#include "ModbusConverter.h"<\/p>\n
int main(int argc, char* argv[]) {
\n QApplication app(argc, argv);
\n try {
\n std::vector<int> data = {10, 20, 30};
\n std::string buffer = "Initial";
\n SerialPort serial("COM3", CBR_9600);<\/p>\n
ModbusTCPDebugger server("0.0.0.0", 502);
\n ReferenceClass refClass(data, buffer, serial);
\n PointerClass ptrClass(&data, &buffer, 3, "127.0.0.1", 502);<\/p>\n
DebugWindow window(&refClass, &ptrClass);
\n window.show();
\n return app.exec();
\n } catch (const std::exception& e) {
\n std::cerr << "Error: " << e.what() << std::endl;
\n return 1;
\n }
\n}<\/p>\n
6. \u4ee3\u7801\u8bf4\u660e<\/p>\n
Qt \u7f51\u7edc\u7f16\u7a0b：<\/p>\n
PointerClass：\u4f7f\u7528 QTcpSocket \u8fde\u63a5\u670d\u52a1\u5668，\u4fe1\u53f7 readyRead \u89e6\u53d1\u6570\u636e\u8bfb\u53d6\u3002<\/p>\n<\/li>\n
ModbusTCPDebugger：\u4f7f\u7528 QTcpServer \u76d1\u542c\u7aef\u53e3，newConnection \u5904\u7406\u5ba2\u6237\u7aef，QThreadPool \u5e76\u53d1\u5904\u7406\u3002<\/p>\n<\/li>\n
\u5f02\u6b65\u5904\u7406\u901a\u8fc7\u4fe1\u53f7\u4e0e\u69fd\u5b9e\u73b0，\u65e0\u9700\u624b\u52a8\u7ebf\u7a0b\u7ba1\u7406\u3002<\/p>\n<\/li>\n<\/ul>\n<\/li>\n
GUI \u589e\u5f3a：<\/p>\n
\u72b6\u6001\u6807\u7b7e (QLabel)：\u663e\u793a\u8fde\u63a5\u72b6\u6001，\u7eff\u8272\u8868\u793a\u8fde\u63a5，\u7ea2\u8272\u8868\u793a\u65ad\u5f00\u3002<\/p>\n<\/li>\n
\u65e5\u5fd7\u533a\u57df (QTextEdit)：\u663e\u793a HEX \u683c\u5f0f\u7684\u4e32\u53e3\u548c Modbus \u6570\u636e\u3002<\/p>\n<\/li>\n
\u8868\u683c (QTableWidget)：\u5b9e\u65f6\u66f4\u65b0\u5bc4\u5b58\u5668\u548c\u7ebf\u5708\u3002<\/p>\n<\/li>\n
\u56fe\u8868 (QChart)：\u7ed8\u5236\u5bc4\u5b58\u5668\u503c\u66f2\u7ebf\u3002<\/p>\n<\/li>\n
\u547d\u4ee4\u8f93\u5165：\u652f\u6301\u4e32\u53e3\u547d\u4ee4\u548c Modbus \u8bf7\u6c42（0x01\u30010x03\u30010x06）\u3002<\/p>\n<\/li>\n<\/ul>\n<\/li>\n
TCP-to-RTU：<\/p>\n
\u5728 Modbus Write Register \u65f6，\u751f\u6210 RTU \u5e27\u5e76\u901a\u8fc7\u4e32\u53e3\u53d1\u9001\u3002<\/p>\n<\/li>\n<\/ul>\n<\/li>\n
\u6570\u636e\u7ed3\u6784：<\/p>\n
std::vector<uint8_t> \u5b58\u50a8 Modbus \u5e27\u3002<\/p>\n<\/li>\n
std::string \u5b58\u50a8\u65e5\u5fd7\u3002<\/p>\n<\/li>\n
std::unique_ptr \u7ba1\u7406\u52a8\u6001\u6570\u7ec4\u3002<\/p>\n<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n
7. \u8f93\u51fa\u793a\u4f8b<\/p>\n
\u5047\u8bbe\u4e32\u53e3\u8fd4\u56de "1 2 3"，Modbus \u670d\u52a1\u5668\u8fd4\u56de\u5bc4\u5b58\u5668 {0x1234, 0x5678} \u548c\u7ebf\u5708 {0, 1}：<\/p>\n
\u65e5\u5fd7\u533a\u57df：<\/p>\n<\/p>\n
Serial: 01 02 03
\nModbus Registers: 00 01 00 00 00 07 01 03 04 12 34 56 78
\nModbus Coils: 00 02 00 00 00 04 01 01 01 02\n<\/li>\n
\u8868\u683c：<\/p>\n<\/p>\n
Address | Register | Coil
\n0 | 4660 | 0
\n1 | 22136 | 1\n<\/li>\n
\u56fe\u8868：\u663e\u793a\u66f2\u7ebf（4660, 22136）\u3002<\/p>\n<\/li>\n
\u72b6\u6001：Connected（\u7eff\u8272）\u3002<\/p>\n<\/li>\n<\/ul>\n
8. Linux \u9002\u914d<\/p>\n
QtNetwork：\u8de8\u5e73\u53f0，\u65e0\u9700\u4fee\u6539\u3002<\/p>\n<\/li>\n
SerialPort：\u66ff\u6362 Windows API \u4e3a POSIX（\u5982 open, read, write）\u3002<\/p>\n<\/li>\n
\u7f16\u8bd1：<\/p>\n<\/p>\n
g++ -o app main.cpp ReferenceClass.cpp PointerClass.cpp SerialPort.cpp ModbusTCPDebugger.cpp ModbusConverter.cpp -std=c++11 -pthread $(pkg-config –cflags –libs Qt5Widgets Qt5Charts Qt5Network)\n<\/li>\n
\u4f9d\u8d56：\u5b89\u88c5 libqt5network5-dev.<\/p>\n<\/li>\n<\/ul>\n
9. \u6269\u5c55\u5efa\u8bae<\/p>\n
UDP \u652f\u6301：\u4f7f\u7528 QUdpSocket \u5b9e\u73b0\u5e7f\u64ad\u901a\u4fe1\u3002<\/p>\n<\/li>\n
SSL \u52a0\u5bc6：\u4f7f\u7528 QSslSocket \u4fdd\u62a4 Modbus \u901a\u4fe1\u3002<\/p>\n<\/li>\n
\u66f4\u591a\u63a7\u4ef6：\u6dfb\u52a0 QProgressBar \u663e\u793a\u6570\u636e\u4f20\u8f93\u8fdb\u5ea6\u3002<\/p>\n<\/li>\n
\u4fdd\u5b58\u65e5\u5fd7：\u4f7f\u7528 QFile \u4fdd\u5b58\u65e5\u5fd7\u4e3a CSV\u3002<\/p>\n<\/li>\n<\/ul>\n
10. \u6ce8\u610f\u4e8b\u9879<\/p>\n
\u7ebf\u7a0b\u5b89\u5168：Qt \u4fe1\u53f7\u4e0e\u69fd\u786e\u4fdd\u4e3b\u7ebf\u7a0b\u66f4\u65b0 UI\u3002<\/p>\n<\/li>\n
\u6027\u80fd：\u5927\u91cf\u6570\u636e\u65f6，\u9650\u5236\u65e5\u5fd7\u884c\u6570\u6216\u4f7f\u7528 QAbstractTableModel\u3002<\/p>\n<\/li>\n
\u9519\u8bef\u5904\u7406：\u901a\u8fc7 errorOccurred \u4fe1\u53f7\u663e\u793a\u7f51\u7edc\u9519\u8bef\u3002<\/p>\n<\/li>\n<\/ul>\n
\u5982\u679c\u4f60\u9700\u8981 UDP \u5b9e\u73b0\u3001SSL \u52a0\u5bc6\u3001\u7279\u5b9a\u63a7\u4ef6（\u5982 QProgressBar），\u6216\u66f4\u8be6\u7ec6\u7684\u65e5\u5fd7\u4fdd\u5b58，\u8bf7\u63d0\u4f9b\u7ec6\u8282，\u6211\u53ef\u4ee5\u8fdb\u4e00\u6b65\u6269\u5c55！<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1k\u6b21\uff0c\u70b9\u8d5e19\u6b21\uff0c\u6536\u85cf6\u6b21\u3002\u6211\u5c06\u8be6\u7ec6\u4ecb\u7ecd Qt \u7684\u7f51\u7edc\u7f16\u7a0b\uff0c\u91cd\u70b9\u5c55\u793a\u5982\u4f55\u4f7f\u7528 Qt \u63d0\u4f9b\u7684\u7f51\u7edc\u6a21\u5757\uff08QtNetwork\uff09\u5b9e\u73b0 TCP \u5ba2\u6237\u7aef\u548c\u670d\u52a1\u5668\uff0c\u4e0e\u524d\u6587\u7684 ReferenceClass\u3001PointerClass\u3001SerialPort \u548c ModbusTCPDebugger \u96c6\u6210\uff0c\u66ff\u4ee3\u539f\u6709\u7684 WinSock2 \u5b9e\u73b0\u3002\u540c\u65f6\uff0c\u6211\u5c06\u6269\u5c55 Qt GUI\uff08\u57fa\u4e8e\u524d\u6587 DebugWindow\uff09\uff0c\u6dfb\u52a0\u7f51\u7edc\u72b6\u6001\u76d1\u63a7\u3001\u6570\u636e\u53d1\u9001\/\u63a5\u6536\u5c55\u793a\uff0c\u5e76\u652f\u6301 Modbus TCP \u529f\u80fd\u7801\uff080x01\u30010x03\u30010x06\uff09\u548c TCP-to-RTU \u8f6c\u6362\u3002_qt network \u670d\u52a1\u7aef<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[55,218,205,78],"topic":[],"class_list":["post-48735","post","type-post","status-publish","format-standard","hentry","category-server","tag-c","tag-qt","tag-tcp-ip","tag-78"],"yoast_head":"\n