Qt怎么實(shí)現(xiàn)網(wǎng)絡(luò)轉(zhuǎn)發(fā)

本篇內(nèi)容介紹了“Qt怎么實(shí)現(xiàn)網(wǎng)絡(luò)轉(zhuǎn)發(fā)”的有關(guān)知識(shí)，在實(shí)際案例的操作過(guò)程中，不少人都會(huì)遇到這樣的困境，接下來(lái)就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！

一、前言

在本系統(tǒng)中網(wǎng)絡(luò)轉(zhuǎn)發(fā)是個(gè)什么功能含義呢，其實(shí)就是將本地采集設(shè)備的所有數(shù)據(jù)打包發(fā)送到指定的網(wǎng)絡(luò)地址，默認(rèn)采用UDP的形式，無(wú)連接開(kāi)銷小，我也是看到很多的組態(tài)軟件有這個(gè)功能，其實(shí)現(xiàn)有的很多的氣體探測(cè)公司、環(huán)境監(jiān)測(cè)公司等，都在大量的使用組態(tài)軟件來(lái)做一個(gè)簡(jiǎn)單的系統(tǒng)提供給客戶使用。這個(gè)網(wǎng)絡(luò)轉(zhuǎn)發(fā)用處很大，比如可以轉(zhuǎn)發(fā)到多個(gè)網(wǎng)絡(luò)中的客戶端，層層級(jí)聯(lián)，一般來(lái)說(shuō)都是設(shè)備采集端作為發(fā)送端，而另外的客戶端作為接收端，消除了設(shè)備采集只能獨(dú)占在一個(gè)客戶端上的局限，層層轉(zhuǎn)發(fā)出去，多個(gè)地方可以看到實(shí)時(shí)的數(shù)據(jù)。

網(wǎng)絡(luò)轉(zhuǎn)發(fā)的功能一般是做成單向的，發(fā)送端負(fù)責(zé)發(fā)送，接收端負(fù)責(zé)接收數(shù)據(jù)解析處理，只要把設(shè)備的處理的數(shù)據(jù)源改成網(wǎng)絡(luò)即可，其實(shí)解析方法完全一致，都是公用一個(gè)解析類，抽象出來(lái)的公用的數(shù)據(jù)解析類，不管你的數(shù)據(jù)是從串口還是tcp還是udp，拿到數(shù)據(jù)以后只管解析處理并存儲(chǔ)即可，如果后期增加其他特定的字段解析，只要更改一個(gè)類即可，而不是寫成多個(gè)類分別解析，其實(shí)串口也好網(wǎng)絡(luò)也是，都是數(shù)據(jù)流，唯一的區(qū)別就是管道不一樣，把不一樣的按照type去區(qū)分就可以了，數(shù)據(jù)的收到和解析，完全一致。最早2014年左右寫過(guò)溫濕度監(jiān)測(cè)項(xiàng)目，那時(shí)候傻逼逼的串口寫一個(gè)類，tcp客戶端寫一個(gè)類，tcp服務(wù)端寫一個(gè)類，udp寫一個(gè)類，后面發(fā)現(xiàn)，一旦增加了一個(gè)回控設(shè)置參數(shù)的功能，好多地方都要增加一樣的函數(shù)功能，真是操蛋，完全沒(méi)有必要。

二、功能特點(diǎn)

1. 采集數(shù)據(jù)端口，支持串口端口+網(wǎng)絡(luò)端口，串口支持自由設(shè)置串口號(hào)+波特率，網(wǎng)絡(luò)支持自由設(shè)置IP地址+通訊端口，每個(gè)端口支持采集周期，默認(rèn)1秒鐘一個(gè)地址，支持設(shè)置通訊超時(shí)次數(shù)，默認(rèn)3次，支持最大重連時(shí)間，用于重新讀取離線的設(shè)備。

2. 控制器信息，能夠添加控制器名稱，選擇控制器地址+控制器型號(hào)，設(shè)置該控制器下面的探測(cè)器數(shù)量。

