|
導(dǎo)讀網(wǎng)頁的本質(zhì)就是超級(jí)文本標(biāo)記語言，通過結(jié)合使用其他的Web技術(shù)（如：腳本語言、公共網(wǎng)關(guān)接口、組件等），可以創(chuàng)造出功能強(qiáng)大的網(wǎng)頁。因而，超級(jí)文本標(biāo)記語言是萬維網(wǎng)（Web）編程的基礎(chǔ)，也就是說萬維網(wǎng)是建立... 網(wǎng)頁的本質(zhì)就是超級(jí)文本標(biāo)記語言，通過結(jié)合使用其他的Web技術(shù)（如：腳本語言、公共網(wǎng)關(guān)接口、組件等），可以創(chuàng)造出功能強(qiáng)大的網(wǎng)頁。因而，超級(jí)文本標(biāo)記語言是萬維網(wǎng)（Web）編程的基礎(chǔ)，也就是說萬維網(wǎng)是建立在超文本基礎(chǔ)之上的。超級(jí)文本標(biāo)記語言之所以稱為超文本標(biāo)記語言，是因?yàn)槲谋局邪怂^“超級(jí)鏈接”點(diǎn)。 本篇文章給大家?guī)淼膬?nèi)容是關(guān)于php下Socket服務(wù)器如何搭建并測(cè)試？（代碼），有一定的參考價(jià)值，有需要的朋友可以參考一下，希望對(duì)你有所幫助。 1、socket服務(wù)器搭建思路 1) 目的：理解socket服務(wù)器工作機(jī)制 2) 思路：創(chuàng)建socket -> 把socket加入連接池 -> 處理接收信息 -> 握手動(dòng)作 -> 發(fā)送信息 2、socket服務(wù)器代碼 注：復(fù)制到php文件，直接命令行可以運(yùn)行，不需要其他支持 特別注意：為了能傳輸中文_sendMsg做了json_encode() <?php
/**
* Socket服務(wù)器
* @author wuchangliang 2018/1/17
*/
class SocketServer
{
private $sockets; //連接池
private $master;
private $handshake;
/**
* @param $address
* @param $port
*/
public function run($address, $port)
{
//配置錯(cuò)誤級(jí)別、運(yùn)行時(shí)間、刷新緩沖區(qū)
echo iconv('UTF-8', 'GBK', "歡迎來到PHP Socket測(cè)試服務(wù)。 \n");
error_reporting(0);
set_time_limit(0);
ob_implicit_flush();
//創(chuàng)建socket
$this->master = $this->_connect($address, $port);
$this->sockets[] = $this->master;
//運(yùn)行socket
while (true) {
$sockets = $this->sockets;
$write = NULL;
$except = NULL;
socket_select($sockets, $write, $except, NULL); //$write,$except傳引用
foreach ($sockets as $socket) {
if ($socket == $this->master) {
$client = socket_accept($socket);
$this->handshake = false;
if ($client) {
$this->sockets[] = $client; //加入連接池
}
} else {
//接收信息
$bytes = @socket_recv($socket, $buffer, 2048, 0);
if ($bytes <= 6) {
$this->_disConnect($socket);
continue;
};
//處理信息
if (!$this->handshake) {
$this->_handshake($socket, $buffer);
} else {
$buffer = $this->_decode($buffer);
$this->_sendMsg($buffer, $socket);
}
}
}
}
}
/**
* 創(chuàng)建socket連接
* @param $address
* @param $port
* @return resource
*/
private function _connect($address, $port)
{
//創(chuàng)建socket
$master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)
or die("socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n");
socket_bind($master, $address, $port)
or die("socket_bind() failed: reason: " . socket_strerror(socket_last_error($master)) . "\n");
socket_listen($master, 5)
or die("socket_listen() failed: reason: " . socket_strerror(socket_last_error($master)) . "\n");
return $master;
}
/**
* 握手動(dòng)作
* @param $socket
* @param $buffer
*/
private function _handshake($socket, $buffer)
{
//握手動(dòng)作信息
$buf = substr($buffer, strpos($buffer, 'Sec-WebSocket-Key:') + 18);
$key = trim(substr($buf, 0, strpos($buf, "\r\n")));
$new_key = base64_encode(sha1($key . "258EAFA5-E914-47DA-95CA-C5AB0DC85B11", true));
$new_message = "HTTP/1.1 101 Switching Protocols\r\n";
$new_message .= "Upgrade: websocket\r\n";
$new_message .= "Sec-WebSocket-Version: 13\r\n";
$new_message .= "Connection: Upgrade\r\n";
$new_message .= "Sec-WebSocket-Accept: " . $new_key . "\r\n\r\n";
//記錄握手動(dòng)作
socket_write($socket, $new_message, strlen($new_message));
$this->handshake = true;
}
/**
* 斷開socket連接
* @param $socket
*/
private function _disConnect($socket)
{
$index = array_search($socket, $this->sockets);
socket_close($socket);
if ($index >= 0) {
array_splice($this->sockets, $index, 1);
}
}
/**
* 發(fā)送信息
* @param $buffer
* @param $client
*/
private function _sendMsg($buffer, $client)
{
$send_buffer = $this->_frame(json_encode($buffer));
foreach ($this->sockets as $socket) {
if ($socket != $this->master && $socket != $client) { //廣播發(fā)送（除了自己）
socket_write($socket, $send_buffer, strlen($send_buffer));
}
}
}
/**
* 解析數(shù)據(jù)幀
* @param $buffer
* @return null|string
*/
private function _decode($buffer)
{
$len = $masks = $data = $decoded = null;
$len = ord($buffer[1]) & 127;
if ($len === 126) {
$masks = substr($buffer, 4, 4);
$data = substr($buffer, 8);
} else if ($len === 127) {
$masks = substr($buffer, 10, 4);
$data = substr($buffer, 14);
} else {
$masks = substr($buffer, 2, 4);
$data = substr($buffer, 6);
}
for ($index = 0; $index < strlen($data); $index++) {
$decoded .= $data[$index] ^ $masks[$index % 4];
}
return $decoded;
}
/**
* 處理返回幀
* @param $buffer
* @return string
*/
private function _frame($buffer)
{
$len = strlen($buffer);
if ($len <= 125) {
return "\x81" . chr($len) . $buffer;
} else if ($len <= 65535) {
return "\x81" . chr(126) . pack("n", $len) . $buffer;
} else {
return "\x81" . char(127) . pack("xxxxN", $len) . $buffer;
}
}
}
$sc = new SocketServer();
$sc->run('127.0.0.1', 2046);3、客戶端代碼 注：直接復(fù)制到html，和上面的php文件在同一文件夾即可，特別注意onmessage解析的兩層 parse <!DOCTYPE html>
<html>
<head>
<meta charset="utf-8" />
<title>WebSocket Test</title>
<script language="javascript"type="text/javascript">
websocket = new WebSocket('ws://127.0.0.1:2046/');
websocket.onopen = function(evt) {
console.log('connect');
websocket.send('{"data":"您好，世界！"}');
};
websocket.onclose = function(evt) {
console.log('onclose');
console.log(evt);
};
websocket.onmessage = function(evt) {
console.log('onmessage');
if (evt.data) {
console.log(JSON.parse(JSON.parse(evt.data)));
}
};
websocket.onerror = function(evt) {
console.log('onerror');
console.log(evt);
};
function sendMsg(){
var sendData = { 'data': document.getElementById('name').value};
websocket.send(JSON.stringify(sendData));
}
</script>
</head>
<body>
<h2>WebSocket Test</h2>
<input type="text" name="name" id="name" />
<a href="javascript:;" onclick="sendMsg()">點(diǎn)擊發(fā)送</a>
</body>
</html>4、測(cè)試示例
相關(guān)推薦： PHP中Socket服務(wù)器搭建和測(cè)試方法教程 以上就是php下Socket服務(wù)器如何搭建并測(cè)試？（代碼）的詳細(xì)內(nèi)容，更多請(qǐng)關(guān)注php中文網(wǎng)其它相關(guān)文章！ 網(wǎng)站建設(shè)是一個(gè)廣義的術(shù)語，涵蓋了許多不同的技能和學(xué)科中所使用的生產(chǎn)和維護(hù)的網(wǎng)站。 |
溫馨提示：喜歡本站的話，請(qǐng)收藏一下本站！
本站發(fā)布的Win7純凈版系統(tǒng)、Win10純凈版和XP純凈版系統(tǒng)僅為個(gè)人學(xué)習(xí)測(cè)試使用，請(qǐng)?jiān)谙螺d后24小時(shí)內(nèi)刪除，不得用于任何商業(yè)用途，否則后果自負(fù)，請(qǐng)支持購(gòu)買微軟正版軟件！
本站所有資源全部來自于網(wǎng)絡(luò)資源,如侵犯到您的權(quán)益,請(qǐng)及時(shí)通知我們(peng896066052@126.com),我們會(huì)及時(shí)處理.
Copyright © 2018-2020 雨林木風(fēng)下載站
