Архивы php - Страница 14 из 22

Простой сервер websockets на php

17.05.2016 Павел Грибов Из жизни

Фактически это каркас, для создания «чего-то поинтереснее» . Чисто логика, ничего лишнего.

javascript клиент:

<!DOCTYPE html>
<!--
(с) 2011-2015 Грибов Павел
http://грибовы.рф
Если исходный код найден в сети - значит лицензия GPL v.3
-->
<html>
    <head>
	<title>TODO supply a title</title>
	<meta charset="UTF-8">
	<meta name="viewport" content="width=device-width, initial-scale=1.0">
    </head>
    <body>
	<div>TODO write content</div>
	<script>
	    var socket = new WebSocket("ws://localhost:8000");
	    socket.onopen = function() {
	      console.log("Соединение установлено.");
	    };

	    socket.onclose = function(event) {
	      if (event.wasClean) {
		console.log('Соединение закрыто чисто');
	      } else {
		console.log('Обрыв соединения'); // например, "убит" процесс сервера
	      }
	      alert('Код: ' + event.code + ' причина: ' + event.reason);
	    };

	    socket.onmessage = function(event) {
	      console.log("Получены данные " + event.data);
	    };

	    socket.onerror = function(error) {
	      console.log("Ошибка " + error.message);
	    };	    
	    var timerId = setInterval(function() {
	      socket.send("тик!");
	    }, 2000);	    
	</script>
    </body>
</html>

<!DOCTYPE html>

<!--

(с) 2011-2015 Грибов Павел

http://грибовы.рф

Если исходный код найден в сети - значит лицензия GPL v.3

-->

<html>

<head>

<title>TODO supply a title</title>

</head>

<body>

<div>TODO write content</div>

var socket = new WebSocket("ws://localhost:8000");

socket.onopen = function() {

console.log("Соединение установлено.");

};

socket.onclose = function(event) {

if (event.wasClean) {

console.log('Соединение закрыто чисто');

} else {

console.log('Обрыв соединения'); // например, "убит" процесс сервера

}

alert('Код: ' + event.code + ' причина: ' + event.reason);

};

socket.onmessage = function(event) {

console.log("Получены данные " + event.data);

};

socket.onerror = function(error) {

console.log("Ошибка " + error.message);

};

var timerId = setInterval(function() {

socket.send("тик!");

}, 2000);

</script>

</body>

</html>

php server:

#!/usr/bin/php
<?php

$socket = stream_socket_server("tcp://0.0.0.0:8000", $errno, $errstr);

if (!$socket) {
    die("$errstr ($errno)\n");
}

$connects = array();
while (true) {
    //формируем массив прослушиваемых сокетов:
    $read = $connects;
    $read []= $socket;
    $write = $except = null;

    if (!stream_select($read, $write, $except, null)) {//ожидаем сокеты доступные для чтения (без таймаута)
        break;
    }

    if (in_array($socket, $read)) {//есть новое соединение
        //принимаем новое соединение и производим рукопожатие:
        if (($connect = stream_socket_accept($socket, -1)) && $info = handshake($connect)) {
            $connects[] = $connect;//добавляем его в список необходимых для обработки
            onOpen($connect, $info);//вызываем пользовательский сценарий
        }
        unset($read[ array_search($socket, $read) ]);
    }

    foreach($read as $connect) {//обрабатываем все соединения
        $data = fread($connect, 100000);

        if (!$data) { //соединение было закрыто
            fclose($connect);
            unset($connects[ array_search($connect, $connects) ]);
            onClose($connect);//вызываем пользовательский сценарий
            continue;
        }

        onMessage($connect, $data,$info);//вызываем пользовательский сценарий
    }
}

fclose($server);

