android studio 通过点击按钮连接使用EMQX

EMQX是一款开源的MQTT消息服务器，可以用于构建物联网应用程序。在Android Studio中，可以使用MQTT客户端库连接到EMQX服务器，并通过点击按钮向服务器发送消息。

以下是连接EMQX服务器的步骤：

1. 添加MQTT客户端库

在Android Studio中打开项目，右键单击项目文件夹，选择“Open Module Settings”，然后选择“Dependencies”选项卡。点击“+”按钮，选择“Library dependency”，输入“org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.5”并点击“OK”按钮。这将添加MQTT客户端库到项目中。

2. 编写连接EMQX服务器的代码

在Android Studio中打开MainActivity.java文件，添加以下代码：

import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

public class MainActivity extends AppCompatActivity {
    private static final String BROKER_URL = "tcp://<EMQX_SERVER>:<EMQX_PORT>";
    private static final String TOPIC = "<MQTT_TOPIC>";
    private static final String CLIENT_ID = "<MQTT_CLIENT_ID>";
    private MqttClient mqttClient;

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

        Button connectButton = findViewById(R.id.connectButton);
        connectButton.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                connectToBroker();
            }
        });

        Button publishButton = findViewById(R.id.publishButton);
        publishButton.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                publishMessage();
            }
        });
    }

    private void connectToBroker() {
        try {
            mqttClient = new MqttClient(BROKER_URL, CLIENT_ID, new MemoryPersistence());
            MqttConnectOptions options = new MqttConnectOptions();
            options.setCleanSession(true);
            mqttClient.connect(options);
            mqttClient.subscribe(TOPIC);
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }

    private void publishMessage() {
        try {
            String message = "Hello, EMQX!";
            MqttMessage mqttMessage = new MqttMessage(message.getBytes());
            mqttClient.publish(TOPIC, mqttMessage);
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }
}

其中，BROKER_URL是EMQX服务器的地址和端口号，TOPIC是MQTT主题，CLIENT_ID是MQTT客户端ID。在connectToBroker()方法中，使用MqttClient类连接到EMQX服务器，并订阅TOPIC。在publishMessage()方法中，使用MqttClient类向TOPIC发布消息。

3. 创建UI界面

在res/layout文件夹中创建一个名为activity_main.xml的文件，添加以下代码：

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    android:orientation="vertical"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:padding="16dp">

    <Button
        android:id="@+id/connectButton"
        android:text="Connect to EMQX"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:layout_marginBottom="16dp"/>

    <Button
        android:id="@+id/publishButton"
        android:text="Publish Message"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"/>

</LinearLayout>

在MainActivity.java文件中，使用findViewById()方法获取按钮控件，并设置点击事件。

4. 运行应用程序

在Android Studio中点击“Run”按钮，选择模拟器或连接的设备。运行应用程序后，点击“Connect to EMQX”按钮连接到EMQX服务器，然后点击“Publish Message”按钮向服务器发送消息。可以在EMQX服务器的控制台中查看接收到的消息。

注意：在连接EMQX服务器时，需要将BROKER_URL、TOPIC和CLIENT_ID替换为实际的值。