96

次のコードを機能させることができない理由がわかりません。JavaScript を使用してサーバー コンソール アプリケーションに接続したいと考えています。そして、データをサーバーに送信します。

サーバーコードは次のとおりです。

    static void Main(string[] args)
    {            
        TcpListener server = new TcpListener(IPAddress.Parse("127.0.0.1"), 9998);
        server.Start();
        var client = server.AcceptTcpClient();
        var stream = client.GetStream();

        while (true)
        {
            var buffer = new byte[1024]; 
            // wait for data to be received
            var bytesRead = stream.Read(buffer, 0, buffer.Length);                
            var r = System.Text.Encoding.UTF8.GetString(buffer);
            // write received data to the console
            Console.WriteLine(r.Substring(0, bytesRead));
        }
    }

JavaScript は次のとおりです。

        var ws = new WebSocket("ws://localhost:9998/service");
        ws.onopen = function () {
            ws.send("Hello World"); // I WANT TO SEND THIS MESSAGE TO THE SERVER!!!!!!!!
        };

        ws.onmessage = function (evt) {
            var received_msg = evt.data;
            alert("Message is received...");
        };
        ws.onclose = function () {
            // websocket is closed.
            alert("Connection is closed...");
        };

そのコードを実行すると、次のようになります。

JavaScript を実行すると、サーバーは接続を受け入れて正常に確立することに注意してください。ただし、JavaScript はデータを送信できません。send メソッドを配置すると、接続が確立されても送信されません。どうすればこれを機能させることができますか？

4

5 に答える 5

78

WebSockets は、TCP ストリーミング接続に依存するプロトコルです。WebSockets はメッセージベースのプロトコルですが。

独自のプロトコルを実装する場合は、最新の安定した仕様 (18/04/12) RFC 6455を使用することをお勧めします。この仕様には、ハンドシェイクとフレーミングに関するすべての必要な情報が含まれています。同様に、ブラウザ側およびサーバー側からの動作のシナリオに関するほとんどの説明。コードの実装中は、サーバー側に関する推奨事項に従うことを強くお勧めします。

簡単に言うと、WebSocket の操作を次のように説明します。

  1. サーバー ソケット(System.Net.Sockets) を作成し、それを特定のポートにバインドし、非同期で接続を受け入れてリッスンし続けます。そんな感じ：
Socket serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP);
serverSocket.Bind(新しい IPEndPoint(IPAddress.Any, 8080));
serverSocket.Listen(128);
serverSocket.BeginAccept(null, 0, OnAccept, null);
  1. ハンドシェイクを実装する受け入れ関数「OnAccept」が必要です。システムが毎秒膨大な量の接続を処理することを意図している場合、将来的には別のスレッドにある必要があります。
プライベート void OnAccept(IAsyncResult 結果) {
    試す {
        ソケット クライアント = null;
        if (serverSocket != null && serverSocket.IsBound) {
            クライアント = serverSocket.EndAccept(結果);
        }
        if (クライアント != null) {
            /* ハンドシェイクと ClientSocket の管理 */
        }
    } catch(SocketException 例外) {

    } 最後に {
        if (serverSocket != null && serverSocket.IsBound) {
            serverSocket.BeginAccept(null, 0, OnAccept, null);
        }
    }
}
  1. 接続が確立されたら、handshakeを行う必要があります。仕様1.3 Opening Handshakeに基づいて、接続が確立された後、いくつかの情報を含む基本的な HTTP 要求を受け取ります。例：
GET /チャット HTTP/1.1
ホスト: server.example.com
アップグレード: ウェブソケット
接続: アップグレード
Sec-WebSocket キー: dGhlIHNhbXBsZSBub25jZQ==
オリジン: http://example.com
Sec-WebSocket-Protocol: チャット、スーパーチャット
Sec-WebSocket-バージョン: 13

この例は、プロトコル 13 のバージョンに基づいています。古いバージョンにはいくつかの違いがありますが、ほとんどの最新バージョンは相互互換性があることに注意してください。ブラウザによっては、追加のデータが送信される場合があります。たとえば、ブラウザと OS の詳細、キャッシュなどです。

提供されたハンドシェイクの詳細に基づいて、回答行を生成する必要があります。それらはほとんど同じですが、提供された Sec-WebSocket-Key に基づく Accept-Key が含まれます。仕様 1.3 では、応答キーの生成方法が明確に説明されています。V13で使用している関数は次のとおりです。

static private string guid = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
プライベート文字列 AcceptKey(参照文字列キー) {
        文字列 longKey = キー + GUID;
        SHA1 sha1 = SHA1CryptoServiceProvider.Create();
        byte[] hashBytes = sha1.ComputeHash(System.Text.Encoding.ASCII.GetBytes(longKey));
        Convert.ToBase64String(hashBytes) を返します。
}

握手の答えは次のようになります。

HTTP/1.1 101 スイッチング プロトコル
アップグレード: ウェブソケット
接続: アップグレード
Sec-WebSocket-Accept: s3pPLMBiTxaQ9kYGzzhZRbK+xOo=

