脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 网络编程 → ASP.NET → 实用技巧 → ASP.NET MVC4异步聊天室

ASP.NET MVC4异步聊天室的示例代码

 更新时间：2017年10月17日 15:02:38   作者：逆世风灵  
这篇文章主要介绍了ASP.NET MVC4异步聊天室的示例代码，具有一定的参考价值，感兴趣的小伙伴们可以参考一下

本文介绍了ASP.NET MVC4异步聊天室的示例代码，分享给大家，具体如下：

类图:

Domain层

IChatRoom.cs

using System;
using System.Collections.Generic;

namespace MvcAsyncChat.Domain
{
  public interface IChatRoom
  {
    void AddMessage(string message);
    void AddParticipant(string name);
    void GetMessages(
      DateTime since, 
      Action<IEnumerable<string>, DateTime> callback);
    void RemoveParticipant(string name);
  }
}

IMessageRepo.cs

using System;
using System.Collections.Generic;

namespace MvcAsyncChat.Domain
{
  public interface IMessageRepo
  {
    DateTime Add(string message);
    IEnumerable<string> GetSince(DateTime since);
  }
}

ICallbackQueue.cs

using System;
using System.Collections.Generic;

namespace MvcAsyncChat.Domain
{
  public interface ICallbackQueue
  {
    void Enqueue(Action<IEnumerable<string>, DateTime> callback);
    IEnumerable<Action<IEnumerable<string>, DateTime>> DequeueAll();
    IEnumerable<Action<IEnumerable<string>, DateTime>> DequeueExpired(DateTime expiry);
  }
}

ChatRoom.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using MvcAsyncChat.Svcs;

namespace MvcAsyncChat.Domain
{
  public class ChatRoom : IChatRoom
  {
    readonly ICallbackQueue callbackQueue;
    readonly IDateTimeSvc dateTimeSvc;
    readonly IMessageRepo messageRepo;

    public ChatRoom(
      ICallbackQueue callbackQueue,
      IDateTimeSvc dateTimeSvc,
      IMessageRepo messageRepo)
    {
      this.callbackQueue = callbackQueue;
      this.dateTimeSvc = dateTimeSvc;
      this.messageRepo = messageRepo;
    }

    public void AddMessage(string message)
    {
      var timestamp = messageRepo.Add(message);

      foreach (var callback in callbackQueue.DequeueAll())
        callback(new[] { message }, timestamp);
    }

    public void AddParticipant(string name)
    {
      AddMessage(string.Format("{0} 已进入房间.", name));
    }

    public void GetMessages(
      DateTime since,
      Action<IEnumerable<string>, DateTime> callback)
    {
      var messages = messageRepo.GetSince(since);

      if (messages.Count() > 0)
        callback(messages, since);
      else
        callbackQueue.Enqueue(callback);
    }

    public void RemoveParticipant(string name)
    {
      AddMessage(string.Format("{0} left the room.", name));
    }
  }
}

InMemMessageRepo.cs

using System;
using System.Collections.Generic;
using System.Linq;

namespace MvcAsyncChat.Domain
{
  public class InMemMessageRepo : IMessageRepo
  {
    public InMemMessageRepo()
    {
      Messages = new List<Tuple<string, DateTime>>();
    }

    public IList<Tuple<string, DateTime>> Messages { get; private set; }

    public DateTime Add(string message)
    {
      var timestamp = DateTime.UtcNow;

      Messages.Add(new Tuple<string, DateTime>(message, timestamp));

      return timestamp;
    }

    public IEnumerable<string> GetSince(DateTime since)
    {
      return Messages
        .Where(x => x.Item2 > since)
        .Select(x => x.Item1);
    }
  }
}

CallbackQueue.cs

using System;
using System.Collections.Generic;
using System.Linq;

namespace MvcAsyncChat.Domain
{
  public class CallbackQueue : ICallbackQueue
  {
    public CallbackQueue()
    {
      Callbacks = new Queue<Tuple<Action<IEnumerable<string>, DateTime>, DateTime>>();
    }

    public Queue<Tuple<Action<IEnumerable<string>, DateTime>, DateTime>> Callbacks { get; private set; }

