1、修改正式环境数据库配置

src/main/java/com/censoft/flink/StreamingJob.java

@@ -115,7 +115,7 @@ public class StreamingJob {
 
         //3、6 打印输出
         outputStreamOperator.print();
-        outputStreamOperator.writeAsText("D:/word" + sceneId + ".txt", FileSystem.WriteMode.OVERWRITE).setParallelism(1);
+        outputStreamOperator.writeAsText("F:/word" + sceneId + ".txt", FileSystem.WriteMode.OVERWRITE).setParallelism(1);
         //3、7 自动执行
         env.execute();
     }
@@ -141,8 +141,8 @@ public class StreamingJob {
             String rtsp = rtsp(channelId, startTime, endTime);
 
             //视频流转mp4
-            String filePath = "D:\\data\\MP4\\1.mp4";
-            RtspToMP4.StartRecord("E:\\ffmpeg\\bin\\ffmpeg.exe",rtsp,filePath);
+            String filePath = "F:\\data\\MP4\\1.mp4";
+            RtspToMP4.StartRecord("F:\\ffmpeg\\ffmpeg-2023-10-29-git-2532e832d2-full_build\\bin\\ffmpeg.exe",rtsp,filePath);
             return filePath;
         } catch (ClientException e) {
             e.printStackTrace();

src/main/java/com/censoft/flink/mqtt/MqttConsumer.java

@@ -32,7 +32,7 @@ public class MqttConsumer extends RichParallelSourceFunction<AlgorithmPushDto> {
     //包装连接的方法
     private void connect() throws MqttException {
         //配置连接参数
-        MqttConfig mqttConfigBean = new MqttConfig("", "", "tcp://172.16.21.3:1883", "DC" + (int) (Math.random() * 100000000), msgTopic);
+        MqttConfig mqttConfigBean = new MqttConfig("", "", "tcp://127.0.0.1:1883", "DC" + (int) (Math.random() * 100000000), msgTopic);
         //连接mqtt服务器
         client = new MqttClient(mqttConfigBean.getHostUrl(), mqttConfigBean.getClientId(), new MemoryPersistence());
         MqttConnectOptions options = new MqttConnectOptions();

src/main/resources/mybatis.xml

@@ -9,9 +9,9 @@
             <!--            下面是配置一下数据源，其实后面我们就不这样配置了，都在.yml文件中配置-->
             <dataSource type="POOLED">
                 <property name="driver" value="com.mysql.cj.jdbc.Driver"/>
-                <property name="url" value="jdbc:mysql://172.16.20.60:3306/aisf?useUnicode=true&amp;characterEncoding=utf8&amp;useSSL=false&amp;serverTimezone=Hongkong&amp;allowMultiQueries=true"/>
+                <property name="url" value="jdbc:mysql://127.0.0.1:3306/ry-vue?useUnicode=true&amp;characterEncoding=utf8&amp;useSSL=false&amp;serverTimezone=Hongkong&amp;allowMultiQueries=true"/>
                 <property name="username" value="root"/>
-                <property name="password" value="mysql"/>
+                <property name="password" value="123456"/>
             </dataSource>
         </environment>
     </environments>