PHP实现队列及队列原理 队列是一种线性表，按照先进先出的原则进行的：PHP实现队列：第一个元素作为队头，最后一个元素作为队尾<?php /** * 队列就是这么简单 * * @link */ $array = array('PHP', 'JAVA'); array_push($array, 'PYTHON'); //入队列 array_shift($array); //出队列什么是双端队列(或双向队列)Deque，全名double-ended queue？即元素可以在队列的任意一段入队或出队，如果我们把这些方法叫做insertLeft()和insertRight()，以及removeLeft()和removeRight()。如果严格禁止调用insertLeft()和removeLeft()方法（或禁用右段的操作），双端队列功能就和栈一样。禁止调用insertLeft()和removeRight()（或相反的另一对方法），它的功能就和队列一样了。双端队列与栈或队列相比，是一种多用途的数据结构。PHP实现双端队列<?php class Deque { public $queue = array(); /**（尾部）入队 **/ public function addLast($value) { return array_push($this->queue,$value); } /**（尾部）出队**/ public function removeLast() { return array_pop($this->queue); } /**（头部）入队**/ public function addFirst($value) { return array_unshift($this->queue,$value); } /**（头部）出队**/ public function removeFirst() { return array_shift($this->queue); } /**清空队列**/ public function makeEmpty() { unset($this->queue); } /**获取列头**/ public function getFirst() { return reset($this->queue); } /** 获取列尾 **/ public function getLast() { return end($this->queue); } /** 获取长度 **/ public function getLength() { return count($this->queue); } }队列的用途：队列可以很好地异步处理数据传送和存储，当你频繁地向数据库中插入数据、频繁地向搜索引擎提交数据，就可采取队列来异步插入。另外，还可以将较慢的处理逻辑、有并发数量限制的处理逻辑，通过消息队列放在后台处理，例如FLV视频转换、发送手机短信、发送电子邮件等。

