HTML5WebSocket实现实时视频文字传输

HTML5 拥有许多引人注目的新特性，如 Canvas、本地存储、多媒体编程接口、WebSocket 等等。虽然现在大家把它捧的很火的样子,但是个人认为它还需要其他平台的支持才能真正的"火起来"。

成都创新互联是一家集网站建设,秀英企业网站建设,秀英品牌网站建设,网站定制,秀英网站建设报价,网络营销,网络优化,秀英网站推广为一体的创新建站企业，帮助传统企业提升企业形象加强企业竞争力。可充分满足这一群体相比中小企业更为丰富、高端、多元的互联网需求。同时我们时刻保持专业、时尚、前沿，时刻以成就客户成长自我，坚持不断学习、思考、沉淀、净化自己，让我们为更多的企业打造出实用型网站。

原来做web通信的时候 基于ajax的“轮询” “长轮询”等其他的方式 网上有很详细的解释

轮询：

这是最早的一种实现实时 Web 应用的方案。客户端以一定的时间间隔向服务端发出请求，以频繁请求的方式来保持客户端和服务器端的同步。这种同步方案的***问题是，当客户端以固定频率向服务器发起请求的时候，服务器端的数据可能并没有更新，这样会带来很多无谓的网络传输，所以这是一种非常低效的实时方案。

长轮询：

长轮询是对定时轮询的改进和提高，目地是为了降低无效的网络传输。当服务器端没有数据更新的时候，连接会保持一段时间周期直到数据或状态改变或者时间过期，通过这种机制来减少无效的客户端和服务器间的交互。当然，如果服务端的数据变更非常频繁的话，这种机制和定时轮询比较起来没有本质上的性能的提高。

流：

流技术方案通常就是在客户端的页面使用一个隐藏的窗口向服务端发出一个长连接的请求。服务器端接到这个请求后作出回应并不断更新连接状态以保证客户端和服务器端的连接不过期。通过这种机制可以将服务器端的信息源源不断地推向客户端。这种机制在用户体验上有一点问题，需要针对不同的浏览器设计不同的方案来改进用户体验，同时这种机制在并发比较大的情况下，对服务器端的资源是一个极大的考验。

最近WebSocket很火啊,曾经做通信都用的 长轮询 后来.Net平台上用上 “SignalR（关于这个有兴趣的可以和我讨论这里就不多说了）”这个血牛B的神器可以看看jabbr（基于它实现的多人聊天室,可能你访问不到这个网站,请自备XX工具访问 ）和老外一起讨论技术是不是很爽?

简单的介绍下SignalR 

SignalR 是一个集成的客户端与服务器库，基于浏览器的客户端和基于 ASP.NET 的服务器组件可以借助它来进行双向多步对话。 换句话说，该对话可不受限制地进行单个无状态请求/响应数据交换；它将继续，直到明确关闭。 对话通过***连接进行，允许客户端向服务器发送多个消息，并允许服务器做出相应答复，值得注意的是，还允许服务器向客户端发送异步消息。它和AJax类似，都是基于现有的技术。本身是一个复合体。一般情况下，SignalR会使用Javascript的长轮询（ long polling），实现客户端和服务端通信。在WebSockets出现以后，SignalR也支持WebSockets通信(前提是使用.NET4.5的版本基于IIS8后面会有介绍)。当然SignalR也使用了服务端的任务并行处理技术以提高服务器的扩展性。

照官方的话讲SignalR它可以实现全双工的通信也就是实时的 而且它有一个“推送消息”的概念通过查看它的文档和源代码可以发现他也非常智能（自动检测当前浏览器和服务器是否支持websocket如果支持则使用websocket通信否则是长轮询），最牛X的是他是跨平台的可以基于Mono！！！！

Mono！

多么牛X的框架！神马IOS Android都能使用它！而且Android有一个叫做 SignalA(Signal for Android 不过它只支持Persistent Connections的连接方式)的框架可以***结合.Net做通信 我已经用上了 ^_^

