kostenloser Webspace werbefrei: lima-city

in: WebSockets

geschrieben von web-tester

public static byte[] getBytes(String mess)
        {
            byte[] rawData = Encoding.UTF8.GetBytes(mess);

            int frameCount = 0
            byte[] frame = new byte[10]

            frame[0] = (byte)129

            if (rawData.Length <= 125)
            {
                frame[1] = (byte)rawData.Length
                frameCount = 2
            }
            else if (rawData.Length >= 126 && rawData.Length <= 65535)
            {
                frame[1] = (byte)126;
                int len = rawData.Length
                frame[2] = (byte)((len >?> 8) & (byte)255)
                frame[3] = (byte)(len & (byte)255)
                frameCount = 4
            }
            else
            {
                frame[1] = (byte)127
                int len = rawData.Length
                frame[2] = (byte)((len >> 56) & (byte)255)
                frame[3] = (byte)((len >> 48) & (byte)255)
                frame[4] = (byte)((len >> 40) & (byte)255)
                frame[5] = (byte)((len >> 32) & (byte)255)
                frame[6] = (byte)((len >> 24) & (byte)255)
                frame[7] = (byte)((len >> 16) & (byte)255)
                frame[8] = (byte)((len >> 8) & (byte)255)
                frame[9] = (byte)(len & (byte)255)
                frameCount = 10
            }

            int bLength = frameCount + rawData.Length

            byte[] reply = new byte[bLength]

            int bLim = 0
            for (int i = 0 i < frameCount; i++)
            {
                reply[bLim] = frame[i]
                bLim++
            }
            for (int i = 0; i < rawData.Length; i++)
            {
                reply[bLim] = rawData[i]
                bLim++
            }
            return reply
        }

in: WebSockets

geschrieben von web-tester

function connect() {
            var ws = new WebSocket("ws://localhost:100");
            ws.onopen = function () {
                alert("Open!");
            }
            ws.onmessage = function (evt) {
                alert("About to receive data");
                var received_msg = evt.data;
                alert("Message received = "+received_msg);
            }
            ws.onclose = function () {
                alert("Connection is closed...");
            }
        }

using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Security.Cryptography;
using System.Text;
using System.Threading.Tasks;

namespace test_server
{
    class Program
    {
        private static byte[] _buffer = new byte[2048];
        private static Socket _serverSocket = new Socket
            (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

        static void Main(string[] args)
        {
            Console.Title = "Server";
            SetupServer();
            Console.ReadLine();
        }
        private static void SetupServer()
        {
            Console.WriteLine("Setting up server...");
            _serverSocket.Bind(new IPEndPoint(IPAddress.Any, 100));
            _serverSocket.Listen(5);
            _serverSocket.BeginAccept(new AsyncCallback(AcceptCallback), true);
        }

        private static void AcceptCallback(IAsyncResult AR)
        {

            Socket socket = _serverSocket.EndAccept(AR);
            Console.WriteLine("Client connected");
            socket.BeginReceive(_buffer, 0, _buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveCallback), socket);
            _serverSocket.BeginAccept(new AsyncCallback(AcceptCallback), true);
        }

        private static void ReceiveCallback(IAsyncResult AR)
        {
            try
            {
                Console.ForegroundColor = ConsoleColor.White;
                Console.WriteLine(Environment.NewLine);
                Socket socket = (Socket)AR.AsyncState;
                int received = socket.EndReceive(AR);
                byte[] dataBuf = new byte[received];
                Array.Copy(_buffer, dataBuf, received);
                string text = Encoding.ASCII.GetString(dataBuf);
                Console.WriteLine("Text received: " + Environment.NewLine + text);
                string responseKey = "";
                string keyRaw = text.Split(new string[] { Environment.NewLine }, StringSplitOptions.None)[11].Split(new string[] { " " }, StringSplitOptions.None)[1] + "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
                using (SHA1 sha1 = SHA1.Create())
                {
                    byte[] hash = sha1.ComputeHash(Encoding.UTF8.GetBytes(keyRaw));
                    responseKey = Convert.ToBase64String(hash);
                }
                String response = "HTTP/1.1 101 Switching Protocols" + Environment.NewLine
                    + "Upgrade: websocket" + Environment.NewLine
                    + "Connection: Upgrade" + Environment.NewLine
                    + "Sec-WebSocket-Accept: " + responseKey + Environment.NewLine + Environment.NewLine
                    + "Sec-WebSocket-Protocol: chat" + Environment.NewLine;
                Console.ForegroundColor = ConsoleColor.Green;
                Console.WriteLine("KEY: " + responseKey);
                Console.ForegroundColor = ConsoleColor.White;
                socket.BeginSend(System.Text.Encoding.UTF8.GetBytes(response), 0, System.Text.Encoding.UTF8.GetBytes(response).Length, SocketFlags.None, new AsyncCallback(SendCallback), socket);

                socket.BeginReceive(_buffer, 0, _buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveCallback), socket);

            }
            catch (Exception e) { Console.ForegroundColor = ConsoleColor.Red; Console.WriteLine("Error: " + e.Message); }
        }
        private static void SendCallback(IAsyncResult AR)
        {
            Socket socket = (Socket)AR.AsyncState;
            socket.EndSend(AR);
        }
    }
}