function handshake($connect) {
    $info = array();

    $line = fgets($connect);
    $header = explode(' ', $line);
    $info['method'] = $header[0];
    $info['uri'] = $header[1];

    //считываем заголовки из соединения
    while ($line = rtrim(fgets($connect))) {
        if (preg_match('/\A(\S+): (.*)\z/', $line, $matches)) {
            $info[$matches[1]] = $matches[2];
        } else {
            break;
        }
    }

    $address = explode(':', stream_socket_get_name($connect, true)); //получаем адрес клиента
    $info['ip'] = $address[0];
    $info['port'] = $address[1];

    if (empty($info['Sec-WebSocket-Key'])) {
        return false;
    }

    //отправляем заголовок согласно протоколу вебсокета
    $SecWebSocketAccept = base64_encode(pack('H*', sha1($info['Sec-WebSocket-Key'] . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
    $upgrade = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
        "Upgrade: websocket\r\n" .
        "Connection: Upgrade\r\n" .
        "Sec-WebSocket-Accept:$SecWebSocketAccept\r\n\r\n";
    fwrite($connect, $upgrade);

    return $info;
}

function encode($payload, $type = 'text', $masked = false){
    $frameHead = array();
    $payloadLength = strlen($payload);

    switch ($type) {
        case 'text':
            // first byte indicates FIN, Text-Frame (10000001):
            $frameHead[0] = 129;
            break;

        case 'close':
            // first byte indicates FIN, Close Frame(10001000):
            $frameHead[0] = 136;
            break;

        case 'ping':
            // first byte indicates FIN, Ping frame (10001001):
            $frameHead[0] = 137;
            break;

        case 'pong':
            // first byte indicates FIN, Pong frame (10001010):
            $frameHead[0] = 138;
            break;
    }

    // set mask and payload length (using 1, 3 or 9 bytes)
    if ($payloadLength > 65535) {
        $payloadLengthBin = str_split(sprintf('%064b', $payloadLength), 8);
        $frameHead[1] = ($masked === true) ? 255 : 127;
        for ($i = 0; $i < 8; $i++) {
            $frameHead[$i + 2] = bindec($payloadLengthBin[$i]);
        }
        // most significant bit MUST be 0
        if ($frameHead[2] > 127) {
            return array('type' => '', 'payload' => '', 'error' => 'frame too large (1004)');
        }
    } elseif ($payloadLength > 125) {
        $payloadLengthBin = str_split(sprintf('%016b', $payloadLength), 8);
        $frameHead[1] = ($masked === true) ? 254 : 126;
        $frameHead[2] = bindec($payloadLengthBin[0]);
        $frameHead[3] = bindec($payloadLengthBin[1]);
    } else {
        $frameHead[1] = ($masked === true) ? $payloadLength + 128 : $payloadLength;
    }

    // convert frame-head to string:
    foreach (array_keys($frameHead) as $i) {
        $frameHead[$i] = chr($frameHead[$i]);
    }
    if ($masked === true) {
        // generate a random mask:
        $mask = array();
        for ($i = 0; $i < 4; $i++) {
            $mask[$i] = chr(rand(0, 255));
        }

        $frameHead = array_merge($frameHead, $mask);
    }
    $frame = implode('', $frameHead);

    // append payload to frame:
    for ($i = 0; $i < $payloadLength; $i++) {
        $frame .= ($masked === true) ? $payload[$i] ^ $mask[$i % 4] : $payload[$i];
    }

    return $frame;
}

function decode($data){
    $unmaskedPayload = '';
    $decodedData = array();

    // estimate frame type:
    $firstByteBinary = sprintf('%08b', ord($data[0]));
    $secondByteBinary = sprintf('%08b', ord($data[1]));
    $opcode = bindec(substr($firstByteBinary, 4, 4));
    $isMasked = ($secondByteBinary[0] == '1') ? true : false;
    $payloadLength = ord($data[1]) & 127;

    // unmasked frame is received:
    if (!$isMasked) {
        return array('type' => '', 'payload' => '', 'error' => 'protocol error (1002)');
    }

    switch ($opcode) {
        // text frame:
        case 1:
            $decodedData['type'] = 'text';
            break;

        case 2:
            $decodedData['type'] = 'binary';
            break;

        // connection close frame:
        case 8:
            $decodedData['type'] = 'close';
            break;

        // ping frame:
        case 9:
            $decodedData['type'] = 'ping';
            break;

        // pong frame:
        case 10:
            $decodedData['type'] = 'pong';
            break;

        default:
            return array('type' => '', 'payload' => '', 'error' => 'unknown opcode (1003)');
    }

    if ($payloadLength === 126) {
        $mask = substr($data, 4, 4);
        $payloadOffset = 8;
        $dataLength = bindec(sprintf('%08b', ord($data[2])) . sprintf('%08b', ord($data[3]))) + $payloadOffset;
    } elseif ($payloadLength === 127) {
        $mask = substr($data, 10, 4);
        $payloadOffset = 14;
        $tmp = '';
        for ($i = 0; $i < 8; $i++) {
            $tmp .= sprintf('%08b', ord($data[$i + 2]));
        }
        $dataLength = bindec($tmp) + $payloadOffset;
        unset($tmp);
    } else {
        $mask = substr($data, 2, 4);
        $payloadOffset = 6;
        $dataLength = $payloadLength + $payloadOffset;
    }

    /**
     * We have to check for large frames here. socket_recv cuts at 1024 bytes
     * so if websocket-frame is > 1024 bytes we have to wait until whole
     * data is transferd.
     */
    if (strlen($data) < $dataLength) {
        return false;
    }

    if ($isMasked) {
        for ($i = $payloadOffset; $i < $dataLength; $i++) {
            $j = $i - $payloadOffset;
            if (isset($data[$i])) {
                $unmaskedPayload .= $data[$i] ^ $mask[$j % 4];
            }
        }
        $decodedData['payload'] = $unmaskedPayload;
    } else {
        $payloadOffset = $payloadOffset - 4;
        $decodedData['payload'] = substr($data, $payloadOffset);
    }

    return $decodedData;
}

//пользовательские сценарии:

function onOpen($connect, $info) {
    echo "open\n";
    var_dump($info);
    fwrite($connect, encode('Соединение установлено!'));
}

function onClose($connect) {
    echo "close\n";
}

function onMessage($connect, $data,$info) {
    var_dump($info);
    echo decode($data)['payload'] . "\n";
    fwrite($connect, encode('так'));
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

#!/usr/bin/php

<?php

$socket = stream_socket_server("tcp://0.0.0.0:8000", $errno, $errstr);

if (!$socket) {

die("$errstr ($errno)\n");

}

$connects = array();

while (true) {

//формируем массив прослушиваемых сокетов:

$read = $connects;

$read []= $socket;

$write = $except = null;

if (!stream_select($read, $write, $except, null)) {//ожидаем сокеты доступные для чтения (без таймаута)

break;

}

if (in_array($socket, $read)) {//есть новое соединение

//принимаем новое соединение и производим рукопожатие:

if (($connect = stream_socket_accept($socket, -1)) && $info = handshake($connect)) {

$connects[] = $connect;//добавляем его в список необходимых для обработки

onOpen($connect, $info);//вызываем пользовательский сценарий

}

unset($read[ array_search($socket, $read) ]);

}

foreach($read as $connect) {//обрабатываем все соединения

$data = fread($connect, 100000);

if (!$data) { //соединение было закрыто

fclose($connect);

unset($connects[ array_search($connect, $connects) ]);

onClose($connect);//вызываем пользовательский сценарий

continue;

}

onMessage($connect, $data,$info);//вызываем пользовательский сценарий

}

fclose($server);

function handshake($connect) {

$info = array();

$line = fgets($connect);

$header = explode(' ', $line);

$info['method'] = $header[0];

$info['uri'] = $header[1];

//считываем заголовки из соединения

while ($line = rtrim(fgets($connect))) {

if (preg_match('/\A(\S+): (.*)\z/', $line, $matches)) {

$info[$matches[1]] = $matches[2];

} else {

break;

}

$address = explode(':', stream_socket_get_name($connect, true)); //получаем адрес клиента

$info['ip'] = $address[0];

$info['port'] = $address[1];

if (empty($info['Sec-WebSocket-Key'])) {

return false;

}

//отправляем заголовок согласно протоколу вебсокета

$SecWebSocketAccept = base64_encode(pack('H*', sha1($info['Sec-WebSocket-Key'] . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));

$upgrade = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .

"Upgrade: websocket\r\n" .

"Connection: Upgrade\r\n" .

"Sec-WebSocket-Accept:$SecWebSocketAccept\r\n\r\n";

fwrite($connect, $upgrade);

return $info;

}

function encode($payload, $type = 'text', $masked = false){

$frameHead = array();

$payloadLength = strlen($payload);

switch ($type) {

case 'text':

// first byte indicates FIN, Text-Frame (10000001):

$frameHead[0] = 129;

break;

case 'close':

// first byte indicates FIN, Close Frame(10001000):

$frameHead[0] = 136;

break;

case 'ping':

// first byte indicates FIN, Ping frame (10001001):

$frameHead[0] = 137;

break;

case 'pong':

// first byte indicates FIN, Pong frame (10001010):

$frameHead[0] = 138;

break;

}

// set mask and payload length (using 1, 3 or 9 bytes)

if ($payloadLength > 65535) {

$payloadLengthBin = str_split(sprintf('%064b', $payloadLength), 8);

$frameHead[1] = ($masked === true) ? 255 : 127;

for ($i = 0; $i < 8; $i++) {

$frameHead[$i + 2] = bindec($payloadLengthBin[$i]);

}

// most significant bit MUST be 0

if ($frameHead[2] > 127) {

return array('type' => '', 'payload' => '', 'error' => 'frame too large (1004)');

}

} elseif ($payloadLength > 125) {

$payloadLengthBin = str_split(sprintf('%016b', $payloadLength), 8);

$frameHead[1] = ($masked === true) ? 254 : 126;

$frameHead[2] = bindec($payloadLengthBin[0]);

$frameHead[3] = bindec($payloadLengthBin[1]);

} else {

$frameHead[1] = ($masked === true) ? $payloadLength + 128 : $payloadLength;

}

// convert frame-head to string:

foreach (array_keys($frameHead) as $i) {

$frameHead[$i] = chr($frameHead[$i]);

}

if ($masked === true) {

// generate a random mask:

$mask = array();

for ($i = 0; $i < 4; $i++) {

$mask[$i] = chr(rand(0, 255));

}

$frameHead = array_merge($frameHead, $mask);

}

$frame = implode('', $frameHead);

// append payload to frame:

for ($i = 0; $i < $payloadLength; $i++) {

$frame .= ($masked === true) ? $payload[$i] ^ $mask[$i % 4] : $payload[$i];

}

return $frame;

}

function decode($data){

$unmaskedPayload = '';

$decodedData = array();

// estimate frame type:

$firstByteBinary = sprintf('%08b', ord($data[0]));

$secondByteBinary = sprintf('%08b', ord($data[1]));

$opcode = bindec(substr($firstByteBinary, 4, 4));

$isMasked = ($secondByteBinary[0] == '1') ? true : false;

$payloadLength = ord($data[1]) & 127;

// unmasked frame is received:

if (!$isMasked) {

return array('type' => '', 'payload' => '', 'error' => 'protocol error (1002)');

}

switch ($opcode) {

// text frame:

case 1:

$decodedData['type'] = 'text';

break;

case 2:

$decodedData['type'] = 'binary';

break;

// connection close frame:

case 8:

$decodedData['type'] = 'close';

break;

// ping frame:

case 9:

$decodedData['type'] = 'ping';

break;

// pong frame:

case 10:

$decodedData['type'] = 'pong';

break;

default:

return array('type' => '', 'payload' => '', 'error' => 'unknown opcode (1003)');

}

if ($payloadLength === 126) {

$mask = substr($data, 4, 4);

$payloadOffset = 8;

$dataLength = bindec(sprintf('%08b', ord($data[2])) . sprintf('%08b', ord($data[3]))) + $payloadOffset;

} elseif ($payloadLength === 127) {

$mask = substr($data, 10, 4);

$payloadOffset = 14;

$tmp = '';

for ($i = 0; $i < 8; $i++) {

$tmp .= sprintf('%08b', ord($data[$i + 2]));

}

$dataLength = bindec($tmp) + $payloadOffset;

unset($tmp);

} else {

$mask = substr($data, 2, 4);

$payloadOffset = 6;

$dataLength = $payloadLength + $payloadOffset;

}

/**

* We have to check for large frames here. socket_recv cuts at 1024 bytes

* so if websocket-frame is > 1024 bytes we have to wait until whole

* data is transferd.

if (strlen($data) < $dataLength) {

return false;

}

if ($isMasked) {

for ($i = $payloadOffset; $i < $dataLength; $i++) {

$j = $i - $payloadOffset;

if (isset($data[$i])) {

$unmaskedPayload .= $data[$i] ^ $mask[$j % 4];

}

$decodedData['payload'] = $unmaskedPayload;

} else {

$payloadOffset = $payloadOffset - 4;

$decodedData['payload'] = substr($data, $payloadOffset);

}

return $decodedData;

}

//пользовательские сценарии:

function onOpen($connect, $info) {

echo "open\n";

var_dump($info);

fwrite($connect, encode('Соединение установлено!'));

}

function onClose($connect) {

echo "close\n";

}

function onMessage($connect, $data,$info) {

var_dump($info);

echo decode($data)['payload'] . "\n";

fwrite($connect, encode('так'));

}

По мотивам: https://habrahabr.ru/post/209864/ и https://learn.javascript.ru/websockets

2 комментария php, socket server, stream_socket_server, WebSocket, сокет сервер

Обмен информацией между серверами на PHP

22.04.2016 Павел Грибов PHP

Задача: получить данные с сервера, без использования apache

Решение: воспользуемся сокетами на php, а точнее поднимем свой «веб сервер», единственной функцией которго, будет на любой запрос отвечать требуемыми нам данными

Код сервера:

#!/usr/local/bin/php
<?php

function GetCurrentTraf($ent){    
    $current_speed = `/usr/bin/netstat -nbI $ent | grep 'Link' | awk '{print $8}'`;     
    $current_speed=rtrim($current_speed);
    return $current_speed;
};

$socket = stream_socket_server("tcp://0.0.0.0:800", $errno, $errstr);

if (!$socket) {
    die("$errstr ($errno)\n");
}

while ($connect = stream_socket_accept($socket, -1)) {

    $current_traf = GetCurrentTraf("iя0");
    $current_time = time();  
    $json_data = array ('speed'=>$current_traf,'time'=>$current_time);
    $jsonen=json_encode($json_data);
    fwrite($connect, "HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nConnection: close\r\n\r\n $jsonen");
    fclose($connect);
}

fclose($socket);

#!/usr/local/bin/php

<?php

function GetCurrentTraf($ent){

$current_speed = `/usr/bin/netstat -nbI $ent | grep 'Link' | awk '{print $8}'`;

$current_speed=rtrim($current_speed);

return $current_speed;

};

$socket = stream_socket_server("tcp://0.0.0.0:800", $errno, $errstr);

if (!$socket) {

die("$errstr ($errno)\n");

}

while ($connect = stream_socket_accept($socket, -1)) {

$current_traf = GetCurrentTraf("iя0");

$current_time = time();

$json_data = array ('speed'=>$current_traf,'time'=>$current_time);

$jsonen=json_encode($json_data);

fwrite($connect, "HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nConnection: close\r\n\r\n $jsonen");

fclose($connect);

}

fclose($socket);

Код клиента:

  $json = file_get_contents($external_traff_url);  
  $obj=json_decode($json);
  $current_speed=$obj->speed;
      echo "--текущий трафик на интерфейсе : $current_speed (внешний)\n";

$json = file_get_contents($external_traff_url);

$obj=json_decode($json);

$current_speed=$obj->speed;

echo "--текущий трафик на интерфейсе : $current_speed (внешний)\n";

Оставить комментарий php, stream_socket_server, обмен данными

Запуск единственной копии скрипта на php

15.11.2015 Павел Грибов Linux, PHP

Задача: в кроне с некой периодичностью запускается скрипт на php. Однако он не всегда успевает завершится за минуту. Соответственно нужно добиться того, чтобы скрипт не запускался повторно, в том случае если предыдущий скрипт еще не завершился.

Решение: при каждом запуске скрипта будем при помощи fopen пробовать открыть некий файл (и создавать его в случае отсутствия). После чего будем проверять — а не открыт ли он уже еще кем-то. Если открыт — думаем что открыт другой копией скрипта, и благополучно завершаем свою работу.

$fl = fopen( ‘/tmp/shaper_new.lock’, ‘w’ );

if( ! ( $fl && flock( $fl, LOCK_EX | LOCK_NB ) ) ) {die("--копия скрипта уже запущена!");};

$fl = fopen( ‘/tmp/shaper_new.lock’, ‘w’ );

if( ! ( $fl && flock( $fl, LOCK_EX | LOCK_NB ) ) ) {die("--копия скрипта уже запущена!");};

В принципе можно и считать запущеные копии при помощи ps -ax | grep name_script | wc -l, но почему то у меня сиё работало не надежно..

Оставить комментарий php, запуск единственной копии скрипта, проверка одного запуска

Свичи Dlink. Получаем список портов на определенном VLAN.

21.10.2015 Павел Грибов Linux, PHP

Сделаем это на PHP:

$ip="222.226.134.21";
$vlan=10;

//получаем порты в 10 VLAN
echo "--опрашиваю $ip\n";
$rez=`snmpget -v2c -c X-Files $ip 1.3.6.1.2.1.17.7.1.4.3.1.4.$vlan`;
$reza=  explode("Hex-STRING: ", $rez);
$tmp=trim($reza[1]);
$reza=  explode(" ", $tmp);
$hx=hexdec($reza[0]."".$reza[1]."".$reza[2]."".$reza[3]);
$bin=decbin($hx);
echo "--бинарная строка: $bin\n";
if (strlen($bin)>1){
  for ($i=0;$i<strlen($bin);$i++){
      if ($bin[$i]==1) {
          $port=$i+1;
          echo "--на $port порту $vlan VLAN\n";          
      };
  };
} else {
  echo "$ip отдал не корректные данные! ($rez)\n";  
};

$ip="222.226.134.21";

$vlan=10;

//получаем порты в 10 VLAN

echo "--опрашиваю $ip\n";

$rez=`snmpget -v2c -c X-Files $ip 1.3.6.1.2.1.17.7.1.4.3.1.4.$vlan`;

$reza= explode("Hex-STRING: ", $rez);

$tmp=trim($reza[1]);

$reza= explode(" ", $tmp);

$hx=hexdec($reza[0]."".$reza[1]."".$reza[2]."".$reza[3]);

$bin=decbin($hx);

echo "--бинарная строка: $bin\n";

if (strlen($bin)>1){

for ($i=0;$i<strlen($bin);$i++){

if ($bin[$i]==1) {

$port=$i+1;

echo "--на $port порту $vlan VLAN\n";

};

} else {

echo "$ip отдал не корректные данные! ($rez)\n";

};

Оставить комментарий dlink, php, vlan, список портов

Обмен данными между серверами..

23.09.2015 Павел Грибов Linux, WEB

Задача: на сервер А, периодически получить некие данные с сервера Б.

Хм. К сожаление не придумал ничего умнее кроме как:

На сервере Б регулярно выполнять скрипт, который собирает данные и при помощи

$handle=fopen("http://сервер/скрипт.php?данные", "r");

выплевывает их на сервер А, в качестве параметра GET. На сервере А, правда настроил доступы при помощи .htaccess для конкретного IP сервера..

Но решение не нравится.. Какие то должны быть механизмы попроще и понадежне..

Оставить комментарий php, обмен данными между серверами

« 1 … 12 13 14 15 16 … 22 »

Декабрь 2024
Пн	Вт	Ср	Чт	Пт	Сб	Вс
						1
2	3	4	5	6	7	8
9	10	11	12	13	14	15
16	17	18	19	20	21	22
23	24	25	26	27	28	29
30	31