从SQL数据库查询实时数据突发延迟问题

Question

我们正在测试一个应用程序，该应用程序应该以 1 秒为基础为多个用户显示实时数据。 服务器应用程序每秒将 128 行的新数据插入 SQL 数据库，然后所有用户必须将其与另一个旧的参考 128 行一起查询。

我们测试了查询时间，没有超过30毫秒； 此外，调用查询的接口函数处理数据的时间不会超过 50 毫秒。

我们开发了一个测试应用程序，为每个用户创建一个线程和一个 SQL 连接。 用户每 1 秒发出 7 个查询。 一切开始都很好，没有用户花费 7 个数据系列（查询）超过 300 毫秒。 然而，10分钟后，延迟超过1秒，并且持续增加。 我们不知道问题是否出在 SQL Server 2008 同时处理多个请求上，以及如何克服这样的问题。

这是我们的测试客户端，如果有帮助的话。 请注意，客户端和服务器是在同一台 8 CPU 和 8 GB RAM 的机器上制作的。 现在我们质疑数据库是否不是我们的最佳解决方案。

   class Program
{
    static void Main(string[] args)
    {   
        Console.WriteLine("Enter  Number of threads");
        int threads = int.Parse(Console.ReadLine());
        ArrayList l = new ArrayList();
        for (int i = 0; i < threads; i++)
        {
            User u = new User();
            Thread th = new Thread(u.Start);
            th.IsBackground = true;
            th.Start();
            l.Add(u);
            l.Add(th);
        }
        Thread.CurrentThread.Join();
        GC.KeepAlive(l);
    }
}
class User
{
    BusinessServer client ; // the data base interface dll
    public static int usernumber =0 ;

    static TextWriter log;
    public User()
    {
        client = new BusinessServer(); // creates an SQL connection in the constructor
        Interlocked.Increment(ref usernumber);
    }

    public static void SetLog(int processnumber)
    {
        log = TextWriter.Synchronized(new StreamWriter(processnumber + ".txt"));
    }
    public void Start()
    {
        Dictionary<short, symbolStruct> companiesdic = client.getSymbolData();
        short [] symbolids=companiesdic.Keys.ToArray();
        Stopwatch sw = new Stopwatch();
        while (true)
        {

            int current;
            sw.Start();
            current = client.getMaxCurrentBarTime();
            for (int j = 0; j < 7; j++)
            {   
                client.getValueAverage(dataType.mv, symbolids,
                    action.Add, actionType.Buy,
                    calculationType.type1,
                    weightType.freeFloatingShares, null, 10, current, functionBehaviour.difference); // this is the function that has the queries

            }
            sw.Stop();
            Console.WriteLine(DateTime.Now.ToString("hh:mm:ss") + "\t" + sw.ElapsedMilliseconds);
            if (sw.ElapsedMilliseconds > 1000)
            {
                Console.WriteLine("warning");
            }
            sw.Reset();

            long diff = 0;//(1000 - sw.ElapsedMilliseconds);
            long sleep = diff > 0 ? diff : 1000;
            Thread.Sleep((int)sleep);
        }
    }



}

Answer 1

警告：这个答案基于 MSSQL 2000 的知识 - 不确定它是否仍然正确。

如果执行大量插入，索引最终会过时，服务器将自动切换到表扫描，直到重建索引。 其中一些是自动完成的，但如果这种性能至关重要，您可能需要定期强制重新索引。

Answer 2

我会怀疑查询本身。 虽然在空数据库上可能不会花费太多时间，但随着数据量的增长，可能需要越来越多的时间，具体取决于查找的完成方式。 您是否检查过查询计划以确保它是通过索引查找而不是表扫描来查找数据？ 如果没有，也许引入一些索引会有所帮助。