Shulou(Shulou.com)06/03 Report--

Today, I will talk to you about what is SignalR Self Host+MVC and other multi-end message push services. Many people may not know much about it. In order to make you understand better, the editor has summarized the following contents for you. I hope you can gain something according to this article.

I. Overview

Due to the needs of the project, recently there is a module function in the company's project, which needs to be immediately notified of approval. The original design scheme is to use ajax to conduct a regular polling query on the server, which is fine at the beginning when the amount of data and usage is small, but later, with the increase in usage and the complexity of various services in the system, the pressure on the server is increasing, so I want to use message push to replace the ajax polling query. When there is an approval submission, call the push method to push the message to the next approver. This reduces the pressure on the server.

Signal is a html websocket framework supported by Microsoft that runs on the. Net platform. The main purpose of it is to enable the server to actively push the message to the client page, so that the client does not have to resend the request or use polling technology to get the message. And the compatibility of SignalR is also very strong, so I won't say much here. Now that you have chosen SignalR, let's get started!

My idea is to make SignalR into a self-hosted service, which is separated from our bstroke project. The advantage is that: 1. The push service does not depend on iis, even if iis is dead, our push service can still run normally; 2. We can call this push service on multiple platforms, and multiple projects can be used at the same time.

Create a server

No more nonsense, this is my first time to write a blog, after introducing the business scenarios and ideas, let's start to code.

1. Create a solution called "SignalRProject" with VS

2. Create a new console named Server under the SignalRProject solution

3. In the package manager console, enter the following command

Install-Package Microsoft.AspNet.SignalR.SelfHost

4. Enter the following command:

Install-Package Microsoft.Owin.Cors

5. Add the UserInfo class to the Server console as follows

Using System; namespace Server {public class UserInfo {public string ConnectionId {get; set;} public string UserName {get; set;} public DateTime LastLoginTime {get; set;}

6. Add the ChatHub class to the Server console as follows

Using Microsoft.AspNet.SignalR;using Microsoft.AspNet.SignalR.Hubs;using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;namespace Server {[HubName ("IMHub")] public class ChatHub: Hub {/ / static attribute public static List OnlineUsers = new List () / / online user list / login connection / user Id / user name public void Register (string userName) {var connnectId = Context.ConnectionId; if (OnlineUsers.Count (x = > x.ConnectionId = = connnectId) = = 0) {if (x = > x.UserName = = userName) {var items = OnlineUsers.Where (x = > x.UserName = = userName). ToList () Foreach (var item in items) {Clients.AllExcept (connnectId) .onUserDisconnected (item.ConnectionId, item.UserName);} OnlineUsers.RemoveAll (x = > x.UserName = = userName);} / / add online personnel OnlineUsers.Add (new UserInfo {ConnectionId = connnectId, UserName = userName, LastLoginTime = DateTime.Now}) } / / all clients synchronize online users Clients.All.onConnected (connnectId, userName, OnlineUsers); send private chat / recipient users connect ID / content public void SendPrivateMessage (string toUserName, string message) {var fromConnectionId = Context.ConnectionId; var toUser = OnlineUsers.FirstOrDefault (x = > x.UserName = = toUserName); var fromUser = OnlineUsers.FirstOrDefault (x = > x.ConnectionId = = fromConnectionId) If (toUser! = null) {Clients.Client (toUser.ConnectionId) .receivePrivateMessage (fromUser.UserName, message); Clients.Client (toUser.ConnectionId) .receivePrivateMessage (message);} else {/ / indicates that the other party is not online Clients.Caller.absentSubscriber ();}} public void Send (string name, string message) {/ / Clients.All {get;} / / represents all clients / Clients.AllExcept (params string [] excludeConnectionIds) / / except for all clients in the parameters / / Clients.Client (string connectionId); / / specific clients, this method is the key to our end-to-end chat / / Clients.Clients (IList connectionIds); / / clients in parameters / / Clients.Group (string groupName, params string [] excludeConnectionIds) / / specify client group, which is also the key to group chat / / Clients.Groups (IList groupNames, params string [] excludeConnectionIds); client group / / Clients.User (string userId) in parameters; / / specific user / / Clients.Users (IList userIds); / / user Console.WriteLine in parameters ("ConnectionId: {0}, InvokeMethod: {1}", Context.ConnectionId, "Send") Clients.All.addMessage (name, message); call / public override Task OnConnected () {Console.WriteLine ("client connection, connection ID is: {0}, current online population is {1}", Context.ConnectionId, OnlineUsers.Count+1); return base.OnConnected () Call / public override Task OnDisconnected (bool stopCalled) {var user = OnlineUsers.FirstOrDefault (u = > u.ConnectionId = = Context.ConnectionId) when disconnected; / / determine whether the user exists or delete if (user = = null) {return base.OnDisconnected (stopCalled);} Clients.All.onUserDisconnected (user.ConnectionId, user.UserName) / / call client user offline notification / / delete user OnlineUsers.Remove (user); Console.WriteLine ("client disconnected, connection ID is: {0}, current online population is {1}", Context.ConnectionId, OnlineUsers.Count); return base.OnDisconnected (stopCalled);} public override Task OnReconnected () {return base.OnReconnected ();}

7. Add the Startup class to the Server console as follows

Using Microsoft.Owin.Cors;using Owin;namespace Server {public class Startup {public void Configuration (IAppBuilder app) {/ / allow CORS to cross-domain app.UseCors (CorsOptions.AllowAll); app.MapSignalR ();}

8. Modify and add the Program class to the Server console, as follows

Using Microsoft.Owin.Hosting;using System;namespace Server {class Program {static void Main (string [] args) {string url = "http://localhost:10086";// sets SignalR Hub Server external interface using (WebApp.Start (url)) / / launches SignalR Hub Server {Console.WriteLine (" Server running on {0} ", url); Console.ReadLine ();}

9. F5 is running

Then access http://localhost:10086/signalr/hubs in the browser

The results are as follows:

See the picture above and the content is basically completed.

After reading the above, do you have any further understanding of SignalR Self Host+MVC and other multi-end message push services? If you want to know more knowledge or related content, please follow the industry information channel, thank you for your support.

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.