利用mqtt协议订阅某专项数据，并设置对应的心跳系统，使用java代码实现

好的，以下是使用Java语言实现订阅MQTT专项数据并设置心跳系统的示例代码：

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

public class MqttSubscriber {

    public static void main(String[] args) {

        String broker = "tcp://mqtt.broker.com:1883";
        String clientId = "JavaMqttSubscriber";
        String topic = "topic/test";
        int qos = 1;

        MemoryPersistence persistence = new MemoryPersistence();

        try {
            MqttClient client = new MqttClient(broker, clientId, persistence);

            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);

            System.out.println("Connecting to broker: " + broker);
            client.connect(connOpts);
            System.out.println("Connected");

            client.subscribe(topic, qos, new IMqttMessageListener() {
                @Override
                public void messageArrived(String topic, MqttMessage message) throws Exception {
                    System.out.println("Message received: " + new String(message.getPayload()));
                }
            });

            // 设置心跳系统
            int delay = 10000; // 延迟10秒
            int period = 10000; // 间隔10秒
            Timer timer = new Timer();
            timer.scheduleAtFixedRate(new TimerTask() {
                public void run() {
                    MqttMessage message = new MqttMessage("heartbeat".getBytes());
                    try {
                        client.publish("topic/heartbeat", message);
                    } catch (MqttException e) {
                        e.printStackTrace();
                    }
                }
            }, delay, period);

        } catch (MqttException me) {
            System.out.println("reason: " + me.getReasonCode());
            System.out.println("msg: " + me.getMessage());
            System.out.println("loc: " + me.getLocalizedMessage());
            System.out.println("cause: " + me.getCause());
            System.out.println("excep: " + me);
        }
    }
}

在这个示例代码中，我们使用Eclipse Paho MQTT库连接到MQTT代理服务器，并订阅了"topic/test"主题。当有新消息到达时，会通过IMqttMessageListener回调函数进行处理。

同时，使用Java的java.util.Timer和java.util.TimerTask实现了10秒钟发送一次心跳消息的心跳系统。需要注意，在心跳消息的发送过程中，可能会出现网络故障等问题，需要进行错误处理。