MySQL的滞后（SELECT）

-3

我的问题是，有更新troo在GET水平，使服务器开始落后于70％的TPS损失，我不知道如何优化？MySQL的滞后（SELECT）

public static int getCoins(Player player) { 
    try { 
     PreparedStatement q = Main.sql.prepareStatement("SELECT Coins FROM Players WHERE Players_UUID = ?"); 
     q.setString(1, player.getUniqueId().toString()); 

     int coins= 0; 
     ResultSet rs = q.executeQuery(); 

     while(rs.next()){ 
      balance = rs.getInt("Coins"); 
     } 

     q.close(); 

     return coins; 

    } catch (SQLException e) { 
     e.printStackTrace(); 
    } 

    return 0; 
}

来源

2017-08-12 Mael

我不明白的问题。 – Shadow

您的Coins表中有多少个条目？ – chrki

你在Players_UUID列上有唯一索引吗？ –

你不需要每次都让硬币做一个SQL查询，只需要创建一个int或HashMap的字段中的数据，并检查每个X的时间，如果数据已更改。

，如果它已经改变了发送更新MySQL服务器和标记数据拯救像两个HashMap中/ int字段。

hashmap1 =数据库中的数据 hashmap2 =服务器数据

如果hashmap1和hashmap2相同不更新。

不要在像schedulerAsync或线程异步功能的更新。

这里一个类似的例子：

package test; 

import java.sql.DriverManager; 
import java.sql.SQLException; 
import java.util.Map.Entry; 
import java.util.UUID; 
import java.util.concurrent.ConcurrentHashMap; 

import org.bukkit.entity.Player; 
import org.bukkit.entity.Zombie; 
import org.bukkit.event.EventHandler; 
import org.bukkit.event.Listener; 
import org.bukkit.event.entity.EntityDeathEvent; 
import org.bukkit.plugin.java.JavaPlugin; 
import org.bukkit.scheduler.BukkitRunnable; 

import com.mysql.jdbc.Connection; 

public class Event extends JavaPlugin implements Listener { 

    // Mysql update data 
    public static ConcurrentHashMap<UUID, Integer> player_zombiekills = new ConcurrentHashMap<UUID, Integer>(); 

    // Mysql connection data 
    public static Connection connection; 
    private String host = "localhost"; 
    private String database = "DB"; 
    private String username = "user"; 
    private String password = "123"; 
    private int port = 3306; 

    //Kill zombie event 
    @EventHandler 
    public void zombieDeath(EntityDeathEvent eve) { 
     if (!(eve.getEntity() instanceof Zombie)) return; // Stop if death is not zombie 
     if (!(eve.getEntity().getKiller() instanceof Player)) return; // Stop if killer is not player 
     UUID uid = eve.getEntity().getKiller().getUniqueId(); // Save player uuid 
     if (player_zombiekills.contains(uid)) player_zombiekills.put(uid, 0); // Set kills 0 if not exist in hashmap 
     player_zombiekills.put(uid, player_zombiekills.get(uid) + 1); // plus 1 kills value 
    } 

    //On enable connection 
    public void onEnable() { 
     try { 
      if (connection != null && !connection.isClosed()) return; 
      Class.forName("com.mysql.jdbc.Driver"); 
      connection = (Connection) DriverManager.getConnection("jdbc:mysql://" + host + ":" + port + "/" + database, username, password); 
      if (!connection.isClosed()) System.out.println("[MySQL] " + "Connected to '" + database + "'"); 
     } catch (Exception e) { 
      System.err.println("[MySQL] " + e.getMessage()); 
     } 

     new BukkitRunnable() { 
      public void run() { 
       // for updates 
       for (Entry<UUID, Integer> ent : player_zombiekills.entrySet()) { 
        try { 
         // send update 
         connection.createStatement().executeUpdate("UPDATE `tablename` SET `zombiekills`=`zombiekills`+" + ent.getValue() + " WHERE `uuid`='" + ent.getKey().toString() + "'"); 
         // Sucess remove entry from hashmap to reset kills 
         player_zombiekills.remove(ent.getKey()); 
        } catch (SQLException e) { // If error 
         System.err.println("[MySQL] " + e.getMessage()); // Print error in console 
        } 
       } 
      } 
     }.runTaskTimerAsynchronously(this, 20, 20 * 60 * 10); // Run async loop every 10 minutes 
    } 
}

来源

2017-08-12 15:49:59 xXNurioXx

-1

我不知道该怎么办，因为如果你改变在BDD中的数据不会更改服务器上，所以如果我没有得到每1秒钟其不会工作让我有一个异步但是如何优化没有回报要获得金币...

来源

2017-08-13 14:31:04 Mael

添加球员列表像“pending_get_list”，并在下一个异步任务做mysql选择并保存数据在任何领域。如果修改添加到另一个列表，如“pending_sync_list”，并在下一个异步任务做mysql更新。 – xXNurioXx

可能举个例子吗？ – Mael

我已经发送了一个示例https://stackoverflow.com/a/45652166/7343009 – xXNurioXx

MySQL的滞后（SELECT）

回答

相关问题