Warning: Cannot use a scalar value as an array in /home/admin/public_html/forum/include/fm.class.php on line 757

Warning: Invalid argument supplied for foreach() in /home/admin/public_html/forum/include/fm.class.php on line 770

Warning: Invalid argument supplied for foreach() in /home/admin/public_html/forum/topic.php on line 737
Форумы портала PHP.SU :: Веб сокеты [2]

 PHP.SU

 Программирование на PHP, MySQL и другие веб-технологии
PHP.SU Портал     На главную страницу форума Главная     Помощь Помощь     Поиск Поиск     Поиск Яндекс Поиск Яндекс     Вакансии  Пользователи Пользователи


 Страниц (3): « 1 [2] 3 »   

> Без описания
Поиск в теме | Версия для печати
dvd2444
Отправлено: 07 Июля, 2014 - 14:57:45
Post Id


Новичок


Покинул форум
Сообщений всего: 30
Дата рег-ции: Дек. 2013  


Помог: 0 раз(а)
OrmaJeverВозможно он имеет в виду что я глупый дядька и пишу на коленке за 5 минут
(Добавление)
Всем спасибо за помощь, все заработало, вот рабочий код(может кому понадобится).Теперь буду углубляться.
PHP:
скопировать код в буфер обмена
  1. <?PHP
  2. //header('Content-Type: text/plain;');
  3. error_reporting(E_ALL); //Выводим все ошибки и предупреждения
  4. set_time_limit(0);              //Время выполнения скрипта не ограничено
  5. ob_get_flush(); //Включаем вывод без буферизации
  8. ob_implicit_flush($flag=TRUE);
  9. $host = "websocket.ru";
  10. $port = 1233;
  11.  
  12. echo "-=SERVER v2.0=-<hr><br />";
  13.  
  14. echo "Socket create----";
  15. if(($socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP))===false)
  16. {
  17.     echo "Error...".socket_strerror(socket_last_error())."<br />";
  18.     //exit();
  19. }
  20. else
  21. {
  22.     echo "OK<br />";
  23. }
  24.  
  25. echo "Socket bind------";
  26. //привязываем его к указанным ip и порту
  27. if((socket_bind($socket, $host, $port))===false)
  28. {
  29.     echo "Error...".socket_strerror(socket_last_error())."<br />\r\n";
  30.     //exit();
  31. }
  32. else
  33. {
  34.     echo "OK <br />\r\n";
  35. }
  36.  
  37. socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 20);//разрешаем использовать один порт для нескольких соединений
  38.  
  39. echo "Socket listening--";
  40. if(($listen = socket_listen($socket))===false)
  41. {
  42.     echo "Error...".socket_strerror(socket_last_error())."<br />\r\n";
  43.     exit();
  44. }
  45. else
  46. {
  47.     echo "OK <br />\r\n<hr>";
  48. }
  49. while(true)
  50. {
  51.     echo "Client connected--";  
  52.    
  53.     $accept = socket_accept($socket);                   //Ждем подключения
  54.     if($accept === false)
  55.     {
  56.         echo "err: ".socket_strerror(socket_last_error())."<br />";        
  57.     }
  58.     else
  59.     {
  60.         echo "OK <br />";
  61.     }
  62.    
  63.     $msg =socket_read($accept, 1024);                  //считываем заголовки
  64.    
  65.     perform_handshaking($msg,$accept);                 //производим рукопожатие
  66.     echo"Headers sends----OK<br />";    
  67.    
  68.     do
  69.     {
  70.         if(($data = socket_read($accept, 2048))===false)
  71.         {
  72.             echo "err: ".socket_strerror(socket_last_error())."<br />";
  73.         }
  74.         else
  75.         {
  76.             echo "Read socket---OK";
  77.         }
  78.         $data = hybi10Decode($data);
  79.         $data = hybi10Encode($data['payload']);
  80.        
  81.         socket_write($accept,$data,strlen($data));
  82.         break 2;
  83.     }
  84.     while (true);
  85. }
  86.  
  87. close($socket);
  88.  
  89. /////       /////         ///////
  90.  
  91. function close($socket)
  92. {
  93.     if (isset($socket))
  94.     {
  95.         echo "<br /><hr>Close connection--";
  96.         socket_close($socket);
  97.         echo "OK <br />";
  98.     }    
  99. }
  100.  
  101.  
  102.  
  103. function perform_handshaking($receved_header,$client_conn)
  104. {
  105.         $headers = array();
  106.         $lines = preg_split("/\r\n/", $receved_header);
  107.         foreach($lines as $line)
  108.         {
  109.                 $line = chop($line);
  110.                 if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
  111.                 {
  112.                         $headers[$matches[1]] = $matches[2];
  113.                 }
  114.         }
  115.  
  116.         $secKey = $headers['Sec-WebSocket-Key'];
  117.         $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
  118.         //hand shaking header
  119.         $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
  120.         "Upgrade: websocket\r\n" .
  121.         "Connection: Upgrade\r\n" .
  122.         "Sec-WebSocket-Origin: http://websocket.ru\r\n" .
  123.         "Sec-WebSocket-Location: ws://websocket.ru:1233\r\n".
  124.         "Sec-WebSocket-Accept: $secAccept\r\n\r\n";
  125.         socket_write($client_conn,$upgrade,strlen($upgrade));
  126. }
  127.  
  128.         function hybi10Encode($payload, $type = 'text', $masked = false)
  129.         {
  130.                 $frameHead = array();
  131.                 $frame = '';
  132.                 $payloadLength = strlen($payload);
  133.  
  134.                 switch($type)
  135.                 {              
  136.                         case 'text':
  137.                                 // first byte indicates FIN, Text-Frame (10000001):
  138.                                 $frameHead[0] = 129;                           
  139.                         break;                 
  140.  
  141.                         case 'close':
  142.                                 // first byte indicates FIN, Close Frame(10001000):
  143.                                 $frameHead[0] = 136;
  144.                         break;
  145.  
  146.                         case 'ping':
  147.                                 // first byte indicates FIN, Ping frame (10001001):
  148.                                 $frameHead[0] = 137;
  149.                         break;
  150.  
  151.                         case 'pong':
  152.                                 // first byte indicates FIN, Pong frame (10001010):
  153.                                 $frameHead[0] = 138;
  154.                         break;
  155.                 }
  156.  
  157.                 // set mask and payload length (using 1, 3 or 9 bytes)
  158.                 if($payloadLength > 65535)
  159.                 {
  160.                         $payloadLengthBin = str_split(sprintf('%064b', $payloadLength), 8);
  161.                         $frameHead[1] = ($masked === true) ? 255 : 127;
  162.                         for($i = 0; $i < 8; $i++)
  163.                         {
  164.                                 $frameHead[$i+2] = bindec($payloadLengthBin[$i]);
  165.                         }
  166.                         // most significant bit MUST be 0 (close connection if frame too big)
  167.                         if($frameHead[2] > 127)
  168.                         {
  169.                                 $this->close(1004);
  170.                                 return false;
  171.                         }
  172.                 }
  173.                 elseif($payloadLength > 125)
  174.                 {
  175.                         $payloadLengthBin = str_split(sprintf('%016b', $payloadLength), 8);
  176.                         $frameHead[1] = ($masked === true) ? 254 : 126;
  177.                         $frameHead[2] = bindec($payloadLengthBin[0]);
  178.                         $frameHead[3] = bindec($payloadLengthBin[1]);
  179.                 }
  180.                 else
  181.                 {
  182.                         $frameHead[1] = ($masked === true) ? $payloadLength + 128 : $payloadLength;
  183.                 }
  184.  
  185.                 // convert frame-head to string:
  186.                 foreach(array_keys($frameHead) as $i)
  187.                 {
  188.                         $frameHead[$i] = chr($frameHead[$i]);
  189.                 }
  190.                 if($masked === true)
  191.                 {
  192.                         // generate a random mask:
  193.                         $mask = array();
  194.                         for($i = 0; $i < 4; $i++)
  195.                         {
  196.                                 $mask[$i] = chr(rand(0, 255));
  197.                         }
  198.  
  199.                         $frameHead = array_merge($frameHead, $mask);                   
  200.                 }                                              
  201.                 $frame = implode('', $frameHead);
  202.  
  203.                 // append payload to frame:
  204.                 $framePayload = array();       
  205.                 for($i = 0; $i < $payloadLength; $i++)
  206.                 {              
  207.                         $frame .= ($masked === true) ? $payload[$i] ^ $mask[$i % 4] : $payload[$i];
  208.                 }
  209.  
  210.                 return $frame;
  211.         }
  212.  
  213.         function hybi10Decode($data)
  214.         {
  215.                 $payloadLength = '';
  216.                 $mask = '';
  217.                 $unmaskedPayload = '';
  218.                 $decodedData = array();
  219.  
  220.                 // estimate frame type:
  221.                 $firstByteBinary = sprintf('%08b', ord($data[0]));             
  222.                 $secondByteBinary = sprintf('%08b', ord($data[1]));
  223.                 $opcode = bindec(substr($firstByteBinary, 4, 4));
  224.                 $isMasked = ($secondByteBinary[0] == '1') ? true : false;
  225.                 $payloadLength = ord($data[1]) & 127;
  226.  
  227.                 // close connection if unmasked frame is received:
  228.                 if($isMasked === false)
  229.                 {
  230.                         $this->close(1002);
  231.                 }
  232.  
  233.                 switch($opcode)
  234.                 {
  235.                         // text frame:
  236.                         case 1:
  237.                                 $decodedData['type'] = 'text';                         
  238.                         break;
  239.  
  240.                         case 2:
  241.                                 $decodedData['type'] = 'binary';
  242.                         break;
  243.  
  244.                         // connection close frame:
  245.                         case 8:
  246.                                 $decodedData['type'] = 'close';
  247.                         break;
  248.  
  249.                         // ping frame:
  250.                         case 9:
  251.                                 $decodedData['type'] = 'ping';                         
  252.                         break;
  253.  
  254.                         // pong frame:
  255.                         case 10:
  256.                                 $decodedData['type'] = 'pong';
  257.                         break;
  258.  
  259.                         default:
  260.                                 // Close connection on unknown opcode:
  261.                                 $this->close(1003);
  262.                         break;
  263.                 }
  264.  
  265.                 if($payloadLength === 126)
  266.                 {
  267.                    $mask = substr($data, 4, 4);
  268.                    $payloadOffset = 8;
  269.                    $dataLength = bindec(sprintf('%08b', ord($data[2])) . sprintf('%08b', ord($data[3]))) + $payloadOffset;
  270.                 }
  271.                 elseif($payloadLength === 127)
  272.                 {
  273.                         $mask = substr($data, 10, 4);
  274.                         $payloadOffset = 14;
  275.                         $tmp = '';
  276.                         for($i = 0; $i < 8; $i++)
  277.                         {
  278.                                 $tmp .= sprintf('%08b', ord($data[$i+2]));
  279.                         }
  280.                         $dataLength = bindec($tmp) + $payloadOffset;
  281.                         unset($tmp);
  282.                 }
  283.                 else
  284.                 {
  285.                         $mask = substr($data, 2, 4);   
  286.                         $payloadOffset = 6;
  287.                         $dataLength = $payloadLength + $payloadOffset;
  288.                 }
  289.  
  290.                 /**
  291.                  * We have to check for large frames here. socket_recv cuts at 1024 bytes
  292.                  * so if websocket-frame is > 1024 bytes we have to wait until whole
  293.                  * data is transferd.
  294.                  */
  295.                 if(strlen($data) < $dataLength)
  296.                 {                      
  297.                         return false;
  298.                 }
  299.  
  300.                 if($isMasked === true)
  301.                 {
  302.                         for($i = $payloadOffset; $i < $dataLength; $i++)
  303.                         {
  304.                                 $j = $i - $payloadOffset;
  305.                                 if(isset($data[$i]))
  306.                                 {
  307.                                         $unmaskedPayload .= $data[$i] ^ $mask[$j % 4];
  308.                                 }
  309.                         }
  310.                         $decodedData['payload'] = $unmaskedPayload;
  311.                 }
  312.                 else
  313.                 {
  314.                         $payloadOffset = $payloadOffset - 4;
  315.                         $decodedData['payload'] = substr($data, $payloadOffset);
  316.                 }
  317.  
  318.                 return $decodedData;
  319.         }