3. 探測(cè)器信息，能夠添加位號(hào)，可自由選擇探測(cè)器型號(hào)，氣體種類，氣體符號(hào)，高報(bào)值，低報(bào)值，緩沖值，清零值，是否啟用，報(bào)警聲音，背景地圖，存儲(chǔ)周期，數(shù)值換算小數(shù)點(diǎn)位數(shù)，報(bào)警延時(shí)時(shí)間，報(bào)警的類型（HH,LL,HL）等。

4. 控制器型號(hào)+探測(cè)器型號(hào)+氣體種類+氣體符號(hào)，均可自由配置。

5. 地圖支持導(dǎo)入和刪除，所有的探測(cè)器對(duì)應(yīng)地圖位置可自由拖動(dòng)保存。

6. 端口信息+控制器信息+探測(cè)器信息，支持導(dǎo)入導(dǎo)出+導(dǎo)出到excel+打印。

7. 運(yùn)行記錄+報(bào)警記錄+用戶記錄，支持多條件組合查詢，比如時(shí)間段+控制器+探測(cè)器等，所有記錄支持導(dǎo)出到excel+打印。

8. 導(dǎo)出到excel的記錄支持所有excel+wps等表格文件版本，不依賴excel等軟件。

9. 可刪除指定時(shí)間范圍內(nèi)的數(shù)據(jù)，支持自動(dòng)清理早期數(shù)據(jù)，設(shè)置最大保存記錄數(shù)。

10. 支持報(bào)警短信轉(zhuǎn)發(fā)，支持多個(gè)接收手機(jī)號(hào)碼，可設(shè)定發(fā)送間隔，比如即時(shí)發(fā)送或者6個(gè)小時(shí)發(fā)送一次所有的報(bào)警信息，短信內(nèi)容過(guò)長(zhǎng)，自動(dòng)拆分多條短信。

11. 支持報(bào)警郵件轉(zhuǎn)發(fā)，支持多個(gè)接收郵箱，可設(shè)定發(fā)送間隔，比如即時(shí)發(fā)送或者6個(gè)小時(shí)發(fā)送一次所有的報(bào)警信息，支持附件發(fā)送。

12. 高報(bào)顏色+低報(bào)顏色+正常顏色+0值顏色+曲線背景+曲線顏色等，都可以自由選擇。

13. 軟件的中文標(biāo)題+英文標(biāo)題+logo路徑+版權(quán)所有都可以自由設(shè)置。

14. 提供開(kāi)關(guān)設(shè)置開(kāi)機(jī)運(yùn)行+報(bào)警聲音+自動(dòng)登錄+記住密碼等。

15. 報(bào)警聲音可設(shè)置播放次數(shù)，界面提供17種皮膚文件選擇。

16. 支持云端數(shù)據(jù)同步，可設(shè)置云端數(shù)據(jù)庫(kù)的信息，比如數(shù)據(jù)庫(kù)名稱，用戶名+密碼等。

17. 支持網(wǎng)絡(luò)轉(zhuǎn)發(fā)和網(wǎng)絡(luò)接收，網(wǎng)絡(luò)接收開(kāi)啟后，軟件從udp接收數(shù)據(jù)進(jìn)行解析。網(wǎng)絡(luò)轉(zhuǎn)發(fā)支持多個(gè)目標(biāo)IP，這樣就實(shí)現(xiàn)了本地采集的軟件，自由將數(shù)據(jù)轉(zhuǎn)到客戶端，隨時(shí)查看探測(cè)器數(shù)據(jù)。

18. 自動(dòng)記住用戶最后停留的界面+其他信息，重啟后自動(dòng)應(yīng)用。

19. 報(bào)警自動(dòng)切換到對(duì)應(yīng)的地圖，探測(cè)器按鈕閃爍。

20. 雙擊探測(cè)器圖標(biāo)，可以進(jìn)行回控。

