java框架在物联网领域的机遇与挑战

import com.google.cloud.pubsub.v1.Publisher;
import com.google.iot.v1.StateProto.State;
import com.google.pubsub.v1.ProjectTopicName;
import com.google.pubsub.v1.PubsubMessage;
import com.google.protobuf.util.JsonFormat;

// 模拟从物联网设备获取传感器数据
class SensorData {
    double temperature;
    int humidity;
}

public class IotDevice {

    public static void main(String[] args) {
        // 创建传感器数据
        SensorData data = new SensorData();
        data.temperature = 25.5;
        data.humidity = 60;

        // 将传感器数据转换为 JSON 字符串
        String json = JsonFormat.printer().omittingInsignificantWhitespace().print(data);

        // 创建 Pub/Sub 主题名称
        ProjectTopicName topicName = ProjectTopicName.of("project-id", "iot-topic");

        // 创建 Pub/Sub 发布者
        Publisher publisher = null;
        try {
            publisher = Publisher.newBuilder(topicName).build();
        } catch (Exception e) {
            e.printStackTrace();
            return;
        }

        // 创建 Pub/Sub 消息
        PubsubMessage message = PubsubMessage.newBuilder()
                .setData(ByteString.copyFromUtf8(json))
                .build();

        // 发布 Pub/Sub 消息
        try {
            publisher.publish(message);
        } catch (Exception e) {
            e.printStackTrace();
            return;
        }

        // 通知设备已成功发送消息
        System.out.println("Message published successfully: " + json);
    }
}