3

因此，我尝试将 Signalr 与 Twitter 流 API 一起使用，特别是，为此我使用了 Tweetinvi C# API ( http://tweetinvi.codeplex.com/ )。

该应用程序的目的是将推文实时流式传输到使用某些关键字过滤的页面。

TweetInvi 库很好用，我有一个命令行应用程序成功打印出带有某些关键字的推文。

我的使用基本大纲如下：

我有一个带有单个页面的 MVC Web 应用程序，带有一个文本输入和一个按钮（用于更新过滤器），然后它调用 Signalr Hub 中的 Hub 方法，如果还没有一个流，则启动流并停止它第二个按钮点击。

所有这些都工作正常，除了信号器部分。

public class TweetHub : Hub
{
    private IStreamManager _streamManager;

    public void AddTweet(String tweet, double lat, double lon)
    {
        Clients.All.addTweet(tweet, lat, lon);
    }

    public void StartStream(String[] filters)
    {
        string accessToken = ConfigurationManager.AppSettings["AccessToken"];
        string accessTokenSecret = ConfigurationManager.AppSettings["AccessTokenSecret"];
        string consumerKey = ConfigurationManager.AppSettings["ConsumerKey"];
        string consumerSecret = ConfigurationManager.AppSettings["ConsumerSecret"];

        IToken token = new Token(accessToken, accessTokenSecret, consumerKey, consumerSecret);

        if (_streamManager != null && _streamManager.StreamIsOpen())
        {
            _streamManager.StopStream();
            _streamManager.StartStream(token, filters, tweet => AddTweet(tweet.Text, tweet.LocationCoordinates.Lattitude, tweet.LocationCoordinates.Longitude));
        }
        else if (_streamManager != null && !_streamManager.StreamIsOpen())
        {
            _streamManager.StartStream(token, filters, tweet => AddTweet(tweet.Text, tweet.LocationCoordinates.Lattitude, tweet.LocationCoordinates.Longitude));
        }
        else
        {
            _streamManager = new StreamManager();
            _streamManager.StartStream(token, filters, tweet => AddTweet(tweet.Text, tweet.LocationCoordinates.Lattitude, tweet.LocationCoordinates.Longitude));
        }
    }

    public void StopStream()
    {
        if (_streamManager != null && _streamManager.StreamIsOpen())
        {
            _streamManager.StopStream();
        }
    }
}

那是我的 Signalr Hub 的代码。正如我所说，使用 js 我可以很好地触发启动和停止流方法。

这是我的 StreamManager 类的代码：

public class StreamManager : IStreamManager
{
    private StreamClient _streamClient;
    private bool _streamOpen = false;

    public void StartStream(IToken token, String[] filters, Action<ITweet> action)
    {
        if (_streamClient == null)
            _streamClient = new StreamClient(token, filters, new FilteredStream());

        _streamClient.StartStream(action);
        _streamOpen = true;
    }

    public void StopStream()
    {
        if (_streamClient != null)
        {
            _streamClient.StopStream();
            _streamOpen = false;
        }
    }

    public bool StreamIsOpen()
    {
        return _streamOpen;
    }

    public void Dispose()
    {
        if (_streamOpen)
        {
            StopStream();
        }
        _streamClient.Dispose();
        _streamClient = null;
    }
}

我的 StreamClient 类的代码：

public class StreamClient : IStreamClient
{
    private IFilteredStream _filteredStream;
    private IToken _token;
    private bool _streamOpen = false;


    public StreamClient(IToken token, String[] filters, IFilteredStream filteredStream)
    {
        _token = token;
        _filteredStream = filteredStream;
        AddFilters(filters);
    }

    private void AddFilters(String[] filters)
    {
        for (int i = 0; i < filters.Length; ++i)
        {
            _filteredStream.AddTrack(filters[i]);
        }
    }

    public void StartStream(Action<ITweet> action)
    {
        _filteredStream.StartStream(_token, action);
        _streamOpen = true;

    }

    public void StartStream(Func<ITweet, bool> predicateFunc)
    {
        _filteredStream.StartStream(_token, predicateFunc);
        _streamOpen = true;
    }

    public void StopStream()
    {
        _filteredStream.StopStream();
        _streamOpen = false;
    }

    public void Dispose()
    {
        Dispose(true);
        GC.SuppressFinalize(this);
    }

    protected virtual void Dispose(bool disposing)
    {
        if (disposing)
        {
            // free managed resources
            if (_streamOpen)
            {
                _filteredStream.StopStream();
                _filteredStream = null;
                _token = null;
            }
        }
    }

上面的代码是直接调用 Tweetinvi 库的地方。

我的问题是，当我将 Hub 方法作为 Action 参数传递给 StreamManager 的 StartStream 方法时，AddTweet 方法永远不会被命中。

正如我所说，当使用命令提示符应用程序作为客户端并使用以下代码时，这一切都很好：

static void Main(string[] args)
{

    string accessToken = ConfigurationManager.AppSettings["AccessToken"];
    string accessTokenSecret = ConfigurationManager.AppSettings["AccessTokenSecret"];
    string consumerKey = ConfigurationManager.AppSettings["ConsumerKey"];
    string consumerSecret = ConfigurationManager.AppSettings["ConsumerSecret"];


    IToken token = new Token(accessToken, accessTokenSecret, consumerKey, consumerSecret);

    String[] filters = new string[2]
    {
            "test",
            "twitter"
    };

    StreamClient streamClient = new StreamClient(token, filters, new FilteredStream());
        streamClient.StartStream(tweet => TestMethod());
}

public static void TestMethod()
{
    Console.WriteLine("test");
}

这完美地工作并在收到这些关键字时打印出带有这些关键字的推文。

这让我相信这是我使用 Signalr 的方式的问题，signalr 方法永远不会受到打击，因为流肯定会被打开，我只是偷偷怀疑它与生命周期有关集线器和我使用它的方式。

我怀疑这是因为，虽然我的集线器中的 StartStream 方法被调用得很好，并更新了被点击的按钮，但当我认为再次点击调用 StopStream 时，StopStream 方法被命中，但我的“_streamManager”成员变量为空，它不应该是如果集线器在其生命周期内保持状态，我猜它不会。

无论是那个还是它都被处理掉了，然后流就不会再存在了。

我真的没有足够的 Signalr 经验来正确调试。

提前感谢您的帮助。

4

1 回答 1

1

集线器类的实例是瞬态的。这意味着每次调用集线器类中的方法或发生连接事件（例如 onConnected、onDisconnected）时，SignalR 都会创建集线器类的实例。当被调用的方法完成其工作时，该集线器实例将被释放。阅读：http ://www.asp.net/signalr/overview/signalr-20/hubs-api/hubs-api-guide-server#transience

因此，您不应尝试在集线器类中维护有关连接的状态信息。在您的情况下，这将是“_streamManager”。因此，我认为您应该将所有业务逻辑移至另一个类（不是从 Hub 派生的）。将它们封装在方法中并从您的 signalR 方法中调用它们。

如果您需要从服务器代码调用集线器中的方法，则应首先获取集线器上下文。在这里查看如何做到这一点：http ://www.asp.net/signalr/overview/signalr-20/hubs-api/hubs-api-guide-server#callfromoutsidehub

希望这可以帮助！

于 2014-01-15T12:52:49.340 回答