    public void Enqueue(Action<IEnumerable<string>, DateTime> callback)
    {
      Callbacks.Enqueue(new Tuple<Action<IEnumerable<string>, DateTime>, DateTime>(callback, DateTime.UtcNow));
    }

    public IEnumerable<Action<IEnumerable<string>, DateTime>> DequeueAll()
    {
      while (Callbacks.Count > 0)
        yield return Callbacks.Dequeue().Item1;
    }

    public IEnumerable<Action<IEnumerable<string>, DateTime>> DequeueExpired(DateTime expiry)
    {
      if (Callbacks.Count == 0)
        yield break;

      var oldest = Callbacks.Peek();
      while (Callbacks.Count > 0 && oldest.Item2 <= expiry)
      {
        yield return Callbacks.Dequeue().Item1;

        if (Callbacks.Count > 0)
          oldest = Callbacks.Peek();
      }
    }
  }
}

RequestModels文件夹实体类

EnterRequest.cs

using System;
using System.ComponentModel;
using System.ComponentModel.DataAnnotations;

namespace MvcAsyncChat.RequestModels
{
  public class EnterRequest
  {
    [DisplayName("名称")]
    [Required, StringLength(16), RegularExpression(@"^[A-Za-z0-9_\ -]+$", ErrorMessage="A name must be alpha-numeric.")]
    public string Name { get; set; }
  }
}

GetMessagesRequest.cs

using System;

namespace MvcAsyncChat.RequestModels
{
  public class GetMessagesRequest
  {
    public string since { get; set; }
  }
}

SayRequest.cs

using System;
using System.ComponentModel;
using System.ComponentModel.DataAnnotations;

namespace MvcAsyncChat.RequestModels
{
  public class SayRequest
  {
    [Required, StringLength(1024), DataType(DataType.MultilineText)]
    public string Text { get; set; }
  }
}

ResponseModels文件夹实体类

GetMessagesResponse.cs

using System;
using System.Collections.Generic;

namespace MvcAsyncChat.ResponseModels
{
  public class GetMessagesResponse
  {
    public string error { get; set; }
    public IEnumerable<string> messages { get; set; }
    public string since { get; set; }
  }
}

SayResponse.cs

using System;

namespace MvcAsyncChat.ResponseModels
{
  public class SayResponse
  {
    public string error { get; set; }
  }
}

ChatController.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.Mvc;
using System.Web.Mvc.Async;
using MvcAsyncChat.Domain;
using MvcAsyncChat.RequestModels;
using MvcAsyncChat.ResponseModels;
using MvcAsyncChat.Svcs;

namespace MvcAsyncChat.Controllers
{
  public class ChatController : AsyncController
  {
    readonly IAuthSvc authSvc;
    readonly IChatRoom chatRoom;
    readonly IDateTimeSvc dateTimeSvc;

    public ChatController(
      IAuthSvc authSvc,
      IChatRoom chatRoom,
      IDateTimeSvc dateTimeSvc)
    {
      this.authSvc = authSvc;
      this.chatRoom = chatRoom;
      this.dateTimeSvc = dateTimeSvc;
    }

    [ActionName("enter"), HttpGet]
    public ActionResult ShowEnterForm()
    {
      if (User.Identity.IsAuthenticated)
        return RedirectToRoute(RouteName.Room);

      return View();
    }

    [ActionName("enter"), HttpPost]
    public ActionResult EnterRoom(EnterRequest enterRequest)
    {
      if (!ModelState.IsValid)
        return View(enterRequest);

      authSvc.Authenticate(enterRequest.Name);
      chatRoom.AddParticipant(enterRequest.Name);

      return RedirectToRoute(RouteName.Room);
    }

    [ActionName("room"), HttpGet, Authorize]
    public ActionResult ShowRoom()
    {
      return View();
    }

    [ActionName("leave"), HttpGet, Authorize]
    public ActionResult LeaveRoom()
    {
      authSvc.Unauthenticate();
      chatRoom.RemoveParticipant(User.Identity.Name);

      return RedirectToRoute(RouteName.Enter);
    }

    [HttpPost, Authorize]
    public ActionResult Say(SayRequest sayRequest)
    {
      if (!ModelState.IsValid)
        return Json(new SayResponse() { error = "该请求无效." });

      chatRoom.AddMessage(User.Identity.Name+" 说:"+sayRequest.Text);

      return Json(new SayResponse());
    }

