0

おそらく私は今、ひどく手を必要としています。

私は現在、c# と HTML5 を使用する websocket サーバーに関して問題を抱えています。html5 で onmessage() イベントが発生しません。ソケット接続を開き、onopen() イベントをトリガーします。ただし、接続が確立されると、接続を閉じ続けます。これが私の簡単なコードです：

サーバー (C#):

using System;
using System.Collections.Generic;
using System.Net.Sockets;
using System.Net;
using System.IO;
using System.Security.Cryptography;
using System.Threading;

namespace ConsoleApplication1
{
    class Program
    {
        public Socket ListenerSocker { get; private set; }
        static IPEndPoint ipLocal;
        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.Listen(200);
            serverSocket.BeginAccept(null, 0, OnAccept, null);

            Console.Read();
        }


        private static void OnClientConnect()
        {

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







        private static void OnAccept(IAsyncResult result)
        {
            byte[] buffer = new byte[1024];

            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-Key: " + test1 + newLine + newLine
                     + "Sec-WebSocket-Key: " + 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);
                Console.WriteLine("***SUBA****:"+subA);
                Console.WriteLine("TEST");
                client.Send(subA);

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

                // OnClientConnect();
            }
        }

        public static T[] SubArray<T>(T[] data, int index, int length)
        {
            T[] result = new T[length];
            Array.Copy(data, index, result, 0, length);
            Console.WriteLine(result);
            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));
        }
    }
}

クライアント (HTML5):

<!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");
            console.log(ws);
            ws.onopen = function () {
                alert("About to send data");
                ws.send("test"); // 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...");
            };
        };

        function send(){
        }


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

</body>
</html>

私はこれを得ることができます：

 alert("About to send data");

この：

alert("Message sent!");

しかしその後、接続は閉じます。サーバーがクライアントからデータを受信することも確認できました。問題は、サーバーからクライアントにデータを送信すると、クライアントから提供されたものを返すことができるようになると、接続が突然閉じてしまうことです。何が問題になる可能性がありますか？

4

1 に答える 1

0

Websocket メッセージはプレーン テキストではありません。シンプルなフレーミング プロトコルを適用する必要がある

client->server メッセージと server->client メッセージでは、フレーミング ルールがわずかに異なります。別のフレーミングを適用せずにメッセージをエコーし​​ようとすると、クライアントが接続を閉じていると思います。

メッセージをデコード/エンコードする方法については、RFC6455のデータ フレーミング セクションを参照してください。または、.NET4.5 を使用している場合は、独自のサーバーを作成する代わりにSystem.Net.WebSocketsを使用することを検討できます。

于 2013-03-26T10:17:49.393 に答える