在 Qt/DBus 适配器中实现异步功能的正确方法

Question

如 D-Bus 文档中所述，所有 IPC 调用都被视为异步。当 Qt 通过 QDBusAbstractInterface 调用远程 D-Bus 对象时，QBusPendingCall 是完全异步的，并在调用运行完成时提供信号。

在我的应用程序设计中，我想在我的对象适配器上实现异步调用，但当前的 Qt/DBus 实现假定所有方法调用都是阻塞的。

所以，有一个问题：是否有适当的方法来实现异步处理 D-Bus 方法调用？

Answer 1

这在 Declaring Slots in D-Bus Adaptors 中有很好的解释。

我们通过编写一个存储请求数据的插槽来实现这一点，该插槽将请求数据存储在持久结构中，使用 QDBusMessage::setDelayedReply(true) 向调用者指示稍后将发送响应。

struct RequestData
{
    QString request;
    QString processedData;
    QDBusMessage reply;
};

QString processRequest(const QString &request, const QDBusMessage &message)
{
    RequestData *data = new RequestData;
    data->request = request;
    message.setDelayedReply(true);
    data->reply = message.createReply();
    QDBusConnection::sessionBus().send(data->reply);

    appendRequest(data);
    return QString();
}

需要使用QDBusConnection::sessionBus().send(data->reply)来明确通知调用者响应将被延迟。在这种情况下，return 值并不重要；我们return一个任意值来满足编译器。

当请求被处理并且回复可用时，应该使用获得的 QDBusMessage 对象发送回复。在我们的示例中，回复代码可能如下所示：

void sendReply(RequestData *data)
{
    // data->processedData has been initialized with the request's reply
    QDBusMessage &reply = &data->reply;

    // send the reply over D-Bus:
    reply << data->processedData;
    QDBusConnection::sessionBus().send(reply);

    // dispose of the transaction data
    delete data;
}

从示例中可以看出，当延迟回复到位时，Qt D-Bus 将忽略插槽中的 return 值。它们仅用于在将适配器的描述传达给远程应用程序时确定插槽的签名，或者在插槽中的代码决定不使用延迟回复的情况下。

通过在原始消息上调用 QDBusMessage::reply() 从 Qt D-Bus 请求延迟回复本身。然后由被调用代码负责最终向调用者发送回复。

警告：当调用方发出方法调用并等待回复时，它只会等待有限的时间。需要很长时间才能完成的插槽应该在文档中明确说明这一事实，以便调用者正确设置更高的超时时间。

在 Qt/DBus 适配器中实现异步功能的正确方法

Proper way to implement async function in Qt/DBus adaptor

c++

qt

c++11

asynchronous

qdbus