29 lines
532 B
PHP
29 lines
532 B
PHP
|
<?php
|
||
|
|
namespace process;
|
||
|
|
|
||
|
|
use Workerman\Connection\TcpConnection;
|
||
|
|
|
||
|
|
class AsyncExport
|
||
|
|
{
|
||
|
|
public function onConnect(TcpConnection $connection)
|
||
|
|
{
|
||
|
|
}
|
||
|
|
|
||
|
|
public function onWebSocketConnect(TcpConnection $connection, $http_buffer)
|
||
|
|
{
|
||
|
|
}
|
||
|
|
|
||
|
|
public function onClose(TcpConnection $connection)
|
||
|
|
{
|
||
|
|
}
|
||
|
|
|
||
|
|
public function onMessage(TcpConnection $connection, $data)
|
||
|
|
{
|
||
|
|
$res = json_decode($data, true);
|
||
|
|
|
||
|
|
|
||
|
|
// 返回异步数据，以结束当前完成进程
|
||
|
|
$connection->send($res);
|
||
|
|
}
|
||
|
|
}
|