И клиент
CODE (htmlphp):
скопировать код в буфер обмена
  1. &#65279;<!DOCTYPE html>
  2. <!--
  3. To change this license header, choose License Headers in Project Properties.
  4. To change this template file, choose Tools | Templates
  5. and open the template in the editor.
  6. -->
  7. <html>
  8.     <head>
  9.         <title>Client</title>
  10.         <meta charset="UTF-8">
  11.         <meta name="viewport" content="width=device-width, initial-scale=1.0">
  12.         <style type="text/css">
  13. html,body {
  14.         font:normal 0.9em arial,helvetica;
  15. }
  16. #log {
  17.         width:400px;
  18.         height:350px;
  19.         border:1px solid #7F9DB9;
  20.         overflow:auto;
  21. }
  22. #msg {
  23.         width:400px;
  24. }
  25. </style>
  26. <script type="text/javascript">
  27. var socket;
  28.  
  29. function init() {
  30.         var host = 'ws://websocket.ru:1233/server.php'; // 'ws://echo.websocket.org'
  31.         try {
  32.                 socket = new WebSocket(host);
  33.                 log('WebSocket - status '+socket.readyState);
  34.                 socket.onopen    = function(msg) {
  35.                                                            log("Welcome - status "+this.readyState);
  36.                                                    };
  37.                 socket.onmessage = function(msg) {
  38.                                                            log("Received: "+msg.data);
  39.                                                    };
  40.                 socket.onclose   = function(msg) {
  41.                                                            log("Disconnected - status "+this.readyState);
  42.                                                    };
  43.         }
  44.         catch(ex){
  45.                 log(ex);
  46.         }
  47.         $("msg").focus();
  48. }
  49.  
  50. function send(){
  51.         var txt,msg;
  52.         txt = $("msg");
  53.         msg = txt.value;
  54.         if(!msg) {
  55.                 alert("Message can not be empty");
  56.                 return;
  57.         }
  58.         txt.value="";
  59.         txt.focus();
  60.         try {
  61.                 socket.send(msg);
  62.                 log('Sent: '+msg);
  63.         } catch(ex) {
  64.                 log(ex);
  65.         }
  66. }
  67. function quit(){
  68.         if (socket != null) {
  69.                 log("Goodbye!");
  70.                 socket.close();
  71.                 socket=null;
  72.         }
  73. }
  74.  
  75. function reconnect() {
  76.         quit();
  77.         init();
  78. }
  79.  
  80. // Utilities
  81. function $(id){ return document.getElementById(id); }
  82. function log(msg){ $("log").innerHTML+="<br>"+msg; }
  83. function onkey(event){ if(event.keyCode==13){ send(); } }
  84. </script>
  85. </head>
  86. <body onload="init()">
  87. <h3>WebSocket v1.0</h3>
  88. <div id="log"></div>
  89. <input id="msg" type="text" onkeypress="onkey(event)"/>
  90. <button onclick="send()">Send</button>
  91. <button onclick="quit()">Quit</button>
  92. <button onclick="reconnect()">Reconnect</button>
  93. </body>
  94. </html>
 
 Top