    [ActionName("messages"), HttpPost, Authorize]
    public void GetMessagesAsync(GetMessagesRequest getMessagesRequest)
    {
      AsyncManager.OutstandingOperations.Increment();

      if (!ModelState.IsValid)
      {
        AsyncManager.Parameters["error"] = "The messages request was invalid.";
        AsyncManager.Parameters["since"] = null;
        AsyncManager.Parameters["messages"] = null;
        AsyncManager.OutstandingOperations.Decrement();
        return;
      }

      var since = dateTimeSvc.GetCurrentDateTimeAsUtc();
      if (!string.IsNullOrEmpty(getMessagesRequest.since))
        since = DateTime.Parse(getMessagesRequest.since).ToUniversalTime();

      chatRoom.GetMessages(since, (newMessages, timestamp) => 
      {
        AsyncManager.Parameters["error"] = null;
        AsyncManager.Parameters["since"] = timestamp;
        AsyncManager.Parameters["messages"] = newMessages;
        AsyncManager.OutstandingOperations.Decrement();
      });
    }

    public ActionResult GetMessagesCompleted(
      string error, 
      DateTime? since, 
      IEnumerable<string> messages)
    {
      if (!string.IsNullOrWhiteSpace(error))
        return Json(new GetMessagesResponse() { error = error });

      var data = new GetMessagesResponse();
      data.since = since.Value.ToString("o");
      data.messages = messages;

      return Json(data);
    }
  }
}

room.js

var since = "",
  errorCount = 0,
  MAX_ERRORS = 6;

function addMessage(message, type) {
  $("#messagesSection > td").append("<div class='" + (type || "") + "'>" + message + "</div>")
}

function showError(error) {
  addMessage(error.toString(), "error");
}

function onSayFailed(XMLHttpRequest, textStatus, errorThrown) {
  showError("An unanticipated error occured during the say request: " + textStatus + "; " + errorThrown);
}

function onSay(data) {
  if (data.error) {
    showError("An error occurred while trying to say your message: " + data.error);
    return;
  }
}

function setSayHandler() {
  $("#Text").keypress(function (e) {
    if (e.keyCode == 13) {
      $("#sayForm").submit();
      $("#Text").val("");
      return false;
    }
  });
}

function retryGetMessages() {
  if (++errorCount > MAX_ERRORS) {
    showError("There have been too many errors. Please leave the chat room and re-enter.");
  }
  else {
    setTimeout(function () {
      getMessages();
    }, Math.pow(2, errorCount) * 1000);
  }
}

function onMessagesFailed(XMLHttpRequest, textStatus, errorThrown) {
  showError("An unanticipated error occured during the messages request: " + textStatus + "; " + errorThrown);
  retryGetMessages();
}

function onMessages(data, textStatus, XMLHttpRequest) {
  if (data.error) {
    showError("An error occurred while trying to get messages: " + data.error);
    retryGetMessages();
    return;
  }

  errorCount = 0;
  since = data.since;

  for (var n = 0; n < data.messages.length; n++)
    addMessage(data.messages[n]);

  setTimeout(function () {
    getMessages();
  }, 0);
}

function getMessages() {
  $.ajax({
    cache: false,
    type: "POST",
    dataType: "json",
    url: "/messages",
    data: { since: since },
    error: onMessagesFailed,
    success: onMessages,
    timeout: 100000
  });
}

Chat视图文件夹

Enter.cshtml

@model MvcAsyncChat.RequestModels.EnterRequest

@{
  View.Title = "Enter";
  Layout = "~/Views/Shared/_Layout.cshtml";
}

@section Head {}

<tr id="enterSection">
  <td>
    <h2>[MVC聊天]是使用ASP.NET MVC 3的异步聊天室
    <table>
      <tr>
        <td class="form-container">
          <fieldset>
            <legend>进入聊天室</legend>
            @using(Html.BeginForm()) {
              @Html.EditorForModel()
              <input type="submit" value="Enter" />
            }
          </fieldset>
        </td>
      </tr>
    </table>
  </td>
</tr>

