SignalR循序渐进(一)

前阵子把玩了一下SignalR,起初以为只是个real-time的web通讯组件。研究了几天后发现,这玩意简直屌炸天,它完全就是个.net的双向异步通讯框架,用它能做很多不可思议的东西。它基于Owin,可以脱离繁重的System.Web,随意寄宿在IIS,WindowsService,或者一个控制台程序,这样它即能用于b/s的Web应用,也能用在客户端程序或者服务之间的通讯上。对它的介绍网上早已铺天盖地,这而就不再啰嗦了,先来个小例子,一个聊天室程序。

服务端



新建一个叫SignalRDemo的工程,注意一定要选择.net Framework4.5及以上。

为了让服务端可以自寄宿,安装signalr self host组件。


public class ChatHub : Hub
{
public void Send(string name, string message)
{
Console.WriteLine("ConnectionId:{0}, InvokeMethod:{1}", Context.ConnectionId, "Send");
Clients.AllExcept(Context.ConnectionId).broadcast(name, message);
}
}

新建一个ChatHub,创建一个行为叫Send,里面包含了一条控制台调用记录以及让所有除了发起者外的链接Hub的客户端执行客户端方法broadcast。


[assembly: OwinStartup(typeof(Host.Startup))]

namespace Host
{
public class Startup
{
public void Configuration(IAppBuilder app)
{
app.MapSignalR();
}
}
}

创建一个启动类,将所有的Hub映射。


class Program
{
static void Main(string[] args)
{
var url = "localhost:10086";
WebApp.Start<Startup>(url);
Console.WriteLine("Server started,url is {0}", url);
Console.ReadLine();
}
}

在Main中写上url和端口,直接用WebApp启动。

控制台启动后的输出。

用浏览器访问

好了,到这儿服务端代码就全部完成了。接下来创建客户端来调用。客户端暂时不采用website,同样用控制台程序来承载。

客户端



创建一个Client的控制台工程,添加SignalR的Client包。


var url = "http://localhost:10086/";
var connection = new HubConnection(url);
var chatHub = connection.CreateHubProxy("ChatHub");
connection.Start().ContinueWith(t =>
{
if (t.IsFaulted)
{
Console.WriteLine("Connection fault.");
}
});

在客户端的Main中创建一个HubConnection,创建ChatHub的代理,通过connection.Start启动连接。


var broadcastHandler = chatHub.On<string, string>("broadcast", (name, message) =>
{
Console.WriteLine("[{0}]{1}: {2}", DateTime.Now.ToString("HH:mm:ss"), name, message);
});

定义客户端方法,之前在服务端用Clients.All.broadcast的就是在这边定义的方法。


Console.WriteLine("Please input your name:");
var _name = Console.ReadLine();
Console.WriteLine("Start chat!");
while (true)
{
var _message = Console.ReadLine();
chatHub.Invoke("Send", _name, _message).ContinueWith(t => {
if (t.IsFaulted)
{
Console.WriteLine("Connection error!");
}
});
}

最后,写上一个简单的聊天逻辑。当输入名字后,在while的循环内,每输入一行文本,hub就调用服务端的Send方法。同时服务端在执行Send的过程后又会回掉客户端方法。这种通讯方式在以前的C#代码中是很不可思议的,因为同样的客户端方法还可以写在js里!

执行效果



执行效果如图。

好了,一个基于SignalR的简单的控制台聊天程序就完成了,强大的SignalR让开发者不需要关心Socket的一堆烦人的问题。

问题



上面的那个聊天程序看似很方便很强大,但似乎哪儿有一些奇怪?

比如说,服务端调用客户端的方法用的是dynamic的,客户端调用服务端的方法传入的都是string类型的,这样首先就不具备扩展性和进行一些规则约束。

  1. 能不能让客户端声明一个强类型的方法列表呢?这样首先不容易写错。

  2. 同样的,能不能让服务端声明一个强类型的方法列表给客户端调用呢?

下一篇将对上面的2个问题进行思考,并给出解决方案。

SignalR循序渐进(一),布布扣,bubuko.com

时间: 2024-10-06 01:14:51

SignalR循序渐进(一)的相关文章

SignalR循序渐进(三)简易的集群通讯组件

