PHP 请求 PHP Websocket
PHP request to PHP Websocket
我正在寻求有关我的 websocket 问题的帮助。我构建了一个简单的 HTML5 websocket 来连接我的 AngularJS 站点（websocket 通过简单的 JS 连接）和我的 PHP-Server。连接也正常，发送和接收数据也正常。我需要一个 websocket 的原因是：我在同一台服务器上有一个不同的 REST 服务（PHP），它也与 AngularJS 站点通信。因此 REST 服务更改数据库中的数据。现在，当我从 AngularJS 站点执行一个操作（例如创建一个新用户）时，REST 服务会在工作列表中创建一个作业，并且该作业将从任何其他服务（不相关）执行)，几秒钟后，如果工作完成，服务将向 REST 服务发出信号。作业将被设置为完成（在数据库中）。
现在，此时工作已完成，我需要从 REST 服务向 PHP Websocket 发送请求，Websocket 应该向 angularJS 网站。我知道，我可以通过 Angular-JS 进行轮询，但这会产生太大的流量，因为许多用户会同时使用该系统。
抱歉我的解释不好（还有我的英语不好 - 我是德国人 ;)）。
我的简单问题：是否有可能从 PHP REST-Service 向 websocket 发送请求，以便 websocket 通知我的 angular：作业完成了。
这个简单的请求是否可行，或者我是否需要创建一个 PHP 客户端，它一遍又一遍地刷新数据库以检查是否完成了作业，然后通过 angular网络套接字？
还有其他想法吗？
感谢您的帮助！
编辑：
也许正如所说，一些代码会很好 :)。只有一些标准的-HTML5 websocket，但也许它会有所帮助：
JS（在 angulars 配置方法中）：
//configure websocket
var uri= "ws://x.x.x:9000/websocket/websocket.php";
ws= new WebSocket(uri);
ws.onopen = function(ev) { // connection is open
console.log("Websocket: Connection established");
}
ws.onmessage = function(ev) {
console.log(ev.data);
};
ws.onerror = function(ev){
console.log("Websocket: Connection Error: " + ev.Error);};
ws.onclose = function(ev){
console.log("Websocket: Connection closed");};
那就是 PHP-Websocket（在互联网上找到）：
$host = 'lucadev.lonzagroup.net'; //host
$port = '9000'; //port
$null = NULL; //null var
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);
socket_bind($socket, 0, $port);
socket_listen($socket);
$clients = array($socket);
//start endless loop, so that our script doesn't stop
while (true) {
//manage multipal connections
$changed = $clients;
//returns the socket resources in $changed array
socket_select($changed, $null, $null, 0, 10);
//check for new socket
if (in_array($socket, $changed)) {
$socket_new = socket_accept($socket); //accpet new socket
$clients[] = $socket_new; //add socket to client array
$header = socket_read($socket_new, 1024); //read data sent by the socket
perform_handshaking($header, $socket_new, $host, $port); //perform websocket handshake
socket_getpeername($socket_new, $ip); //get ip address of connected socket
$response = mask(json_encode(array('type'=>'system', 'message'=>$ip.' connected'))); //prepare json data
send_message($response); //notify all users about new connection
//make room for new socket
$found_socket = array_search($socket, $changed);
unset($changed[$found_socket]);
}
//loop through all connected sockets
foreach ($changed as $changed_socket) {
//check for any incomming data
while(socket_recv($changed_socket, $buf, 1024, 0) >= 1)
{
$received_text = unmask($buf); //unmask data
$tst_msg = json_decode($received_text); //json decode
$user_name = $tst_msg->name; //sender name
$user_message = $tst_msg->message; //message text
$user_color = $tst_msg->color; //color
//prepare data to be sent to client
$response_text = mask(json_encode(array('type'=>'usermsg', 'name'=>$user_name, 'message'=>$user_message, 'color'=>$user_color)));
send_message($response_text); //send data
break 2; //exist this loop
}
$buf = @socket_read($changed_socket, 1024, PHP_NORMAL_READ);
if ($buf === false) { // check disconnected client
// remove client for $clients array
$found_socket = array_search($changed_socket, $clients);
socket_getpeername($changed_socket, $ip);
unset($clients[$found_socket]);
//notify all users about disconnected connection
$response = mask(json_encode(array('type'=>'system', 'message'=>$ip.' disconnected')));
send_message($response);
}
}
}
// close the listening socket
socket_close($sock);
function send_message($msg)
{
global $clients;
foreach($clients as $changed_socket)
{
@socket_write($changed_socket,$msg,strlen($msg));
}
return true;
}
//Unmask incoming framed message
function unmask($text) {
$length = ord($text[1]) & 127;
if($length == 126) {
$masks = substr($text, 4, 4);
$data = substr($text, 8);
}
elseif($length == 127) {
$masks = substr($text, 10, 4);
$data = substr($text, 14);
}
else {
$masks = substr($text, 2, 4);
$data = substr($text, 6);
}
$text = "";
for ($i = 0; $i < strlen($data); ++$i) {
$text .= $data[$i] ^ $masks[$i%4];
}
return $text;
}
//Encode message for transfer to client.
function mask($text)
{
$b1 = 0x80 | (0x1 & 0x0f);
$length = strlen($text);
if($length <= 125)
$header = pack('CC', $b1, $length);
elseif($length > 125 && $length < 65536)
$header = pack('CCn', $b1, 126, $length);
elseif($length >= 65536)
$header = pack('CCNN', $b1, 127, $length);
return $header.$text;
}
//handshake new client.
function perform_handshaking($receved_header,$client_conn, $host, $port)
{
$headers = array();
$lines = preg_split("/\r\n/", $receved_header);
foreach($lines as $line)
{
$line = chop($line);
if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
{
$headers[$matches[1]] = $matches[2];
}
}
$secKey = $headers['Sec-WebSocket-Key'];
$secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
//hand shaking header
$upgrade = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
"Upgrade: websocket\r\n" .
"Connection: Upgrade\r\n" .
"WebSocket-Origin: $host\r\n" .
"WebSocket-Location: wss://$host:$port/websocket/websocket.php\r\n".
"Sec-WebSocket-Accept:$secAccept\r\n\r\n";
socket_write($client_conn,$upgrade,strlen($upgrade));
}
我不认为，REST 服务是相关的。
编辑 2
我认为，对我来说唯一的解决方案（在你说过之后，一个简单的请求是不可能的）是创建一个单独的 class (php) 来与 websocket 通信。它将打开一个连接发送，工作完成，然后关闭它。那应该对我有用，不是那么优雅，但应该有用。
感谢您的帮助！
无法像这样向特定的 php 进程发出信号，您必须向另一个系统寻求帮助：
unix socket - angular WS 打开一个套接字，并将其路径发送到作业 WS，等待套接字中可用的数据。作业 WS 完成后写入套接字。
inotify - angular WS 等待在某个路径中创建文件
消息队列系统(eg RabbitMQ) - angular WS订阅一个事件，由job WS
您可以轮询（长轮询可能适合）或推送后台作业的状态。
我想，您正在寻找 "push notification" 系统。
您的内容如下：
- 从客户端到服务器的请求
- 当我从 AngularJS- 站点执行操作时 - 创建一个新用户
- 服务器（REST-API）接受新任务
- 在职位列表中创建职位
- 后台工作人员做他的事/队列处理开始
- 此作业的结果状态已写入数据库
下一步是添加
- 推送通知已发送至客户端
- 因此，需要存储客户端id，以便将消息发送到正确的客户端。
在内部，这是一个带有订阅的消息队列。它基于 client_id 或 channel_id。
- 您必须考虑一些极端情况，例如：如果客户离开并且再也不会回来怎么办。您将需要一些额外的时间或重试条件来处理此问题。
- 关于您的代码请求。图书馆的使用是一个品味问题，你可以看看
- https://github.com/pusher & http://test.pusher.com/
- 示例代码位于
- 棘轮 - http://socketo.me/docs/push
- 使用 AMPQ（ZeroMQ/RabbitMq/ActiveMq）构建您自己的
另一种方法是使用简单的 MySQL table 进行通知。
有关基本 table 结构，请参阅 。
这类似于会话中的闪存消息传输机制。
您可以将其与 "intervalic" ajax 投票相结合。
一旦用户登录系统（用于显示），您将从此 table 获取通知数据。在客户端登录期间，它可能会使用 ajax 请求检查新数据。
比方说：就像每 60 秒一个 ajax 从客户端到服务器获取请求以检查来自后台状态队列的新消息。这种方法适合少量用户，否则您的服务器会受到请求的冲击。
这取决于您的系统的复杂程度（事件数量、用户数量、通知渠道）。
具有基于 id/channel 订阅的消息队列系统允许更复杂的场景以及通过限制进行带宽和流量控制。
萨姆，
看看 Thruway, WampPost and Angular-WAMP. These projects use a protocol called WAMP，它允许不同的组件通过 Websockets 相互通信。
您的设置将如下所示：
[WampPost 客户端]<---->[高速公路 WAMP 路由器]<---->[Angular 客户端]
我会给你一些快速的代码示例，这样你就可以看到它们是如何协同工作的，但你需要转到每个单独的项目来了解如何配置每个组件。
高速公路路由器：
<?php
require 'vendor/autoload.php';
use Thruway\Peer\Router;
use Thruway\Transport\RatchetTransportProvider;
$router = new Router();
//Websockets listen on port 9090
$transportProvider = new RatchetTransportProvider("127.0.0.1", 9090);
$router->addTransportProvider($transportProvider);
//WampPost Client listens on port 8181
$router->addInternalClient(new \WampPost\WampPost('realm1', null, '127.0.0.1', 8181));
$router->start();
Angular:
app.config(function ($wampProvider) {
$wampProvider.init({url: 'ws://127.0.0.1:9090/',realm: 'realm1'});
})
app.run(function($wamp){
$wamp.open(); //This will open the connection when the app starts
})
app.controller("MyCtrl", function($scope, $wamp) {
// Subscribe to a topic
function onevent(args) {
$scope.hello = args[0];
}
$wamp.subscribe('com.myapp.hello', onevent);
});
正在使用 Request/Response 发布消息。这可以通过 PHP、Curl 或任何可以发出 HTTP 请求的东西来完成。
curl -H "Content-Type: application/json" -d '{"topic": "com.myapp.hello", "args": ["Hello, world"]}' http://127.0.0.1:8181/pub
现在订阅主题 "com.myapp.hello" 的每个人都将收到消息 "Hello, world"。
这只是一个非常基本的例子。您可以使用 WAMP 做更多事情，包括 RPC 和 websocket 身份验证。
另外，我是 Thruway 的开发者之一，所以如果您有任何问题或一般问题，请告诉我。
可以在 REST 服务和 WebSockets 服务器之间发送数据。
四种主要方式是：
让您的 REST 服务连接到您的 WebSockets 服务器。
让您的 WebSockets 服务器轮询您的 REST 服务。
拥有您的 REST 服务和 WebSockets 服务器可以同时访问的共享存储。
信号。
最容易实现的是让您的 WebSockets 服务器定期轮询您的 REST 服务以获取更新。
优点：绝大多数工作都为您完成：只需使用您最喜欢的 PHP 库来发出 Web 请求，例如 cURL file_get_contents()，等等。
缺点：不是实时的。如果几秒钟的延迟就足够了，那么为什么不使用 AJAX 甚至完整的 HTTP 请求来代替 WebSockets？此外，REST 服务不使用持久脚本；从您的 WebSockets 服务器设置请求的成本与从任何其他客户端设置请求的成本相同。
接下来的两种方法，连接到您的 WebSockets 服务器和使用共享存储在技术上都比较困难，但可以轻松处理大量数据。
如果您选择将 REST 服务器连接到 WebSockets，则必须按照 WebSockets 标准 (RFC 6455, The WebSocket Protocol) 中的定义正确执行客户端握手和处理帧。我不知道任何 PHP WebSockets client 库。
或者，如果您自己编写服务器和客户端，您可以放弃 WebSockets 握手并使用原始 TCP 套接字编写自己的 client/server 连接而不实现 WebSockets 协议，并且您可以充分、完全地确保可能连接到您的服务器的任何流量的安全性、真实性和有效性。（这是一个很大的假设。说到安全性，请不要假设。）
在您的 REST 服务中实现 WebSockets 客户端：
优点：实时路况。任意大小的数据。与上述定期轮询方法相比，每个请求的设置成本更低。
缺点：RFC 6455 实施起来很痛苦。从长远来看还不是最糟糕的，但仍然很痛苦。此外，您的 REST 服务仍在为每个请求使用 运行-一次脚本。这意味着如果实施不当，您可能会产生几个不必要的连接到您的 WebSockets 服务器。如果发送小批量数据，还有其他更有效的方式来传输数据。
共享存储空间：
我不会推荐任何一种选择。您的主要选择是文件（平面文件、套接字文件）、关系数据库（MySQL、PostgreSQL）、键值持久存储（Cassandra、Redis）和内存键值存储（Memcache）。
每个都有自己的权衡，我不会在这里讨论。使用每一个的错综复杂和陷阱太多了，如果我不告诉你去花一些时间去深入研究它们，那将是对你的伤害。
优点：数量多
缺点：多。 “计算机科学中只有两件难事：缓存失效、命名事物和差一错误。” -- Phil Karlton（解释为加上 off-by-one）
信号：
我对信号的最好比喻是走到某人身后大喊“嘿！”
如果您的消息只是发生了什么事，那么信号就是完美的。您所需要的只是要向其发送消息的脚本的进程 ID (PID)。
只需确保您要向其发送信号的进程可以处理它，否则它可能会死掉。
使用：
- 获取您的 PID (
posix_getpid())。
- 存储您的 PID (
/tmp/websocket.pid)。
- 注册信号处理程序。 (
pcntl_signal()).
- 在您的其他进程中，发送信号 (
posix_kill())。
很简单。
优点：最容易实现。最快到 运行.
缺点：“-9”。无法随消息一起发送任何内容。 （你可以说有变化，但你不能说那些变化是什么。）只能向同一台机器上的进程发送消息。
我正在寻求有关我的 websocket 问题的帮助。我构建了一个简单的 HTML5 websocket 来连接我的 AngularJS 站点（websocket 通过简单的 JS 连接）和我的 PHP-Server。连接也正常，发送和接收数据也正常。我需要一个 websocket 的原因是：我在同一台服务器上有一个不同的 REST 服务（PHP），它也与 AngularJS 站点通信。因此 REST 服务更改数据库中的数据。现在，当我从 AngularJS 站点执行一个操作（例如创建一个新用户）时，REST 服务会在工作列表中创建一个作业，并且该作业将从任何其他服务（不相关）执行)，几秒钟后，如果工作完成，服务将向 REST 服务发出信号。作业将被设置为完成（在数据库中）。
现在，此时工作已完成，我需要从 REST 服务向 PHP Websocket 发送请求，Websocket 应该向 angularJS 网站。我知道，我可以通过 Angular-JS 进行轮询，但这会产生太大的流量，因为许多用户会同时使用该系统。
抱歉我的解释不好（还有我的英语不好 - 我是德国人 ;)）。
我的简单问题：是否有可能从 PHP REST-Service 向 websocket 发送请求，以便 websocket 通知我的 angular：作业完成了。
这个简单的请求是否可行，或者我是否需要创建一个 PHP 客户端，它一遍又一遍地刷新数据库以检查是否完成了作业，然后通过 angular网络套接字？ 还有其他想法吗？
感谢您的帮助！
编辑： 也许正如所说，一些代码会很好 :)。只有一些标准的-HTML5 websocket，但也许它会有所帮助：
JS（在 angulars 配置方法中）：
//configure websocket
var uri= "ws://x.x.x:9000/websocket/websocket.php";
ws= new WebSocket(uri);
ws.onopen = function(ev) { // connection is open
console.log("Websocket: Connection established");
}
ws.onmessage = function(ev) {
console.log(ev.data);
};
ws.onerror = function(ev){
console.log("Websocket: Connection Error: " + ev.Error);};
ws.onclose = function(ev){
console.log("Websocket: Connection closed");};
那就是 PHP-Websocket（在互联网上找到）：
$host = 'lucadev.lonzagroup.net'; //host
$port = '9000'; //port
$null = NULL; //null var
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);
socket_bind($socket, 0, $port);
socket_listen($socket);
$clients = array($socket);
//start endless loop, so that our script doesn't stop
while (true) {
//manage multipal connections
$changed = $clients;
//returns the socket resources in $changed array
socket_select($changed, $null, $null, 0, 10);
//check for new socket
if (in_array($socket, $changed)) {
$socket_new = socket_accept($socket); //accpet new socket
$clients[] = $socket_new; //add socket to client array
$header = socket_read($socket_new, 1024); //read data sent by the socket
perform_handshaking($header, $socket_new, $host, $port); //perform websocket handshake
socket_getpeername($socket_new, $ip); //get ip address of connected socket
$response = mask(json_encode(array('type'=>'system', 'message'=>$ip.' connected'))); //prepare json data
send_message($response); //notify all users about new connection
//make room for new socket
$found_socket = array_search($socket, $changed);
unset($changed[$found_socket]);
}
//loop through all connected sockets
foreach ($changed as $changed_socket) {
//check for any incomming data
while(socket_recv($changed_socket, $buf, 1024, 0) >= 1)
{
$received_text = unmask($buf); //unmask data
$tst_msg = json_decode($received_text); //json decode
$user_name = $tst_msg->name; //sender name
$user_message = $tst_msg->message; //message text
$user_color = $tst_msg->color; //color
//prepare data to be sent to client
$response_text = mask(json_encode(array('type'=>'usermsg', 'name'=>$user_name, 'message'=>$user_message, 'color'=>$user_color)));
send_message($response_text); //send data
break 2; //exist this loop
}
$buf = @socket_read($changed_socket, 1024, PHP_NORMAL_READ);
if ($buf === false) { // check disconnected client
// remove client for $clients array
$found_socket = array_search($changed_socket, $clients);
socket_getpeername($changed_socket, $ip);
unset($clients[$found_socket]);
//notify all users about disconnected connection
$response = mask(json_encode(array('type'=>'system', 'message'=>$ip.' disconnected')));
send_message($response);
}
}
}
// close the listening socket
socket_close($sock);
function send_message($msg)
{
global $clients;
foreach($clients as $changed_socket)
{
@socket_write($changed_socket,$msg,strlen($msg));
}
return true;
}
//Unmask incoming framed message
function unmask($text) {
$length = ord($text[1]) & 127;
if($length == 126) {
$masks = substr($text, 4, 4);
$data = substr($text, 8);
}
elseif($length == 127) {
$masks = substr($text, 10, 4);
$data = substr($text, 14);
}
else {
$masks = substr($text, 2, 4);
$data = substr($text, 6);
}
$text = "";
for ($i = 0; $i < strlen($data); ++$i) {
$text .= $data[$i] ^ $masks[$i%4];
}
return $text;
}
//Encode message for transfer to client.
function mask($text)
{
$b1 = 0x80 | (0x1 & 0x0f);
$length = strlen($text);
if($length <= 125)
$header = pack('CC', $b1, $length);
elseif($length > 125 && $length < 65536)
$header = pack('CCn', $b1, 126, $length);
elseif($length >= 65536)
$header = pack('CCNN', $b1, 127, $length);
return $header.$text;
}
//handshake new client.
function perform_handshaking($receved_header,$client_conn, $host, $port)
{
$headers = array();
$lines = preg_split("/\r\n/", $receved_header);
foreach($lines as $line)
{
$line = chop($line);
if(preg_match('/\A(\S+): (.*)\z/', $line, $matches))
{
$headers[$matches[1]] = $matches[2];
}
}
$secKey = $headers['Sec-WebSocket-Key'];
$secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
//hand shaking header
$upgrade = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
"Upgrade: websocket\r\n" .
"Connection: Upgrade\r\n" .
"WebSocket-Origin: $host\r\n" .
"WebSocket-Location: wss://$host:$port/websocket/websocket.php\r\n".
"Sec-WebSocket-Accept:$secAccept\r\n\r\n";
socket_write($client_conn,$upgrade,strlen($upgrade));
}
我不认为，REST 服务是相关的。
编辑 2 我认为，对我来说唯一的解决方案（在你说过之后，一个简单的请求是不可能的）是创建一个单独的 class (php) 来与 websocket 通信。它将打开一个连接发送，工作完成，然后关闭它。那应该对我有用，不是那么优雅，但应该有用。 感谢您的帮助！
无法像这样向特定的 php 进程发出信号，您必须向另一个系统寻求帮助：
unix socket - angular WS 打开一个套接字，并将其路径发送到作业 WS，等待套接字中可用的数据。作业 WS 完成后写入套接字。
inotify - angular WS 等待在某个路径中创建文件
消息队列系统(eg RabbitMQ) - angular WS订阅一个事件，由job WS
触发
您可以轮询（长轮询可能适合）或推送后台作业的状态。 我想，您正在寻找 "push notification" 系统。
您的内容如下：
- 从客户端到服务器的请求
- 当我从 AngularJS- 站点执行操作时 - 创建一个新用户
- 服务器（REST-API）接受新任务
- 在职位列表中创建职位
- 后台工作人员做他的事/队列处理开始
- 此作业的结果状态已写入数据库
下一步是添加
- 推送通知已发送至客户端
- 因此，需要存储客户端id，以便将消息发送到正确的客户端。 在内部，这是一个带有订阅的消息队列。它基于 client_id 或 channel_id。
- 您必须考虑一些极端情况，例如：如果客户离开并且再也不会回来怎么办。您将需要一些额外的时间或重试条件来处理此问题。
- 关于您的代码请求。图书馆的使用是一个品味问题，你可以看看
- https://github.com/pusher & http://test.pusher.com/
- 示例代码位于
- 棘轮 - http://socketo.me/docs/push
- 使用 AMPQ（ZeroMQ/RabbitMq/ActiveMq）构建您自己的
- https://github.com/pusher & http://test.pusher.com/
另一种方法是使用简单的 MySQL table 进行通知。 有关基本 table 结构，请参阅 。
这类似于会话中的闪存消息传输机制。 您可以将其与 "intervalic" ajax 投票相结合。
一旦用户登录系统（用于显示），您将从此 table 获取通知数据。在客户端登录期间，它可能会使用 ajax 请求检查新数据。 比方说：就像每 60 秒一个 ajax 从客户端到服务器获取请求以检查来自后台状态队列的新消息。这种方法适合少量用户，否则您的服务器会受到请求的冲击。
这取决于您的系统的复杂程度（事件数量、用户数量、通知渠道）。 具有基于 id/channel 订阅的消息队列系统允许更复杂的场景以及通过限制进行带宽和流量控制。
萨姆，
看看 Thruway, WampPost and Angular-WAMP. These projects use a protocol called WAMP，它允许不同的组件通过 Websockets 相互通信。
您的设置将如下所示：
[WampPost 客户端]<---->[高速公路 WAMP 路由器]<---->[Angular 客户端]
我会给你一些快速的代码示例，这样你就可以看到它们是如何协同工作的，但你需要转到每个单独的项目来了解如何配置每个组件。
高速公路路由器：
<?php
require 'vendor/autoload.php';
use Thruway\Peer\Router;
use Thruway\Transport\RatchetTransportProvider;
$router = new Router();
//Websockets listen on port 9090
$transportProvider = new RatchetTransportProvider("127.0.0.1", 9090);
$router->addTransportProvider($transportProvider);
//WampPost Client listens on port 8181
$router->addInternalClient(new \WampPost\WampPost('realm1', null, '127.0.0.1', 8181));
$router->start();
Angular:
app.config(function ($wampProvider) {
$wampProvider.init({url: 'ws://127.0.0.1:9090/',realm: 'realm1'});
})
app.run(function($wamp){
$wamp.open(); //This will open the connection when the app starts
})
app.controller("MyCtrl", function($scope, $wamp) {
// Subscribe to a topic
function onevent(args) {
$scope.hello = args[0];
}
$wamp.subscribe('com.myapp.hello', onevent);
});
正在使用 Request/Response 发布消息。这可以通过 PHP、Curl 或任何可以发出 HTTP 请求的东西来完成。
curl -H "Content-Type: application/json" -d '{"topic": "com.myapp.hello", "args": ["Hello, world"]}' http://127.0.0.1:8181/pub
现在订阅主题 "com.myapp.hello" 的每个人都将收到消息 "Hello, world"。
这只是一个非常基本的例子。您可以使用 WAMP 做更多事情，包括 RPC 和 websocket 身份验证。
另外，我是 Thruway 的开发者之一，所以如果您有任何问题或一般问题，请告诉我。
可以在 REST 服务和 WebSockets 服务器之间发送数据。
四种主要方式是：
让您的 REST 服务连接到您的 WebSockets 服务器。
让您的 WebSockets 服务器轮询您的 REST 服务。
拥有您的 REST 服务和 WebSockets 服务器可以同时访问的共享存储。
信号。
最容易实现的是让您的 WebSockets 服务器定期轮询您的 REST 服务以获取更新。
优点：绝大多数工作都为您完成：只需使用您最喜欢的 PHP 库来发出 Web 请求，例如 cURL
file_get_contents()，等等。缺点：不是实时的。如果几秒钟的延迟就足够了，那么为什么不使用 AJAX 甚至完整的 HTTP 请求来代替 WebSockets？此外，REST 服务不使用持久脚本；从您的 WebSockets 服务器设置请求的成本与从任何其他客户端设置请求的成本相同。
接下来的两种方法，连接到您的 WebSockets 服务器和使用共享存储在技术上都比较困难，但可以轻松处理大量数据。
如果您选择将 REST 服务器连接到 WebSockets，则必须按照 WebSockets 标准 (RFC 6455, The WebSocket Protocol) 中的定义正确执行客户端握手和处理帧。我不知道任何 PHP WebSockets client 库。
或者，如果您自己编写服务器和客户端，您可以放弃 WebSockets 握手并使用原始 TCP 套接字编写自己的 client/server 连接而不实现 WebSockets 协议，并且您可以充分、完全地确保可能连接到您的服务器的任何流量的安全性、真实性和有效性。（这是一个很大的假设。说到安全性，请不要假设。）
在您的 REST 服务中实现 WebSockets 客户端：
优点：实时路况。任意大小的数据。与上述定期轮询方法相比，每个请求的设置成本更低。
缺点：RFC 6455 实施起来很痛苦。从长远来看还不是最糟糕的，但仍然很痛苦。此外，您的 REST 服务仍在为每个请求使用 运行-一次脚本。这意味着如果实施不当，您可能会产生几个不必要的连接到您的 WebSockets 服务器。如果发送小批量数据，还有其他更有效的方式来传输数据。
共享存储空间：
我不会推荐任何一种选择。您的主要选择是文件（平面文件、套接字文件）、关系数据库（MySQL、PostgreSQL）、键值持久存储（Cassandra、Redis）和内存键值存储（Memcache）。
每个都有自己的权衡，我不会在这里讨论。使用每一个的错综复杂和陷阱太多了，如果我不告诉你去花一些时间去深入研究它们，那将是对你的伤害。
优点：数量多
缺点：多。 “计算机科学中只有两件难事：缓存失效、命名事物和差一错误。” -- Phil Karlton（解释为加上 off-by-one）
信号：
我对信号的最好比喻是走到某人身后大喊“嘿！”
如果您的消息只是发生了什么事，那么信号就是完美的。您所需要的只是要向其发送消息的脚本的进程 ID (PID)。
只需确保您要向其发送信号的进程可以处理它，否则它可能会死掉。
使用：
- 获取您的 PID (
posix_getpid())。 - 存储您的 PID (
/tmp/websocket.pid)。 - 注册信号处理程序。 (
pcntl_signal()). - 在您的其他进程中，发送信号 (
posix_kill())。
很简单。
优点：最容易实现。最快到 运行.
缺点：“-9”。无法随消息一起发送任何内容。 （你可以说有变化，但你不能说那些变化是什么。）只能向同一台机器上的进程发送消息。