c# - 使用 C# 异步发送和检索 MySQL 数据

Question

我正在尝试用 C# 创建某种机器人，它可以加入网络浏览器游戏并收集数据并踢出被禁止的人。我将我的数据发送到 MySQL 数据库，以便人们可以在网站上查找他们的数据。

我已尝试尽可能地简化我的代码，以更好地解释发生了什么。

我有一个事件处理程序，当有人在游戏中发生某些事情时会调用它，所以我相信它可以在同一时间被调用。

//EventHandler
public static void OnMessage(object sender, InOutPlayerc.Message m)
{
    int id = m.getInt(0);

    switch (m.Type)
    {
        //If a player logged in (m = [id, name])
        case "login":
            Player p = loadPlayerSQL(m.getString(1));
            if(p.Status == "BANNED") {
                kickPlayer(p);
            }
            else {
                //Store the player local, this way 
                savePlayerLocal(id, p);
            }
            return;

        //If a player said something (m = [id, chatmessage])
        case "talk":
            addTimesTalked(loadPlayerLocal(id));
            return;

        //If a player logs out (m = [id])
        case "logout":
            savePlayerSQL(loadPlayerLocal(id));
            return;
    }
}

因为 InOutPlayerc.Message m 只包含不同 InOutPlayerc.Message.Type 的 ID，所以我必须将播放器存储在本地。所以我可以通过提供 id 来取回 Player 对象。

public static void savePlayerLocal(int id, Player p){...};
public static Player loadPlayerLocal(int id){...};

这是我的其余功能:

public static Player loadPlayerSQL(string username)
{
    try
    {
        int timessaid;
        string status;
        using (MySqlCommand cmd = DB.CreateCommand())
        {
            cmd.CommandText = "SELECT * FROM Players WHERE Username = @Username";
            cmd.Parameters.AddWithValue("@Username", username);
            using (MySqlDataReader reader = cmd.ExecuteReader())
            {
                reader.Read();
                timessaid = Convert.ToInt32(reader["Chat"]);
                status = reader["Status"].ToString();
            }
        }
        return new Player(username, status, timessaid);
    }
    catch (Exception e)
    {
        return new Player(username, "DEFAULT", 0);
    }
}

public static void addTimesTalked(Player p)
{
    try
    {
        using (MySqlCommand cmd = DB.CreateCommand())
        {
            p.Chat = p.Chat + 1;
            cmd.CommandText = "UPDATE Players SET Chat = @Chat WHERE Username = @Username";
            cmd.Parameters.AddWithValue("@Username", p.Username);
            cmd.Parameters.AddWithValue("@Chat", p.Chat);
            cmd.ExecuteNonQuery();
        }
    }
    catch (Exception e)
    {
    }
}

public static void savePlayerSQL(Player p)
{
    try
    {
        using (MySqlCommand cmd = DB.CreateCommand())
        {
            cmd.CommandText = "UPDATE Players SET Status = @Status, Chat = @Chat WHERE Username = @Username";
            cmd.Parameters.AddWithValue("@Username", p.Username);
            cmd.Parameters.AddWithValue("@Status", p.Status);
            cmd.Parameters.AddWithValue("@Chat", p.Chat);
            cmd.ExecuteNonQuery();
        }
    }
    catch (Exception e)
    {
    }
}

现在这是我的问题:- 我在 'if(p.Status == "BANNED") {' 处收到 System.NullReferenceException。这段代码是不是没有等到Player对象在之前函数中用MySQL数据创建出来就立即调用了？- 可以同时调用函数，同时创建MySQL命令。- 我想要处理所有 MySQL 查询。不应跳过任何一个。

所以我在考虑异步的东西或在处理新的 MySQL 查询之前等待的锁？

我刚开始学习 C#，我发现这部分有点难解决。有人可以帮我解决这些问题吗？或者甚至提示我应该寻找什么？

提前致谢!

Answer 1

如果 id 和 username 不一样，那就是你的问题了。您在 loadPlayerSQL(string username) 中的 SQL 将找不到您的用户，因为您传递的是 id 而不是用户名。