如何求解Android 12无法使用MQTTANDROIDCLIENT

Question

在我的Android Studio中，我想将MQTT Android客户端连接到我的笔记本电脑主机（在同一台计算机中）。我使其与本指南相似

然后，我发现Android 12（在我的情况下为API 32）可能不支持 org。 eclipse.paho：org.eclipse.paho.android.service：1.1.1 依赖关系。因此，我遵循下面的解决方案，以导入 servicelibrary-release.aar 库中提供的库。 （此链接中出现的问题是我的情况相同的）

android paho mqtt崩溃android 12-针对S+（版本31及更高版本）要求flag_immutable或flag_mutable之一

之后，我遇到了另一个错误。

error: constructor MqttAndroidClient in class MqttAndroidClient cannot be applied to given types;
                MqttAndroidClient client = new MqttAndroidClient(MainActivity.this, "tcp://10.0.2.2:1883", clientId);
                                           ^
  required: Context,String,String,Ack
  found: MainActivity,String,String
  reason: actual and formal argument lists differ in length

因此，我不确定上面解决方案的库是否可以应用于我的旧代码，还是需要修改一些代码？

这是我的代码和Gradle文件。

存储库

maven {
    url "https://repo.eclipse.org/content/repositories/paho-releases/"
}

依赖项

implementation files('libs/serviceLibrary-release.aar')
implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.5'

android清单 （下面添加了权限）

<uses-permission android:name="android.permission.WAKE_LOCK" />
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
<uses-permission android:name="android.permission.INTERNET" />
<uses-permission android:name="android.permission.READ_PHONE_STATE" />

<service android:name="info.mqtt.android.service.MqttService"/>

主要活动

import info.mqtt.android.service.MqttAndroidClient;

public class MainActivity extends AppCompatActivity {

    private Button buttonConnect;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        buttonConnect = findViewById(R.id.buttonConnect);
        buttonConnect.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                String clientId = MqttClient.generateClientId();
                Toast.makeText(MainActivity.this, clientId, Toast.LENGTH_SHORT).show();

                MqttAndroidClient client = new MqttAndroidClient(MainActivity.this, "tcp://10.0.2.2:1883", clientId);

                try {
                    IMqttToken token = client.connect();
                    token.setActionCallback(new IMqttActionListener() {
                        @Override
                        public void onSuccess(IMqttToken asyncActionToken) {
                            Log.d("Debug", "onSuccess");
                            Toast.makeText(MainActivity.this, "onSuccess", Toast.LENGTH_SHORT).show();
                        }

                        @Override
                        public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
                            Log.d("Debug", "onFailure");
                            Toast.makeText(MainActivity.this, "onFailure", Toast.LENGTH_SHORT).show();
                            exception.printStackTrace();
                        }
                    });
                } catch (MqttException e) {
                    e.printStackTrace();
                }
            }
        });
    }
}

该错误出现在此行中（单击按钮时）

mqttandroidclient client = new mqttandroidclient（mainActivity.this，“ tcp：//10.0.2.2：1883”，clientid）;

从上面提示的错误消息中。我认为这是因为此类的构造函数的参数也需要类型 ack ，但我对此不知道。

Answer 1

从您提供的输出中，您似乎只需要将ACK指定为构造函数的最后一个参数。
确认您收到了一条消息。根据官方的，有两种模式可用。

首先， mqttandroidclient.ack.auto_ack ，一旦收到消息，它会自动确认。

然后，您拥有 mqttandroidclient.ack.ack.manual_ack ，它要求您通过执行 mqttandroidclient.acknowledgemessage（string）（string）

您可以通过现在添加自动添加自动，从如果可以的话，那么您可以手动承认自己使用自定义规则。