更新

src/main/java/com/qniao/iot/IotMonitoringDataJob.java

@@ -427,7 +427,8 @@ public class IotMonitoringDataJob {
 
                             @Override
                             public String computeRoutingKey(DeviceMonitoringData data) {
-                                return null;
+
+                                return ApolloConfig.getStr(ConfigConstant.SINK_RABBITMQ_ROUTING_KEY);
                             }
 
                             @Override

src/main/java/com/qniao/iot/constant/ConfigConstant.java

@@ -39,4 +39,6 @@ public interface ConfigConstant {
     String SINK_RABBITMQ_PASSWORD = "sink.rabbitmq.password";
 
     String SINK_RABBITMQ_EXCHANGE = "sink.rabbitmq.exchange";
+
+    String SINK_RABBITMQ_ROUTING_KEY = "sink.rabbitmq.routingKey";
 }