2

我在 android 端使用 pahoo mqtt 并在 Flutter 上实现它以使其在应用程序关闭时运行。但是,客户端仍然连接,并且在我关闭应用程序后仍然从经纪人那里收到消息。但是,当我再次打开应用程序时,似乎无法在消息到达时从 android 端调用方法mBackgroundChannel.invokeMethod("mqttMessageArrive", strMessage)并收到此警告消息Tried to send a platform message to Flutter, but FlutterJNI was detached from native C++. Could not send. Channel: com.example.research_cahyo/method_dart. Response ID: 0

关闭应用程序后我也收到此错误

2020-06-18 17:27:16.751 27939-27939/com.example.research_cahyo E/ActivityThread: Activity com.example.research_cahyo.MainActivity has leaked ServiceConnection org.eclipse.paho.android.service.MqttAndroidClient$MyServiceConnection@4c11377 that was originally bound here
    android.app.ServiceConnectionLeaked: Activity com.example.research_cahyo.MainActivity has leaked ServiceConnection org.eclipse.paho.android.service.MqttAndroidClient$MyServiceConnection@4c11377 that was originally bound here
        at android.app.LoadedApk$ServiceDispatcher.<init>(LoadedApk.java:1813)
        at android.app.LoadedApk.getServiceDispatcherCommon(LoadedApk.java:1685)
        at android.app.LoadedApk.getServiceDispatcher(LoadedApk.java:1664)
        at android.app.ContextImpl.bindServiceCommon(ContextImpl.java:1732)
        at android.app.ContextImpl.bindService(ContextImpl.java:1661)
        at android.content.ContextWrapper.bindService(ContextWrapper.java:715)
        at org.eclipse.paho.android.service.MqttAndroidClient.connect(MqttAndroidClient.java:425)
        at com.example.research_cahyo.mqtt.MQTTConnection.doConnect(MqttConnection.kt:32)
        at com.example.research_cahyo.MyPlugin.doStartMqttService(MyPlugin.kt:69)
        at com.example.research_cahyo.MyPlugin.onMethodCall(MyPlugin.kt:149)
        at io.flutter.plugin.common.MethodChannel$IncomingMethodCallHandler.onMessage(MethodChannel.java:231)
        at io.flutter.embedding.engine.dart.DartMessenger.handleMessageFromDart(DartMessenger.java:93)
        at io.flutter.embedding.engine.FlutterJNI.handlePlatformMessage(FlutterJNI.java:642)

下面是我的 mainactivity.kt

class MainActivity : FlutterActivity() {

    private val TAG = "MAIN ACTIVITY";

    override fun configureFlutterEngine(@NonNull flutterEngine: FlutterEngine) {
            if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
                startForegroundService(Intent(activity.applicationContext, NotificationService::class.java))
            } else {
                startService(Intent(activity.applicationContext, NotificationService::class.java))
            }

            GeneratedPluginRegistrant.registerWith(flutterEngine);
            Storage.initValue(this.applicationContext)

            val binaryMessenger = flutterEngine.getDartExecutor().getBinaryMessenger()
            MethodChannel(binaryMessenger, INVOKE_METHOD_ANDROID)
                    .setMethodCallHandler(MyPlugin(this, binaryMessenger))
    }
}

这是 myplugin.kt

class MyPlugin(private val activity: Activity, binaryMessenger: BinaryMessenger) : MethodChannel.MethodCallHandler, IMqttCallback {

    private var mBackgroundChannel: MethodChannel

    private lateinit var subscribeTopic: String

    init {
        mBackgroundChannel = MethodChannel(binaryMessenger, INVOKE_METHOD_DART)
    }

    fun onPublishMessage(call: MethodCall, rawResult: MethodChannel.Result) {
        val params = call.arguments<Map<String, String>>()

        if (params.containsKey("messages") && params.containsKey("topic")) {
            val messages = params["messages"] ?: ""
            val topic = params["topic"] ?: ""

            MQTTConnection.instance?.doPublishMessages(messages, topic)

            rawResult.success(true)
        } else {
            rawResult.error("INCOMPLETE ARGS", "ARGUMEN ARE INCOMPLETE", null);
        }
    }

    fun doCheckMqttStatus(result: MethodChannel.Result) {
        result.success(MQTTConnection.instance?.isConnected)
    }

    fun doUnSubscribeTopic(call: MethodCall, result: MethodChannel.Result) {
        val param: Map<String, String> = call.arguments();
        val topic: String = param.get("topic") ?: ""

        if (topic.isNotEmpty()) {
            MQTTConnection.instance?.doUnSubscribeTopic(topic, this)
        }
    }

