dfd

admin-client-temperature.iml

@@ -17,6 +17,7 @@
         <setting name="validation-enabled" value="true" />
         <setting name="provider-name" value="Hibernate" />
         <datasource-mapping>
+          <factory-entry name="admin-client-temperature" />
           <factory-entry name="entityManagerFactory" />
         </datasource-mapping>
         <naming-strategy-map />

pom.xml

@@ -11,7 +11,7 @@
     <groupId>com.rehome</groupId>
     <artifactId>admin-client-temperature</artifactId>
     <version>1.0.0</version>
-    <packaging>war</packaging>
+    <packaging>jar</packaging>
     <name>admin-client-temperature</name>
     <description>admin-client-temperature</description>
     <properties>

src/main/java/com/rehome/mqttclienttemperature/MqttRSAClient.java

@@ -107,7 +107,7 @@ public class MqttRSAClient {
                     System.out.println("topic:"+s);
                     System.out.println("Qos:"+mqttMessage.getQos());
                     System.out.println("message RSA:"+strData);
-                    temperatureService.saveTemperature(strData,s);
+                    //temperatureService.saveTemperature(strData,s);
                 }
 
                 @Override

src/main/java/com/rehome/mqttclienttemperature/controller/JdbcDemoController.java

@@ -69,12 +69,12 @@ public class JdbcDemoController {
     static {
         //配置数据源
         //mysql
-        ds.setId("1");
-        ds.setName("mysql");
-        ds.setUrl("jdbc:mysql://192.168.3.9:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true");
-        ds.setUsername("root");
-        ds.setPassword("Skyinno251,");
-        ds.setDriver("com.mysql.cj.jdbc.Driver");
+//        ds.setId("1");
+//        ds.setName("mysql");
+//        ds.setUrl("jdbc:mysql://192.168.3.9:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true");
+//        ds.setUsername("root");
+//        ds.setPassword("Skyinno251,");
+//        ds.setDriver("com.mysql.cj.jdbc.Driver");
 
 //        oracle
 //        ds.setId("2");
@@ -85,12 +85,12 @@ public class JdbcDemoController {
 //        ds.setDriver("oracle.jdbc.driver.OracleDriver");
 
         //postgres
-//        ds.setId("3");
-//        ds.setName("postgres");
-//        ds.setUrl("jdbc:postgresql://192.168.3.24:5432/postgres");
-//        ds.setUsername("postgres");
-//        ds.setPassword("452131wW");
-//        ds.setDriver("org.postgresql.Driver");
+        ds.setId("3");
+        ds.setName("postgres");
+        ds.setUrl("jdbc:postgresql://192.168.3.24:5432/postgres");
+        ds.setUsername("postgres");
+        ds.setPassword("452131wW");
+        ds.setDriver("org.postgresql.Driver");
     }
 
     /**
@@ -98,7 +98,7 @@ public class JdbcDemoController {
      *
      * @return
      */
-    //@RequestMapping("/api/list")
+    @RequestMapping("/api/list")
     public ResponseDto queryList() {
         // 自定义一个线程池,内部包含8个线程
         ExecutorService customPool = Executors.newFixedThreadPool(2);
@@ -107,7 +107,7 @@ public class JdbcDemoController {
         CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
             String sql = "select * from temperature where id = ?";
             List<Object> jdbcParamValues = new ArrayList<>();
-            for (int i = 0; i < 2390470; i++) {
+            for (int i = 0; i < 2500470; i++) {
                 jdbcParamValues.add(i + 1);
                 Gson gson = new Gson();
                 ResponseDto responseDto = JdbcUtil.executeSql(ds, sql, jdbcParamValues);

src/main/resources/application.yml

@@ -22,7 +22,7 @@ spring:
     #url: jdbc:mysql://192.168.3.24:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
     #url: jdbc:mysql://192.168.1.24:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
     #url: jdbc:mysql://47.242.184.139:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
-    url: jdbc:postgresql://192.168.3.26:5432/appserver
+    url: jdbc:postgresql://192.168.3.26:5432/postgres
     driverClassName: org.postgresql.Driver #com.mysql.cj.jdbc.Driver com.mysql.jdbc.Driver
     username: postgres
     password: 452131wW