User932259438 posted
Hi,
I have problem. When updated in table from text "test1" to "test2" no update real time. I need again reload page.
My code:
private static readonly ConcurrentDictionary<string, User> Users = new ConcurrentDictionary<string, User>(StringComparer.InvariantCultureIgnoreCase);
#region Methods
/// <summary>
/// Provides the handler for SignalR OnConnected event
/// supports async threading
/// </summary>
/// <returns></returns>
public override Task OnConnected()
{
string profileId = "111"; //Context.QueryString["id"];
string connectionId = Context.ConnectionId;
var user = Users.GetOrAdd(profileId, _ => new User
{
ProfileId = profileId,
ConnectionIds = new HashSet<string>()
});
lock (user.ConnectionIds)
{
user.ConnectionIds.Add(connectionId);
Groups.Add(connectionId, user.ProfileId);
}
return base.OnConnected();
}
/// <summary>
/// Provides the handler for SignalR OnDisconnected event
/// supports async threading
/// </summary>
/// <returns></returns>
public override Task OnDisconnected(bool stopCalled)
{
string profileId = Context.QueryString["id"];
string connectionId = Context.ConnectionId;
User user;
Users.TryGetValue(profileId, out user);
if (user != null)
{
lock (user.ConnectionIds)
{
user.ConnectionIds.RemoveWhere(cid => cid.Equals(connectionId));
Groups.Remove(connectionId, user.ProfileId);
if (!user.ConnectionIds.Any())
{
User removedUser;
Users.TryRemove(profileId, out removedUser);
}
}
}
return base.OnDisconnected(stopCalled);
}
/// <summary>
/// Provides the handler for SignalR OnReconnected event
/// supports async threading
/// </summary>
/// <returns></returns>
public override Task OnReconnected()
{
return base.OnReconnected();
}
/// <summary>
/// Provides the facility to send individual user notification message
/// </summary>
/// <param name="profileId">
/// Set to the ProfileId of user who will receive the notification
/// </param>
/// <param name="message">
/// set to the notification message
/// </param>
public void Send(string profileId, string message)
{
//Clients.User(profileId).send(message);
}
/// <summary>
/// Provides the facility to send group notification message
/// </summary>
/// <param name="username">
/// set to the user groupd name who will receive the message
/// </param>
/// <param name="message">
/// set to the notification message
/// </param>
public void SendUserMessage(String username, String message)
{
Clients.Group(username).sendUserMessage(message);
}
/// <summary>
/// Provides the ability to get User from the dictionary for passed in profileId
/// </summary>
/// <param name="profileId">
/// set to the profileId of user that need to be fetched from the dictionary
/// </param>
/// <returns>
/// return User object if found otherwise returns null
/// </returns>
private User GetUser(string profileId)
{
User user;
Users.TryGetValue(profileId, out user);
return user;
}
/// <summary>
/// Provide theability to get currently connected user
/// </summary>
/// <returns>
/// profileId of user based on current connectionId
/// </returns>
public IEnumerable<string> GetConnectedUser()
{
return Users.Where(x =>
{
lock (x.Value.ConnectionIds)
{
return !x.Value.ConnectionIds.Contains(Context.ConnectionId, StringComparer.InvariantCultureIgnoreCase);
}
}).Select(x => x.Key);
}
#endregion
Int16 totalNewMessages = 0;
// Int16 totalNewCircles = 0;
// Int16 totalNewJobs = 0;
// Int16 totalNewNotification = 0;
[HubMethodName("sendNotifications")]
public int SendNotifications()
{
using (var connection = new SqlConnection(ConfigurationManager.ConnectionStrings["DefaultConnection"].ConnectionString))
{
string query = "SELECT NewMessageCount FROM [dbo].[Modeling_NewMessageNotificationCount]";
connection.Open();
using (SqlCommand command = new SqlCommand(query, connection))
{
try {
command.Notification = null;
DataTable dt = new DataTable();
SqlDependency dependency = new SqlDependency(command);
dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
if (connection.State == ConnectionState.Closed)
connection.Open();
var reader = command.ExecuteReader();
dt.Load(reader);
if (dt.Rows.Count > 0)
{
totalNewMessages =Int16.Parse(dt.Rows[0]["NewMessageCount"].ToString());
// totalNewCircles = Int16.Parse(dt.Rows[0]["NewCircleRequestCount"].ToString());
// totalNewJobs = Int16.Parse(dt.Rows[0]["NewJobNotificationsCount"].ToString());
// totalNewNotification = Int16.Parse(dt.Rows[0]["NewNotificationsCount"].ToString());
}
connection.Close();
}
catch(Exception ex)
{
throw;
}
}
}
IHubContext context = GlobalHost.ConnectionManager.GetHubContext<NotificationHub>();
return context.Clients.All.RecieveNotification(totalNewMessages);
}
private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
{
if (e.Type == SqlNotificationType.Change)
{
NotificationHub nHub = new NotificationHub();
nHub.SendNotifications();
}
}
}
<html xmlns="http://www.w3.org/1999/xhtml">
<head runat="server">
<title></title>
<script src="Scripts/jquery-1.10.2.min.js"></script>
<script src="Scripts/jquery.signalR-2.2.2.min.js"></script>
<script src="signalr/hubs"></script>
<script type="text/javascript">
$(function () {
// Declare a proxy to reference the hub.
var notifications = $.connection.notificationHub;
debugger;
// Create a function that the hub can call to broadcast messages.
notifications.client.recieveNotification = function (totalNewMessages) {
// Add the message to the page.
$('#spanNewMessages').text(totalNewMessages);
// $('#spanNewCircles').text(totalNewCircles);
// $('#spanNewJobNotifications').text(totalNewJobs);
// $('#spanNewNotifications').text(totalNewNotifications);
};
// Start the connection.
$.connection.hub.start().done(function () {
notifications.server.sendNotifications();
}).fail(function (e) {
alert(e);
});
$.connection.hub.start();
});
</script>
</head>
<body>
<form id="form1" runat="server">
<div>
<p>You have <span id="spanNewMessages">0</span> New Message Notification.</p>
<%-- <p>You have <span id="spanNewCircles">0</span> New Circles Notification.</p>
<p>You have <span id="spanNewJobNotifications">0</span> New Job Notification.</p>
<p>You have <span id="spanNewNotifications">0</span> New Notification.</p> --%>
</div>
</form>
