nginx代理后，测试swoole-larvel和nginx-laravel

在 2016年8月24日2016年8月24日上张贴由 BestLove

server {
    listen 80; 
    server_name laravel.fengfeng.com;
    index index.php;
    root  /home/wwwroot/laravel/public;
    if (!-e $request_filename) {
        rewrite ^(.*)$ /index.php last;break;
    }   
    location ~ [^/]\.php(/|$) {   
            try_files $uri =404;
            fastcgi_pass  unix:/tmp/php-cgi.sock;
            fastcgi_index index.php;
            include fastcgi.conf;
    }   
    location ~ .*\.(gif|jpg|jpeg|png|bmp|swf)$ {   
            expires      30d;
    }   
    location ~ .*\.(js|css)?$ {   
            expires      12h;
    }   
}

server {

listen 80;

server_name laravel.fengfeng.com;

index index.php;

root /home/wwwroot/laravel/public;

if (!-e $request_filename) {

rewrite ^(.*)$ /index.php last;break;

}

location ~ [^/]\.php(/|$) {

try_files $uri =404;

fastcgi_pass unix:/tmp/php-cgi.sock;

fastcgi_index index.php;

include fastcgi.conf;

}

location ~ .*\.(gif|jpg|jpeg|png|bmp|swf)$ {

expires 30d;

}

location ~ .*\.(js|css)?$ {

expires 12h;

}

server {
    listen 80; 
    server_name swoole.fengfeng.com;
    location / {   
        proxy_pass http://127.0.0.1:9501;
        proxy_redirect off;  
        proxy_set_header Host $host;  
        proxy_set_header X-Real-IP $remote_addr;  
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;                                                                         
    }       
}

server {

listen 80;

server_name swoole.fengfeng.com;

location / {

proxy_pass http://127.0.0.1:9501;

proxy_redirect off;

proxy_set_header Host $host;

proxy_set_header X-Real-IP $remote_addr;

proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;

}

ab -n 100 -c 100 http://swoole.fengfeng.com/
#请求后返回laravel默认的欢迎页面
#nginx反向代理->swoole_http_server每秒请求数明显比原生nginx->php-fpm高
#但是swoole_http_server有一定几率会报如下错误
[2016-08-24 17:54:25 *22191.0]  ERROR   swFactoryProcess_finish (ERROR 1004): send 902 byte failed, because session#1010 is closed.

Server Software:        nginx
Server Hostname:        swoole.fengfeng.com
Server Port:            80

Document Path:          /
Document Length:        1023 bytes

Concurrency Level:      100
Time taken for tests:   4.458 seconds
Complete requests:      100
Failed requests:        0
Write errors:           0
Total transferred:      191736 bytes
HTML transferred:       102300 bytes
Requests per second:    22.43 [#/sec] (mean)
Time per request:       4458.223 [ms] (mean)
Time per request:       44.582 [ms] (mean, across all concurrent requests)
Transfer rate:          42.00 [Kbytes/sec] received

Connection Times (ms)
           min  mean[+/-sd] median   max
Connect:        0    7   1.0      7       9
Processing:    10 2256 1224.0   2186    4442
Waiting:        3 2256 1224.2   2186    4442
Total:         10 2263 1224.3   2192    4448

Percentage of the requests served within a certain time (ms)
50%   2192
66%   2261
75%   2301
80%   2322
90%   4410
95%   4431
98%   4444
99%   4448
100%   4448 (longest request)

ab -n 100 -c 100 http://swoole.fengfeng.com/

#请求后返回laravel默认的欢迎页面

#nginx反向代理->swoole_http_server每秒请求数明显比原生nginx->php-fpm高

#但是swoole_http_server有一定几率会报如下错误

[2016-08-24 17:54:25 *22191.0] ERROR swFactoryProcess_finish (ERROR 1004): send 902 byte failed, because session#1010 is closed.

Server Software: nginx

Server Hostname: swoole.fengfeng.com

Server Port: 80

Document Path: /

Document Length: 1023 bytes

Concurrency Level: 100

Time taken for tests: 4.458 seconds

Complete requests: 100

Failed requests: 0

Write errors: 0

Total transferred: 191736 bytes

HTML transferred: 102300 bytes

Requests per second: 22.43 [#/sec] (mean)

Time per request: 4458.223 [ms] (mean)

Time per request: 44.582 [ms] (mean, across all concurrent requests)

Transfer rate: 42.00 [Kbytes/sec] received

Connection Times (ms)

min mean[+/-sd] median max

Connect: 0 7 1.0 7 9

Processing: 10 2256 1224.0 2186 4442

Waiting: 3 2256 1224.2 2186 4442

Total: 10 2263 1224.3 2192 4448

Percentage of the requests served within a certain time (ms)

50% 2192

66% 2261

75% 2301

80% 2322

90% 4410

95% 4431

98% 4444

99% 4448

100% 4448 (longest request)

ab -n 100 -c 100 http://laravel.fengfeng.com/

Server Software:        nginx
Server Hostname:        laravel.fengfeng.com
Server Port:            80

Document Path:          /
Document Length:        1023 bytes

Concurrency Level:      100
Time taken for tests:   34.714 seconds
Complete requests:      100
Failed requests:        0
Write errors:           0
Total transferred:      201864 bytes
HTML transferred:       102300 bytes
Requests per second:    2.88 [#/sec] (mean)
Time per request:       34713.635 [ms] (mean)
Time per request:       347.136 [ms] (mean, across all concurrent requests)
Transfer rate:          5.68 [Kbytes/sec] received

Connection Times (ms)
              min  mean[+/-sd] median   max
Connect:        0    3   0.3      3       3
Processing:   440 19471 9261.3  23374   34271
Waiting:      439 19471 9261.4  23374   34271
Total:        441 19473 9261.3  23377   34274

Percentage of the requests served within a certain time (ms)
  50%  23377
  66%  24695
  75%  27787
  80%  29166
  90%  31187
  95%  31235
  98%  31273
  99%  34274
 100%  34274 (longest request)

ab -n 100 -c 100 http://laravel.fengfeng.com/

Server Software: nginx

Server Hostname: laravel.fengfeng.com

Server Port: 80

Document Path: /

Document Length: 1023 bytes

Concurrency Level: 100

Time taken for tests: 34.714 seconds

Complete requests: 100

Failed requests: 0

Write errors: 0

Total transferred: 201864 bytes

HTML transferred: 102300 bytes

Requests per second: 2.88 [#/sec] (mean)

Time per request: 34713.635 [ms] (mean)

Time per request: 347.136 [ms] (mean, across all concurrent requests)

Transfer rate: 5.68 [Kbytes/sec] received

Connection Times (ms)

min mean[+/-sd] median max

Connect: 0 3 0.3 3 3

Processing: 440 19471 9261.3 23374 34271

Waiting: 439 19471 9261.4 23374 34271

Total: 441 19473 9261.3 23377 34274

Percentage of the requests served within a certain time (ms)

50% 23377

66% 24695

75% 27787

80% 29166

90% 31187

95% 31235

98% 31273

99% 34274

100% 34274 (longest request)

swoole_http_server-laravel

在 2016年8月24日上张贴由 BestLove

#!/usr/bin/env php
<?php 
require __DIR__.'/../bootstrap/autoload.php';

$appGlobal = require_once __DIR__.'/../bootstrap/app.php';

$swooleConfig = require __DIR__.'/config.php';
require __DIR__.'/Request.php';
require __DIR__.'/Response.php';

$serv = new swoole_http_server(SWOOLE_HTTP_SERVER_HOST, SWOOLE_HTTP_SERVER_PORT);

if (!empty($swooleConfig['setting'])) {
    $serv->set($swooleConfig['setting']);
}

$serv->on('start', function($swooleHttpServer){
    if (!empty(SWOOLE_HTTP_SERVER_LOG_DIR)) {
        swooleHttpServerLog('swoole_http_server start');
    }
});

$serv->on('shutdown', function($swooleHttpServer){
    if (!empty(SWOOLE_HTTP_SERVER_LOG_DIR)) {
        swooleHttpServerLog('swoole_http_server shutdown');
    }
});

$serv->on('request', function($swooleRequest, $swooleResponse) {
    global $appGlobal;
    $app = clone $appGlobal;
    $kernel = $app->make(Illuminate\Contracts\Http\Kernel::class);
    
    $response = $kernel->handle(
        $request = \SwooleAdapter\Request::createWithSwooleRequest($swooleRequest)
    );
    \SwooleAdapter\Response::end($swooleResponse, $response);
    $kernel->terminate($request, $response);
    $app->flush();
    unset($app);
    unset($kernel);
    unset($request);
    unset($response);
});

$serv->start();

#!/usr/bin/env php

<?php

require __DIR__.'/../bootstrap/autoload.php';

$appGlobal = require_once __DIR__.'/../bootstrap/app.php';

$swooleConfig = require __DIR__.'/config.php';

require __DIR__.'/Request.php';

require __DIR__.'/Response.php';

$serv = new swoole_http_server(SWOOLE_HTTP_SERVER_HOST, SWOOLE_HTTP_SERVER_PORT);

if (!empty($swooleConfig['setting'])) {

$serv->set($swooleConfig['setting']);

}

$serv->on('start', function($swooleHttpServer){

if (!empty(SWOOLE_HTTP_SERVER_LOG_DIR)) {

swooleHttpServerLog('swoole_http_server start');

}

});

$serv->on('shutdown', function($swooleHttpServer){

if (!empty(SWOOLE_HTTP_SERVER_LOG_DIR)) {

swooleHttpServerLog('swoole_http_server shutdown');

}

});

$serv->on('request', function($swooleRequest, $swooleResponse) {

global $appGlobal;

$app = clone $appGlobal;

$kernel = $app->make(Illuminate\Contracts\Http\Kernel::class);

$response = $kernel->handle(

$request = \SwooleAdapter\Request::createWithSwooleRequest($swooleRequest)

);

\SwooleAdapter\Response::end($swooleResponse, $response);

$kernel->terminate($request, $response);

$app->flush();

unset($app);

unset($kernel);

unset($request);

unset($response);

});

$serv->start();

<?php 
define('SWOOLE_HTTP_SERVER_HOST', '0.0.0.0');
define('SWOOLE_HTTP_SERVER_PORT', 9501);
define('SWOOLE_HTTP_SERVER_LOG_DIR', '/tmp/swoole_http_server.log');

function swooleHttpServerLog($content, $dir='')
{
    if (empty($dir) && empty(SWOOLE_HTTP_SERVER_LOG_DIR)) {
        return;
    }
    $dir = !empty($dir) ? $dir : SWOOLE_HTTP_SERVER_LOG_DIR;
    if (is_array($content)) {
        $content = var_export($content, true);
    } elseif (!is_string($content)) {
        $content = json_encode($content);
    }
    $dateTime = date('Y-m-d H:i:s');
    file_put_contents($dir, '[' . $dateTime . ']   ' . $content . PHP_EOL, FILE_APPEND);
}

//@see http://wiki.swoole.com/wiki/page/274.html
return array(
    'setting' => array(
        'worker_num' => 1,
        'max_request' => 999,
        'reactor_num' => 2,
    ),
);

<?php

define('SWOOLE_HTTP_SERVER_HOST', '0.0.0.0');

define('SWOOLE_HTTP_SERVER_PORT', 9501);

define('SWOOLE_HTTP_SERVER_LOG_DIR', '/tmp/swoole_http_server.log');

function swooleHttpServerLog($content, $dir='')

{

if (empty($dir) && empty(SWOOLE_HTTP_SERVER_LOG_DIR)) {

return;

}

$dir = !empty($dir) ? $dir : SWOOLE_HTTP_SERVER_LOG_DIR;

if (is_array($content)) {

$content = var_export($content, true);

} elseif (!is_string($content)) {

$content = json_encode($content);

}

$dateTime = date('Y-m-d H:i:s');

file_put_contents($dir, '[' . $dateTime . '] ' . $content . PHP_EOL, FILE_APPEND);

}

//@see http://wiki.swoole.com/wiki/page/274.html

return array(

'setting' => array(

'worker_num' => 1,

'max_request' => 999,

'reactor_num' => 2,

);

<?php 
namespace SwooleAdapter;

class Request extends \Illuminate\Http\Request {
    
    public static function createWithSwooleRequest($swooleRequest)
    {
        $get     = isset($swooleRequest->get)    ? $swooleRequest->get    : [];
        $post    = isset($swooleRequest->post)   ? $swooleRequest->post   : [];
        $cookie  = isset($swooleRequest->cookie) ? $swooleRequest->cookie : [];
        $server  = isset($swooleRequest->server) ? $swooleRequest->server : [];
        $header  = isset($swooleRequest->header) ? $swooleRequest->header : [];
        $files   = isset($swooleRequest->files)  ? $swooleRequest->files  : [];
        $content = $swooleRequest->rawContent()  ?: null;
        return static::create($server['request_uri'], $server['request_method'], array_merge($get, $post), $cookie, $files, $server, $content);
    }
    
}

<?php

namespace SwooleAdapter;

class Request extends \Illuminate\Http\Request {

public static function createWithSwooleRequest($swooleRequest)

{

$get = isset($swooleRequest->get) ? $swooleRequest->get : [];

$post = isset($swooleRequest->post) ? $swooleRequest->post : [];

$cookie = isset($swooleRequest->cookie) ? $swooleRequest->cookie : [];

$server = isset($swooleRequest->server) ? $swooleRequest->server : [];

$header = isset($swooleRequest->header) ? $swooleRequest->header : [];

$files = isset($swooleRequest->files) ? $swooleRequest->files : [];

$content = $swooleRequest->rawContent() ?: null;

return static::create($server['request_uri'], $server['request_method'], array_merge($get, $post), $cookie, $files, $server, $content);

}

<?php 
namespace SwooleAdapter;

class Response {
    
    public static function end($swooleResponse, $response)
    {
        foreach ($response->headers->allPreserveCase() as $key => $value) {
            foreach ($value as $v) {
                $swooleResponse->header($key, $v);
            }
        }

        $swooleResponse->status($response->getStatusCode());

        foreach ($response->headers->getCookies() as $cookie) {
            $swooleResponse->cookie($cookie->getName(), $cookie->getValue(), $cookie->getExpiresTime(), $cookie->getPath(), $cookie->getDomain(), $cookie->isSecure(), $cookie->isHttpOnly());
        }
        
        $swooleResponse->end($response->getContent());
    }

}

<?php

namespace SwooleAdapter;

class Response {

public static function end($swooleResponse, $response)

{

foreach ($response->headers->allPreserveCase() as $key => $value) {

foreach ($value as $v) {

$swooleResponse->header($key, $v);

}

$swooleResponse->status($response->getStatusCode());

foreach ($response->headers->getCookies() as $cookie) {

$swooleResponse->cookie($cookie->getName(), $cookie->getValue(), $cookie->getExpiresTime(), $cookie->getPath(), $cookie->getDomain(), $cookie->isSecure(), $cookie->isHttpOnly());

}

$swooleResponse->end($response->getContent());

}

swoole异步mysql demo

在 2015年11月13日2015年11月16日上张贴由 BestLove

<?php 
class asyncmysql
{
    protected $poolSize = 20;
    protected $freePool = array();
    protected $busyPool = array();
    protected $waitQueue = array();
    protected $waitSize = 50;
    protected $serv;

    public function run()
    {
        $serv = new swoole_server("127.0.0.1", 9501);
        $serv->on('connect', array($this, 'onConnect'));
        $serv->on('receive', array($this, 'onReceive'));
        $serv->on('close', array($this, 'onClose'));
        $serv->on('workerstart', array($this, 'onWorkerStart'));
        $serv->start();
    }

    public function onConnect($serv, $fd)
    {
    }

    public function onClose($serv, $fd)
    {
    }

    public function onWorkerStart($serv, $work_id)
    {
        $this->serv = $serv;
        for ($i=0; $i < $this->poolSize; $i++) {
            $db = new mysqli();
            $db->connect('localhost', 'root', '123456', 'swooletest');
            //swoole获取mysqli的socket文件描述符，需要php有mysqlnd、mysqli扩展
            //swoole编译时需要加入 --enable-async-mysql
            $db_sock = swoole_get_mysqli_sock($db);
            //将mysqli的socket加入到事件监听
            swoole_event_add($db_sock, array($this, 'query'));
            $this->freePool[]=array(
                'db' => $db,
                'db_sock' => $db_sock,
                'fd' => 0
            );
        }
    }

    public function onReceive($serv, $fd, $from_id, $sql)
    {
        if (!empty($this->freePool)) {
            $this->preQuery($fd, $sql);
        } else {
            if (count($this->waitQueue) >= $this->waitSize) {
                $serv->send($fd, '服务器繁忙，请稍后再试！');
            } else {
                $this->waitQueue[]=array(
                    'fd' => $fd,
                    'sql' => $sql
                );
            }
        }
    }

    public function preQuery($fd, $sql)
    {
        $dbArray = array_pop($this->freePool);
        $db = $dbArray['db'];
        for ($i=0; $i < 2; $i++) { 
            //mysqli异步query，并不是真正的执行
            $rs = $db->query($sql, MYSQLI_ASYNC);
            if ($rs === false) {
                //尝试一次超时重连
                if ($db->errno == 2013 || $db->errno == 2006) {
                    $db->close();
                    $r = $db->connect();
                    if ($r === true) continue;
                }
            }
            break;
        }
        $dbArray['fd'] = $fd;
        $this->busyPool[$dbArray['db_sock']] = $dbArray;
    }

    public function query($db_sock)
    {
        $dbArray = $this->busyPool[$db_sock];
        $db = $dbArray['db'];
        $fd = $dbArray['fd'];
        //执行mysqli异步查询
        $rs = $db->reap_async_query();
        if ($rs === true) {
            $this->serv->send($fd, '操作成功！'); 
        } elseif ($rs === false) {
            $this->serv->send($fd, '操作失败！');
        } else {
            $rs = $rs->fetch_all(MYSQLI_ASSOC);
            $this->serv->send($fd, json_encode($rs, JSON_UNESCAPED_UNICODE));
            unset($rs);
        }
        $this->freePool[]=$dbArray;
        unset($this->busyPool[$db_sock]);
        //如果等待队列中有未执行的SQL，循环所有的空闲连接执行SQL
        if (count($this->waitQueue) > 0) {
            $freeCount = count($this->freePool);
            for ($i=0; $i < $freePool; $i++) { 
                $waitArray = array_shift($this->waitQueue);
                $this->preQuery($waitArray['fd'], $waitArray['sql']);
            }
        }
    }
}

$test = new asyncmysql();
$test->run();

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

<?php

class asyncmysql

{

protected $poolSize = 20;

protected $freePool = array();

protected $busyPool = array();

protected $waitQueue = array();

protected $waitSize = 50;

protected $serv;

public function run()

{

$serv = new swoole_server("127.0.0.1", 9501);

$serv->on('connect', array($this, 'onConnect'));

$serv->on('receive', array($this, 'onReceive'));

$serv->on('close', array($this, 'onClose'));

$serv->on('workerstart', array($this, 'onWorkerStart'));

$serv->start();

}

public function onConnect($serv, $fd)

{

}

public function onClose($serv, $fd)

{

}

public function onWorkerStart($serv, $work_id)

{

$this->serv = $serv;

for ($i=0; $i < $this->poolSize; $i++) {

$db = new mysqli();

$db->connect('localhost', 'root', '123456', 'swooletest');

//swoole获取mysqli的socket文件描述符，需要php有mysqlnd、mysqli扩展

//swoole编译时需要加入 --enable-async-mysql

$db_sock = swoole_get_mysqli_sock($db);

//将mysqli的socket加入到事件监听

swoole_event_add($db_sock, array($this, 'query'));

$this->freePool[]=array(

'db' => $db,

'db_sock' => $db_sock,

'fd' => 0

);

}

public function onReceive($serv, $fd, $from_id, $sql)

{

if (!empty($this->freePool)) {

$this->preQuery($fd, $sql);

} else {

if (count($this->waitQueue) >= $this->waitSize) {

$serv->send($fd, '服务器繁忙，请稍后再试！');

} else {

$this->waitQueue[]=array(

'fd' => $fd,

'sql' => $sql

);

}

public function preQuery($fd, $sql)

{

$dbArray = array_pop($this->freePool);

$db = $dbArray['db'];

for ($i=0; $i < 2; $i++) {

//mysqli异步query，并不是真正的执行

$rs = $db->query($sql, MYSQLI_ASYNC);

if ($rs === false) {

//尝试一次超时重连

if ($db->errno == 2013 || $db->errno == 2006) {

$db->close();

$r = $db->connect();

if ($r === true) continue;

}

break;

}

$dbArray['fd'] = $fd;

$this->busyPool[$dbArray['db_sock']] = $dbArray;

}

public function query($db_sock)

{

$dbArray = $this->busyPool[$db_sock];

$db = $dbArray['db'];

$fd = $dbArray['fd'];

//执行mysqli异步查询

$rs = $db->reap_async_query();

if ($rs === true) {

$this->serv->send($fd, '操作成功！');

} elseif ($rs === false) {

$this->serv->send($fd, '操作失败！');

} else {

$rs = $rs->fetch_all(MYSQLI_ASSOC);

$this->serv->send($fd, json_encode($rs, JSON_UNESCAPED_UNICODE));

unset($rs);

}

$this->freePool[]=$dbArray;

unset($this->busyPool[$db_sock]);

//如果等待队列中有未执行的SQL，循环所有的空闲连接执行SQL

if (count($this->waitQueue) > 0) {

$freeCount = count($this->freePool);

for ($i=0; $i < $freePool; $i++) {

$waitArray = array_shift($this->waitQueue);

$this->preQuery($waitArray['fd'], $waitArray['sql']);

}

$test = new asyncmysql();

$test->run();

swoole websocket demo

在 2015年11月10日2015年11月10日上张贴由 BestLove

<?php 
//创建websocket服务器对象，监听0.0.0.0:9502端口
$ws = new swoole_websocket_server("0.0.0.0", 9502);

//监听WebSocket连接打开事件
$ws->on('open', function ($ws, $request) {
    // var_dump($request->fd, $request->get, $request->server);
    foreach($ws->connections as $fd) {
        $ws->push($fd, "你好，有人加入聊天。");
    }
    // $ws->push($request->fd, "你好，有人加入聊天。\n");
});

//监听WebSocket消息事件
$ws->on('message', function ($ws, $frame) {
    // echo "Message: {$frame->data}\n";
    foreach($ws->connections as $fd) {
        $ws->push($fd, "有人说: {$frame->data}");
    }
    // $ws->push($frame->fd, "server: {$frame->data}");
});

//监听WebSocket连接关闭事件
$ws->on('close', function ($ws, $fd) {
    echo "client-{$fd} is closed\n";
});

$ws->start();
?>

<?php

//创建websocket服务器对象，监听0.0.0.0:9502端口

$ws = new swoole_websocket_server("0.0.0.0", 9502);

//监听WebSocket连接打开事件

$ws->on('open', function ($ws, $request) {

// var_dump($request->fd, $request->get, $request->server);

foreach($ws->connections as $fd) {

$ws->push($fd, "你好，有人加入聊天。");

}

// $ws->push($request->fd, "你好，有人加入聊天。\n");

});

//监听WebSocket消息事件

$ws->on('message', function ($ws, $frame) {

// echo "Message: {$frame->data}\n";

foreach($ws->connections as $fd) {

$ws->push($fd, "有人说: {$frame->data}");

}

// $ws->push($frame->fd, "server: {$frame->data}");

});

//监听WebSocket连接关闭事件

$ws->on('close', function ($ws, $fd) {

echo "client-{$fd} is closed\n";

});

$ws->start();

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>websocket</title>
</head>
<body>

测试一下啊：<input type="text" value="" id="test">&nbsp;
            <input type="button" value="发送" id="bt">
<div id="div1"></div>
<script>
    var wsServer = 'ws://192.168.22.228:9502';
    var websocket = new WebSocket(wsServer);
    websocket.onopen = function (evt) {
        console.log("Connected to WebSocket server.");
    };

    websocket.onclose = function (evt) {
        console.log("Disconnected");
    };

    websocket.onmessage = function (evt) {
        // console.log('Retrieved data from server: ' + evt.data);
        div1.innerHTML+=evt.data+'<br>';
    };

    websocket.onerror = function (evt, e) {
        console.log('Error occured: ' + evt.data);
    };
    
    var bt = document.getElementById("bt");
    var test = document.getElementById("test");
    bt.onclick=function(){
        websocket.send(test.value);
    };
</script>
</body>
</html>

<!DOCTYPE html>

<head>

<title>websocket</title>

</head>

<body>

测试一下啊：<input type="text" value="" id="test"> 

var wsServer = 'ws://192.168.22.228:9502';

var websocket = new WebSocket(wsServer);

websocket.onopen = function (evt) {

console.log("Connected to WebSocket server.");

};

websocket.onclose = function (evt) {

console.log("Disconnected");

};

websocket.onmessage = function (evt) {

// console.log('Retrieved data from server: ' + evt.data);

div1.innerHTML+=evt.data+'<br>';

};

websocket.onerror = function (evt, e) {

console.log('Error occured: ' + evt.data);

};

var bt = document.getElementById("bt");

var test = document.getElementById("test");

bt.onclick=function(){

websocket.send(test.value);

};

</script>

</body>

</html>

<?php
//创建websocket服务器对象，监听0.0.0.0:9502端口
$ws = new swoole_websocket_server("0.0.0.0", 9502);
//设置异步任务的工作进程数量
$ws->set(array('task_worker_num' => 4));

//监听WebSocket连接打开事件
$ws->on('open', function ($ws, $request) {
    $ws->task("你好，有人加入聊天。");
});

//监听WebSocket消息事件
$ws->on('message', function ($ws, $frame) {
    $ws->task("有人说: {$frame->data}");
});

//监听WebSocket连接关闭事件
$ws->on('close', function ($ws, $fd) {
    echo "client-{$fd} is closed\n";
});

//处理异步任务
$ws->on('task', function ($ws, $task_id, $from_id, $data) {
    foreach ($ws->connections as $fd) {
        $ws->push($fd, $data);
    }
    //finish操作是可选的
    $ws->finish("ok");
});

//处理异步任务的结果
$ws->on('finish', function ($ws, $task_id, $data) {
    echo $data . PHP_EOL;
});

$ws->start();

<?php

//创建websocket服务器对象，监听0.0.0.0:9502端口

$ws = new swoole_websocket_server("0.0.0.0", 9502);

//设置异步任务的工作进程数量

$ws->set(array('task_worker_num' => 4));

//监听WebSocket连接打开事件

$ws->on('open', function ($ws, $request) {

$ws->task("你好，有人加入聊天。");

});

//监听WebSocket消息事件

$ws->on('message', function ($ws, $frame) {

$ws->task("有人说: {$frame->data}");

});

//监听WebSocket连接关闭事件

$ws->on('close', function ($ws, $fd) {

echo "client-{$fd} is closed\n";

});

//处理异步任务

$ws->on('task', function ($ws, $task_id, $from_id, $data) {

foreach ($ws->connections as $fd) {

$ws->push($fd, $data);

}

//finish操作是可选的

$ws->finish("ok");

});

//处理异步任务的结果

$ws->on('finish', function ($ws, $task_id, $data) {

echo $data . PHP_EOL;

});

$ws->start();

swoole数据库连接复用demo

在 2015年11月9日2015年11月9日上张贴由 BestLove

<?php
require __DIR__ . '/db.php';
$dbPool = array();
$poolSize = 20;
for ($i=0; $i < $poolSize; $i++) { 
    $dbPool[$i]= new Db();
}

$serv = new swoole_server("127.0.0.1", 9501);
// $serv->set(array(
//     'worker_num' => 8,   //工作进程数量
//     'daemonize' => true, //是否作为守护进程
// ));
$serv->on('connect', function ($serv, $fd){
    echo "Client:Connect.\n";
});
$serv->on('receive', function ($serv, $fd, $from_id, $sql) {
    global $dbPool;
    $rs = false;
    if (!empty($dbPool)) {
        $db = array_pop($dbPool);
        $rs = $db->execute($sql);
        array_push($dbPool, $db);
    }
    if ($rs) {
        $serv->send($fd, 'ok');
    } else {
        $serv->send($fd, 'not ok');
    }
    $serv->close($fd);
});
$serv->on('close', function ($serv, $fd) {
    echo "Client: Close.\n";
});
$serv->start();

<?php

require __DIR__ . '/db.php';

$dbPool = array();

$poolSize = 20;

for ($i=0; $i < $poolSize; $i++) {

$dbPool[$i]= new Db();

}

$serv = new swoole_server("127.0.0.1", 9501);

// $serv->set(array(

// 'worker_num' => 8, //工作进程数量

// 'daemonize' => true, //是否作为守护进程

// ));

$serv->on('connect', function ($serv, $fd){

echo "Client:Connect.\n";

});

$serv->on('receive', function ($serv, $fd, $from_id, $sql) {

global $dbPool;

$rs = false;

if (!empty($dbPool)) {

$db = array_pop($dbPool);

$rs = $db->execute($sql);

array_push($dbPool, $db);

}

if ($rs) {

$serv->send($fd, 'ok');

} else {

$serv->send($fd, 'not ok');

}

$serv->close($fd);

});

$serv->on('close', function ($serv, $fd) {

echo "Client: Close.\n";

});

$serv->start();

db类下载地址：

http://www.fengfengphp.com/yaf/db.zip

swoole安装与调试

在 2015年3月27日2015年3月27日上张贴由 BestLove

一.安装

1.下载swoole，尽量使用stable版本，即稳定版
地址：https://github.com/swoole/swoole-src/releases

2.通过ftp上传到linux服务器

3.解压与安装

//解压缩文件
unzip swoole-src-swoole-1.7.14-stable.zip
//进入安装目录
cd swoole-src-swoole-1.7.14-stable
//phpize是用来扩展php扩展模块的，通过phpize可以建立php的外挂模块
phpize
//./configure是配置扩展模块的
//注：swoole的./configure有很多额外参数，可以通过./configure --help命令查看，这里仅开启其中async-mysql项，其他均选择默认项
//--with-php-config=php-config的路径
./configure --with-php-config=/usr/local/php/bin/php-config --enable-async-mysql
//编译
make
//安装
make install

//解压缩文件

unzip swoole-src-swoole-1.7.14-stable.zip

//进入安装目录

cd swoole-src-swoole-1.7.14-stable

//phpize是用来扩展php扩展模块的，通过phpize可以建立php的外挂模块

phpize

//./configure是配置扩展模块的

//注：swoole的./configure有很多额外参数，可以通过./configure --help命令查看，这里仅开启其中async-mysql项，其他均选择默认项

//--with-php-config=php-config的路径

./configure --with-php-config=/usr/local/php/bin/php-config --enable-async-mysql

//编译

make

//安装

make install

安装完成后进入php.ini加入以下语句

extension=swoole.so

php.ini路径可通过 php –ini 查看

运行php -m 看看swoole扩展是否安装成功

重启nginx、php（不知道是否需要重启- – 保险起见还是重启一下）

/etc/init.d/nginx restart

/etc/init.d/php-fpm restart

二.调试

在网站根目录编写index.php，内容如下：

<?php
$http = new swoole_http_server("127.0.0.1", 9501);
$http->on('request', function ($request, $response) {
    	$response->end("<h1>Hello Swoole. #".rand(1000, 9999)."</h1>");
});
$http->start();

<?php

$http = new swoole_http_server("127.0.0.1", 9501);

$http->on('request', function ($request, $response) {

$response->end("<h1>Hello Swoole. #".rand(1000, 9999)."</h1>");

});

$http->start();

通过 php index.php 启动服务

此时，通过浏览器访问127.0.0.1即可访问swoole的http服务器。

唐晓锋–BLOG

This is just a personal note.

分类：swoole

nginx代理后，测试swoole-larvel和nginx-laravel

swoole_http_server-laravel

swoole异步mysql demo

swoole websocket demo

swoole数据库连接复用demo

swoole安装与调试