上一篇演示了泛型Hub的实现,微软于6月17日更新了SignalR 2.1.0,然后自带了泛型Hub,于是就不需要自己去实现了…(微软你为啥不早一个月自带啊…).不过没关系,SignalR出彩之处不在泛型Hub,本篇为各位观众带来了基于SignalR的简易集群通讯组件Demo,可用于分布式定时任务. 说到集群,自然想到了NLB啊Cluster啊HPC啊等等.NLB受制于成员数量,Cluster用数量堆高可用性,HPC太复杂.本着SignalR的双向异步通讯的特点,其实是可以用来玩弹性计算的.初始

SignalR 循序渐进

SignalR 循序渐进(五)多个Hub服务器下的消息订阅 hellsoul86 2014-08-18 11:29 阅读:840 评论:7 SignalR 循序渐进(四) Hub的生命周期以及IoC hellsoul86 2014-07-29 16:55 阅读:953 评论:6 SignalR循序渐进(三)简易的集群通讯组件 hellsoul86 2014-06-27 01:39 阅读:1350 评论:7 SignalR循序渐进(二)泛型Hub hellsoul86 2014-05-24 21:

SignalR 循序渐进(四) Hub的生命周期以及IoC

有阵子没更新这个系列了,最近太忙了.本篇带来的是Hub的生命周期以及IoC. 首先,Hub的生命周期,我们用一个Demo来看看: public class TestHub : Hub { public TestHub() { Console.WriteLine(Guid.NewGuid().ToString()); } public void Hello() { } } static HubConnection hubConnection; static IHubProxy hubProxy;

SignalR 循序渐进(五)多个Hub服务器下的消息订阅

SignalR的通讯方式决定了其高性能,但是即便如此,当消息的并发量上来以后,单节点的Hub服务器依然可能无法承载总的消息吞吐量,那么如何对Hub服务器做水平扩展呢? 从微软官方的文档上看,SignalR是具有消息底板功能的,SignalR核心组件公开了一个IMessageBus的接口,只需要实现该接口,就能实现消息订阅功能.官网提供了3种解决方案:Azure.Redis.SqlServer,nuget平台上有更多的基于消息队列的第三方底板.本篇以Redis为例子展示一下以消息底板模式运作的Hu

SignalR循序渐进(二)

接上一篇,文章末尾抛出了2个问题: 能不能让客户端声明一个强类型的方法列表呢?这样首先不容易写错. 同样的,能不能让服务端声明一个强类型的方法列表给客户端调用呢? 如果要让客户端的方法以强类型出现在服务端,同样的,服务端的方法也以强类型出现在客户端,那就必须声明类似契约一样的载体.比如: public interface IChatClient { void broadcast(string name, string message); } public interface IChatHub {

SignalR循序渐进(二)泛型Hub

position:static(静态定位) 当position属性定义为static时,可以将元素定义为静态位置,所谓静态位置就是各个元素在HTML文档流中应有的位置 podisition定位问题.所以当没有定义position属性时,并不说明该元素没有自己的位置,它会遵循默认显示为静态位置,在静态定位状态下无法通过坐标值(top,left,right,bottom)来改变它的位置. position:absolute(绝对定位) 当position属性定义为absolute时,元素会脱离文档流

使用SignalR实现消息提醒

Asp.net SignalR是微软为实现实时通信的一个类库.一般情况下,SignalR会使用JavaScript的长轮询(long polling)的方式来实现客户端和服务器通信,随着Html5中WebSockets出现,SignalR也支持WebSockets通信.另外SignalR开发的程序不仅仅限制于宿主在IIS中,也可以宿主在任何应用程序,包括控制台,客户端程序和Windows服务等,另外还支持Mono,这意味着它可以实现跨平台部署在Linux环境下. SignalR内部有两类对象:

【SignalR学习系列】2. 第一个SignalR程序

新建项目 1.使用VisualStudio 2015 新建一个Web项目 2.选择空模板 3.添加一个新的SignalR Hub Class (v2)类文件,并修改类名为ChatHub 4.修改ChatHub代码 using System; using System.Collections.Generic; using System.Linq; using System.Web; using Microsoft.AspNet.SignalR; namespace SignalRDemo { pu

Asp.Net SignalR 多平台的Client与Server

多平台 SignalR在.Net的大环境下都可以做到即时通讯,也就是说都可以使用,客户端也不仅是js.下面就来一个控制台的Client 我们需要在nuget上下载包 Microsoft.AspNet.SignalR.Client 有了它,我就可以进行开发了 下面创建一个Hub集线器的连接,地址填的之前的集线器server,可以看到使用与js的语法类似.客户端的服务是用on而执行服务器的方法副作用Invoke static void Main(string[] args) { var hub =