ただし、受け入れキーは、クライアントから提供されたキーと、以前に提供したメソッド AcceptKey に基づいて生成されたものでなければなりません。同様に、accept キーの最後の文字の後に、2 つの改行 "\r\n\r\n" を挿入してください。

  1. ハンドシェイクの応答がサーバーから送信された後、クライアントは " onopen " 関数をトリガーする必要があります。つまり、後でメッセージを送信できます。

  2. メッセージは未加工の形式で送信されませんが、データ フレーミングがあります。また、クライアントからサーバーへも、メッセージ ヘッダーで提供された 4 バイトに基づいてデータのマスキングを実装します。ただし、サーバーからクライアントへは、データにマスキングを適用する必要はありません。仕様のセクション5. データ フレーミングをお読みください。これが私自身の実装からのコピーアンドペーストです。これはすぐに使用できるコードではなく、変更する必要があります。WebSocket フレーミングを使用した読み取り/書き込みのアイデアと全体的なロジックを提供するために投稿しています。このリンクに移動します。

  3. フレーミングを実装したら、ソケットを使用してデータを正しく受信していることを確認してください。たとえば、TCP はまだストリームベースのプロトコルであるため、一部のメッセージが 1 つにマージされるのを防ぐためです。つまり、特定のバイト数のみを読み取る必要があります。メッセージの長さは常にヘッダーに基づいており、ヘッダー自体に含まれるデータ長の詳細が提供されます。したがって、ソケットからデータを受信する場合、最初に 2 バイトを受信し、フレーミング仕様に基づいてヘッダーから詳細を取得します。次に、マスクが別の 4 バイトを提供する場合、データの長さに基づいて 1、4、または 8 バイトの長さになります。そして、データの後、それは自己です。読んだ後、マスキング解除を適用すると、メッセージ データを使用する準備が整います。

  4. いくつかのData Protocolを使用したい場合があります。JSON を使用することをお勧めします。これは、トラフィックの経済性と、JavaScript のクライアント側で使いやすいためです。サーバー側では、いくつかのパーサーをチェックしたいかもしれません。それらはたくさんあります、グーグルは本当に役に立ちます。

独自の WebSockets プロトコルを実装すると、プロトコル自体を制御できるだけでなく、いくつかの利点と優れた経験が確実に得られます。ただし、これにはある程度の時間を費やす必要があり、実装の信頼性が高いことを確認する必要があります。

同時に、Google が (再び) 十分に備えている、すぐに使用できるソリューションを調べているかもしれません。

于 2012-04-18T09:46:16.603 に答える
13

（OPに代わって投稿された回答） .

データ送信できるようになりました。これは、あなたの回答と@Maksims Mihejevsのコードのおかげで、私の新しいバージョンのプログラムです。

サーバ

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);

                }
                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("\n\nPress enter to send data to client");
                    Console.Read();

                    var subA = SubArray<byte>(buffer, 0, i);
                    client.Send(subA);
                    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>(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));
        }
    }
}

JavaScript:

<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" 
    "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
    <script type="text/javascript">
        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...");
            };
        };


    </script>
</head>
<body style="font-size:xx-large" >
    <div>
    <a href="#" onclick="connect()">Click here to start</a></div>
</body>
</html>

そのコードを実行すると、クライアントとサーバーの両方からデータを送受信できます。唯一の問題は、メッセージがサーバーに到着したときに暗号化されることです。プログラムの実行手順は次のとおりです。

ここに画像の説明を入力

クライアントからのメッセージがどのように暗号化されるかに注意してください。

于 2017-07-27T10:39:54.177 に答える
9

(1 月 19 日現在) どこにも簡単な実例が見つからなかったので、ここに更新版を示します。Chrome バージョン 71.0.3578.98 を使用しています。

C# Websocket サーバー:

using System;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Security.Cryptography;

namespace WebSocketServer
{
    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(1); //just one socket
        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
                     ;

                client.Send(System.Text.Encoding.UTF8.GetBytes(response));
                var i = client.Receive(buffer); // wait for client to send a message
                string browserSent = GetDecodedData(buffer, i);
                Console.WriteLine("BrowserSent: " + browserSent);

