Hàng đợi tin nhắn nhanh nhờ AIDL

Kể từ Android 12, bạn có thể sử dụng Fast Message Queue (Hàng đợi tin nhắn nhanh) với các giao diện AIDL bằng cách sử dụng phần phụ trợ NDK. Điều này cho phép các quy trình giao tiếp mà không gây hao tổn và hạn chế đối với các giao dịch liên kết sau một số thiết lập ngắn. Việc sử dụng AIDL ổn định cho phép giao tiếp giữa quy trình của hệ thống và nhà cung cấp.

Các loại trọng tải được hỗ trợ

Các thông điệp được gửi giữa các quy trình trong hàng đợi thông điệp bộ nhớ dùng chung phải có cùng bố cục bộ nhớ trên các ranh giới quy trình và không được chứa con trỏ. Việc cố gắng tạo một AidlMessageQueue có loại không được hỗ trợ sẽ gây ra lỗi biên dịch.

Các loại hàng đợi được hỗ trợ

AIDL hỗ trợ các loại hàng đợi giống nhau từ HIDL, thường được gọi là phiên bản. Các đối số này được dùng làm đối số mẫu cho hàng đợi và chỉ số mô tả.

Loại HIDL Loại AIDL
android::hardware::kSynchronizedReadWrite android.hardware.common.fmq.SynchronizedReadWrite
android::hardware::kUnsynchronizedWrite android.hardware.common.fmq.UnsynchronizedWrite

How to use

Xác định giao diện AIDL sẽ truyền MQDescriptor đến quy trình khác. Bạn có thể sử dụng MQDescriptor ở bất cứ nơi nào có thể phân phối.

Các đối số mẫu bắt buộc cho MQDescriptor là loại tải trọng và hương vị hàng đợi.

import android.hardware.common.fmq.MQDescriptor
import android.hardware.common.fmq.SynchronizedReadWrite

void getQueue(out MQDescriptor<int, SynchronizedReadWrite> mqDesc);

Quy trình thiết lập mỗi bên của hàng đợi thông báo gần giống với quy trình sử dụng HIDL, chỉ cần sử dụng các loại AIDL.

#include <fmq/AidlMessageQueue.h>
...
using ::android::AidlMessageQueue;
using ::aidl::android::hardware::common::fmq::MQDescriptor;
using ::aidl::android::hardware::common::fmq::SynchronizedReadWrite;
...
ndk::ScopedAStatus MyInterface::getQueue(MQDescriptor<int32_t, SynchronizedReadWrite>* mqDesc) {
    *mqDesc = mFmqSynchronized->dupeDesc();
    return ndk::ScopedAStatus::ok();
}
...
// Create the first side of the queue before servicing getQueue() in this example
mFmqSynchronized =
  new AidlMessageQueue<int32_t, SynchronizedReadWrite>(kNumElementsInQueue);

Quá trình nhận sẽ tạo phía bên kia của hàng đợi bằng chỉ số mô tả nhận được từ giao diện AIDL.

MQDescriptor<int32_t, SynchronizedReadWrite> desc;
auto ret = service->getQueue(true, &desc);
if (!ret.isOk()) {
   ...
}
// By default the constructor will reset the read and write pointers of the queue.
// Add a second `false` argument to avoid resetting the pointers.
mQueue = new (std::nothrow) AidlMessageQueue<int32_t, SynchronizedReadWrite>(desc);
if (!mQueue->isValid()) {
   ...
}

Việc sử dụng AidlMessageQueue sau khi thiết lập giống như HIDL MessageQueue. Tất cả API được mô tả tại bài viết Sử dụng MessageQueue đều được hỗ trợ đầy đủ với AidlMessageQueue, ngoại trừ một trường hợp ngoại lệ:

const MQDescriptor<T, flavor>* getDesc() được thay thế bằng MQDescriptor<T, U> dupeDesc() để trả về AIDL MQDescriptor.