Node Js 里面有个 socket.io 的东西 目测使用方法和SignalR 非常的类似（指的是Signal 的 Hub连接方式） 稍后会介绍的。

继续说WebSocket 从w3c上看文档能够看到一些东西的比如

客户端发到服务器的内容:

1.GET /chat HTTP/1.1

2.Host: server.example.com

3.Upgrade: websocket

4.Connection:Upgrade

5.Sec-WebSocket-Key: dGhlIHNhbXBsZSBub25jZQ==

6.Origin: http://example.com

7.Sec-WebSocket-Protocol: chat, superchat

8.Sec-WebSocket-Version:13

从服务器到客户端的内容:

1.HTTP/1.1101SwitchingProtocols

2.Upgrade: websocket

3.Connection:Upgrade

4.Sec-WebSocket-Accept: s3pPLMBiTxaQ9kYGzzhZRbK+xOo=

5.Sec-WebSocket-Protocol: chat

关于这个概念 可以去参考 WebSocket简单使用(一) - 概念然后今天要说的是 利用HTML5的 WebSocket做传输基础然后Canvas绘图 来实现视频实时传输首先说一下平台 Chrome和Safari的***版本浏览器已经支持是绝对可以的 火狐也可以（好像要用MozWebSocket） 然后恭喜IE10也支持了 最奇葩的时 Windows Phone8上的浏览器也支持参照网上的（来源自）先写一个简单的Demo应该是这样

#p#

客户端

在支持WebSocket的浏览器中，可以直接在Javascript中通过WebSocket对象来实现通信。WebSocket对象主要通过onopen，onmessage，onclose即onerror四个事件实现对socket消息的异步响应。