esterio
Отправлено: 07 Июля, 2014 - 16:01:51
Post Id



Активный участник


Покинул форум
Сообщений всего: 5025
Дата рег-ции: Нояб. 2012  
Откуда: Украина, Львов


Помог: 127 раз(а)
dvd2444
Нет не это я имел ввиду. Я говорю про то что там все нюансы обкатаны и работают без сбоев в работе. А также то что писали эго далеко не глупые люди. Но должен согласиться дешевый хостинг не подойдет. Но и с другой стороны как зациклить PHP скрипт на дешевом хостинге без краша по таймауту. насколько я помню там нельзя поставить timelimit 0. Так что в любом случае такые вещи на хостингах не стоят
 
 Top
dvd2444
Отправлено: 07 Июля, 2014 - 16:06:27
Post Id


Новичок


Покинул форум
Сообщений всего: 30
Дата рег-ции: Дек. 2013  


Помог: 0 раз(а)
esterioСпасибо, понял.Но все же хотелось бы самому наступить на все грабли что бы понимание пришло, у меня так происходит обучение, пока свой велосипед не напишу с мертвой точки не сдвинусь Улыбка
 
 Top
Panoptik
Отправлено: 07 Июля, 2014 - 16:06:30
Post Id



Постоянный участник


Покинул форум
Сообщений всего: 2493
Дата рег-ции: Нояб. 2011  
Откуда: Одесса, Украина


