目录

• 写在开始
• 技术点
  • 接受方式
  • 判读在线方式
  • 接受数据
  • 发送数据
•  敬上代码
  • 入口函数
  • 消息处理
  •  单聊实现
•  传送门：

写在开始

上面一篇写了一篇使用WebSocket做客户端，然后服务端是socke代码实现的。传送门：webSocket和Socket实现聊天群发

本来我是打算写到一章上的，毕竟实现的都是一样的功能，后来想了想就没写在一起，主要是两个方面，

一个原因是这是另一种实现服务方式，放在一起看着有点乱。单独写也方便查阅。二是写是分开写的回家晚上写一点，不能直接在原文上写，就重新起来一个草稿，但是写完就感觉有点懒，不想整合到一块了。嘿嘿，，，

所以对开头说的不明白的同学可以先看一下前面的东西。看一下基础，事半功倍哦。

这一篇不做功能的更改，既然我们使用了WebSocket为什么不使用到底哪，我不喜欢socket的里面出现的打包请求连接数据处理和发送数据处理。可以没有问题啊。那你继续往下看吧。

首先WebSocket服务器这篇我们还是实现的6个功能：

• 单聊：可以指定人进行聊天。
• 群发：这个的意思就是当前服务器内的所有人包含自己，这个就跟一个推送效果一样。
• 开启连接（客户端）：通知除自己以外的所有用户
• 关闭连接（客户端）：通知除自己以外的所有用户
• 群组A：实现一个群组名字为A
• 群组B：实现一个群组名字为B

技术点

前端写法都是一样的我就不做过多的叙述了，这里只要是针对socket协议的方法进行修改成WebSocket形式。

首先我这次是把服务写成了一般处理程序进行挂载的。（有些有强迫症的小伙伴想改访问路由路径可以参考一下：mvc中路由的映射和实现IHttpHandler挂载

我在本示例就是把放在model下的一个一般处理程序，改写成了socket路径.

原来访问是：http“//http://localhost:端口号/文件夹位置/SocketServer.ashx

改完之后是：http“//http://localhost:端口号/socket/SocketServer.ashx

在实际项目中可以不暴露文件的真是路径位置，还是有点用处的。

不得不说WebSocket确实不错，比如接受发送数据解析方法都给封装好了。

接受方式

既然使用WebSocket做协议当然接受就不用用socket而是使用WebSocket啦。通过在接受到请求后获取上下文中的WebSocket。

            //创建新WebSocket实例             
WebSocket myClientSocket = context.WebSocket;             
string userId = context.QueryString["userId"];

在这里我们有一点变化就是socke用户是通过socket随机获取的，这里我修改成了页面传输。前台代码：

 var userId = parseInt(Math.random() * (999999 - 100000 + 1) + 100000, 10);         
console.log(userId)         
ws = new WebSocket('ws://' + window.location.hostname + ':' + window.location.port + '/socket?userId=' + userId);

判读在线方式

WebSocket有单独的状态来进行在线的判断，不用我们自己写判断处理还是比较好的。

#region 关闭Socket处理，删除连接池                             
if (myClientSocket.State != WebSocketState.Open)//连接关闭                             {                                 
    if (ListUser.ContainsKey(userId)) ListUser.Remove(userId);//删除连接池                                 
         break;                             }                             #endregion

接受数据

WebSocket也没有辜负我们的期望，接受数据的处理也不需要我们处理的，使用ReceiveAsync方法可以得到消息字节，我们只需要定义一个字节数组段用来接受即可，例如：

ArraySegment<byte> buffer = new ArraySegment<byte>(new byte[2048]);//定义字节数组                         
WebSocketReceiveResult result = await myClientSocket.ReceiveAsync(buffer, CancellationToken.None);//获得字节                         string userMsg = Encoding.UTF8.GetString(buffer.Array, 0, result.Count);//发送过来的消息

是不是感觉特别的方便，没有了那些乱七八糟的处理了。看着还是挺舒心的。

发送数据

既然接受数据都有单独的方法封装，发送消息没有道理没有的，是的发送使用SendAsync方法，使用形式和ReceiveAsync类似，首先定义一个字节数组段用来存放内容，例如：

ArraySegment<byte> buffer = new ArraySegment<byte>(Encoding.UTF8.GetBytes($"用户（{userIdA}=>{userIdB}）:{msg}"));                         socket.SendAsync(buffer, WebSocketMessageType.Text, true, CancellationToken.None);

这样子就是一个发送过程，先把要发送的字符串转换成字节数组段，然后把这个数组段使用SendAsync发送出去就可以了。

 注：在上面的两个方法中我们都看到了ArraySegment这个东西，他到底是个什么哪，他是一个命名在System命名空间下的一个结构体。类似与Array数组但是他又不是数组，为什么这么说，因为他可以接受数组段，他可以只保存内容中的一部分而不是全部。就像别人说的小抽屉一样。我是把他理解成先把他放到这里当作数据缓存区，等真实发送的时候进行发送数据。WebSocketMessageType是一个枚举类型，通过F12可以看到：

// 摘要:     
//     指示消息类型：     
public enum WebSocketMessageType     {         
//         
// 摘要:         
//     该消息是明文形式。         
   Text = 0,         
//         
// 摘要:         
//     消息采用二进制格式。         
   Binary = 1,         
//         
// 摘要:         
//     因为收到关闭的消息，接受已完成。        
     Close = 2     }

回到顶部

 敬上代码

入口函数

一般处理程序中判断只接受WebSocket协议连接进入的运行：

if (context.IsWebSocketRequest)            
  {                 
     context.AcceptWebSocketRequest(Accept);             
   }             
   else            
  {            
  }

消息处理

下面就是同意连接后的主要方法，类似上一篇写的ReceiveMessage方法（接受消息），这里的处理存在一些改动，所以我就把所有代码贴上来了。

 单聊实现

这里我就不把写的所有单聊，群里，实现群组方法贴上来了，实现的思路还是和以前一样，只是写法不同，我就写一个单聊作为代表示例贴上来。想看全部在下面下载源码就好了。

也可以看看 GoEasy文库 的其他资料.