User395405350 posted
Connect twice to SignalR hub. Disconnect and connect again. Connection ID is repeated on server side. Javascript client properly shows two distinct connection ids in console.
<body>
<div class="container">
<input type="text" id="status" />
<input type="text" id="message" />
</div>
<!--Script references. -->
<!--Reference the jQuery library. -->
<script src="Scripts/jquery-3.3.1.min.js"></script>
<!--Reference the SignalR library. -->
<script src="Scripts/jquery.signalR-2.2.2.min.js"></script>
<!--Reference the autogenerated SignalR hub script. -->
<!--<script src="/signalr/hubs"></script>-->
<!--Add script to update the page and send messages.-->
<script type="text/javascript">
$(function () {
var _initialize = function () {
// Declare a proxy to reference the hub.
var _hubConnection = $.hubConnection("http://localhost:57903/signalr");
var _hubProxy = _hubConnection.createHubProxy("chatHub");
//_hubProxy.on('updateData', _updateData);
_hubProxy.on('updateDisplayData', _updateData);
_hubConnection.start().done(function () {
//alert('success');
_connectedToSignalR();
}).fail(function (error) {
//alert(error);
_connectionFailure(error)
});
var _updateData = function (message) {
$('#message').val(message);
}
var _connectedToSignalR = function () {
$('#status').val('connected');
}
var _connectionFailure = function (error) {
$('#status').val('disconnected');
}
_hubConnection.disconnected(function () {
setTimeout(function () {
_hubConnection.start().done(function () {
//alert('success');
//alert(_hubProxy.connection.id);
console.log('Now connected, connection ID=' + _hubProxy.connection.id);
_connectedToSignalR();
}).fail(function (error) {
//alert(error);
console.log('Could not connect!');
_connectionFailure(error)
});
}, 2000);
});
}
_initialize();
});
</script>
</body>
public class ChatHub : Hub
{
private readonly ISubscriber _subscriber;
public ChatHub(ISubscriber subscriber)
{
_subscriber = subscriber;
}
public override async Task OnConnected()
{
try
{
//using (StreamWriter sw = File.AppendText(HostingEnvironment.MapPath(@"~/log.txt")))
//{
// sw.WriteLine("Getting connected" + Context.ConnectionId);
//}
_subscriber.Subscribe(Context.ConnectionId);
await base.OnConnected();
}
catch (Exception ex)
{
var message = ex.Message;
throw;
}
}
public override async Task OnReconnected()
{
//using (StreamWriter sw = File.AppendText(HostingEnvironment.MapPath(@"~/log.txt")))
//{
// sw.WriteLine("Getting reconnected" + Context.ConnectionId);
//}
_subscriber.Resubscribe(Context.ConnectionId);
await base.OnReconnected();
}
public override async Task OnDisconnected(bool stop)
{
//using (StreamWriter sw = File.AppendText(HostingEnvironment.MapPath(@"~/log.txt")))
//{
// sw.WriteLine("Getting disconnected " + Context.ConnectionId);
//}
_subscriber.Unsubscribe(Context.ConnectionId);
await base.OnDisconnected(stop);
}
}
