转载

一步一步学习SignalR进行实时通信_6_案例

  • 一步一步学习SignalR进行实时通信_6_案例1
    • 前言
    • 类的定义
    • 各块功能
      • 后台
        • 上线
        • 下线
        • 修改昵称
        • 发送消息给所有人
      • 前台
        • 用户上线消息
        • 昵称改变消息
        • 用户下线消息
        • 更新个人信息
        • 用户上线提醒
        • 发送消息
        • 效果图
    • 结束语
    • 参考文献

前言

由于这段时间在找房子,所以耽误了一段时间。前几讲把一些基础的东西稍微介绍了下,这一讲就简单介绍一个小例子,大致功能是实现在线聊天,并显示在线用户、用户上下线实时提醒。这个例子并不复杂只是把之前介绍联系起来。

在这里为了简单起见,暂时不涉及到数据库的操作。

类的定义

用户信息类UserInfo

  1. public class UserInfo
  2. {
  4. /// <summary>
  5. /// ConnectionId
  6. /// </summary>
  7. public string ConnectionId { get; set; }
  8. /// <summary>
  9. /// 姓名
  10. /// </summary>
  11. public string Name { get; set; }
  12. /// <summary>
  13. /// 上线时间
  14. /// </summary>
  15. public DateTime ConnectedAt { get; set; }
  16. /// <summary>
  17. /// 在线标志
  18. /// </summary>
  19. public bool IsOnline { get; set; }
  20. }

各块功能

后台

上线

  1. public override Task OnConnected()
  2. {
  3. Interlocked.Increment(ref _usersCount);
  4. var user = new UserInfo()
  5. {
  6. ConnectionId = Context.ConnectionId,
  7. IsOnline = true,
  8. Name = "user" + _usersCount,
  9. ConnectedAt = DateTime.Now
  10. };
  11. _users[Context.ConnectionId] = user;
  12. var notifyAll = (Task)Clients.All.NewUserNotification(user);
  13. var updateMessage = (Task)Clients.Caller.UpdateMessage(user.Name, _users.Values.ToArray());
  14. var sendToAll = (Task)Clients.Others.welcome(_users.Values.ToArray());
  15. return notifyAll.ContinueWith(_ => updateMessage).ContinueWith(_ => sendToAll);
  16. }

下线

  1. public override Task OnDisconnected()
  2. {
  3. UserInfo user;
  4. if (_users.TryRemove(Context.ConnectionId, out user))
  5. {
  6. return Clients.All.UserDisconnectedNotification(user);
  7. }
  8. return base.OnDisconnected();
  9. }

修改昵称

  1. public Task ChangeNickname(string newName)
  2. {
  3. UserInfo user;
  4. if (_users.TryGetValue(Context.ConnectionId, out user))
  5. {
  6. var oldName = user.Name;
  7. user.Name = newName;
  8. return Clients.All.NicknameChangedNotification(user, oldName);
  9. }
  10. return null;
  11. }

发送消息给所有人

  1. public Task Send(string message)
  2. {
  3. UserInfo user;
  4. if (_users.TryGetValue(Context.ConnectionId, out user))
  5. {
  6. var msgToSend = string.Format("[{0}]: {1}", user.Name, message);
  7. return Clients.All.Message(msgToSend);
  8. }
  9. return null;
  10. }

前台

用户上线消息

  1. function newUserNotification(user) {
  2. if (getUserElement(user.ConnectionId).length == 0) {
  3. $("#users").append($(getUserListItem(user)));
  4. }
  5. systemMessage("欢迎 " + user.Name + " 用户进入聊天室!");
  6. }

昵称改变消息

  1. function nicknameChangedNotification(user, oldName) {
  2. var userElement = getUserElement(user.ConnectionId);
  3. if (userElement.length > 0) {
  4. userElement.replaceWith($(getUserListItem(user)));
  5. systemMessage(oldName + " 改名为 " + user.Name + ".");
  6. }
  7. if (user.Id === $.connection.hub.id) {
  8. $("#name").text(user.Name);
  9. }

用户下线消息

  1. function userDisconnectedNotification(user) {
  2. var userElement = getUserElement(user.ConnectionId);
  3. if (userElement.length > 0) {
  4. systemMessage(user.Name + " 离开聊天室.");
  5. userElement.remove();
  6. }
  7. }

更新个人信息

  1. function updateMessage(assignedNickname, userList) {
  2. var result = "";
  3. for (var i = 0; i < userList.length; i++) {
  4. var user = userList[i];
  5. result += getUserListItem(user);
  6. }
  7. $("#users").empty();
  8. $("#users").append(result);
  9. $("#username").text(assignedNickname);
  10. $("#user-info").show();
  11. }

用户上线提醒

  1. function welcome(userList) {
  2. var result = "";
  3. for (var i = 0; i < userList.length; i++) {
  4. var user = userList[i];
  5. result += getUserListItem(user);
  6. }
  7. $("#users").empty();
  8. $("#users").append(result);
  9. }

发送消息

  1. function message(message) {
  2. var $panel = $("#chatpanel");
  3. $panel.append("<li class='list-group-item'>" + message + "</li>");
  4. $panel.scrollTop($panel[0].scrollHeight);
  5. }

效果图

一步一步学习SignalR进行实时通信_6_案例

结束语

功能较为简单,本来还加了其他的功能,但是由于最近太忙了,打好了一半然后又全部删掉了,后面有时间再慢慢加上去。

源码下载

本文发布至 作业部落

参考文献

SignalR Programming in Microsoft ASP.NET pdf 下载

正文到此结束
所属分类： 编程技术

热门推荐

相关文章

阿里云首购8折
说给你听

本文目录
随机标签
书籍教程
springboot-demo Java入门教程 bootstrap3 CSS Apache基础教程 php ionic 教程 Python mysql教程 eclipse Ubuntu VPS系统配置 AngularJS 教程 MongoDB教程 Struts2教程 Redis教程 Spring教程 Git教程 Java设计模式 Jenkins进阶系列 openfire参考指南 HBase教程 Maven教程 hibernate教程 Docker 教程 memcached教程 Quartz指南 Hive教程 ANTLR教程 Ant教程 java实例教程 SpringCloud Elastic-Job-Lite XStream教程 深入浅出MyBatis Hazelcast教程 ibaties教程 SVN教程 rabittmq教程 Hadoop教程 solr教程 WebService CXF学习 springcloud-demo JPA教程 ActiveMQ中文指南 Java内存模型 java-demo dubbo教程 Linux入门视频教程
近期评论
  1. 1 Spring Cloud Circuit Breaker快速入门Demo
  2. 2 Spring Cloud Bus快速入门Demo
  3. 3 Spring Cloud Config快速入门Demo
  4. 4 Spring Cloud Function快速入门Demo
  5. 5 SSPanel-Uim搭建教程 2023年全新定制版主题-解决老版本命令失效问题
  6. 6 Spring Boot集成Milvus和deeplearning4j实现图搜图功能
  7. 7 Spring Boot集成Aviator实现参数校验
  8. 8 ACME自动申请免费的通配符https域名证书
  9. 9 wordpress 数据库和文件优化
  10. 10 CentOS安装Docker与Docker-Compose
网站信息
  • 文章总数：82,696 篇
  • 文件总数：284,257 个
  • 标签总数：2,380 个
  • 分类总数：84 个
  • 留言数量：2,560 条
  • 在线人数：610 人
  • 运行天数：4,392天
  • 最后更新：2024年11月05日20点
Loading...

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

[HBLOG]公众号 HBLOG HBLOG