90

我在需要处理各种类型的断开连接的移动应用程序中使用 SignalR 2.0 和 .NET 客户端。有时 SignalR 客户端会自动重新连接 - 有时必须通过再次调用直接重新连接HubConnection.Start()

由于 SignalR 有时会神奇地自动重新连接,我想知道我是否缺少功能或配置设置?

设置自动重新连接的客户端的最佳方法是什么?


我已经看到处理Closed()事件然后在 n 秒后连接的 javascript 示例。有什么推荐的方法吗?

我已经阅读了有关 SignalR 连接生命周期的文档和几篇文章,但我仍然不清楚如何处理客户端重新连接。

4

5 回答 5

73

我终于想通了。这是我从开始这个问题以来学到的东西:

背景:我们正在使用 Xamarin / Monotouch 和 .NET SignalR 2.0.3 客户端构建一个 iOS 应用程序。我们正在使用默认的 SignalR 协议 - 它似乎使用 SSE 而不是 Web 套接字。我还不确定是否可以将 Web 套接字与 Xamarin / Monotouch 一起使用。一切都使用 Azure 网站托管。

我们需要该应用程序快速重新连接到我们的 SignalR 服务器,但我们一直遇到连接没有自行重新连接的问题 - 或者重新连接需要 30 秒(由于底层协议超时)。

我们最终测试了三种场景:

场景 A - 首次加载应用程序时连接。这从第一天开始就完美无缺。即使通过 3G 移动连接,连接也可以在 0.25 秒内完成。(假设收音机已经打开)

场景 B - 在应用程序空闲/关闭 30 秒后重新连接到 SignalR 服务器。在这种情况下,SignalR 客户端最终将自行重新连接到服务器而无需任何特殊工作 - 但它似乎在尝试重新连接之前等待正好 30 秒。(对于我们的应用来说太慢了)

在这 30 秒的等待期间,我们尝试调用 HubConnection.Start(),但没有任何效果。调用 HubConnection.Stop() 也需要 30 秒。我在 SignalR 网站上发现了一个似乎已解决的相关错误,但我们在 v2.0.3 中仍然遇到同样的问题。

方案 C - 在应用程序空闲/关闭 120 秒或更长时间后重新连接到 SignalR 服务器。在这种情况下,SignalR 传输协议已经超时,因此客户端永远不会自动重新连接。这解释了为什么客户端有时但并不总是自行重新连接。好消息是,调用 HubConnection.Start() 几乎可以像场景 A 一样立即工作。

所以我花了一段时间才意识到重新连接的条件是不同的,这取决于应用程序是否关闭了 30 秒和 120 多秒。尽管 SignalR 跟踪日志说明了底层协议的情况,但我不相信有一种方法可以处理代码中的传输级别事件。(在场景 B 中,Closed() 事件在 30 秒后触发,在场景 C 中立即触发;在这些重新连接等待期间,State 属性显示“已连接”;没有其他相关事件或方法)

解决方案: 解决方案很明显。我们不是在等待 SignalR 发挥其重新连接的魔力。相反,当应用程序被激活或手机的网络连接恢复时,我们只是清理事件并取消引用 HubConnection (无法释放它,因为它需要 30 秒,希望垃圾收集会处理它) 并创建一个新实例。现在一切都很好。出于某种原因,我认为我们应该重用持久连接并重新连接,而不是仅仅创建一个新实例。

于 2014-05-13T23:59:05.623 回答
47

在断开连接的事件上设置一个计时器以自动尝试重新连接是我知道的唯一方法。

在javascript中它是这样完成的:

$.connection.hub.disconnected(function() {
   setTimeout(function() {
       $.connection.hub.start();
   }, 5000); // Restart connection after 5 seconds.
});

这是文档中推荐的方法:

http://www.asp.net/signalr/overview/signalr-20/hubs-api/handling-connection-lifetime-events#clientdisconnect

于 2014-05-01T11:56:13.423 回答
17

由于OP要求.NET客户端(下面的winform实现),

private async Task<bool> ConnectToSignalRServer()
{
    bool connected = false;
    try
    {
        Connection = new HubConnection("server url");
        Hub = Connection.CreateHubProxy("MyHub");
        await Connection.Start();

        //See @Oran Dennison's comment on @KingOfHypocrites's answer
        if (Connection.State == ConnectionState.Connected)
        {
            connected = true;
            Connection.Closed += Connection_Closed;
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine($"Error: {ex.Message}");
    }
    return connected;
}

private async void Connection_Closed()
{   // A global variable being set in "Form_closing" event 
    // of Form, check if form not closed explicitly to prevent a possible deadlock.
    if(!IsFormClosed) 
    {
        // specify a retry duration
        TimeSpan retryDuration = TimeSpan.FromSeconds(30);
        DateTime retryTill = DateTime.UtcNow.Add(retryDuration);

        while (DateTime.UtcNow < retryTill)
        {
            bool connected = await ConnectToSignalRServer();
            if (connected)
                return;
        }
        Console.WriteLine("Connection closed")
    }
}
于 2017-07-24T13:58:39.387 回答
1

我为ibubi答案添加了一些更新。可能有人需要它。我发现在某些情况下,信号器在重新连接停止后不会引发“关闭”事件。我使用事件“StateChanged”解决了它。连接 SignalR 服务器的方法:

private async Task<bool> ConnectToSignalRServer()
        {
            bool connected = false;
            try
            {
                var connection = new HubConnection(ConnectionUrl);
                var proxy = connection.CreateHubProxy("CurrentData");
                await connection.Start();

                if (connection.State == ConnectionState.Connected)
                {
                    await proxy.Invoke("ConnectStation");

                    connection.Error += (ex) =>
                    {
                        Console.WriteLine("Connection error: " + ex.ToString());
                    };
                    connection.Closed += () =>
                    {
                        Console.WriteLine("Connection closed");
                    };
                    connection.StateChanged += Connection_StateChanged;
                    Console.WriteLine("Server for Current is started.");
                    connected = true;
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine($"Error: {ex.Message}");
            }
            return connected;
        }

重连方法:

private async void Connection_StateChanged(StateChange obj)
        {
            if (obj.NewState == ConnectionState.Disconnected)
            {
                await RestartConnection();
            }
        }

无休止尝试连接服务器的方法(我也使用这种方法创建第一个连接):

public async Task RestartConnection()
        {
            while (!ApplicationClosed)
            {
                bool connected = await ConnectToSignalRServer();
                if (connected)
                    return;
            }
        }
于 2020-08-21T05:55:57.083 回答
-2

You might try to invoke server method from your android before reconnect state start to prevent magic reconnect problem.

SignalR Hub C#

 public class MyHub : Hub
    {
        public void Ping()
        {
            //ping for android long polling
        }
 }

In Android

private final int PING_INTERVAL = 10 * 1000;

private boolean isConnected = false;
private HubConnection connection;
private ClientTransport transport;
private HubProxy hubProxy;

private Handler handler = new Handler();
private Runnable ping = new Runnable() {
    @Override
    public void run() {
        if (isConnected) {
            hubProxy.invoke("ping");
            handler.postDelayed(ping, PING_INTERVAL);
        }
    }
};

@Override
public void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.main);
    System.setProperty("http.keepAlive", "false");

    .....
    .....

    connection.connected(new Runnable() {
        @Override
        public void run() {
            System.out.println("Connected");
            handler.postDelayed(ping, PING_INTERVAL);
    });
}
于 2015-01-24T23:18:09.920 回答