28

我编写了一个简单的 C# 函数，通过以下 API 调用从 MtGox 检索交易历史：

https://data.mtgox.com/api/1/BTCUSD/trades?since=<trade_id>

记录在这里：https ://en.bitcoin.it/wiki/MtGox/API/HTTP/v1#Multi_currency_trades

这是功能：

string GetTradesOnline(Int64 tid)
{
    Thread.Sleep(30000);

    // communicate
    string url = "https://data.mtgox.com/api/1/BTCUSD/trades?since=" + tid.ToString();
    HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
    HttpWebResponse response = (HttpWebResponse)request.GetResponse();
    StreamReader reader = new StreamReader(response.GetResponseStream());

    string json = reader.ReadToEnd();
    reader.Close();
    reader.Dispose();
    response.Close();

    return json;
}

我从 tid=0 (trade id) 开始获取数据（从一开始）。对于每个请求，我都会收到包含 1000 个交易详细信息的响应。我总是从上一个响应中为下一个请求发送交易 ID。它适用于恰好 4 个请求和响应。但在那之后，以下行抛出“System.Net.WebException”，表示“操作已超时”：

HttpWebResponse response = (HttpWebResponse)request.GetResponse();

以下是事实：

  • 捕获异常并重新绑定不断导致相同的异常
  • 默认的 HttpWebRequest .Timeout 和 .ReadWriteTimeout 已经足够高（超过一分钟）
  • 将 HttpWebRequest.KeepAlive 更改为 false 也没有解决任何问题
  • 即使功能失败，它似乎也总是在浏览器中工作
  • 从https://www.google.com检索响应没有问题
  • 异常之前的成功响应数量每天都在变化（但浏览器始终有效）
  • 从上次失败的交易 id 开始立即导致异常
  • 从主线程调用此函数仍然导致异常
  • 在另一台机器上运行它不起作用
  • 从不同的 IP 运行它不起作用
  • 在请求之间增加 Thread.Sleep 无济于事

有什么想法可能是错的吗？

4

5 回答 5

40

我有同样的问题。对我来说，修复就像将 HttpWebResponse 代码包装在 using 块中一样简单。

using (HttpWebResponse response = (HttpWebResponse) request.GetResponse())
{
    // Do your processings here....
}

详细信息：当向同一主机发出多个请求并且WebResponse未正确处理时，通常会发生此问题。这就是using块将正确处理WebResponse对象并因此解决问题的地方。

于 2016-07-02T11:08:36.310 回答
20

有两种超时。客户端超时和服务器超时。您是否尝试过这样做：

request.Timeout = Timeout.Infinite;
request.KeepAlive = true;

尝试这样的事情......

于 2013-05-24T22:35:19.240 回答
10

我只是在通过 ssl 调用 LINUX 服务器上的 REST 服务时遇到了类似的麻烦。在尝试了许多不同的配置方案后，我发现我必须在 http 头中发送一个 UserAgent。

这是我调用 REST API 的最终方法。

        private static string RunWebRequest(string url, string json)
    {
        HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);

        // Header
        request.ContentType = "application/json";
        request.Method = "POST";
        request.AllowAutoRedirect = false;
        request.KeepAlive = false;
        request.Timeout = 30000;
        request.ReadWriteTimeout = 30000;
        request.UserAgent = "test.net";
        request.Accept = "application/json";
        request.ProtocolVersion = HttpVersion.Version11;
        request.Headers.Add("Accept-Language","de_DE");
        ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls;
        ServicePointManager.ServerCertificateValidationCallback = delegate { return true; };
        byte[] bytes = Encoding.UTF8.GetBytes(json);
        request.ContentLength = bytes.Length;
        using (var writer = request.GetRequestStream())
        {
            writer.Write(bytes, 0, bytes.Length);
            writer.Flush();
            writer.Close();
        }

        var httpResponse = (HttpWebResponse)request.GetResponse();
        using (var streamReader = new StreamReader(httpResponse.GetResponseStream()))
        {
            var jsonReturn = streamReader.ReadToEnd();
            return jsonReturn;
        }
    }
于 2014-02-04T14:27:15.493 回答
2

这不是一个解决方案，而只是一个替代方案：这些天我几乎只使用 WebClient 而不是 HttpWebRequest。特别是用于 POST 和 PUT 的 WebClient.UploadString 和 WebClient.DownloadString。这些只是获取和返回字符串。这样我就不必处理流对象，除非我得到一个 WebException。如有必要，我还可以使用 WebClient.Headers["Content-type"] 设置内容类型。using 语句还通过为我调用 Dispose 使生活更轻松。

很少出于性能考虑，我将 System.Net.ServicePointManager.DefaultConnectionLimit 设置为高，而是将 HttpClient 与它的异步方法一起用于同时调用。

这就是我现在要做的

string GetTradesOnline(Int64 tid)
{
    using (var wc = new WebClient())
    {
        return wc.DownloadString("https://data.mtgox.com/api/1/BTCUSD/trades?since=" + tid.ToString());
    }
}

还有 2 个 POST 示例

// POST
string SubmitData(string data)
{
    string response;
    using (var wc = new WebClient())
    {
        wc.Headers["Content-type"] = "text/plain";
        response = wc.UploadString("https://data.mtgox.com/api/1/BTCUSD/trades", "POST", data);
    }

    return response;
}

// POST: easily url encode multiple parameters
string SubmitForm(string project, string subject, string sender, string message)
{
    // url encoded query
    NameValueCollection query = HttpUtility.ParseQueryString(string.Empty);
    query.Add("project", project);
    query.Add("subject", subject);

    // url encoded data
    NameValueCollection data = HttpUtility.ParseQueryString(string.Empty);
    data.Add("sender", sender);
    data.Add("message", message);

    string response;
    using (var wc = new WebClient())
    {
        wc.Headers[HttpRequestHeader.ContentType] = "application/x-www-form-urlencoded";
        response = wc.UploadString( "https://data.mtgox.com/api/1/BTCUSD/trades?"+query.ToString()
                                  , WebRequestMethods.Http.Post
                                  , data.ToString()
                                  );
    }

    return response;
}

错误处理

try
{
    Console.WriteLine(GetTradesOnline(0));

    string data = File.ReadAllText(@"C:\mydata.txt");
    Console.WriteLine(SubmitData(data));

    Console.WriteLine(SubmitForm("The Big Project", "Progress", "John Smith", "almost done"));
}
catch (WebException ex)
{
    string msg;
    if (ex.Response != null)
    {
        // read response HTTP body
        using (var sr = new StreamReader(ex.Response.GetResponseStream())) msg = sr.ReadToEnd();
    }
    else
    {
        msg = ex.Message;
    }

    Log(msg);
}
于 2018-08-04T07:50:34.003 回答
1

对于它的价值，我每次使用它时都会遇到同样的超时问题，即使调用通过了我正在调用的服务器。我的问题是我将 Expect 设置为 application/json，而这不是服务器返回的内容。

于 2017-11-16T08:38:34.767 回答