                Console.WriteLine("=====================");
                //now send message to client
                client.Send(GetFrameFromString("This is message from server to client."));
                System.Threading.Thread.Sleep(10000);//wait for message to be sent
            }
        }
        catch (SocketException exception)
        {
            throw exception;
        }
        finally
        {
            if (serverSocket != null && serverSocket.IsBound)
            {
                serverSocket.BeginAccept(null, 0, OnAccept, null);
            }
        }
    }

    public static T[] SubArray<T>(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));
    }

    //Needed to decode frame
    public static string GetDecodedData(byte[] buffer, int length)
    {
        byte b = buffer[1];
        int dataLength = 0;
        int totalLength = 0;
        int keyIndex = 0;

        if (b - 128 <= 125)
        {
            dataLength = b - 128;
            keyIndex = 2;
            totalLength = dataLength + 6;
        }

        if (b - 128 == 126)
        {
            dataLength = BitConverter.ToInt16(new byte[] { buffer[3], buffer[2] }, 0);
            keyIndex = 4;
            totalLength = dataLength + 8;
        }

        if (b - 128 == 127)
        {
            dataLength = (int)BitConverter.ToInt64(new byte[] { buffer[9], buffer[8], buffer[7], buffer[6], buffer[5], buffer[4], buffer[3], buffer[2] }, 0);
            keyIndex = 10;
            totalLength = dataLength + 14;
        }

        if (totalLength > length)
            throw new Exception("The buffer length is small than the data length");

        byte[] key = new byte[] { buffer[keyIndex], buffer[keyIndex + 1], buffer[keyIndex + 2], buffer[keyIndex + 3] };

        int dataIndex = keyIndex + 4;
        int count = 0;
        for (int i = dataIndex; i < totalLength; i++)
        {
            buffer[i] = (byte)(buffer[i] ^ key[count % 4]);
            count++;
        }

        return Encoding.ASCII.GetString(buffer, dataIndex, dataLength);
    }

    //function to create  frames to send to client 
    /// <summary>
    /// Enum for opcode types
    /// </summary>
    public enum EOpcodeType
    {
        /* Denotes a continuation code */
        Fragment = 0,

        /* Denotes a text code */
        Text = 1,

        /* Denotes a binary code */
        Binary = 2,

        /* Denotes a closed connection */
        ClosedConnection = 8,

        /* Denotes a ping*/
        Ping = 9,

        /* Denotes a pong */
        Pong = 10
    }

    /// <summary>Gets an encoded websocket frame to send to a client from a string</summary>
    /// <param name="Message">The message to encode into the frame</param>
    /// <param name="Opcode">The opcode of the frame</param>
    /// <returns>Byte array in form of a websocket frame</returns>
    public static byte[] GetFrameFromString(string Message, EOpcodeType Opcode = EOpcodeType.Text)
    {
        byte[] response;
        byte[] bytesRaw = Encoding.Default.GetBytes(Message);
        byte[] frame = new byte[10];

        long indexStartRawData = -1;
        long length = (long)bytesRaw.Length;

        frame[0] = (byte)(128 + (int)Opcode);
        if (length <= 125)
        {
            frame[1] = (byte)length;
            indexStartRawData = 2;
        }
        else if (length >= 126 && length <= 65535)
        {
            frame[1] = (byte)126;
            frame[2] = (byte)((length >> 8) & 255);
            frame[3] = (byte)(length & 255);
            indexStartRawData = 4;
        }
        else
        {
            frame[1] = (byte)127;
            frame[2] = (byte)((length >> 56) & 255);
            frame[3] = (byte)((length >> 48) & 255);
            frame[4] = (byte)((length >> 40) & 255);
            frame[5] = (byte)((length >> 32) & 255);
            frame[6] = (byte)((length >> 24) & 255);
            frame[7] = (byte)((length >> 16) & 255);
            frame[8] = (byte)((length >> 8) & 255);
            frame[9] = (byte)(length & 255);

            indexStartRawData = 10;
        }

        response = new byte[indexStartRawData + length];

        long i, reponseIdx = 0;

        //Add the frame bytes to the reponse
        for (i = 0; i < indexStartRawData; i++)
        {
            response[reponseIdx] = frame[i];
            reponseIdx++;
        }

        //Add the data bytes to the response
        for (i = 0; i < length; i++)
        {
            response[reponseIdx] = bytesRaw[i];
            reponseIdx++;
        }

        return response;
    }
}
}

クライアントの html と javascript:

<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
    "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
    <script type="text/javascript">
        var socket = new WebSocket('ws://localhost:8080/websession');
        socket.onopen = function() {
           // alert('handshake successfully established. May send data now...');
           socket.send("Hi there from browser.");
        };
        socket.onmessage = function (evt) {
                //alert("About to receive data");
                var received_msg = evt.data;
                alert("Message received = "+received_msg);
            };
        socket.onclose = function() {
            alert('connection closed');
        };
    </script>
</head>
<body>
</body>
</html>

于 2019-01-15T14:51:25.330 に答える
6

WebSocket は、クライアントとサーバー間のハンドシェイクを含むプロトコルで実装されます。通常のソケットのように機能するとは思えません。プロトコルを読み、アプリケーションにそれを話させます。または、既存の WebSocket ライブラリ、またはWebSocket APIを持つ .Net4.5beta を使用します。

于 2012-04-18T00:05:10.637 に答える
3

問題

あなたは WebSocket を使用しているので、spender は正しいです。WebSocket から初期データを受信したら、それ以上の情報が流れる前に、C# サーバーからハンドシェイク メッセージを送信する必要があります。

HTTP/1.1 101 Web Socket Protocol Handshake
Upgrade: websocket
Connection: Upgrade
WebSocket-Origin: example
WebSocket-Location: something.here
WebSocket-Protocol: 13

それらの線に沿った何か。

WebSocket が w3 または google でどのように機能するかについて、さらに調査を行うことができます。

リンクとリソース

プロトコル仕様は次のとおりです: https://datatracker.ietf.org/doc/html/draft-hixie-thewebsocketprotocol-76#section-1.3

作業例のリスト:

于 2012-04-18T00:14:05.540 に答える