ASP.NET SingalR + MongoDB 实现简单聊天室(一):搭建基本框架

ASP.NET SingalR不多介绍。让我介绍不如看官网,我这里就是直接上源代码,当然代码还是写的比较简单的,考虑的也少,希望各位技友多多提意见。

先简单介绍聊天室功能:

  • 用户加入聊天室,自动给用户名和头像。(可扩展用户自定义昵称和头像,未做)
  • 聊天信息发送,群聊。(可扩展1对1聊天,群组聊天,1对多聊天,扩展多种消息格式,未做)
  • 本地存储用户信息
  • 后台结合mongodb存储聊天信息,用户下次进入可以看到聊天记录(MongoDB .NET客户端的使用,可以用SQL或者缓存存储,不作为重点阐述)

写了这么多文字,是不是激不起兴趣来,好直接上一张图,然后搭建基本框架。

ASP.NET SingalR + MongoDB 实现简单聊天室(一):搭建基本框架

ok,我们开始搭建界面。

新建asp.net mvc 项目,然后添加一个SingalR集线器类。(不用手动引用singalR.dll,当然可以从nuget上安装)

ASP.NET SingalR + MongoDB 实现简单聊天室(一):搭建基本框架

其实hub代码比较简单,这里只为了实现简单聊天室功能,就不多写其他代码。因为未完善代码,所以暂时不公开。较为复杂点的代码,有兴趣的同学可以邮箱留言,我发给你们。

编写后台代码之前呢,先分析页面结构。首先,聊天基本内容包含:聊天内容,用户昵称,用户头像,用户发表时间,ok,那么新建一个model吧。

     public class ZjMessage : MongoBaseModel
{
public ZjMessage(){
createTime = DateTime.Now.ToString("MM-dd hh:mm:ss");
}
public ZjMessage(string connectionId)
{
this.connectionId = connectionId;
}
public string connectionId { get; set; } /// <summary>
/// 头像
/// </summary>
public string photo { get; set; }
/// <summary>
/// 消息内容
/// </summary>
public string msg { get; set; }
/// <summary>
/// 用户名
/// </summary>
public string username { get; set; }
/// <summary>
/// 用户ID 这个用户ID,是为了区分是谁发的,(判断消息展示在左边或者右边)
/// </summary>
public string userid { get; set; }
/// <summary>
/// 创建时间
/// </summary>
public string createTime { get; set; }
}

Model不多说,下面上zjHub代码(至于这个命名吗,你们随便),里面的各个方法已经注明,后面文章也会对各个方法做详细介绍。

   public class ZjHub : Hub
{
private readonly IBaseQuery<ZjMessage> query = MongoDBFactory<ZjMessage>.CreateInstance("zj");
/// <summary>
/// 连接服务器的方法,自动调用客户端,客户端需要定义receiveMessage方法
/// </summary>
/// <returns></returns>
public override async Task OnConnected()
{
try
{
//用户第一次进来,读取历史记录
var result = await query.GetListAsync(x => x.userid.Length > );
Clients.Caller.receiveHistoryMessage(new { type = "system", msg = "您已经进入聊天室", oldlist = result.ToList() });
}
catch (TimeoutException ex)
{ }
} /// <summary>
/// 重新连接服务器,自动调用客户端
/// </summary>
/// <returns></returns>
public override Task OnReconnected()
{
return Clients.Caller.receiveMessage(new { type = "system", msg = "您已经重新进入聊天室。" });
} public override Task OnDisconnected(bool stopCalled)
{
ZjMessage message = new ZjMessage(Context.ConnectionId);
//用户离开
return Clients.All.receiveMessage(new { type = "left", msg = message });
} public Task Join(ZjMessage message)
{
message.connectionId = Context.ConnectionId;
//就是用户加入的时候
return Clients.All.receiveMessage(new { type = "join", msg = message });
}
/// <summary>
/// 主要看这个方法,这个就是往服务器发送数据
/// </summary>
/// <param name="message">消息体是一个zjMessage </param>
/// <returns></returns>
public async Task Send(ZjMessage message)
{
message.connectionId = Context.ConnectionId;
//存到数据库
await query.InsertAsync(new List<ZjMessage> { message });
//定义客户端接收方法 ,这里是receiveMessage
//这里写成消息类型为msg new { type = "msg", msg = message }
Clients.All.receiveMessage(new { type = "msg", msg = message });
}
}

至此,后台代码基本已经结束了,其实好多业务功能就是前端的,后端主要负责的是服务器稳定性,性能优化等方面。这里暂且不提,看前端之前,在做一下服务地址的配置,在startup类里面编写如下代码。

 public partial class Startup
{
public void Configuration(IAppBuilder app)
{
app.Map("/push/im", map =>
{
var hubConfiguration = new HubConfiguration()
{
EnableJSONP = true
};
map.RunSignalR(hubConfiguration);
});
}
}

好了,让我们运行一下,看看这个hub类有没有起作用,本机地址是:http://localhost:40716/push/im/hubs (如果不加上述配置,地址默认为:http://localhost:40716/singalr/hubs),如果你看到这个地址是js文件,那么前台就能调用了。先看一下推送效果:

ASP.NET SingalR + MongoDB 实现简单聊天室(一):搭建基本框架

第一篇到此先告一段落。下篇预告:

  • 实现用户加入聊天室,推送用户加入信息
  • 实现用户加入聊天室,自动生成头像和对应昵称,并且保存到本地
  • 实现历史记录读取。(简单介绍)

就到这里啦,谢谢各位大牛捧场。

上一篇:利用socket.io+nodejs打造简单聊天室


下一篇:java 线程基础篇,看这一篇就够了。