21. 支持用戶權(quán)限管理，管理員+操作員兩大類，用戶登錄+用戶退出，可以記住密碼和自動(dòng)登錄，超過(guò)三次報(bào)錯(cuò)提示并關(guān)閉程序。

22. 支持四種監(jiān)控模式，設(shè)備面板監(jiān)控+地圖監(jiān)控+表格數(shù)據(jù)監(jiān)控+曲線數(shù)據(jù)監(jiān)控，可自由切換，四種同步應(yīng)用。

23. 支持報(bào)警繼電器聯(lián)動(dòng)，一個(gè)位號(hào)可以跨串口聯(lián)動(dòng)多個(gè)模塊和繼電器號(hào)，支持多對(duì)多。

24. 本地?cái)?shù)據(jù)存儲(chǔ)支持sqlite+mysql，支持遠(yuǎn)程數(shù)據(jù)同步到云端數(shù)據(jù)庫(kù)。自動(dòng)重連。

25. 本地設(shè)備采集到的數(shù)據(jù)實(shí)時(shí)上傳到云端，以便手機(jī)APP或者web等其他方式提取。

26. 支持兩種數(shù)據(jù)源，一種是串口和網(wǎng)絡(luò)通過(guò)協(xié)議采集設(shè)備數(shù)據(jù)，一種是數(shù)據(jù)庫(kù)采集。數(shù)據(jù)庫(kù)采集模式可以作為通用的系統(tǒng)使用。

27. 自帶設(shè)備模擬工具，支持16個(gè)設(shè)備數(shù)據(jù)模擬，同時(shí)還帶數(shù)據(jù)庫(kù)數(shù)據(jù)模擬，以便在沒(méi)有設(shè)備的時(shí)候測(cè)試數(shù)據(jù)。

28. 默認(rèn)通信協(xié)議采用modbus協(xié)議，后期增加mqtt等物聯(lián)網(wǎng)協(xié)議的支持，做成通用系統(tǒng)。

29. 支持所有windows操作系統(tǒng)+linux操作系統(tǒng)和其他操作系統(tǒng)。

三、效果圖

四、核心代碼

#include "udpsend.h"
#include "quiwidget.h"
#include "dbhelper.h"

QScopedPointer<UdpSend> UdpSend::self;
UdpSend *UdpSend::Instance()
{
    if (self.isNull()) {
        static QMutex mutex;
        QMutexLocker locker(&mutex);
        if (self.isNull()) {
            self.reset(new UdpSend);
        }
    }

    return self.data();
}

UdpSend::UdpSend(QObject *parent) : QObject(parent)
{
    udpSocket = new QUdpSocket(this);
}

UdpSend::~UdpSend()
{
}

void UdpSend::sendData(const QString &portName, quint8 addr, const QByteArray &data)
{
    if (!App::UseNetSend) {
        return;
    }

    //取出ip和端口
    QList<QString> ips;
    QList<int> ports;
    QStringList list = App::NetSendInfo.split(";");
    foreach (QString str, list) {
        if (str.contains(":")) {
            QStringList temp = str.split(":");
            ips << temp.at(0);
            ports << temp.at(1).toInt();
        }
    }

    //逐個(gè)發(fā)送
    for (int i = 0; i < ips.count(); i++) {
        if (data.size() > 0) {
            QString buffer;
            if (portName == "PortInfo" || portName == "DeviceInfo" || portName == "NodeInfo") {
                buffer = QString("%1|%2").arg(portName).arg(QString(data));
            } else {
                buffer = QString("%1|%2").arg(portName).arg(QUIHelper::byteArrayToHexStr(data));
            }

            udpSocket->writeDatagram(buffer.toUtf8(), QHostAddress(ips.at(i)), ports.at(i));
            udpSocket->flush();
        }
    }
}

void UdpSend::start()
{
    DBHelper::addUserLog("設(shè)備上報(bào)", "網(wǎng)絡(luò)轉(zhuǎn)發(fā)啟動(dòng)服務(wù)");
}