    fun doStartMqttService(call: MethodCall, result: MethodChannel.Result) {
        val param: Map<String, String> = call.arguments();
        val serverUri: String = param.get("serverUri") ?: ""
        val clientId: String = param.get("clientId") ?: ""
        val clientUsername: String = param.get("clientUsername") ?: ""
        val clientPassword: String = param.get("clientPassword") ?: ""
        subscribeTopic = param.get("subscribeTopic") ?: ""

        val valid = serverUri.length > 0 && clientId.length > 0 &&
                clientUsername.length > 0 && clientPassword.length > 0 &&
                subscribeTopic.length > 0

        if (valid) {
            Storage.saveValue(MQTTOPTIONS_STORAGE_KEY, "$serverUri,$clientId,$clientUsername,$clientPassword,$subscribeTopic")
        }

        if (valid && !(MQTTConnection.instance?.isConnected ?: false)) {
            MQTTConnection.instance?.doConnect(activity, serverUri, clientId, clientUsername, clientPassword, this)
            result.success("Start mqtt invoked")
        } else {
            result.error("Invalid Arguments", "Mqtt failed to invoked", null)
        }
    }

    fun doStopMqttService(result: MethodChannel.Result) {
        MQTTConnection.instance?.doDisConnect(true)
        result.success("Stop mqtt invoked")
    }

    fun onGetNotifications(result: MethodChannel.Result) {
        val listMessage = (Storage.getValue(NOTIFICATION_STORAGE_KEY) as List<*>).map { it.toString() }
        result.success(listMessage)
    }

    fun onSetNotification(call: MethodCall, result: MethodChannel.Result) {
        try {
            val params = (call.arguments() as List<*>).map { it.toString() };
            Storage.saveValue(NOTIFICATION_STORAGE_KEY, params)
        } catch (e: Exception) {
            result.error("Set storage error", "Set Notification Error", null);
        }
    }

    override fun onMQTTConnectionSuccess() {
        if (!(MQTTConnection.instance?.hasTopic(subscribeTopic) ?: false)) {
            MQTTConnection.instance?.doSubscribeTopic(subscribeTopic, this)
        }
    }

    override fun onMQTTSubscribeTopicSuccess() {
        MQTTConnection.instance?.doMessageListen(this)
    }

    override fun onMQTTSubscribeTopicFailed(messages: String?) {
        mBackgroundChannel.invokeMethod("mqttSubscribeFailed", messages)
    }

    override fun onMQTTConnectionFailed(messages: String?) {
        mBackgroundChannel.invokeMethod("mqttConnectFailed", messages)
    }

    override fun onMQTTMessagesArrived(mqttMessage: MqttMessage?) {
        mqttMessage?.let {
            val strMessage = String(it.payload)
            mBackgroundChannel.invokeMethod("mqttMessageArrive", strMessage)

            val listMessage = (Storage.getValue(NOTIFICATION_STORAGE_KEY) as MutableList<*>).map {
                it.toString()
            }.toMutableList()
            listMessage.add(strMessage)
            Storage.saveValue(NOTIFICATION_STORAGE_KEY, listMessage)

            Log.d(TAG, "message has arrived")
            val notificationBuilder = NotificationCompat.Builder(activity.applicationContext, Constant.CHANNEL_ID)
            notificationBuilder.setSmallIcon(R.drawable.ic_launcher_foreground)
                    .setContentTitle("Message")
                    .setContentText(strMessage)
                    .setVibrate(arrayListOf(1000L, 1000L, 1000L, 1000L).toLongArray())
            val notification = notificationBuilder.build()

            with(NotificationManagerCompat.from(activity.applicationContext)) {
                this.notify(Random.nextInt(0, 100), notification)
            }
        }
    }

    override fun onMQTTUnsubscribeSuccess() {
        mBackgroundChannel.invokeMethod("mqttUnsubscribeSuccess", "Mqtt unsubscribe success")
    }

    override fun onMQTTUnsubscribeFailed() {
        mBackgroundChannel.invokeMethod("mqttUnsubscribeFailed", "Mqtt unsubscribe failed")
    }

    override fun onMethodCall(call: MethodCall, result: MethodChannel.Result) {
        when (call.method) {
            "publishMessage" -> onPublishMessage(call, result)
            "startMqttService" -> doStartMqttService(call, result)
            "stopMqttService" -> doStopMqttService(result)
            "checkMqttStatus" -> doCheckMqttStatus(result)
            "unsubscribeTopic" -> doUnSubscribeTopic(call, result)
            "getNotification" -> onGetNotifications(result)
            "setNotification" -> onSetNotification(call, result)
            else -> result.notImplemented()
        }
    }
}

谁能解决这个问题,抱歉英语不好

4

0 回答 0