swoole安裝基本配置
php安裝swoole
1. 下載swoole安裝
wget http://pecl.php.net/get/swoole-1.9.1.tgz tar -zxvf swoole-1.9.1.tgz cd swoole-1.9.1 phpize ./configure make make install
2. 在php.ini添加swoole.so
extension=swoole.so
php -m查看是否安裝成功
環境依賴
- 僅支持Linux，FreeBSD，MacOS，3類操作系統
- Linux內核版本2.3.32以上
- PHP5.3.10以上版本
- gcc4.4以上版本或者clang
- cmake2.4+，編譯為libswoole.so作為C/C++庫時需要使用cmake
PHP版本依賴
- swoole僅支持PHP5.3.10或更高版本，建議使用PHP5.4+
- swoole不依賴php的stream、sockets、pcntl、posix、sysvmsg等擴展。PHP只需安裝最基本的擴展即可
PHP直播代碼
1.start.php 使用時需要開啟，服務器輸入（php start.php）
<?php
//php在線直播示例代碼 //使用PHPCLI模式運行 //命令：php start.php //設置路徑 define('_ROOT_', dirname(__FILE__)); require_once _ROOT_.'/function.php'; //監聽地址和端口 $server = new swoole_websocket_server("0.0.0.0（這里就是四個0，不要改）", 8888); //服務端接收連接事件 $server->on('open', function (swoole_websocket_server $server, $request) { if(!file_exists(_ROOT_.'/client/'.$request->fd.'.client')){ @file_put_contents(_ROOT_.'/client/'.$request->fd.'.client',$request->fd); } }); //服務端接收信息事件 $server->on('message', function (swoole_websocket_server $server, $frame) { foreach(notice(_ROOT_.'/client/') as $v){ $server->push($v,$frame->data); } }); //服務端接收關閉事件 $server->on('close', function ($ser, $fd) { @unlink(_ROOT_.'/client/'.$fd.'.client'); }); //服務開啟 $server->start();
2.index.html 直播頁面，訪問該頁面觀看直播
<!DOCTYPE html>
<html>
<head lang="en">
<meta charset="UTF-8">
<title>在線直播界面</title>
</head>
<body>
<img id="receiver" style='width:640px;height:480px'/>
<script type="text/javascript" charset="utf-8">
var ws = new WebSocket("ws://改成自己服務器ip:8888"); var image = document.getElementById('receiver'); ws.onopen = function(){ } ws.onmessage = function(data) { image.src=data.data; } </script> </body> </html>
3.rec.html主播錄制頁面，訪問該頁面進行直播錄制
<!DOCTYPE html>
<html>
<head lang="en">
<meta charset="UTF-8">
<title>主播錄制界面</title>
</head>
<body>
<video id="video" autoplay="" style='width:640px;height:480px'></video>
<canvas id="output" style="display:none"></canvas>
<script type="text/javascript" charset="utf-8">
var ws = new WebSocket("ws://自己服務器ip:8888"); var back = document.getElementById('output'); var backcontext = back.getContext('2d'); var video = document.getElementById("video"); var success = function(stream){ video.src = window.URL.createObjectURL(stream); } ws.onopen = function(){ draw(); } var draw = function(){ try{ backcontext.drawImage(video,0,0, back.width, back.height); }catch(e){ if (e.name == "NS_ERROR_NOT_AVAILABLE") { return setTimeout(draw, 100); } else { throw e; } } if(video.src){ ws.send(back.toDataURL("image/jpeg", 0.5)); } setTimeout(draw, 100); } navigator.getUserMedia = navigator.getUserMedia || navigator.webkitGetUserMedia || navigator.mozGetUserMedia || navigator.msGetUserMedia; navigator.getUserMedia({video:true, audio:false}, success, console.log); </script> </body> </html>
4.function.php 統計數據頁面
<?php
//統計在線人數 function clearDir($dir) { $n = 0; if ($dh = opendir($dir)) { while (($file = readdir($dh)) !== false) { if ($file == '.' or $file == '..') { continue; } if (is_file($dir . $file)) { $n++; } } } closedir($dh); return $n; } //通知在線的人 function notice($dir){ if ($dh = opendir($dir)) { while (($file = readdir($dh)) !== false) { if ($file == '.' or $file == '..') { continue; } if (is_file($dir . $file)) { $array[]=file_get_contents($dir.$file); } } } closedir($dh); return $array; }
5.在同級目錄php
PHP 即使通訊
1.socket.php 一樣，使用時需要開啟
2.socket.html聊天頁面
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Title</title>
</head>
<body>
<div id="msg"></div>
<input type="text" id="text">
<input type="submit" value="發送數據" onclick="song()">
</body>
<script>
var msg = document.getElementById("msg"); var wsServer = 'ws://60.205.208.176:9502'; //調用websocket對象建立連接： //參數：ws/wss(加密)：//ip:port （字符串） var websocket = new WebSocket(wsServer); //onopen監聽連接打開 websocket.onopen = function (evt) { //websocket.readyState 屬性： /* CONNECTING 0 The connection is not yet open. OPEN 1 The connection is open and ready to communicate. CLOSING 2 The connection is in the process of closing. CLOSED 3 The connection is closed or couldn't be opened. */ msg.innerHTML = websocket.readyState; }; function song(){ var text = document.getElementById('text').value; document.getElementById('text').value = ''; //向服務器發送數據 websocket.send(text); } //監聽連接關閉 // websocket.onclose = function (evt) { // console.log("Disconnected"); // }; //onmessage 監聽服務器數據推送 websocket.onmessage = function (evt) { msg.innerHTML += evt.data +'<br>'; // console.log('Retrieved data from server: ' + evt.data); }; //監聽連接錯誤信息 // websocket.onerror = function (evt, e) { // console.log('Error occured: ' + evt.data); // }; </script> </html>