qt访问OPC服务同时具有重连机制的代码

以下是一个基于Qt的访问OPC服务并具有重连机制的示例代码：

#include <QOpcUaClient>
#include <QOpcUaNode>
#include <QOpcUaMonitoringParameters>
#include <QTimer>
#include <QDebug>

class OpcUaClient : public QObject
{
    Q_OBJECT
public:
    explicit OpcUaClient(QObject *parent = nullptr)
        : QObject(parent)
        , m_client(new QOpcUaClient(this))
        , m_reconnectTimer(new QTimer(this))
        , m_isConnected(false)
    {
        m_client->setEndpointUrl(QUrl("opc.tcp://localhost:4840"));
        connect(m_client, &QOpcUaClient::stateChanged, this, &OpcUaClient::onStateChanged);
        connect(m_reconnectTimer, &QTimer::timeout, this, &OpcUaClient::reconnect);
    }

    void connectToServer()
    {
        m_client->connectToEndpoint();
    }

    void disconnectFromServer()
    {
        m_client->disconnectFromEndpoint();
    }

    void readNode(const QString &nodeId)
    {
        if (m_isConnected) {
            QOpcUaNode *node = m_client->nodeByIdentifier(nodeId);
            if (node) {
                connect(node, &QOpcUaNode::valueChanged, this, &OpcUaClient::onNodeValueChanged);
                node->readAttributes(QOpcUa::NodeAttribute::Value);
            } else {
                qWarning() << "Node not found for id" << nodeId;
            }
        } else {
            qWarning() << "Not connected to OPC UA server";
        }
    }

signals:
    void nodeValueChanged(const QString &nodeId, const QVariant &value);

private slots:
    void onStateChanged(QOpcUaClient::ClientState state)
    {
        switch (state) {
        case QOpcUaClient::ClientState::Disconnected:
            m_isConnected = false;
            m_reconnectTimer->start(5000); // try to reconnect every 5 seconds
            break;
        case QOpcUaClient::ClientState::Connected:
            m_isConnected = true;
            m_reconnectTimer->stop();
            break;
        default:
            break;
        }
    }

    void onNodeValueChanged(QOpcUa::NodeAttribute attr, const QVariant &value)
    {
        Q_UNUSED(attr);
        QOpcUaNode *node = qobject_cast<QOpcUaNode *>(sender());
        if (node) {
            emit nodeValueChanged(node->nodeId(), value);
        }
    }

    void reconnect()
    {
        m_client->connectToEndpoint();
    }

private:
    QOpcUaClient *m_client;
    QTimer *m_reconnectTimer;
    bool m_isConnected;
};

这个示例代码使用了Qt提供的`QOpcUaClient`类来访问OPC服务。它有一个`onStateChanged()`槽函数，当连接状态发生变化时会被调用。在连接断开时，它会启动一个定时器来定期尝试重新连接。在连接成功时，它会停止定时器。

此外，这个示例代码还有一个`readNode()`函数来读取指定节点的值，并在值发生变化时发出`nodeValueChanged()`信号。在这个函数中，我们需要检查连接状态，如果没有连接则发出警告信息。如果连接已经建立，我们可以使用`m_client->nodeByIdentifier()`函数来获取指定节点的`QOpcUaNode`对象，并连接它的`valueChanged()`信号以便在值发生变化时处理它。然后我们调用`readAttributes()`函数来读取节点的属性，其中包括`Value`属性，以获取节点的当前值。

可以根据需要对这个示例代码进行修改和扩展，以满足特定的要求。