cncml手绘网

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

---

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

服务器端代码编写

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

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

3.Handler1.ashx代码如下：

1. using System;
   
2. using System.Collections.Generic;
   
3. using System.Linq;
     c1 F( b' ]4 R: B7 J
4. using System.Net.WebSockets;
   
5. using System.Text;
   " J& z( b/ m3 q6 s2 p
6. using System.Threading;
   
7. using System.Threading.Tasks;
   
8. using System.Web;
   3 _5 S2 \! z, N4 t: N
9. using System.Web.WebSockets;
   ' K7 ]2 W; U* i. i) T9 P
10. 
    7 W  ]" h7 E6 a3 I0 J/ k" h' Q* t
11. 
    
12. namespace WebApplicationWebsocketHandler
    : l/ a7 L! u# X0 L3 L! G- a
13. {
    
14.     /// <summary>
    
15.     /// 离线消息
    9 ~! p* N) a; F; {) ]% {* w
16.     /// </summary>
    
17.     public class MessageInfo
    
18.     {
    ' W+ W5 ?, ^  g' c
19.         public MessageInfo(DateTime _MsgTime, ArraySegment<byte> _MsgContent)
    ; F$ g6 b5 g" w& P. R. e8 p
20.         {
    
21.             MsgTime = _MsgTime;
    
22.             MsgContent = _MsgContent;
    
23.         }
    
24.         public DateTime MsgTime { get; set; }
    
25.         public ArraySegment<byte> MsgContent { get; set; }
    3 j* T! {0 F- S6 N, @& z
26.     }
    
27. 
    3 ~, A6 s" K5 U/ s2 ]2 J
28. 
    
29. 
    
30. 
    2 W3 O. c% ]& z6 h( T1 N
31.     /// <summary>
    ! `- z; e. y+ q5 B- m( i
32.     /// Handler1 的摘要说明
    
33.     /// </summary>
    % i. J. c. N% y/ ^
34.     public class Handler1 : IHttpHandler
    5 a5 x3 [/ Y4 U
35.     {
    
36.         private static Dictionary<string, WebSocket> CONNECT_POOL = new Dictionary<string, WebSocket>();//用户连接池
    
37.         private static Dictionary<string, List<MessageInfo>> MESSAGE_POOL = new Dictionary<string, List<MessageInfo>>();//离线消息池
    * O& A% ], ?$ I" B; W( w8 u& k
38.         public void ProcessRequest(HttpContext context)
    
39.         {
    7 G) H% \/ W7 j& i
40.             //context.Response.ContentType = "text/plain";
    
41.             //context.Response.Write("Hello World");
    2 ]% w# S' r5 p4 Q0 T
42.             if (context.IsWebSocketRequest)
    
43.             {
    : }( b1 \4 S7 v5 v# X
44.                 context.AcceptWebSocketRequest(ProcessChat);
    8 m2 U/ [6 E! q
45.             }
    
46.         }
    3 `" b9 m2 S$ R/ [( s' I
47. 
    
48.         private async Task ProcessChat(AspNetWebSocketContext context)
    7 _- d6 E) a1 e
49.         {
    
50.             WebSocket socket = context.WebSocket;
    
51.             string user = context.QueryString["user"].ToString();
    
52. 
    3 b0 w6 R, b7 C; O& Y- ~
53.             try
    
54.             {
    1 @5 k5 v" B( _
55.                 #region 用户添加连接池
    
56.                 //第一次open时，添加到连接池中
    1 n  d+ W4 p# s% m8 V* Y
57.                 if (!CONNECT_POOL.ContainsKey(user))
    
58.                     CONNECT_POOL.Add(user, socket);//不存在，添加
    % H+ I( c3 ?$ r
59.                 else
    2 m- I( X; Z; @" W9 d, {4 ]
60.                     if (socket != CONNECT_POOL[user])//当前对象不一致，更新
    
61.                         CONNECT_POOL[user] = socket;
    
62.                 #endregion
    
63. 
    4 _6 b# n# q) X. P% S
64.                 #region 离线消息处理
    
65.                 if (MESSAGE_POOL.ContainsKey(user))
    - l9 O5 i2 E* t. J* L2 d  D7 l
66.                 {
    ! @9 v& m* o# c/ r- {) p+ T8 X% s
67.                     List<MessageInfo> msgs = MESSAGE_POOL[user];
    2 S: K3 j5 @9 L, j* i" p
68.                     foreach (MessageInfo item in msgs)
    5 i0 e9 L: n  w; [/ {2 K
69.                     {
    ( P* I8 x/ l0 M! Z' `& @* W
70.                         await socket.SendAsync(item.MsgContent, WebSocketMessageType.Text, true, CancellationToken.None);
    
71.                     }
    4 E9 d5 U- i0 y) z
72.                     MESSAGE_POOL.Remove(user);//移除离线消息
    # _3 W! T% n" s2 j3 Q' X
73.                 }
    
74.                 #endregion
    " M1 N5 T3 i) j
75. 
    
76.                 string descUser = string.Empty;//目的用户
    $ z- t, r6 d" F  q
77.                 while (true)
    
78.                 {
    
79.                     if (socket.State == WebSocketState.Open)
    
80.                     {
    1 b  n: j: |# }! c1 K% a
81.                         ArraySegment<byte> buffer = new ArraySegment<byte>(new byte[2048]);
    8 ~# n& t/ A1 }
82.                         WebSocketReceiveResult result = await socket.ReceiveAsync(buffer, CancellationToken.None);
    ! O7 l+ N6 _, x" \8 x
83. 
    
84.                         #region 消息处理（字符截取、消息转发）
    
85.                         try
    
86.                         {
    # z; L; Z* u0 H& S/ P& f) Z- B: U0 i9 P
87.                             #region 关闭Socket处理，删除连接池
    
88.                             if (socket.State != WebSocketState.Open)//连接关闭
    
89.                             {
    
90.                                 if (CONNECT_POOL.ContainsKey(user)) CONNECT_POOL.Remove(user);//删除连接池
    
91.                                 break;
    
92.                             }
    
93.                             #endregion
    ; n1 g4 y( g6 T" A4 j
94. 
    
95.                             string userMsg = Encoding.UTF8.GetString(buffer.Array, 0, result.Count);//发送过来的消息
    ( z9 \' C. g1 n0 w( ?( a; x5 u
96.                             string[] msgList = userMsg.Split('|');
    1 T' \$ F1 y$ I+ }
97.                             if (msgList.Length == 2)
    
98.                             {
    8 Y: x+ U7 [9 U0 Y* F9 W
99.                                 if (msgList[0].Trim().Length > 0)
    
100.                                     descUser = msgList[0].Trim();//记录消息目的用户
     % D$ [! @) x, `- Q0 u. m( x
101.                                 buffer = new ArraySegment<byte>(Encoding.UTF8.GetBytes(msgList[1]));
     
102.                             }
     9 q# f6 w; X+ d( Y
103.                             else
     $ q& [# B6 V1 r1 z% A7 @1 ]7 n
104.                                 buffer = new ArraySegment<byte>(Encoding.UTF8.GetBytes(userMsg));
     6 X& w1 ?# W2 t& d0 e
105. 
     4 h( h7 m. D2 }7 k% [8 `
106.                             if (CONNECT_POOL.ContainsKey(descUser))//判断客户端是否在线
     + R: v8 }' ]) d- ~, V! O5 \
107.                             {
     % `* \- `$ a5 `
108.                                 WebSocket destSocket = CONNECT_POOL[descUser];//目的客户端
     0 }# o# n7 @+ ]5 V
109.                                 if (destSocket != null && destSocket.State == WebSocketState.Open)
     
110.                                     await destSocket.SendAsync(buffer, WebSocketMessageType.Text, true, CancellationToken.None);
     
111.                             }
     
112.                             else
     * Y* y* K  `  U" v6 i: f! N6 u" q3 |
113.                             {
     ( w$ ~; D9 {# w& ^% b: c$ y1 }9 b
114.                                 Task.Run(() =>
     ) r/ F" s+ H' |
115.                                 {
     / b, d# c- i( u& |
116.                                     if (!MESSAGE_POOL.ContainsKey(descUser))//将用户添加至离线消息池中
     
117.                                         MESSAGE_POOL.Add(descUser, new List<MessageInfo>());
     
118.                                     MESSAGE_POOL[descUser].Add(new MessageInfo(DateTime.Now, buffer));//添加离线消息
     , y2 u# ~! V/ c
119.                                 });
     
120.                             }
     + d. G0 {. U& X8 n8 \: o3 Y- z1 Z
121.                         }
     
122.                         catch (Exception exs)
     
123.                         {
     - I0 A% S) y; ^, D+ i8 |& C
124.                             //消息转发异常处理，本次消息忽略 继续监听接下来的消息
     
125.                         }
     
126.                         #endregion
     0 ]$ G- Z3 o* Z
127.                     }
     
128.                     else
     
129.                     {
     ' j  {$ F& }- C3 C/ [4 t: C
130.                         break;
     
131.                     }
     
132.                 }//while end
     
133.             }
     ( c5 o% R* _1 [$ [% r
134.             catch (Exception ex)
     
135.             {
     ' P; j: b9 C5 R$ c; m! i1 P! Y% J
136.                 //整体异常处理
     7 E% r8 w6 a6 K4 P7 x
137.                 if (CONNECT_POOL.ContainsKey(user)) CONNECT_POOL.Remove(user);
     ' |8 _0 S2 d5 S8 D
138.             }
     
139.         }
     : o9 \& o5 d0 v+ v( X5 ?2 F6 }
140. 
     
141. 
     0 E7 Q6 \6 U: l1 ~( o# Z
142.         public bool IsReusable
     / P6 j; c( q1 x5 x- m
143.         {
     7 v- O+ L: m6 U
144.             get
     : t* K7 Y" h" f5 W9 b/ s/ B- d
145.             {
     6 X' J, t& k. g# L& ?
146.                 return false;
     
147.             }
     ) e9 C, m$ W5 G9 D  y4 L9 P& ^9 Q
148.         }
     / K" N3 C6 S9 j% I7 M- q
149.     }
     1 S5 r) @# |& p1 S# R- z
150. }

复制代码

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

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

3 d6 z3 u& l' j* k  N4 q

---

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

Powered by Discuz! X3.2