Note: This sample is targeting SignalR 1.0.1 <\/p>\n
SignalR<\/a> offers a simple and clean API to write real time web applications where the server needs to continuously push data to clients. Common applications are chat, news feed, notifications, multiplayer games.<\/p>\n In this sample, I demonstrate powerful features like:<\/p>\n Server derives the Hub class, and it handles incoming requests in two ways:<\/p>\n Server is also pushing data to clients in two ways using the BackgroundThread class:<\/p>\n As you can see, dynamic methods define the events that need to be handled on the client side. Think of them as if they were interface methods to execute remote calls.<\/p>\n <\/p>\n To write a client, you must define how to handle Server <DynamicMethods>: "client.Broadcast", "client.Group", and "client.ResponseAsync".<\/p>\n Then, client is started, and after the connection succeeds, the client can make requests to server by invoking "server.requestAsync" and "server.joinGroup".<\/p>\n You will see similar patterns in the ConsoleApp and WindowsStoreApp clients.<\/p>\n There is more information about how I wrote the code when running the sample, simply follow these instructions:<\/p>\n There are more advanced samples in the SignalR source code repository, follow these steps to get them:<\/p>\n\n
Server<\/h2>\n
\n
\n\n
\n \n public class <\/span>SampleHub <\/span>: <\/span>Hub\n<\/span>{\n <\/span>public <\/span>FromServerToClientData <\/span>Request(<\/span>FromClientToServerData <\/span>request)\n {\n <\/span>FromServerToClientData <\/span>response = <\/span>new <\/span>FromServerToClientData<\/span>();\n response.Text = <\/span>"Responding to: " <\/span>+ request.Text;\n <\/span>return <\/span>response;\n }\n\n <\/span>public async <\/span>Task<\/span><<\/span>FromServerToClientData<\/span>> RequestAsync(<\/span>FromClientToServerData <\/span>request)\n {\n <\/span>FromServerToClientData <\/span>response = <\/span>new <\/span>FromServerToClientData<\/span>();\n response.Text = <\/span>"Responding to: " <\/span>+ request.Text;\n <\/span>await <\/span>Task<\/span>.Delay(<\/span>TimeSpan<\/span>.FromSeconds(5));\n <\/span>return <\/span>response;\n }\n\n <\/span>public async <\/span>Task <\/span>RequestWithCallbackAsync(<\/span>FromClientToServerData <\/span>request)\n {\n <\/span>FromServerToClientData <\/span>response = <\/span>new <\/span>FromServerToClientData<\/span>();\n response.Text = <\/span>"Responding to: " <\/span>+ request.Text;\n <\/span>await <\/span>Task<\/span>.Delay(<\/span>TimeSpan<\/span>.FromSeconds(5));\n Clients.Others.OthersCallback(response);\n }\n\n <\/span>public void <\/span>JoinGroup(<\/span>string <\/span>groupName)\n {\n Groups.Add(Context.ConnectionId, groupName);\n }\n}<\/span><\/pre>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n\n
\n\n
\n \n public class <\/span>BackgroundThread\n<\/span>{\n <\/span>public static void <\/span>Start()\n {\n <\/span>ThreadPool<\/span>.QueueUserWorkItem(_ =>\n {\n <\/span>IHubContext <\/span>hubContext = <\/span>GlobalHost<\/span>.ConnectionManager.GetHubContext<<\/span>SampleHub<\/span>>();\n\n <\/span>while <\/span>(<\/span>true<\/span>)\n {\n ...\n hubContext.Clients.All.Broadcast(data);\n hubContext.Clients.Group(<\/span>"WebApp"<\/span>).BroadcastToGroup(\n <\/span>string<\/span>.Format(<\/span>"WebApp {0}"<\/span>, <\/span>DateTime<\/span>.Now));\n hubContext.Clients.Group(<\/span>"ConsoleApp"<\/span>).BroadcastToGroup(\n <\/span>string<\/span>.Format(<\/span>"ConsoleApp {0}"<\/span>, <\/span>DateTime<\/span>.Now));\n hubContext.Clients.Group(<\/span>"SilverlightApp"<\/span>).BroadcastToGroup(\n <\/span>string<\/span>.Format(<\/span>"SilverlightApp {0}"<\/span>, <\/span>DateTime<\/span>.Now));\n hubContext.Clients.Group(<\/span>"WindowsStoreApp"<\/span>).BroadcastToGroup(\n <\/span>string<\/span>.Format(<\/span>"WindowsStoreApp {0}"<\/span>, <\/span>DateTime<\/span>.Now));\n } \n }\n });\n}<\/span><\/pre>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\nClient<\/h2>\n
\n\n
\n \n $(<\/span>function <\/span>() {\n $.connection.sampleHub.client.broadcast = <\/span>function <\/span>(value) {\n $(<\/span>'#BroadcastText'<\/span>).html(<\/span>'<pre>Broadcast: ' <\/span>+ value.Now + <\/span>' ' <\/span>+\n value.Integer + <\/span>' ' <\/span>+ value.Text + <\/span>'<\/pre>'<\/span>);\n }\n\n $.connection.sampleHub.client.broadcastToGroup = <\/span>function <\/span>(value) {\n $(<\/span>'#BroadcastToGroupText'<\/span>).html(<\/span>'<pre>BroadcastToGroup: ' <\/span>+ value + <\/span>'<\/pre>'<\/span>);\n }\n\n $.connection.sampleHub.client.othersCallback = <\/span>function <\/span>(value) {\n $(<\/span>'#OthersCallbackText'<\/span>).html(<\/span>'<pre>OthersCallback: ' <\/span>+ value.Text + <\/span>'<\/pre>'<\/span>);\n }\n\n $.connection.hub.logging = <\/span>true<\/span>;\n $.connection.hub.start().done(<\/span>function <\/span>() {\n <\/span>var <\/span>request = {};\n request.Text = <\/span>'This is a request from a WebApp!'\n\n <\/span>$.connection.sampleHub.server.request(request).done(<\/span>function <\/span>(response) {\n $(<\/span>'#ResponseText'<\/span>).html(<\/span>'<pre>Response: ' <\/span>+ response.Text + <\/span>'<\/pre>'<\/span>);\n });\n $.connection.sampleHub.server.requestAsync(request).done(<\/span>function <\/span>(response) {\n $(<\/span>'#ResponseAsyncText'<\/span>).html(<\/span>'<pre>ResponseAsync: ' <\/span>+ response.Text + <\/span>'<\/pre>'<\/span>);\n });\n $.connection.sampleHub.server.requestWithCallbackAsync(request);\n $.connection.sampleHub.server.joinGroup(<\/span>'WebApp'<\/span>);\n });\n});<\/span><\/pre>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n\n
\n
\n