void UdpSend::stop()
{
    DBHelper::addUserLog("設(shè)備上報(bào)", "網(wǎng)絡(luò)轉(zhuǎn)發(fā)停止服務(wù)");
}

void UdpSend::sendInfo()
{
    if (!App::UseNetSend) {
        return;
    }

    //發(fā)送端口信息表+設(shè)備信息表+探測(cè)器信息表
    QStringList portInfo, deviceInfo, nodeInfo;

    for (int i = 0; i < DBData::PortInfo_Count; i++) {
        QStringList list;
        list << QString::number(DBData::PortInfo_PortID.at(i));
        list << DBData::PortInfo_PortName.at(i);
        list << DBData::PortInfo_ComName.at(i);
        list << QString::number(DBData::PortInfo_BaudRate.at(i));
        list << DBData::PortInfo_TcpIP.at(i);
        list << QString::number(DBData::PortInfo_TcpPort.at(i));
        list << QString::number(DBData::PortInfo_ReadInterval.at(i));
        list << QString::number(DBData::PortInfo_ReadTimeout.at(i));
        list << QString::number( DBData::PortInfo_ReadMaxtime.at(i));
        portInfo << list.join(";");
    }

    for (int i = 0; i < DBData::DeviceInfo_Count; i++) {
        QStringList list;
        list << QString::number(DBData::DeviceInfo_DeviceID.at(i));
        list << DBData::DeviceInfo_PortName.at(i);
        list << DBData::DeviceInfo_DeviceName.at(i);
        list << QString::number(DBData::DeviceInfo_DeviceAddr.at(i));
        list << DBData::DeviceInfo_DeviceType.at(i);
        list << QString::number(DBData::DeviceInfo_NodeNumber.at(i));
        deviceInfo << list.join(";");
    }

    for (int i = 0; i < DBData::NodeInfo_Count; i++) {
        QStringList list;
        list << QString::number(DBData::NodeInfo_NodeID.at(i));
        list << DBData::NodeInfo_PositionID.at(i);
        list << DBData::NodeInfo_DeviceName.at(i);
        list << DBData::NodeInfo_NodeName.at(i);
        list << QString::number(DBData::NodeInfo_NodeAddr.at(i));
        list << DBData::NodeInfo_NodeType.at(i);
        list << DBData::NodeInfo_NodeClass.at(i);
        list << DBData::NodeInfo_NodeSign.at(i);
        list << QString::number(DBData::NodeInfo_NodeUpper.at(i));
        list << QString::number(DBData::NodeInfo_NodeLimit.at(i));
        list << QString::number(DBData::NodeInfo_NodeMax.at(i));
        list << QString::number(DBData::NodeInfo_NodeMin.at(i));
        list << QString::number(DBData::NodeInfo_NodeRange.at(i));
        list << DBData::NodeInfo_NodeEnable.at(i);
        list << DBData::NodeInfo_NodeSound.at(i);
        list << DBData::NodeInfo_NodeImage.at(i);
        list << QString::number(DBData::NodeInfo_SaveInterval.at(i));
        list << QString::number(DBData::NodeInfo_DotCount.at(i));
        list << QString::number(DBData::NodeInfo_AlarmDelay.at(i));
        list << DBData::NodeInfo_AlarmType.at(i);
        list << QString::number(DBData::NodeInfo_NodeX.at(i));
        list << QString::number(DBData::NodeInfo_NodeY.at(i));
        nodeInfo << list.join(";");
    }

    sendData("PortInfo", 255, QString(portInfo.join(" ")).toUtf8());
    sendData("DeviceInfo", 255, QString(deviceInfo.join(" ")).toUtf8());
    sendData("NodeInfo", 255, QString(nodeInfo.join(" ")).toUtf8());
}

“Qt怎么實(shí)現(xiàn)網(wǎng)絡(luò)轉(zhuǎn)發(fā)”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注億速云網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實(shí)用文章！