请创建静态页面 不用创建ruant=“server”的 否则会自动reload

 
 
 
 
    
  
  
  
  
  1.  
    2.   
  
  
  
  2.  
    3.   
  
  
  
  3.  
    4.   
  
  
  
  4.  
    5.   
  
  
  
  5.      
    6.   
  
  
  
  6.      
    7.   
  
  
  
  7.         var wsServer = 'ws://localhost:9999/webSocket.ashx'; //基于.NET4.5服务器地址  
    8.   
  
  
  
  8.         //var wsServer = 'ws://localhost:1818'; //基于.NET服务器地址  
    9.   
  
  
  
  9.  
    10.   
  
  
  
  10.         var websocket = new WebSocket(wsServer); //创建WebSocket对象  
    11.   
  
  
  
  11.         //websocket.send("hello");//向服务器发送消息  
    12.   
  
  
  
  12.         //alert(websocket.readyState);//查看websocket当前状态  
    13.   
  
  
  
  13.         websocket.onopen = function (evt) {  
    14.   
  
  
  
  14.             //已经建立连接  
    15.   
  
  
  
  15.             alert("已经建立连接");  
    16.   
  
  
  
  16.         };  
    17.   
  
  
  
  17.         websocket.onclose = function (evt) {  
    18.   
  
  
  
  18.             //已经关闭连接  
    19.   
  
  
  
  19.             alert("已经关闭连接");  
    20.   
  
  
  
  20.         };  
    21.   
  
  
  
  21.         websocket.onmessage = function (evt) {  
    22.   
  
  
  
  22.             //收到服务器消息，使用evt.data提取  
    23.   
  
  
  
  23.             evt.stopPropagation()  
    24.   
  
  
  
  24.             evt.preventDefault()  
    25.   
  
  
  
  25.             //alert(evt.data);  
    26.   
  
  
  
  26.             writeToScreen(evt.data);  
    27.   
  
  
  
  27.             //websocket.close();  
    28.   
  
  
  
  28.         };  
    29.   
  
  
  
  29.         websocket.onerror = function (evt) {  
    30.   
  
  
  
  30.             //产生异常  
    31.   
  
  
  
  31.             //alert(evt.message);  
    32.   
  
  
  
  32.             writeToScreen(evt.message);  
    33.   
  
  
  
  33.         };  
    34.   
  
  
  
  34.         function sendMsg() {  
    35.   
  
  
  
  35.             if (websocket.readyState == websocket.OPEN) {  
    36.   
  
  
  
  36.                 msg = document.getElementById("msg").value;  
    37.   
  
  
  
  37.                 websocket.send(msg);  
    38.   
  
  
  
  38.                 writeToScreen("发送成功!");  
    39.   
  
  
  
  39.             } else {  
    40.   
  
  
  
  40.                 writeToScreen("连接失败!");  
    41.   
  
  
  
  41.             }  
    42.   
  
  
  
  42.         }  
    43.   
  
  
  
  43.  
    44.   
  
  
  
  44.         function writeToScreen(message) {  
    45.   
  
  
  
  45.             var pre = document.createElement("p");  
    46.   
  
  
  
  46.             pre.style.wordWrap = "break-word";  
    47.   
  
  
  
  47.             pre.innerHTML += message;  
    48.   
  
  
  
  48.             output.appendChild(pre);  
    49.   
  
  
  
  49.         }  
    50.   
  
  
  
  50.      
    51.   
  
  
  
  51.  
    52.   
  
  
  
  52.  
    53.   
  
  
  
  53.     
     
    54.   
  
  
  
  54.          
    55.   
  
  
  
  55.         send 
    56.   
  
  
  
  56.     
 
  •     
    •  
  •  
  •  

    • readyState表示连接有四种状态：

    CONNECTING (0)：表示还没建立连接；

    OPEN (1)： 已经建立连接，可以进行通讯；

    CLOSING (2)：通过关闭握手，正在关闭连接；

    CLOSED (3)：连接已经关闭或无法打开；

    url是代表 WebSocket 服务器的网络地址，协议通常是”ws”或“wss(加密通信)”,send 方法就是发送数据到服务器端；

    close 方法就是关闭连接；

    onopen连接建立，即握手成功触发的事件；

    onmessage收到服务器消息时触发的事件；

    onerror异常触发的事件；

    onclose关闭连接触发的事件；

    先说说基于.NET4.5的吧 ashx里面应该是这样写的

     
 
 
 
      
  
  
  
  
    1. 　　　　　　//得到当前WebSocket请求  
      2.   
  
  
  
    2.             HttpContext.Current.AcceptWebSocketRequest(async (context) =>  
      3.   
  
  
  
    3.             {  
      4.   
  
  
  
    4.                 WebSocket socket = context.WebSocket;//Socket  
      5.   
  
  
  
    5.                 while (true)  
      6.   
  
  
  
    6.                 {  
      7.   
  
  
  
    7.                     ArraySegment buffer = new ArraySegment(new byte[1024]);  
      8.   
  
  
  
    8.                     CancellationToken token;  
      9.   
  
  
  
    9.                     WebSocketReceiveResult result =  
      10.   
  
  
  
    10.                             await socket.ReceiveAsync(buffer, token);  
      11.   
  
  
  
    11.                     if (socket.State == WebSocketState.Open)  
      12.   
  
  
  
    12.                     {  
      13.   
  
  
  
    13.                         string userMessage = Encoding.UTF8.GetString(buffer.Array, 0,  
      14.   
  
  
  
    14.                                 result.Count);  
      15.   
  
  
  
    15.                         userMessage = "You sent: " + userMessage + " at " +  
      16.   
  
  
  
    16.                                 DateTime.Now.ToLongTimeString();  
      17.   
  
  
  
    17.                         buffer = new ArraySegment(Encoding.UTF8.GetBytes(userMessage));  
      18.   
  
  
  
    18.                         await socket.SendAsync(buffer, WebSocketMessageType.Text,  
      19.   
  
  
  
    19.                                 true, CancellationToken.None);  
      20.   
  
  
  
    20.                     }  
      21.   
  
  
  
    21.                     else { break; }  
      22.   
  
  
  
    22.                 }  
      23.   
  
  
  
    23.             }); 
      24.

    然后需要注意的是 部署到IIS8上面  转到 Windows程序和功能 -打开Windows功能里面 IIS选项启动4.5 和WebSocket支持  否则会报错误的。

    如果你不是Windows8 或者IIS的问题 你可以使用其他方式实现websocket服务器 比如.net socket模拟（因为websocket本身就是基于TCP的完全可以模拟只是规则特别..）

    网上有人写了下面一段

     
 
 
 
      
  
  
  
  
    1. class Program  
      2.   
  
  
  
    2.   {  
      3.   
  
  
  
    3.       static void Main(string[] args)  
      4.   
  
  
  
    4.       {  
      5.   
  
  
  
    5.           int port = 1818;  
      6.   
  
  
  
    6.           byte[] buffer = new byte[1024];  
      7.   
  
  
  
    7.  
      8.   
  
  
  
    8.           IPEndPoint localEP = new IPEndPoint(IPAddress.Any, port);  
      9.   
  
  
  
    9.           Socket listener = new Socket(localEP.Address.AddressFamily,SocketType.Stream, ProtocolType.Tcp);  
      10.   
  
  
  
    10.             
      11.   
  
  
  
    11.           try{  
      12.   
  
  
  
    12.               listener.Bind(localEP);  
      13.   
  
  
  
    13.               listener.Listen(10);  
      14.   
  
  
  
    14.  
      15.   
  
  
  
    15.               Console.WriteLine("等待客户端连接....");  
      16.   
  
  
  
    16.               Socket sc = listener.Accept();//接受一个连接  
      17.   
  
  
  
    17.               Console.WriteLine("接受到了客户端："+sc.RemoteEndPoint.ToString()+"连接....");  
      18.   
  
  
  
    18.                 
      19.   
  
  
  
    19.               //握手  
      20.   
  
  
  
    20.               int length = sc.Receive(buffer);//接受客户端握手信息  
      21.   
  
  
  
    21.               sc.Send(PackHandShakeData(GetSecKeyAccetp(buffer,length)));  
      22.   
  
  
  
    22.               Console.WriteLine("已经发送握手协议了....");  
      23.   
  
  
  
    23.                 
      24.   
  
  
  
    24.               //接受客户端数据  
      25.   
  
  
  
    25.               Console.WriteLine("等待客户端数据....");  
      26.   
  
  
  
    26.               length = sc.Receive(buffer);//接受客户端信息  
      27.   
  
  
  
    27.               string clientMsg=AnalyticData(buffer, length);  
      28.   
  
  
  
    28.               Console.WriteLine("接受到客户端数据：" + clientMsg);  
      29.   
  
  
  
    29.  
      30.   
  
  
  
    30.               //发送数据  
      31.   
  
  
  
    31.               string sendMsg = "您好，" + clientMsg;  
      32.   
  
  
  
    32.               Console.WriteLine("发送数据：“"+sendMsg+"” 至客户端....");  
      33.   
  
  
  
    33.               sc.Send(PackData(sendMsg));  
      34.   
  
  
  
    34.                 
      35.   
  
  
  
    35.               Console.WriteLine("演示Over!");  
      36.   
  
  
  
    36.  
      37.   
  
  
  
    37.           }  
      38.   
  
  
  
    38.           catch (Exception e)  
      39.   
  
  
  
    39.           {  
      40.   
  
  
  
    40.               Console.WriteLine(e.ToString());  
      41.   
  
  
  
    41.           }  
      42.   
  
  
  
    42.       }  
      43.   
  
  
  
    43.  
      44.   
  
  
  
    44.       ///   
      45.   
  
  
  
    45.       /// 打包握手信息  
      46.   
  
  
  
    46.       ///   
      47.   
  
  
  
    47.       /// Sec-WebSocket-Accept  
      48.   
  
  
  
    48.       /// 数据包  
      49.   
  
  
  
    49.       private static byte[] PackHandShakeData(string secKeyAccept)  
      50.   
  
  
  
    50.       {  
      51.   
  
  
  
    51.           var responseBuilder = new StringBuilder();  
      52.   
  
  
  
    52.           responseBuilder.Append("HTTP/1.1 101 Switching Protocols" + Environment.NewLine);  
      53.   
  
  
  
    53.           responseBuilder.Append("Upgrade: websocket" + Environment.NewLine);  
      54.   
  
  
  
    54.           responseBuilder.Append("Connection: Upgrade" + Environment.NewLine);  
      55.   
  
  
  
    55.           responseBuilder.Append("Sec-WebSocket-Accept: " + secKeyAccept + Environment.NewLine + Environment.NewLine);  
      56.   
  
  
  
    56.           //如果把上一行换成下面两行，才是thewebsocketprotocol-17协议，但居然握手不成功，目前仍没弄明白！  
      57.   
  
  
  
    57.           //responseBuilder.Append("Sec-WebSocket-Accept: " + secKeyAccept + Environment.NewLine);  
      58.   
  
  
  
    58.           //responseBuilder.Append("Sec-WebSocket-Protocol: chat" + Environment.NewLine);  
      59.   
  
  
  
    59.  
      60.   
  
  
  
    60.           return Encoding.UTF8.GetBytes(responseBuilder.ToString());  
      61.   
  
  
  
    61.       }  
      62.   
  
  
  
    62.  
      63.   
  
  
  
    63.       ///   
      64.   
  
  
  
    64.       /// 生成Sec-WebSocket-Accept  
      65.   
  
  
  
    65.       ///   
      66.   
  
  
  
    66.       /// 客户端握手信息  
      67.   
  
  
  
    67.       /// Sec-WebSocket-Accept  
      68.   
  
  
  
    68.       private static string GetSecKeyAccetp(byte[] handShakeBytes,int bytesLength)  
      69.   
  
  
  
    69.       {  
      70.   
  
  
  
    70.           string handShakeText = Encoding.UTF8.GetString(handShakeBytes, 0, bytesLength);  
      71.   
  
  
  
    71.           string key = string.Empty;  
      72.   
  
  
  
    72.           Regex r = new Regex(@"Sec\-WebSocket\-Key:(.*?)\r\n");  
      73.   
  
  
  
    73.           Match m = r.Match(handShakeText);  
      74.   
  
  
  
    74.           if (m.Groups.Count != 0)  
      75.   
  
  
  
    75.           {  
      76.   
  
  
  
    76.               key = Regex.Replace(m.Value, @"Sec\-WebSocket\-Key:(.*?)\r\n", "$1").Trim();  
      77.   
  
  
  
    77.           }  
      78.   
  
  
  
    78.           byte[] encryptionString = SHA1.Create().ComputeHash(Encoding.ASCII.GetBytes(key + "258EAFA5-E914-47DA-95CA-C***B0DC85B11"));  
      79.   
  
  
  
    79.           return Convert.ToBase64String(encryptionString);  
      80.   
  
  
  
    80.       }  
      81.   
  
  
  
    81.  
      82.   
  
  
  
    82.       ///   
      83.   
  
  
  
    83.       /// 解析客户端数据包  
      84.   
  
  
  
    84.       ///   
      85.   
  
  
  
    85.       /// 服务器接收的数据包  
      86.   
  
  
  
    86.       /// 有效数据长度  
      87.   
  
  
  
    87.       ///   
      88.   
  
  
  
    88.       private static string AnalyticData(byte[] recBytes, int recByteLength)  
      89.   
  
  
  
    89.       {  
      90.   
  
  
  
    90.           if (recByteLength < 2) { return string.Empty; }  
      91.   
  
  
  
    91.  
      92.   
  
  
  
    92.           bool fin = (recBytes[0] & 0x80) == 0x80; // 1bit，1表示***一帧    
      93.   
  
  
  
    93.           if (!fin){  
      94.   
  
  
  
    94.               return string.Empty;// 超过一帧暂不处理   
      95.   
  
  
  
    95.           }  
      96.   
  
  
  
    96.  
      97.   
  
  
  
    97.           bool mask_flag = (recBytes[1] & 0x80) == 0x80; // 是否包含掩码    
      98.   
  
  
  
    98.           if (!mask_flag){  
      99.   
  
  
  
    99.               return string.Empty;// 不包含掩码的暂不处理  
      100.   
  
  
  
    100.           }  
      101.   
  
  
  
    101.  
      102.   
  
  
  
    102.           int payload_len = recBytes[1] & 0x7F; // 数据长度    
      103.   
  
  
  
    103.  
      104.   
  
  
  
    104.           byte[] masks = new byte[4];  
      105.   
  
  
  
    105.           byte[] payload_data;  
      106.   
  
  
  
    106.  
      107.   
  
  
  
    107.           if (payload_len == 126){  
      108.   
  
  
  
    108.               Array.Copy(recBytes, 4, masks, 0, 4);  
      109.   
  
  
  
    109.               payload_len = (UInt16)(recBytes[2] << 8 | recBytes[3]);  
      110.   
  
  
  
    110.               payload_data = new byte[payload_len];  
      111.   
  
  
  
    111.               Array.Copy(recBytes, 8, payload_data, 0, payload_len);  
      112.   
  
  
  
    112.  
      113.   
  
  
  
    113.           }else if (payload_len == 127){  
      114.   
  
  
  
    114.               Array.Copy(recBytes, 10, masks, 0, 4);  
      115.   
  
  
  
    115.               byte[] uInt64Bytes = new byte[8];  
      116.   
  
  
  
    116.               for (int i = 0; i < 8; i++){  
      117.   
  
  
  
    117.                   uInt64Bytes[i] = recBytes[9 - i];  
      118.   
  
  
  
    118.               }  
      119.   
  
  
  
    119.               UInt64 len = BitConverter.ToUInt64(uInt64Bytes, 0);  
      120.   
  
  
  
    120.  
      121.   
  
  
  
    121.               payload_data = new byte[len];  
      122.   
  
  
  
    122.               for (UInt64 i = 0; i < len; i++){  
      123.   
  
  
  
    123.                   payload_data[i] = recBytes[i + 14];  
      124.   
  
  
  
    124.               }  
      125.   
  
  
  
    125.           }else{  
      126.   
  
  
  
    126.               Array.Copy(recBytes, 2, masks, 0, 4);  
      127.   
  
  
  
    127.               payload_data = new byte[payload_len];  
      128.   
  
  
  
    128.               Array.Copy(recBytes, 6, payload_data, 0, payload_len);  
      129.   
  
  
  
    129.  
      130.   
  
  
  
    130.           }  
      131.   
  
  
  
    131.  
      132.   
  
  
  
    132.           for (var i = 0; i < payload_len; i++){  
      133.   
  
  
  
    133.               payload_data[i] = (byte)(payload_data[i] ^ masks[i % 4]);  
      134.   
  
  
  
    134.           }  
      135.   
  
  
  
    135.             
      136.   
  
  
  
    136.           return Encoding.UTF8.GetString(payload_data);  
      137.   
  
  
  
    137.       }  
      138.   
  
  
  
    138.  
      139.   
  
  
  
    139.  
      140.   
  
  
  
    140.       ///   
      141.   
  
  
  
    141.       /// 打包服务器数据  
      142.   
  
  
  
    142.       ///   
      143.   
  
  
  
    143.       /// 数据  
      144.   
  
  
  
    144.       /// 数据包  
      145.   
  
  
  
    145.       private static byte[] PackData(string message)  
      146.   
  
  
  
    146.       {  
      147.   
  
  
  
    147.           byte[] contentBytes = null;  
      148.   
  
  
  
    148.           byte[] temp = Encoding.UTF8.GetBytes(message);  
      149.   
  
  
  
    149.  
      150.   
  
  
  
    150.           if (temp.Length < 126){  
      151.   
  
  
  
    151.               contentBytes = new byte[temp.Length + 2];  
      152.   
  
  
  
    152.               contentBytes[0] = 0x81;  
      153.   
  
  
  
    153.               contentBytes[1] = (byte)temp.Length;  
      154.   
  
  
  
    154.               Array.Copy(temp, 0, contentBytes, 2, temp.Length);  
      155.   
  
  
  
    155.           }else if (temp.Length < 0xFFFF){  
      156.   
  
  
  
    156.               contentBytes = new byte[temp.Length + 4];  
      157.   
  
  
  
    157.               contentBytes[0] = 0x81;  
      158.   
  
  
  
    158.               contentBytes[1] = 126;  
      159.   
  
  
  
    159.               contentBytes[2] = (byte)(temp.Length & 0xFF);  
      160.   
  
  
  
    160.               contentBytes[3] = (byte)(temp.Length >> 8 & 0xFF);  
      161.   
  
  
  
    161.               Array.Copy(temp, 0, contentBytes, 4, temp.Length);  
      162.   
  
  
  
    162.           }else{  
      163.   
  
  
  
    163.               // 暂不处理超长内容    
      164.   
  
  
  
    164.           }  
      165.   
  
  
  
    165.  
      166.   
  
  
  
    166.           return contentBytes;  
      167.   
  
  
  
    167.       }    
      168.   
  
  
  
    168.   } 
      169.

    或者参考这里

    ok! 基本上能实现传输文字了,接下来是图像 可以通过base64编码的方式传输 也可以通过二进制传输

    #p#

    HTML5的Canvas 可以实现绘图 然后应该是这样写的

     
 
 
 
      
  
  
  
  
    1.  
      2.   
  
  
  
    2.  
      3.   
  
  
  
    3.  
      4.   
  
  
  
    4.      
      5.   
  
  
  
    5.  
      6.   
  
  
  
    6.  
      7.   
  
  
  
    7.     
       
      8.   
  
  
  
    8.          
      9.   
  
  
  
    9.         走你~ 
      10.   
  
  
  
    10.     
     
  •      
  •      
  •      
  •         var wsServer = 'ws://192.168.10.242:9999/webSocket.ashx'; //服务器地址  
  •         //var wsServer = 'ws://localhost:36027/webSocket.ashx'; //服务器地址  
  •         var canvas = document.getElementById("myCanvas");  
  •         var context = canvas.getContext("2d");  
  •         var websocket = new WebSocket(wsServer); //创建WebSocket对象  
  •         websocket.onopen = function (evt) {  
  •             //已经建立连接  
  •             alert("已经建立连接");  
  •         };  
  •         websocket.onclose = function (evt) {  
  •             //已经关闭连接  
  •             //alert("已经关闭连接");  
  •             writeToScreen("连接关闭");  
  •         };  
  •         websocket.onmessage = function (evt) {  
  •             //收到服务器消息，使用evt.data提取  
  •             var image = new Image();  
  •             image.onload = function () {  
  •                 //image.height  
  •                 context.clearRect(0, 0,  
  •                    canvas.width, canvas.height);  
  •                 context.drawImage(image, 0, 0, canvas.width, canvas.height);  
  •             }  
  •             image.src = URL.createObjectURL(evt.data);  
  •         };  
  •         websocket.onerror = function (evt) {  
  •             //产生异常  
  •             writeToScreen(evt.message);  
  •         };  
  •         function sendMsg() {  
  •             if (websocket.readyState == websocket.OPEN) {  
  •                 msg = document.getElementById("msg").value;  
  •                 websocket.send(msg);  
  •                 writeToScreen("发送成功!");  
  •             } else {  
  •                 writeToScreen("连接失败!");  
  •             }  
  •         }  
  •  
  •         function writeToScreen(message) {  
  •             var pre = document.createElement("p");  
  •             pre.style.wordWrap = "break-word";  
  •             pre.innerHTML += message;  
  •             output.appendChild(pre);  
  •         }  
  •      
  •  
  •  

    • 通过   context.drawImage(image, 0, 0, canvas.width, canvas.height); 来绘制图像

    websocket接到数据后通过

    image.src = URL.createObjectURL(evt.data);转换成图片对象

    ok 这样能实现接收图片了，然后服务端发送的时候

     
 
 
 
      
  
  
  
  
    1. //Buffer里面为你的图片数据 你可以通过文件流的方式来打开  
      2.   
  
  
  
    2. await socket.SendAsync(buffer, WebSocketMessageType.Binary,true, CancellationToken.None);  
      3.   
  
  
  
    3. //注意此时WebSocketMessageType 为Binary二进制流 
      4.

    然后我实现了一个 读取本地文件夹 每隔1秒发送图片给网页的服务端

    部分代码如下

     
 
 
 
      
  
  
  
  
    1.  string imgPath = HttpContext.Current.Server.MapPath("images");  
      2.   
  
  
  
    2.                string[] files = Directory.GetFiles(imgPath);  
      3.   
  
  
  
    3. for (int i = 0; i < files.Length; i++)  
      4.   
  
  
  
    4.                        {  
      5.   
  
  
  
    5.                            using (FileStream fs = new FileStream(files[i], FileMode.Open))  
      6.   
  
  
  
    6.                            {  
      7.   
  
  
  
    7.                                byte[] imgData = new byte[fs.Length];  
      8.   
  
  
  
    8.                                fs.Read(imgData, 0, imgData.Length);  
      9.   
  
  
  
    9.                                //buffer = new ArraySegment(Encoding.UTF8.GetBytes(userMessage));  
      10.   
  
  
  
    10.                                buffer = new ArraySegment(imgData);  
      11.   
  
  
  
    11.                                // Asynchronously send a message to the client  
      12.   
  
  
  
    12.                                await socket.SendAsync(buffer, WebSocketMessageType.Binary,  
      13.   
  
  
  
    13.                                        true, CancellationToken.None);  
      14.   
  
  
  
    14.                                Thread.Sleep(1000);  
      15.   
  
  
  
    15.                            }  
      16.   
  
  
  
    16.                            if (i == files.Length - 1)  
      17.   
  
  
  
    17.                                i = 0;  
      18.   
  
  
  
    18.                        } 
      19.

    这样图像传输解决了,然后实现套接字 就可以传输实时图片了。

    我做了一个Windows Phone的客户端不断的采集图片发送给服务器 然后服务器接到图片发送给浏览器的Demo 就不贴代码了 上图！

    (这张图是在Windows Phone模拟器里面的IE浏览器上 证明了 它支持WebSocket)

    （Windows 上的客户端 ^.^ Windows Phone Windows 8都能的 ）

    上面说的仅仅是简单的演示程序 距离做项目还差的很远，写这篇文章为的是给大家一个信心... Windows 8&Windows Phone也可以的...

    原文链接：http://www.cnblogs.com/beyondblog/archive/2013/04/11/3015756.html

    网页标题：HTML5WebSocket实现实时视频文字传输
    路径分享：http://www.gawzjz.com/qtweb2/news49/8299.html

    网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

    广告

    声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

    猜你还喜欢下面的内容

    定制网站知识

    同城分类信息

    蓬溪网站建设　　 　新华建筑装饰　　 　成都网站建设公司　　 　成都网站设计　　 　成都定制网站建设　　 　成都搬家公司　　 　无边发光字厂家　　 　成都网站制作　　 　巴中倍辉科技　　 　营销型网站建设　　 　成都网站建设　　 　西信服务器托管　　 　腾讯云免备案空间　　 　发光字制作　　 　平武做网站　　 　云服务器　　 　格蓝特设备　　 　网站优化排名　　 　内江做网站　　 　h5响应式网站