PHP多线程的实现方法详解 多线程是java中一个很不错的东西，很多朋友说在php中不可以使用PHP多线程了，其实那是错误的说法PHP多线程实现方法和fsockopen函数有关，下面我们来介绍具体实现程序代码，有需要了解的同学可参考。当有人想要实现并发功能时，他们通常会想到用fork或者spawn threads，但是当他们发现php不支持多线程的时候，大概会转换思路去用一些不够好的语言，比如perl。其实的是大多数情况下，你大可不必使用 fork 或者线程，并且你会得到比用 fork 或 thread 更好的性能。假设你要建立一个服务来检查正在运行的n台服务器，以确定他们还在正常运转。你可能会写下面这样的代码：代码如下<?php $hosts = array("host1.sample.com", "host2.sample.com", "host3.sample.com"); $timeout = 15; $status = array(); foreach ($hosts as $host) { $errno = 0; $errstr = ""; $s = fsockopen($host, 80, $errno, $errstr, $timeout); if ($s) { $status[$host] = "Connectedn"; fwrite($s, "HEAD / HTTP/1.0rnHost: $hostrnrn"); do { $data = fread($s, 8192); if (strlen($data) == 0) { break; } $status[$host] .= $data; } while (true); fclose($s); } else { $status[$host] = "Connection failed: $errno $errstrn"; } } print_r($status); ?>它运行的很好，但是在fsockopen()分析完hostname并且建立一个成功的连接（或者延时$timeout秒）之前，扩充这段代码来管理大量服务器将耗费很长时间。因此我们必须放弃这段代码；我们可以建立异步连接-不需要等待fsockopen返回连接状态。PHP仍然需要解析hostname（所以直接使用ip更加明智），不过将在打开一个连接之后立刻返回，继而我们就可以连接下一台服务器。有两种方法可以实现；PHP5中可以使用新增的stream_socket_client()函数直接替换掉fsocketopen()。PHP5之前的版本，你需要自己动手，用sockets扩展解决问题。下面是PHP5中的解决方法：它运行的很好，但是在fsockopen()分析完hostname并且建立一个成功的连接（或者延时$timeout秒）之前，扩充这段代码来管理大量服务器将耗费很长时间。因此我们必须放弃这段代码；我们可以建立异步连接-不需要等待fsockopen返回连接状态。PHP仍然需要解析hostname（所以直接使用ip更加明智），不过将在打开一个连接之后立刻返回，继而我们就可以连接下一台服务器。有两种方法可以实现；PHP5中可以使用新增的stream_socket_client()函数直接替换掉fsocketopen()。PHP5之前的版本，你需要自己动手，用sockets扩展解决问题。下面是PHP5中的解决方法：代码如下<?php $hosts = array("host1.sample.com", "host2.sample.com", "host3.sample.com"); $timeout = 15; $status = array(); $sockets = array(); /* Initiate connections to all the hosts simultaneously */ foreach ($hosts as $id => $host) { $s = stream_socket_client(" $ $host:80", $errno, $errstr, $timeout, STREAM_CLIENT_ASYNC_CONNECT|STREAM_CLIENT_CONNECT); if ($s) { $sockets[$id] = $s; $status[$id] = "in progress"; } else { $status[$id] = "failed, $errno $errstr"; } } /* Now, wait for the results to come back in */ while (count($sockets)) { $read = $write = $sockets; /* This is the magic function - explained below */ $n = stream_select($read, $write, $e = null, $timeout); if ($n > 0) { /* readable sockets either have data for us, or are failed * connection attempts */ foreach ($read as $r) { $id = array_search($r, $sockets); $data = fread($r, 8192); if (strlen($data) == 0) { if ($status[$id] == "in progress") { $status[$id] = "failed to connect"; } fclose($r); unset($sockets[$id]); } else { $status[$id] .= $data; } } /* writeable sockets can accept an HTTP request */ foreach ($write as $w) { $id = array_search($w, $sockets); fwrite($w, "HEAD / HTTP/1.0rnHost: " . $hosts[$id] . "rnrn"); $status[$id] = "waiting for response"; } } else { /* timed out waiting; assume that all hosts associated * with $sockets are faulty */ foreach ($sockets as $id => $s) { $status[$id] = "timed out " . $status[$id]; } break; } } foreach ($hosts as $id => $host) { echo "Host: $hostn"; echo "Status: " . $status[$id] . "nn"; } ?>我们用stream_select()等待sockets打开的连接事件。stream_select()调用系统的select(2)函数来工作：前面三个参数是你要使用的streams的数组；你可以对其读取，写入和获取异常（分别针对三个参数）。stream_select()可以通过设置$timeout（秒）参数来等待事件发生-事件发生时，相应的sockets数据将写入你传入的参数。下面是PHP4.1.0之后版本的实现，如果你已经在编译PHP时包含了sockets(ext/sockets)支持，你可以使用根上面类似的代码，只是需要将上面的streams/filesystem函数的功能用ext/sockets函数实现。主要的不同在于我们用下面的函数代替stream_socket_client()来建立连接：代码如下<?php // This value is correct for Linux, other systems have other values define('EINPROGRESS', 115); function non_blocking_connect($host, $port, &$errno, &$errstr, $timeout) { $ip = gethostbyname($host); $s = socket_create(AF_INET, SOCK_STREAM, 0); if (socket_set_nonblock($s)) { $r = @socket_connect($s, $ip, $port); if ($r || socket_last_error() == EINPROGRESS) { $errno = EINPROGRESS; return $s; } } $errno = socket_last_error($s); $errstr = socket_strerror($errno); socket_close($s); return false; } ?>现在用socket_select()替换掉stream_select()，用socket_read()替换掉fread()，用socket_write()替换掉fwrite()，用socket_close()替换掉fclose()就可以执行脚本了！PHP5的先进之处在于，你可以用stream_select()处理几乎所有的stream-例如你可以通过include STDIN用它接收键盘输入并保存进数组，你还可以接收通过proc_open()打开的管道中的数据。下面来分享一个PHP多线程类代码如下* @title: PHP多线程类(Thread) * @version: 1.0 * @author: phper.org.cn < web@phper.org.cn > * @published: 2010-11-2 * * PHP多线程应用示例： * require_once 'thread.class.php'; * $thread = new thread(); * $thread->addthread('action_log','a'); * $thread->addthread('action_log','b'); * $thread->addthread('action_log','c'); * $thread->runthread(); * * function action_log($info) { * $log = 'log/' . microtime() . '.log'; * $txt = $info . "rnrn" . 'Set in ' . Date('h:i:s', time()) . (double)microtime() . "rn"; * $fp = fopen($log, 'w'); * fwrite($fp, $txt); * fclose($fp); * } */ class thread { var $hooks = array(); var $args = array(); function thread() { } function addthread($func) { $args = array_slice(func_get_args(), 1); $this->hooks[] = $func; $this->args[] = $args; return true; } function runthread() { if(isset($_GET['flag'])) { $flag = intval($_GET['flag']); } if($flag || $flag === 0) { call_user_func_array($this->hooks[$flag], $this->args[$flag]); } else { for($i = 0, $size = count($this->hooks); $i < $size; $i++) { $fp=fsockopen($_SERVER['HTTP_HOST'],$_SERVER['SERVER_PORT']); if($fp) { $out = "GET {$_SERVER['PHP_SELF']}?flag=$i HTTP/1.1rn"; $out .= "Host: {$_SERVER['HTTP_HOST']}rn"; $out .= "Connection: Closernrn"; fputs($fp,$out); fclose($fp); } } } } }

