Dieser Artikel stellt hauptsächlich die Implementierung der Socket-Push-Technologie in PHP vor, die einen gewissen Referenzwert hat. Jetzt kann ich sie mit allen teilen. Freunde in Not können sich darauf beziehen
Vor dem Aufkommen von Socket gab es Es gibt bereits Ajax-Timing-Anfragen, lange Abfragen und andere Lösungen, aber keine davon kann die Anforderungen erfüllen, also wurde Socket geboren.
Socket-Grundfunktion Socket
Zusammenfassung häufig verwendeter Socket-Funktionen
Serverseite: socket_create erstellt einen Socket und legt grundlegende Parameter fest
socket_bind bindet IP und Port Nummer
socket_listen lauscht
socket_accept Client-Verbindung
socket_read liest Client-Daten
socket_write sendet Daten an einen separaten Client
socket_close Schließen Sie die Verbindung
Client: socket_create Socket erstellen und Grundparameter festlegen
socket_connect Socket verbinden
socket_write Daten an den Server senden
socket_read Serverdaten lesen
socket_close schließt die Verbindung
H5websocket Nicht viel zu sagen, laden Sie den Link hoch
OK, beginnen Sie mit der Veröffentlichung des Codes~
--------- -------------------------------------------------Segmentierung Zeile
Servercode:
<?php
class WS {
var $master;
var $sockets = array();
var $debug = false;//true为调试模式，输出log日志
var $handshake = array();
function __construct($address, $port){
$this->master=socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die("socket_create() failed");
socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1) or die("socket_option() failed");
socket_bind($this->master, $address, $port) or die("socket_bind() failed");
socket_listen($this->master,20) or die("socket_listen() failed");
$this->sockets[] = $this->master;
$this->say("Server Started : ".date('Y-m-d H:i:s'));
$this->say("Listening on : ".$address." port ".$port);
$this->say("Master socket : ".$this->master."\n");
while(true){
$socketArr = $this->sockets;
$write = NULL;
$except = NULL;
socket_select($socketArr, $write, $except, NULL); //自动选择来消息的socket 如果是握手 自动选择主机
foreach ($socketArr as $socket){
if ($socket == $this->master){ //主机
$client = socket_accept($this->master);
if ($client < 0){
$this->log("socket_accept() failed");
continue;
} else{
$this->connect($client);
}
} else {
$bytes = @socket_recv($socket,$buffer,2048,0);
if ($bytes == 0){
$this->disConnect($socket);
}
else{
$key = array_search($socket, $this->sockets);
if (empty($this->handshake) || !isset($this->handshake[$key]) || !$this->handshake[$key]){
$this->doHandShake($socket, $buffer, $key);
}
else{
$buffer = $this->decode($buffer);
echo $buffer.PHP_EOL;
$key = array_search($socket, $this->sockets);
$arr = $this->sockets;
array_shift($arr);
foreach ($arr as $s){
$this->send($s, $buffer);
}
}
}
}
}
}
}
function send($client, $msg){
$msg = $this->frame($msg);
socket_write($client, $msg, strlen($msg));
}
function connect($socket){
array_push($this->sockets, $socket);
$this->say("\n" . $socket . " CONNECTED!");
$this->say(date("Y-n-d H:i:s"));
}
function disConnect($socket){
$index = array_search($socket, $this->sockets);
socket_close($socket);
$this->say($socket . " DISCONNECTED!");
if ($index >= 0){
echo 'unset index is:'.PHP_EOL;
unset($this->sockets[$index]);
}
}
function doHandShake($socket, $buffer, $handKey){
$this->log("\nRequesting handshake...");
$this->log($buffer);
list($resource, $host, $origin, $key) = $this->getHeaders($buffer);
$this->log("Handshaking...");
$upgrade = "HTTP/1.1 101 Switching Protocol\r\n" .
"Upgrade: websocket\r\n" .
"Connection: Upgrade\r\n" .
"Sec-WebSocket-Accept: " . $this->calcKey($key) . "\r\n\r\n"; //必须以两个回车结尾
$this->log($upgrade);
$sent = socket_write($socket, $upgrade, strlen($upgrade));
$this->handshake[$handKey]=true;
$this->log("Done handshaking...");
return true;
}
function getHeaders($req){
$r = $h = $o = $key = null;
if (preg_match("/GET (.*) HTTP/" ,$req,$match)) { $r = $match[1]; }
if (preg_match("/Host: (.*)\r\n/" ,$req,$match)) { $h = $match[1]; }
if (preg_match("/Origin: (.*)\r\n/" ,$req,$match)) { $o = $match[1]; }
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/",$req,$match)) { $key = $match[1]; }
return array($r, $h, $o, $key);
}
function calcKey($key){
//基于websocket version 13
$accept = base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));
return $accept;
}
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;
}
function frame($s){
$a = str_split($s, 125);
if (count($a) == 1){
return "\x81" . chr(strlen($a[0])) . $a[0];
}
$ns = "";
foreach ($a as $o){
$ns .= "\x81" . chr(strlen($o)) . $o;
}
return $ns;
}
function say($msg = ""){
echo $msg . "\n";
}
function log($msg = ""){
if ($this->debug){
echo $msg . "\n";
}
}
}
new WS('localhost', 4000);Nach dem Login kopieren
Clientcode (H5):
<html>
<head>
<title>demo</title>
<script src="https://cdn.bootcss.com/jquery/1.9.1/jquery.min.js"></script>
</head>
<body>
<input type="text" id="content">
<input type="button" value="send" id="send">
<script type="text/javascript"> var ws = new WebSocket("ws://localhost:4000");
ws.onopen = function(){
console.log("握手成功");
}
ws.onmessage = function(e){
console.log("message:" + e.data);
}
ws.onerror = function(){
console.log("error");
}
$("#send").click(function(){
content = $("#content").val();
console.log(content);
ws.send(content);
}) </script>
</body>
</html>Nach dem Login kopieren
Führen Sie dann php demo.php aus, um den Socket zu öffnen (stehlen Sie einen Trick aus dem Betrieb und der Wartung, führen Sie nohup php demo.php unter Linux aus und können Sie es ausführen Hintergrund), der Browser kann mehrere index.html öffnen und eine Kommunikation herstellen.
Code-Analyse:
1. Das Attribut $sockets-Array speichert jede akzeptierte Verbindung (ich weiß nicht, ob das die richtige Beschreibung ist); 🎜>2. Attribut Das $handshake-Array speichert, ob die Verbindung im verbundenen Zustand ist;
Das Obige ist der gesamte Inhalt dieses Artikels. Ich hoffe, dass er für das Lernen aller hilfreich ist. Bitte achten Sie auf die chinesische PHP-Website!
Verwandte Empfehlungen:
So verwenden Sie Elasticsearch in PHP
Batch-Update von PHP
Das obige ist der detaillierte Inhalt vonPHP implementiert die Socket-Push-Technologie. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
