Архивы Из жизни - Страница 19 из 69

10 лет Яртелесервису

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

Довелось побывать на «корпоративе» — 10 лет Яртелесервису. Мероприятие происходило в Углическом районе,Ярославской области. Утром — сплав на байдарках. Потом пейнтбол, волебол, баня, песни у костра до утра. Палатки, комары. В общем романтека. Очень понравилось. Давно так не расслаблялся и не отдыхал.

Оставить комментарий 10 лет яртелесервису, корпоратив

Простой сервер 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, сокет сервер

Theme Hospital, игра

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

На днях ностальгировал с игрой «Theme Hospital» — экономический симулятор госпиталя. Оригинально игра выпущена в 1998 году, и на современных ПК запускается с пляской и бубном. Однако! Есть клон этой игры, которая позволит поиграть в оригинальную игру с нормальным разрешением экрана. Для запуска понадобится оригинальная игра.

Скачать последний релиз CorsixTH можно по ссылке (на момент публикации поста ver 0.30):
https://github.com/CorsixTH/CorsixTH/releases

Оригинальные файлы с игрой можно скачать по ссылке (RIP версия 26,24 Mb):
http://www.old-games.ru/game/download/361.html

Оставить комментарий госпиталь, игра

Накласть или наложить?

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

Вот в чем вопрос который возник во время ужина! 😉

наложить на себя руки (покончить с собой) – заметим, что в данном значении глагол не может быть употреблен в форме несовершенного вида (незавершенного действия), ведь нельзя несколько раз покончить с собой
наложить в штанишки от страха (в разговорной речи)
наложить (в медицине) повязку, мазь, шину, гипс, жгут и т. д.
наложить резолюцию, визу, арест и т. д.
наложить позолоту, краску и т. д.
наложить (в значении «наполнить чем-либо») корзину яблоками, телегу снопами и т. д. Следовательно, если мы «наложим гарнир в тарелку«, в ней не останется места ни для чего другого.

Положить:

положить (поместить что-либо в лежачее положение, поместить сверху чего-либо) папку, книгу и т. д.: «положить гарнир на тарелку» и т. п.
положить (поместить кого-либо в лежачее положение) раненого, больного и т. д.

Оставить комментарий накласть, наложить, русский язык

Рубрика: Из жизни

Книги Олега Роя, «Джинглики» в складчину.

10 лет Яртелесервису

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

Theme Hospital, игра

Накласть или наложить?

Ноябрь 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