2010-01-14 64 views
50

我想在我的Windows窗体或WPF应用程序中使用WebSockets。是否有.NET控件支持实现的WebSockets?还是有任何开源项目开始呢?是否有为.NET实现的WebSocket客户端?

支持WebSockets的Java客户端的开源解决方案也可以帮助我。

回答

20

,SuperWebSocket还包括的WebSocket客户端实现 SuperWebSocket Project Homepage

其他.NET客户端实现包括:

+1

我看不到在SuperWebSocket中关于客户端实现的任何内容?它还在吗? – 2011-11-27 04:48:03

+0

在源代码/主线/客户端 – 2011-12-08 08:14:54

+8

SuperWebSocket中的客户端已分离为WebSocket4Net:http://websocket4net.codeplex.com/ – 2012-01-09 02:31:24

1

这是一个非常简单的协议。有一个Java实现here,不应该太难以转换为C#。如果我开始这样做,我会在这里发布它...

24

下面是将Java代码移植到C#时的第一个快速入门。不支持SSL模式,只经过非常轻微的测试,但这是一个开始。

using System; 
using System.Collections.Generic; 
using System.IO; 
using System.Net; 
using System.Net.Sockets; 
using System.Text; 

public class WebSocket 
{ 
    private Uri mUrl; 
    private TcpClient mClient; 
    private NetworkStream mStream; 
    private bool mHandshakeComplete; 
    private Dictionary<string, string> mHeaders; 

    public WebSocket(Uri url) 
    { 
     mUrl = url; 

     string protocol = mUrl.Scheme; 
     if (!protocol.Equals("ws") && !protocol.Equals("wss")) 
      throw new ArgumentException("Unsupported protocol: " + protocol); 
    } 

    public void SetHeaders(Dictionary<string, string> headers) 
    { 
     mHeaders = headers; 
    } 

    public void Connect() 
    { 
     string host = mUrl.DnsSafeHost; 
     string path = mUrl.PathAndQuery; 
     string origin = "http://" + host; 

     mClient = CreateSocket(mUrl); 
     mStream = mClient.GetStream(); 

     int port = ((IPEndPoint)mClient.Client.RemoteEndPoint).Port; 
     if (port != 80) 
      host = host + ":" + port; 

     StringBuilder extraHeaders = new StringBuilder(); 
     if (mHeaders != null) 
     { 
      foreach (KeyValuePair<string, string> header in mHeaders) 
       extraHeaders.Append(header.Key + ": " + header.Value + "\r\n"); 
     } 

     string request = "GET " + path + " HTTP/1.1\r\n" + 
         "Upgrade: WebSocket\r\n" + 
         "Connection: Upgrade\r\n" + 
         "Host: " + host + "\r\n" + 
         "Origin: " + origin + "\r\n" + 
         extraHeaders.ToString() + "\r\n"; 
     byte[] sendBuffer = Encoding.UTF8.GetBytes(request); 

     mStream.Write(sendBuffer, 0, sendBuffer.Length); 

     StreamReader reader = new StreamReader(mStream); 
     { 
      string header = reader.ReadLine(); 
      if (!header.Equals("HTTP/1.1 101 Web Socket Protocol Handshake")) 
       throw new IOException("Invalid handshake response"); 

      header = reader.ReadLine(); 
      if (!header.Equals("Upgrade: WebSocket")) 
       throw new IOException("Invalid handshake response"); 

      header = reader.ReadLine(); 
      if (!header.Equals("Connection: Upgrade")) 
       throw new IOException("Invalid handshake response"); 
     } 

     mHandshakeComplete = true; 
    } 

    public void Send(string str) 
    { 
     if (!mHandshakeComplete) 
      throw new InvalidOperationException("Handshake not complete"); 

     byte[] sendBuffer = Encoding.UTF8.GetBytes(str); 

     mStream.WriteByte(0x00); 
     mStream.Write(sendBuffer, 0, sendBuffer.Length); 
     mStream.WriteByte(0xff); 
     mStream.Flush(); 
    } 