Помог: 131 раз(а)
слай скрипт не имеет ограничения по времени


-----
Just do it
 
 Top
Zuldek
Отправлено: 08 Июля, 2014 - 15:01:33
Post Id


Постоянный участник


Покинул форум
Сообщений всего: 2122
Дата рег-ции: Июнь 2010  


Помог: 50 раз(а)
K socket.io придут когда откроют что веб-сокеты не работают в половине браузеров Улыбка

(Отредактировано автором: 08 Июля, 2014 - 15:02:00)

 
 Top
esterio
Отправлено: 08 Июля, 2014 - 15:24:52
Post Id



Активный участник


Покинул форум
Сообщений всего: 5025
Дата рег-ции: Нояб. 2012  
Откуда: Украина, Львов


Помог: 127 раз(а)
Zuldek
dvd2444 пишет:
Но все же хотелось бы самому наступить на все грабли что бы понимание пришло

В даном случае соглашусь с ТС
 
 Top
LIME
Отправлено: 08 Июля, 2014 - 15:31:49
Post Id


Активный участник


Покинул форум
Сообщений всего: 10732
Дата рег-ции: Нояб. 2010  


Помог: 322 раз(а)
а кто-то пытается сокет-сервер на хостинге поднять? веселенькое должно быть занятие)) как и пользование))
(Добавление)
че за фигня)) куда сообщение дели))
(Добавление)
аа...эт я предыдущую страницу коментирую)
тоже весело)
 
 Top
