cncml手绘网

标题: 在IIS上搭建WebSocket服务器（二） [打印本页]

---

作者: admin    时间: 2018-11-7 00:43
标题: 在IIS上搭建WebSocket服务器（二）

服务器端代码编写

1.新建一个ASP.net Web MVC5项目

$ K8 |5 j2 R- b2 X1 u" E

2.新建一个“一般处理程序”

3.Handler1.ashx代码如下：

1. using System;
   ) ?& O0 s0 ]0 l8 n6 t5 p, t
2. using System.Collections.Generic;
   0 Z8 K) w8 Y6 I- `/ D( _
3. using System.Linq;
   
4. using System.Net.WebSockets;
   : `4 z. U" N* f+ U
5. using System.Text;
   4 y: P; |+ ^5 K9 F/ G+ k2 X  Q
6. using System.Threading;
   # ^) {' |# @- m+ U8 c# P
7. using System.Threading.Tasks;
   
8. using System.Web;
   ) m0 Q) u1 K' ?& V
9. using System.Web.WebSockets;
   2 J0 M+ z' O- U
10. 
    + B& N; H8 d2 a$ z; T: V5 K
11. 
    
12. namespace WebApplicationWebsocketHandler
    & O1 n  H+ G" G6 B* k$ |
13. {
    . r& I. A. [# x
14.     /// <summary>
    ' y% G( a/ U0 o' c1 x. z& R
15.     /// 离线消息
    
16.     /// </summary>
    # V% D4 W' q! E6 e" s& M
17.     public class MessageInfo
    8 ?3 \* n5 k( z2 t' t. v
18.     {
    
19.         public MessageInfo(DateTime _MsgTime, ArraySegment<byte> _MsgContent)
    
20.         {
    
21.             MsgTime = _MsgTime;
    
22.             MsgContent = _MsgContent;
    
23.         }
    
24.         public DateTime MsgTime { get; set; }
    9 X6 \# ]( E) F: W+ \
25.         public ArraySegment<byte> MsgContent { get; set; }
    
26.     }
    5 u" F2 i. D4 i3 e3 @5 B
27. 
    1 e8 t; z- H; s( E
28. 
    $ m2 _( d4 p$ Y1 m  T0 N& Q' ]7 ^  J/ q
29. 
    ; N# r6 t% a- i1 e  U) _! _
30. 
    
31.     /// <summary>
    
32.     /// Handler1 的摘要说明
    # ~( {4 B. G7 i0 x
33.     /// </summary>
    
34.     public class Handler1 : IHttpHandler
    " q* L) x) D+ ]( {0 ]
35.     {
    ( F  v- f: j0 F2 b/ [3 k
36.         private static Dictionary<string, WebSocket> CONNECT_POOL = new Dictionary<string, WebSocket>();//用户连接池
    9 H- B/ i  U6 g  r* ^
37.         private static Dictionary<string, List<MessageInfo>> MESSAGE_POOL = new Dictionary<string, List<MessageInfo>>();//离线消息池
    9 {& Z$ H; L( b0 {9 T+ t  z
38.         public void ProcessRequest(HttpContext context)
    ) d' l1 ~# x) H! b8 D& N5 O) P
39.         {
    
40.             //context.Response.ContentType = "text/plain";
    , t- Z  U2 F' z' C; L1 z$ v2 v
41.             //context.Response.Write("Hello World");
    
42.             if (context.IsWebSocketRequest)
    0 a* R; X7 {2 `4 m7 L4 K# {
43.             {
    
44.                 context.AcceptWebSocketRequest(ProcessChat);
    : h2 o1 A& f3 j
45.             }
    
46.         }
    
47. 
    6 p" V2 T# B# p' o" c
48.         private async Task ProcessChat(AspNetWebSocketContext context)
    5 q$ l0 Y( ^# c+ c+ X4 z2 p6 y1 k6 Q
49.         {
    & u2 _% Q7 j# U# `
50.             WebSocket socket = context.WebSocket;
    
51.             string user = context.QueryString["user"].ToString();
    
52. 
    # F/ C, j2 R% G
53.             try
    
54.             {
    
55.                 #region 用户添加连接池
    
56.                 //第一次open时，添加到连接池中
    
57.                 if (!CONNECT_POOL.ContainsKey(user))
    
58.                     CONNECT_POOL.Add(user, socket);//不存在，添加
    
59.                 else
    
60.                     if (socket != CONNECT_POOL[user])//当前对象不一致，更新
    
61.                         CONNECT_POOL[user] = socket;
    / E  z+ X' Y6 I+ u7 m8 ]# ]
62.                 #endregion
      z" A- i, ?1 j% O2 V# d. ?% u
63. 
    
64.                 #region 离线消息处理
    
65.                 if (MESSAGE_POOL.ContainsKey(user))
    * k' I# ~2 F& r3 E+ ]& d* K
66.                 {
    5 P7 B! w( C2 ~
67.                     List<MessageInfo> msgs = MESSAGE_POOL[user];
    
68.                     foreach (MessageInfo item in msgs)
    # V% Z, A$ `4 \
69.                     {
    
70.                         await socket.SendAsync(item.MsgContent, WebSocketMessageType.Text, true, CancellationToken.None);
    
71.                     }
      |4 `# M& R$ {+ P
72.                     MESSAGE_POOL.Remove(user);//移除离线消息
    2 w, E# t0 R1 N& k; g: J3 {
73.                 }
    
74.                 #endregion
    - N( ~' y5 `4 k; v
75. 
    
76.                 string descUser = string.Empty;//目的用户
    
77.                 while (true)
    " {' X+ S+ T9 a. V+ Y) {: F; ~
78.                 {
    
79.                     if (socket.State == WebSocketState.Open)
    4 t7 O. p; C9 R( A$ M
80.                     {
    ! R% Y6 u$ g. P0 N8 R( h
81.                         ArraySegment<byte> buffer = new ArraySegment<byte>(new byte[2048]);
    ( y) i8 i! c+ t0 i2 Q7 Q$ R" \( Z4 V
82.                         WebSocketReceiveResult result = await socket.ReceiveAsync(buffer, CancellationToken.None);
    
83. 
    , k1 [3 h3 O6 T1 v6 ], L
84.                         #region 消息处理（字符截取、消息转发）
    
85.                         try
    5 j3 q0 @1 z) S5 ]& B
86.                         {
    
87.                             #region 关闭Socket处理，删除连接池
    
88.                             if (socket.State != WebSocketState.Open)//连接关闭
    
89.                             {
    
90.                                 if (CONNECT_POOL.ContainsKey(user)) CONNECT_POOL.Remove(user);//删除连接池
    ' v6 q, T0 E( T" T
91.                                 break;
    + f7 d+ k! A/ r
92.                             }
    & t" t! m$ Z3 |* Q' [. U0 u
93.                             #endregion
    
94. 
    
95.                             string userMsg = Encoding.UTF8.GetString(buffer.Array, 0, result.Count);//发送过来的消息
    7 ?! T# P3 u, E- l* Z
96.                             string[] msgList = userMsg.Split('|');
    % o( R3 }* [# g0 g, ^0 Z/ A
97.                             if (msgList.Length == 2)
    ( q$ d9 O% n0 b, Z" H+ d
98.                             {
    
99.                                 if (msgList[0].Trim().Length > 0)
    
100.                                     descUser = msgList[0].Trim();//记录消息目的用户
     
101.                                 buffer = new ArraySegment<byte>(Encoding.UTF8.GetBytes(msgList[1]));
     - J6 }! |+ B0 m! `3 L/ W% {, z% A
102.                             }
     
103.                             else
     $ S2 G( R1 G2 r# x
104.                                 buffer = new ArraySegment<byte>(Encoding.UTF8.GetBytes(userMsg));
     
105. 
     
106.                             if (CONNECT_POOL.ContainsKey(descUser))//判断客户端是否在线
     
107.                             {
     
108.                                 WebSocket destSocket = CONNECT_POOL[descUser];//目的客户端
     ' W1 z: J4 `! k: c+ j( z
109.                                 if (destSocket != null && destSocket.State == WebSocketState.Open)
     
110.                                     await destSocket.SendAsync(buffer, WebSocketMessageType.Text, true, CancellationToken.None);
     ' T) S6 [0 N: x) \9 N; \
111.                             }
     
112.                             else
     
113.                             {
     
114.                                 Task.Run(() =>
     
115.                                 {
     
116.                                     if (!MESSAGE_POOL.ContainsKey(descUser))//将用户添加至离线消息池中
     ; G, S2 a& k1 e$ V1 U
117.                                         MESSAGE_POOL.Add(descUser, new List<MessageInfo>());
       x/ u9 c; {) H7 R
118.                                     MESSAGE_POOL[descUser].Add(new MessageInfo(DateTime.Now, buffer));//添加离线消息
     3 C! u5 A6 a4 \  o& L4 p
119.                                 });
     3 M& K; W2 O7 e6 k
120.                             }
     7 {$ M! \7 n+ N9 ?# }
121.                         }
     
122.                         catch (Exception exs)
     
123.                         {
     
124.                             //消息转发异常处理，本次消息忽略 继续监听接下来的消息
     
125.                         }
     
126.                         #endregion
     
127.                     }
     ( n8 R0 r7 m# i6 V6 K
128.                     else
     - z  `. f% k, s/ N1 }
129.                     {
     
130.                         break;
     ! {3 ^2 m; x) q: m* V9 Y1 l
131.                     }
     
132.                 }//while end
     % A6 Z( v' _7 @: a
133.             }
     
134.             catch (Exception ex)
     ' x* t  V$ Y  Q1 O. [7 M- F. M5 r
135.             {
     . H' A# G" ]6 X# V  `- U5 |
136.                 //整体异常处理
     
137.                 if (CONNECT_POOL.ContainsKey(user)) CONNECT_POOL.Remove(user);
     4 Q, V- _! f+ i/ }  D( z% {+ d; d
138.             }
     
139.         }
       R. C3 l2 v) \# A  ]
140. 
     9 K8 g0 M% \% E. \2 M" M( g
141. 
     , ~1 u( A: o. l" X* n
142.         public bool IsReusable
     
143.         {
     
144.             get
     
145.             {
     + B% [! T6 n3 k& T, g
146.                 return false;
     - C  C) Q: K) n$ f
147.             }
     
148.         }
     1 ?$ w( N4 h) H5 V5 z# _
149.     }
     
150. }

复制代码

4.运行看是否报错，若没错将我们的服务器网站发布到IIS（支持WebSocket的IIS上，win7的系统时不可以的）上

点击“生成”->"发布........",以文件系统的方式发布，目标位置为我们创建的IIS网站对应的物理路径

---

欢迎光临 cncml手绘网 (http://www.cncml.com/)

Powered by Discuz! X3.2