0

我能够让它运行而不会引发任何错误，但是在它到达“string responseData = new StreamReader(response.GetResponseStream()).ReadToEnd();”行之后 它只是挂起。我在下一行有一个断点，但仍然没有。我没有正确使用它吗？这是在 Windows 窗体应用程序中。我需要做什么才能解析出来？如何在保持流打开的同时获取数据？

我的目标是能够抓取推文并根据标准 TBD 对其进行排序。

var oAuthToken = "****";
        var oAuthTokenSecret = "****";
        var oAuthConsumerKey = "****";
        var oAuthConsumerSecret = "****";

        var oAuthVersion = "1.0";
        var oAuthSignatureMethod = "HMAC-SHA1";

        var oAuthNonce = Convert.ToBase64String(new ASCIIEncoding().GetBytes(DateTime.Now.Ticks.ToString()));
        var timeSpan = DateTime.UtcNow - new DateTime(1970, 1, 1, 0, 0, 0, 0, DateTimeKind.Utc);
        var oAuthTimeStamp = Convert.ToInt64(timeSpan.TotalSeconds).ToString();

        var resourceURL = "https://stream.twitter.com/1.1/statuses/filter.json";
        var locations = "-180,-90,180,90";

        var baseFormat = "locations={6}&oauth_consumer_key={0}&oauth_nonce={1}&oauth_signature_method={2}" +
                        "&oauth_timestamp={3}&oauth_token={4}&oauth_version={5}";
        var baseString = string.Format(baseFormat,
                        oAuthConsumerKey,
                        oAuthNonce,
                        oAuthSignatureMethod,
                        oAuthTimeStamp,
                        oAuthToken,
                        oAuthVersion,
                        Uri.EscapeDataString(locations)
                        );

        baseString = string.Concat("POST&", Uri.EscapeDataString(resourceURL), "&", Uri.EscapeDataString(baseString));

        var compositeKey = string.Concat(Uri.EscapeDataString(oAuthConsumerSecret),
                    "&", Uri.EscapeDataString(oAuthTokenSecret));

        string oAuthSignature;
        using (HMACSHA1 hasher = new HMACSHA1(ASCIIEncoding.ASCII.GetBytes(compositeKey)))
        {
            oAuthSignature = Convert.ToBase64String(
                hasher.ComputeHash(ASCIIEncoding.ASCII.GetBytes(baseString)));
        }

        // create the request header
        var headerFormat = "OAuth oauth_nonce=\"{0}\", oauth_signature_method=\"{1}\", " +
                           "oauth_timestamp=\"{2}\", oauth_consumer_key=\"{3}\", " +
                           "oauth_token=\"{4}\", oauth_signature=\"{5}\", " +
                           "oauth_version=\"{6}\"";

        var authHeader = string.Format(headerFormat,
                                Uri.EscapeDataString(oAuthNonce),
                                Uri.EscapeDataString(oAuthSignatureMethod),
                                Uri.EscapeDataString(oAuthTimeStamp),
                                Uri.EscapeDataString(oAuthConsumerKey),
                                Uri.EscapeDataString(oAuthToken),
                                Uri.EscapeDataString(oAuthSignature),
                                Uri.EscapeDataString(oAuthVersion)
                        );

        //make the request

        ServicePointManager.Expect100Continue = false;

        var postBody = "locations=" + Uri.EscapeDataString(locations);
        resourceURL += "?" + postBody;
        HttpWebRequest request = (HttpWebRequest)WebRequest.Create(resourceURL);
        request.Headers.Add("Authorization", authHeader);
        request.Method = "POST";
        request.ContentType = "application/x-www-form-urlencoded";
        request.PreAuthenticate = true;
        request.AllowWriteStreamBuffering = true;
        try
        {

            WebResponse response = request.GetResponse();
            string responseData = new StreamReader(response.GetResponseStream()).ReadToEnd();
        }
        catch (Exception exception)
        {
            throw (exception);
        }
4

1 回答 1

0

好吧，它是一个流式 API，因此它将无限流式传输。因此，如果您尝试读取流的末尾，它将永远阻塞，直到您耗尽内存或由于网络错误等而断开连接。

您需要在连接到流时处理数据。如果我是你，我只会使用客户端库（请参阅https://dev.twitter.com/docs/twitter-libraries）。

于 2013-09-01T21:24:57.547 回答