php return 和 finally 组合使用，使return不终止函数运行 php return 和 finally 组合使用，使return不终止函数运行如下示例：php>=5.5<?php function example() { try { //例如打开mysql连接 if(condition) { return false; } } finally { // 关闭sql连接，这里会执行即使return被调用。 } } ?>

php全局异常/错误处理 php全局异常/错误处理php自有try{throw{}}catch{}异常/错误捕获系统，难以在生产环境中运用；生产环境中，我们一般要求，一旦出现异常/错误，php立刻结束脚本，向访客浏览器输出出错提示，并通过自定义函数向管理员发送消息以下就是php生产环境中的异常/错误处理方法工具/原料无方法/步骤在php代码开头处，增加代码：set_error_handler ( 'customerror' );这是php的常规错误捕获函数，一旦程序运行过程中出现常规错误，customerror（）函数就会被调用；customerror（）运行完毕，php程序继续运行，因此在customerror（）函数中的最后一句，需要die(); 结束脚本customerror（）有5个参数，这些参数会由set_error_handler（）自动提供customerror（）函数的具体书写形式：function customerror($error_level,$error_message,$error_file,$error_line,$error_context) {<--这里就是错误处理脚本-->die();//终止脚本}用set_exception_handler ( 'customexception' );捕获php运行过程中产生的第一个异常，因为该函数一旦捕获异常，就会停止执行脚本，因此只能捕获到第一个异常，捕获到异常后，会调用customexception（）函数customexception（）有一个参数，由set_exception_handler（）自动提供customexception（）函数的具体书写形式：function customexception($exception) {<--这里就是错误处理脚本-->}用register_shutdown_function('customend');这个不是用来处理错误的，这是一个在php脚本结束时自动调用一个函数的函数，因此我们可以利用它捕获能导致php脚本停止运行的严重错误（这类错误是不能被set_error_handler (）捕获的）一旦脚本停止运行，customend（）函数就会被调用，在customend（）函数中通过error_get_last()来判断脚本是正常结束还是发生严重错误而中断，如果是发生严重错误而中断，则运行错误处理程序customend（）函数没有参数customend（）函数的具体书写形式如下：function customend(){if(error_get_last()){<--这里就是错误处理脚本-->}}php全局异常/错误处理END注意事项set_error_handler () 还有第二个可省略参数，来确定低于哪个级别的错误不会被拦截

Websocket介绍 WebSocket:是一种计算机通信协议，通过单个TCP连接提供全双工通信通道。IETF于 2011 年将 WebSocket 协议标准化为RFC 6455。当前允许 Web 应用程序使用该协议的 API 规范称为WebSockets。[1]它是由WHATWG维护的活跃标准，也是W3C的 WebSocket API的继承者。[2]WebSocket 与HTTP不同。这两种协议都位于OSI 模型的第 7 层，并依赖于第 4 层的 TCP。尽管它们不同，但RFC 6455声明 WebSocket“旨在通过 HTTP 端口 443 和 80 工作以及支持 HTTP 代理和中介” ，从而使其与 HTTP 兼容。为了实现兼容性，WebSocket握手使用HTTP Upgrade 标头将 HTTP 协议更改为 WebSocket 协议。与 HTTP轮询等半双工替代方案相比，WebSocket 协议支持Web 浏览器（或其他客户端应用程序）和Web 服务器之间的交互，从而促进与服务器之间的实时数据传输。这是通过为服务器提供一种标准化的方式来实现的，即无需客户端首先请求即可向客户端发送内容，并允许在保持连接打开的同时来回传递消息。通过这种方式，可以在客户端和服务器之间进行双向正在进行的对话。通信通信通常通过 TCP 端口号 443（在不安全连接的情况下为 80）完成，这对于使用防火墙阻止非 Web Internet 连接的环境很有用。大多数浏览器都支持该协议，包括Google Chrome、Firefox、Microsoft Edge、Internet Explorer、Safari和Opera。与 HTTP 不同，WebSocket 提供全双工通信。此外，WebSocket 在 TCP 之上启用消息流。TCP 单独处理字节流，没有固有的消息概念。在 WebSocket 之前，使用Comet通道可以实现 80 端口全双工通信；然而，Comet 的实现并不简单，而且由于 TCP 握手和 HTTP 标头开销，它对于小消息的效率很低。WebSocket 协议旨在在不损害 Web 安全假设的情况下解决这些问题。WebSocket 协议规范将ws(WebSocket) 和wss(WebSocket Secure) 定义为两个新的统一资源标识符(URI) 方案，分别用于未加密和加密连接。除了方案名称和片段（即#不支持），其余的 URI 组件被定义为使用URI 通用语法,示例: ws-URI = "ws:" "//" host [ ":" port ] path [ "?" query ] 或wss-URI = "wss:" "//" host [ ":" port ] path [ "?" query ].websocket服务端与客户端代码示例.用到了ws库.步骤:1安装wsnpm install ws步骤2:服务端代码:创建websocket.mjs文件,写入以下代码:import { WebSocketServer } from "ws"; const server = new WebSocketServer({ port: 3000 }); server.on("connection", (socket) => { // send a message to the client socket.send(JSON.stringify({ type: "hello from server", content: [ 1, "2" ] })); // receive a message from the client socket.on("message", (data) => { const packet = JSON.parse(data); switch (packet.type) { case "hello from client": console.log(packet.content) // ... break; } }); });运行服务端代码:node websocket.mjs步骤3:编写客户端代码:在目录中创建index.html写入以下代码:<html> <head> <meta charset="utf-8"> <title>HTML文档</title> <meta name="keywords" content=""> <meta name="description" content=""> </head> <body> <script> const socket = new WebSocket("ws://localhost:3000"); socket.addEventListener("open", () => { // send a message to the server socket.send(JSON.stringify({ type: "hello from client", content: [ 3, "4" ] })); }); // receive a message from the server socket.addEventListener("message", ({ data }) => { const packet = JSON.parse(data); switch (packet.type) { case "hello from server": console.log(packet.content) // ... break; } }); </script> </body> </html>用浏览器打开index.html按f12查看console输出即可.参考更多 https://www.ruanyifeng.com/blog/2017/05/websocket.htmlhttps://www.cnblogs.com/chyingp/p/websocket-deep-in.htmlhttp://www.52im.net/thread-3713-1-1.htmlhttps://en.wikipedia.org/wiki/WebSockethttps://www.runoob.com/html/html5-websocket.htmlhttps://developer.mozilla.org/en-US/docs/Web/API/WebSockethttps://blog.p2hp.com/archives/4987