每次添加ListView數據庫中的新條目

Question

我需要我的學生項目幫助。 目前我正在使用JavaFX，MQTT和Mysql開發聊天應用程序。 我想做一個用戶列表（哪個用戶在線）

我試過這樣，一個新的用戶會通過一個特殊的主題發送消息，並且所有將「私下」訂閱這個主題它會收到消息（使用回調）並調用方法insertedMysql（）和updatingList（）。但不知何故，它不起作用。

這是我給的用戶名

public static void logging(String username) throws MqttException { 
    if(username != null && !username.isEmpty()) { 
     MysqlDatabase.insertingMysql(username); 
     window.close(); 
    } 
} 

這是添加的ListView

public static void addItem(String item) { 
    userList.getItems().add(item); 
} 

這是我有（我認爲）問題的一部分

public class MysqlDatabase { 

static String topic_body = "chat";; 
static String topic_ext = "userList"; 

static MqttCallback sqlCallback = new MqttCallback() { 
    @Override 
    public void connectionLost(Throwable thrwbl) { 
    } 

    @Override 
    public void messageArrived(String string, MqttMessage mm) throws Exception { 
     String username = new String(mm.getPayload()); 
     System.out.println(username); // Checking 

     updatingList(); 
    } 

    @Override 
    public void deliveryComplete(IMqttDeliveryToken imdt) { 
    } 
}; 

public static void sqlConnection() { 
    try { 
     Class.forName("com.mysql.jdbc.Driver"); 
    } catch (ClassNotFoundException e) { 
     e.printStackTrace(); 
    } 
    System.out.println("Connected"); 
} 

public static void mqttConnection(String username) throws MqttException { 
    MqttClient sqlClient = new MqttClient("tcp://iot.eclipse.org:1883", username); 
    sqlClient.connect(); 
    sqlClient.subscribe(topic_body + topic_ext + "#"); 
    sqlClient.setCallback(sqlCallback); 

    MqttMessage sqlMessage = new MqttMessage(); 
    sqlMessage.setPayload((username).getBytes()); 
    sqlClient.publish(topic_body + "userlist", sqlMessage); 
} 

public static void insertingMysql(String username) throws MqttException { 
    sqlConnection(); 
    String host = "jdbc:mysql://localhost/test"; 
    String user = "root"; 
    String password = ""; 
    try { 
     Connection connect = DriverManager.getConnection(host, user, password); 
     PreparedStatement statement = (PreparedStatement) connect.prepareStatement("INSERT INTO chat_test(username)VALUES(?)"); 
     statement.setString(1, username); 
     statement.executeUpdate(); 
     statement.close(); 
     System.out.println("Inserted to database!"); 
     mqttConnection(username); 
    } catch (SQLException e) { 
     // TODO Auto-generated catch block 
     System.out.println("Error"); 
     e.printStackTrace(); 
    } 
} 

public static void updatingList() { 
    sqlConnection(); 
    String host = "jdbc:mysql://localhost/test"; 
    String user = "root"; 
    String password = ""; 
    try { 
     Connection connect = DriverManager.getConnection(host, user, password); 
     PreparedStatement statement = (PreparedStatement) connect.prepareStatement("SELECT * FROM chat_test"); 
     ResultSet rs = statement.executeQuery(); 
     while(rs.next()) { 
      String uName = rs.getString("username"); 
      System.out.println("Username: " + uName); 
      JavaFXChat.addItem(uName); 
     } 
    } catch (SQLException e) { 
     // TODO Auto-generated catch block 
     System.out.println("Error"); 
     e.printStackTrace(); 
    } 
} 

}

Answer 1

這裏有兩個選項：

1. 數據庫觸發器。這是在更改表時更改數據庫服務器上運行的代碼。通常情況下，這些觸發器是SQL語句，但是此博客（https://patternbuffer.wordpress.com/2012/09/14/triggering-shell-script-from-mysql/）發佈接口來討論插件以支持運行腳本，該腳本可能會發送MQTT消息，通知新用戶聯機。

2. 使用MQTT消息和Last Will and Testament功能。用戶會發布一條消息給已知的主題，然後他們會聯機，他們會在離線時發佈類似的消息。如果連接由於問題而下降，則LWT可用於自動發佈離線消息。 （LWT的細節可以在這裏反正找到http://www.hivemq.com/blog/mqtt-essentials-part-9-last-will-and-testament