/**
 * 需要寫入到共享內(nèi)存中的數(shù)據(jù)
 */
private val bytes = "風(fēng)蕭蕭兮易水寒。".toByteArray()


/**
 * 創(chuàng)建 MemoryFile 并返回 ParcelFileDescriptor
 */
private fun createMemoryFile(): ParcelFileDescriptor? {
    // 創(chuàng)建 MemoryFile 對(duì)象，1024 是最大占用內(nèi)存的大小。
    val file = MemoryFile("TestAshmemFile", 1024)

    // 獲取文件描述符，因?yàn)榉椒ū粯?biāo)注為 @hide，只能反射獲取
    val descriptor = invokeMethod("getFileDescriptor", file) as? FileDescriptor

    // 如果獲取失敗，返回
    if (descriptor == null) {
        Log.i("ZHP", "獲取匿名共享內(nèi)存的 FileDescriptor 失敗")
        return null
    }

    // 往共享內(nèi)存中寫入數(shù)據(jù)
    file.writeBytes(bytes, 0, 0, bytes.size)

    // 因?yàn)橐邕M(jìn)程傳遞，需要序列化 FileDescriptor
    return ParcelFileDescriptor.dup(descriptor)
}


/**
 * 通過(guò)反射執(zhí)行 obj.name() 方法
 */
private fun invokeMethod(name: String, obj: Any): Any? {
    val method = obj.javaClass.getDeclaredMethod(name)
    return method.invoke(obj)
}

/**
 * 兩個(gè)進(jìn)程在傳遞 FileDescriptor 時(shí)用到的 Code。
 */
const val MY_TRANSACT_CODE = 920511

// 創(chuàng)建服務(wù)進(jìn)程
val intent = Intent(this, MyService::class.java)
bindService(intent, serviceConnection, Context.BIND_AUTO_CREATE)

private val serviceConnection = object: ServiceConnection {

    override fun onServiceConnected(name: ComponentName?, binder: IBinder?) {
        if (binder == null) {
            return
        }

        // 創(chuàng)建 MemoryFile，并拿到 ParcelFileDescriptor
        val descriptor = createMemoryFile() ?: return

        // 傳遞 FileDescriptor 和 共享內(nèi)存中數(shù)據(jù)的大小
        val sendData = Parcel.obtain()
        sendData.writeParcelable(descriptor, 0)
        sendData.writeInt(bytes.size)

        // 保存對(duì)方進(jìn)程的返回值
        val reply = Parcel.obtain()

        // 開始跨進(jìn)程傳遞
        binder.transact(MY_TRANSACT_CODE, sendData, reply, 0)

        // 讀取 Binder 執(zhí)行的結(jié)果
        val msg = reply.readString()
        Log.i("ZHP", "Binder 執(zhí)行結(jié)果是：「$msg」")
    }

    override fun onServiceDisconnected(name: ComponentName?) {}

}

class MyService : Service() {

    private val binder by lazy { MyBinder() }

    override fun onBind(intent: Intent) = binder
}

/**
 * 這里不必使用 AIDL，繼承 Binder 類 重寫 onTransact 即可。
 */
class MyBinder: Binder() {

    /**
     * 文件描述符 和 數(shù)據(jù)大小 通過(guò) data 傳入。
     */
    override fun onTransact(code: Int, data: Parcel, reply: Parcel?, flags: Int): Boolean {
        val parent = super.onTransact(code, data, reply, flags)
        if (code != MY_TRANSACT_CODE && code != 931114) {
            return parent
        }

        // 讀取 ParcelFileDescriptor 并轉(zhuǎn)為 FileDescriptor
        val pfd = data.readParcelable<ParcelFileDescriptor>(javaClass.classLoader)
        if (pfd == null) {
            return parent
        }
        val descriptor = pfd.fileDescriptor

        // 讀取共享內(nèi)存中數(shù)據(jù)的大小
        val size = data.readInt()

        // 根據(jù) FileDescriptor 創(chuàng)建 InputStream
        val input = FileInputStream(descriptor)

        // 從 共享內(nèi)存 中讀取字節(jié)，并轉(zhuǎn)為文字
        val bytes = input.readBytes()
        val message = String(bytes, 0, size, Charsets.UTF_8)

        Log.i("ZHP", "讀取到另外一個(gè)進(jìn)程寫入的字符串：「$message」")

        // 回復(fù)調(diào)用進(jìn)程
        reply?.writeString("Server 端收到 FileDescriptor, 并且從共享內(nèi)存中讀到了：「$message」")

        return true
    }

}