    public string Recv() 
    { 
     if (!mHandshakeComplete) 
      throw new InvalidOperationException("Handshake not complete"); 

     StringBuilder recvBuffer = new StringBuilder(); 

     BinaryReader reader = new BinaryReader(mStream); 
     byte b = reader.ReadByte(); 
     if ((b & 0x80) == 0x80) 
     { 
      // Skip data frame 
      int len = 0; 
      do 
      { 
       b = (byte)(reader.ReadByte() & 0x7f); 
       len += b * 128; 
      } while ((b & 0x80) != 0x80); 

      for (int i = 0; i < len; i++) 
       reader.ReadByte(); 
     } 

     while (true) 
     { 
      b = reader.ReadByte(); 
      if (b == 0xff) 
       break; 

      recvBuffer.Append(b);   
     } 

     return recvBuffer.ToString(); 
    } 

    public void Close() 
    { 
     mStream.Dispose(); 
     mClient.Close(); 
     mStream = null; 
     mClient = null; 
    } 

    private static TcpClient CreateSocket(Uri url) 
    { 
     string scheme = url.Scheme; 
     string host = url.DnsSafeHost; 

     int port = url.Port; 
     if (port <= 0) 
     { 
      if (scheme.Equals("wss")) 
       port = 443; 
      else if (scheme.Equals("ws")) 
       port = 80; 
      else 
       throw new ArgumentException("Unsupported scheme"); 
     } 

     if (scheme.Equals("wss")) 
      throw new NotImplementedException("SSL support not implemented yet"); 
     else 
      return new TcpClient(host, port); 
    } 
} 
+6

注意StringBuilder.Append(字节)不会做什么你认为它确实 - 它将字节的文本表示附加到缓冲区。构建一个字节列表,然后使用Encoding.UTF8.GetString(字节)将该字节[]转换为字符串效果更好。 – 2010-07-07 20:38:48

+1

+1为我工作。我最终修改了'mStream = new SslStream(mClient.GetStream());'并添加了'mStream.AuthenicateAsClient(host);',这就是SSL支持所需要的。 – primo 2016-02-10 13:01:18

1

最近互通桥梁和实验室中心发布的WebSockets协议规范的两份草案的原型实现(在托管代码):

选秀hixie-thewebsocketprotocol-75选秀hixie -thewebsocketprotocol-76

该原型可以在HTML5实验室找到。我在this blog post中发现了我发现的所有信息(直到现在)以及关于如何使用WCF完成这些代码的代码片段。现在

1

如果你想要一个更轻量级的东西,看看一个朋友和我发布的C#服务器:https://github.com/Olivine-Labs/Alchemy-Websockets

支持香草websockets以及flash网络套接字。它专为我们的在线游戏而设计,重点在于可扩展性和效率。

5

有一个客户端实现:http://websocket4net.codeplex.com/

+0

我推荐这一款,我与它合作,说实话它的惊人。 – Rushino 2014-03-19 20:38:10

+0

快速,干净,谢谢你的分享。 – Thomas 2014-10-13 19:25:51

10

对WebSockets的支持是coming in .NET 4.5。该链接还包含一个使用System.Net.WebSockets.WebSocket类的示例。

+2

从文档“客户端和服务器WebSocket的唯一公共实现在Windows 8和Windows Server 2012上受支持” - 即。它不适用于旧版本的Windows。 – 2014-05-31 05:50:08

0

还有炼金术。 http://olivinelabs.com/Alchemy-Websockets/这很酷。

+0

和哪个不是WebSocket客户端 – Shaddix 2014-03-18 05:56:48

+0

是的。它有一个WebSocket客户端库。再看一遍! – Rushino 2014-03-19 20:37:38

+0

我不认为它实际上是一个lib。虽然有一个[WebSocketClient类](https://github.com/Olivine-Labs/Alchemy-Websockets/blob/master/src/Alchemy/WebSocketClient.cs),对 – Shaddix 2014-03-20 03:09:08

4

另一种选择:XSockets.Net,具有实现服务器和客户端。

可以通过安装服务器:

PM> Install-Package XSockets 

或安装客户端:

PM> Install-Package XSockets.Client 

目前的版本是:3.0.4