我是Websockets的新手，正在寻找使用WS和c＃控制台应用程序的工作示例。 我跑进this one，但我已经有问题了。当服务器向客户端发送消息时，似乎连接关闭。我不确定，但我认为握手是好的。下面是一个代码：Websockets - 断开服务器消息

服务器：

using System;

using System.Net.Sockets;

using System.Net;

using System.Security.Cryptography;

using System.Threading;

namespace ConsoleApplication1

{

class Program

{

static Socket serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP);

static private string guid = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";

static void Main(string[] args)

{

serverSocket.Bind(new IPEndPoint(IPAddress.Any, 8080));

serverSocket.Listen(128);

serverSocket.BeginAccept(null, 0, OnAccept, null);

Console.Read();

}

private static void OnAccept(IAsyncResult result)

{

byte[] buffer = new byte[1024];

try

{

Socket client = null;

string headerResponse = "";

if (serverSocket != null && serverSocket.IsBound)

{

client = serverSocket.EndAccept(result);

var i = client.Receive(buffer);

headerResponse = (System.Text.Encoding.UTF8.GetString(buffer)).Substring(0, i);

// write received data to the console

Console.WriteLine(headerResponse);

Console.WriteLine("=====================");

}

if (client != null)

{

/* Handshaking and managing ClientSocket */

var key = headerResponse.Replace("ey:", "`")

.Split('`')[1] // dGhlIHNhbXBsZSBub25jZQ== \r\n .......

.Replace("\r", "").Split('\n')[0] // dGhlIHNhbXBsZSBub25jZQ==

.Trim();

// key should now equal dGhlIHNhbXBsZSBub25jZQ==

var test1 = AcceptKey(ref key);

var newLine = "\r\n";

var response = "HTTP/1.1 101 Switching Protocols" + newLine

+ "Upgrade: websocket" + newLine

+ "Connection: Upgrade" + newLine

+ "Sec-WebSocket-Accept: " + test1 + newLine + newLine

//+ "Sec-WebSocket-Protocol: chat, superchat" + newLine

//+ "Sec-WebSocket-Version: 13" + newLine

;

// which one should I use? none of them fires the onopen method

client.Send(System.Text.Encoding.UTF8.GetBytes(response));

var i = client.Receive(buffer); // wait for client to send a message

// once the message is received decode it in different formats

Console.WriteLine(Convert.ToBase64String(buffer).Substring(0, i));

Console.WriteLine("=====================");

Console.WriteLine("\n\nPress enter to send data to client");

Console.Read();

var subA = SubArray(buffer, 0, i);

client.Send(subA);

Console.Read();

Thread.Sleep(10000);//wait for message to be send

}

}

catch (SocketException exception)

{

throw exception;

}

finally

{

if (serverSocket != null && serverSocket.IsBound)

{

serverSocket.BeginAccept(null, 0, OnAccept, null);

}

}

}

public static T[] SubArray(T[] data, int index, int length)

{

T[] result = new T[length];

Array.Copy(data, index, result, 0, length);

return result;

}

private static string AcceptKey(ref string key)

{

string longKey = key + guid;

byte[] hashBytes = ComputeHash(longKey);

return Convert.ToBase64String(hashBytes);

}

static SHA1 sha1 = SHA1CryptoServiceProvider.Create();

private static byte[] ComputeHash(string str)

{

return sha1.ComputeHash(System.Text.Encoding.ASCII.GetBytes(str));

}

}

}

克伦特：

/p>

"http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">

function connect() {

var ws = new WebSocket("ws://localhost:8080/service");

ws.onopen = function() {

alert("About to send data");

ws.send("Hello World"); // I WANT TO SEND THIS MESSAGE TO THE SERVER!!!!!!!!

alert("Message sent!");

};

ws.onmessage = function (evt) {

alert("About to receive data");

var received_msg = evt.data;

alert("Message received = "+received_msg);

};

ws.onclose = function() {

// websocket is closed.

alert("Connection is closed...");

};

};

下面是来自客户机的连接请求和消息：

任何帮助将不胜感激。