c# - StreamWriter 变量声明延迟

问题描述

在我的 C# 应用程序中，我有一个 while 循环，它从 Redis 消息队列中收集一个字符串并将其发送到侦听服务器。在每个 cicle 中，使用 HttpWebRequest Post 方法打开连接，并使用 StreamWriter 变量发送数据。问题是：在发送两个字符串后，应用程序冻结而没有返回任何错误，它可能一分钟内什么也没做，之后它再次正常工作并继续为另外几个字符串工作，冻结等等。调试显示在 StreamWriter 变量的声明期间发生延迟。

这是代码的核心：

// configure Redis
var redis = new RedisClient("127.0.0.1");

while (true)
{
    // read from Redis queue
    string json = redis.BRPop(30, "sensors_data");

    //...
    //URL DECLARATION
    //...

    try
    {
        var httpWebRequest = (HttpWebRequest)WebRequest.Create(url);
        httpWebRequest.ContentLength = json.Length;
        httpWebRequest.ContentType = "application/json";
        httpWebRequest.Method = "POST";
        httpWebRequest.Proxy = null;

            SendDataAsync(json, url);
        }
    }

    static async Task SendDataAsync(string json, string url)
    {
        try
            {
            var httpWebRequest = (HttpWebRequest)WebRequest.Create(url);
            httpWebRequest.ContentLength = json.Length;
            httpWebRequest.ContentType = "application/json";
            httpWebRequest.Method = "POST";
            httpWebRequest.Proxy = null;

            using (var streamWriter = new StreamWriter(httpWebRequest.GetRequestStream()))
            {
                try
                {
                    streamWriter.Write(json);
                    streamWriter.Flush();
                    streamWriter.Close();
                    Console.Write("Data Sent");
                }
                catch (Exception e)
                {

                    Console.WriteLine(e.Message);
                }
            }

        }
        catch (Exception err)
        {
            Console.Write(err.Message);
        }
        Console.WriteLine();
    }

所以代码实际上可以工作，只是在声明 StreamWriter 时存在一些奇怪的巨大延迟。有人有什么主意吗？我不知道如何处理这个问题。

编辑

        while (true)
        {
            i = 0;
            // read from Redis queue
            string json = redis.BRPop(30, "sensors_data");

            try
                {
                    var httpWebRequest = (HttpWebRequest)WebRequest.Create(url);
                    httpWebRequest.ContentLength = json.Length;
                    httpWebRequest.ContentType = "application/json";
                    httpWebRequest.Method = "POST";
                    httpWebRequest.Proxy = null;
                using (StreamWriter streamWriter = new StreamWriter(httpWebRequest.GetRequestStream()))
                    {
                        try
                        {
                            streamWriter.Write(json);
                            streamWriter.Flush();
                            streamWriter.Close();
                            var response = httpWebRequest.GetResponse();
                            StreamReader reader = new StreamReader(response.GetResponseStream());
                            string reply=reader.ReadToEnd();
                            Console.WriteLine(reply);
                        }
                        catch (Exception e)
                        {
                            Console.WriteLine(e.Message);
                        }
                    }
            }
                catch (Exception err)
                {
                    Console.Write(err.Message);
                }

                Console.WriteLine();
        }

标签： c#streamwriter

c# - StreamWriter 变量声明延迟

问题描述

解决方案

推荐阅读