Panoptik
Отправлено: 08 Июля, 2014 - 16:09:42
Post Id



Постоянный участник


Покинул форум
Сообщений всего: 2493
Дата рег-ции: Нояб. 2011  
Откуда: Одесса, Украина


Помог: 131 раз(а)
никаких проблем поднять сокет сервер нет даже на унылом хостинге. главное чтобы там был пхп с поддержкой сокетов


-----
Just do it
 
 Top
esterio
Отправлено: 08 Июля, 2014 - 18:45:13
Post Id



Активный участник


Покинул форум
Сообщений всего: 5025
Дата рег-ции: Нояб. 2012  
Откуда: Украина, Львов


Помог: 127 раз(а)
Panoptik
esterio пишет:
веселенькое должно быть занятие))

Zuldek пишет:
K socket.io придут когда откроют что веб-сокеты не работают в половине браузеров

добавить больше нечего. поднять то можно. но цена (время и усилия) слишком большие.
 
 Top
LIME
Отправлено: 08 Июля, 2014 - 19:07:06
Post Id


Активный участник


Покинул форум
Сообщений всего: 10732
Дата рег-ции: Нояб. 2010  


Помог: 322 раз(а)
не знаю какие проблемы но смысла никакого
если уж нужны проекту сокеты значит нужен vps
 
 Top
OrmaJever Модератор
Отправлено: 08 Июля, 2014 - 19:48:08
Post Id



Активный участник


Покинул форум
Сообщений всего: 7540
Дата рег-ции: Янв. 2010  
Откуда: Чернигов


Помог: 299 раз(а)
Panoptik пишет:
никаких проблем поднять сокет сервер нет даже на унылом хостинге. главное чтобы там был пхп с поддержкой сокетов

ну и как там твои движения в этом направлении?))


-----
Если вы хотя бы 3-4 раза не решите всё выкинуть и начать заново - вы явно что-то делаете не так.
 
 Top
LIME
Отправлено: 08 Июля, 2014 - 20:37:43
Post Id


Активный участник


Покинул форум
Сообщений всего: 10732
Дата рег-ции: Нояб. 2010  


Помог: 322 раз(а)
мне тоже интересно что за пхп с поддержкой сокетов
такое есть? 1
на хостингах? 2

(Отредактировано автором: 08 Июля, 2014 - 20:38:26)

 
 Top
OrmaJever Модератор
Отправлено: 08 Июля, 2014 - 22:56:05
Post Id



Активный участник


Покинул форум
Сообщений всего: 7540
Дата рег-ции: Янв. 2010  
Откуда: Чернигов


Помог: 299 раз(а)
LIME ну типа семейство socket_*, хотя я не представляю где эти функции могут не работать Растерялся


-----
Если вы хотя бы 3-4 раза не решите всё выкинуть и начать заново - вы явно что-то делаете не так.
 
 Top
LIME
Отправлено: 08 Июля, 2014 - 23:05:51
Post Id


Активный участник


Покинул форум
Сообщений всего: 10732
Дата рег-ции: Нояб. 2010  


Помог: 322 раз(а)
а я не представляю как ими вебсокеты поддерживать
я думал че поумнее будет
 
 Top
OrmaJever Модератор
Отправлено: 08 Июля, 2014 - 23:33:31
Post Id



Активный участник


Покинул форум
Сообщений всего: 7540
Дата рег-ции: Янв. 2010  
Откуда: Чернигов


Помог: 299 раз(а)
Так же как и на Си только в одном потоке Ха-ха


-----
Если вы хотя бы 3-4 раза не решите всё выкинуть и начать заново - вы явно что-то делаете не так.
 
 Top
Поиск в теме | Версия для печати
Страниц (3): « 1 [2] 3 »
Сейчас эту тему просматривают: 0 (гостей: 0, зарегистрированных: 0)
« Вопросы новичков »


Все гости форума могут просматривать этот раздел.
Только зарегистрированные пользователи могут создавать новые темы в этом разделе.
Только зарегистрированные пользователи могут отвечать на сообщения в этом разделе.
  



Powered by PHP  Powered By MySQL  Powered by Nginx  Valid CSS  RSS

 
Powered by ExBB FM 1.0 RC1. InvisionExBB