@section PostScript {
  <script>
    $(document).ready(function() {
      $("#Name").focus();  
    });
  </script>
}

Room.cshtml

@using MvcAsyncChat;
@using MvcAsyncChat.RequestModels;
@model SayRequest

@{
  View.Title = "Room";
  Layout = "~/Views/Shared/_Layout.cshtml";
}

@section Head {
  <script src="@Url.Content("~/Scripts/room.js")"></script>
}

<tr id="messagesSection">
  <td></td>
</tr>
<tr id="actionsSection">
  <td>

    <label for="actionsList">操作:</label>
    <ul id="actionsList">
      <li>@Html.RouteLink("离开房间", RouteName.Leave)</li>
    </ul>
    @using (Ajax.BeginForm("say", new { }, new AjaxOptions() { 
      OnFailure = "onSayFailed", 
      OnSuccess = "onSay", 
      HttpMethod = "POST", }, new { id = "sayForm"})) {
      @Html.EditorForModel()
    }
  </td>
</tr>

@section PostScript {
  <script>
    $(document).ready(function() {
      $("#Text").attr("placeholder", "你说:");
      $("#Text").focus();
      setSayHandler();
      getMessages();
    });
  </script>
}

运行结果如图:

这里写图片描述

这里写图片描述

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

相关文章

  • asp.net保存远程图片的代码

    asp.net保存远程图片的代码

    最近有点烦，没怎么看书，几天下来，就研究了一个保存远程图片的。
    2008-09-09
  • 判断WebBrowser浏览器网页加载完成的处理方法

    判断WebBrowser浏览器网页加载完成的处理方法

    .net 中通过 SqlConnection 连接 sql server，我们会发现第一次连接时总是很耗时，但后面连接就很快，这个其实和SqlConnection 的连接池机制有关，正确的理解这个连接池机制，有助于我们编写高效的数据库应用程序。
    2013-04-04
  • asp.net XML文件操作实现代码

    asp.net XML文件操作实现代码

    这几天在项目中用到了XML文件配置存储一些基本信息，如：参数、表格等一些信息存储。由于记录不是很多，所以用此文件来代替数据库中设计的表结构。
    2009-12-12
  • asp.net 基于forms验证的目录角色权限的实现

    asp.net 基于forms验证的目录角色权限的实现

    一个系统中经常有多种身份的用户，往往要根据其身份来控制目录的访问权限。asp.net提供了forms验证，能够轻易的在配置文件中设置用户对目录的访问权限.
    2009-11-11
  • ASP.NET Core如何添加统一模型验证处理机制详解

    ASP.NET Core如何添加统一模型验证处理机制详解

    这篇文章主要给大家介绍了关于ASP.NET Core如何添加统一模型验证处理机制的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用ASP.NET Core具有一定的参考学习价值，需要的朋友可以参考下
    2018-05-05
  • asp.net Linq to Xml学习笔记

    asp.net Linq to Xml学习笔记

    之前都没有学习过关于XML文件的操作，由于最近开发的项目需要用到，开始时学习了原始的XML文件操作方法，看了半天，也看的头晕眼花，没学习到真正的用法，后来在同事的推荐下学习了Linq to Xml
    2010-03-03
  • C#中常用的IO操作介绍

    C#中常用的IO操作介绍

    这篇文章介绍了C#中常用的IO操作，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2022-06-06
  • ASP.NET MVC 2右键菜单和简单分页实例讲解

    ASP.NET MVC 2右键菜单和简单分页实例讲解

    在这里我们将讨论的是通过一个插件实现ASP.NET MVC 2中的右键菜单和一个相当简单的分页，希望对大家有所帮助。
    2015-09-09
  • ASP.Net MVC_DotNetZip简单使用方法,解决文件压缩的问题

    ASP.Net MVC_DotNetZip简单使用方法,解决文件压缩的问题

    下面小编就为大家带来一篇ASP.Net MVC_DotNetZip简单使用方法,解决文件压缩的问题。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2016-06-06
  • ASP.NET MVC解决上传图片脏数据的方法

    ASP.NET MVC解决上传图片脏数据的方法

    这篇文章介绍了ASP.NET MVC解决上传图片脏数据的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2022-09-09

最新评论