Java emqx订阅与发布16进制

要在Java中使用emqx进行订阅和发布16进制数据，需要使用MQTT客户端库。以下是一个简单的示例代码，它将以16进制格式发布一个字节数组，并订阅一个主题以接收16进制格式的消息。

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

public class MqttExample {
    public static void main(String[] args) throws MqttException {
        String broker = "tcp://localhost:1883";
        String clientId = "JavaExample";
        MemoryPersistence persistence = new MemoryPersistence();

        // 创建MQTT客户端实例
        MqttClient client = new MqttClient(broker, clientId, persistence);

        // 设置回调函数
        client.setCallback(new MqttCallback() {
            public void connectionLost(Throwable cause) {}
            public void messageArrived(String topic, MqttMessage message) throws Exception {
                // 接收到消息时执行的代码
                byte[] payload = message.getPayload();
                String hexString = bytesToHexString(payload);
                System.out.println("Received message: " + hexString);
            }
            public void deliveryComplete(IMqttDeliveryToken token) {}
        });

        // 连接到MQTT代理服务器
        client.connect();

        // 订阅主题
        String topic = "test";
        client.subscribe(topic);

        // 发布消息
        byte[] payload = {0x01, 0x02, 0x03};
        MqttMessage message = new MqttMessage(payload);
        message.setQos(0);
        client.publish(topic, message);

        // 断开连接
        client.disconnect();
    }

    // 将字节数组转换为16进制字符串
    public static String bytesToHexString(byte[] bytes) {
        StringBuilder sb = new StringBuilder();
        for (byte b : bytes) {
            sb.append(String.format("%02X", b));
        }
        return sb.toString();
    }
}

在上面的示例中，`bytesToHexString`方法将字节数组转换为16进制字符串。在订阅的回调函数中，接收到的消息将转换为16进制字符串并打印到控制台上。在发布消息时，字节数组将作为`MqttMessage`对象的负载，并使用`client.publish`方法发布到指定的主题上。