composer require "hhxsv5/laravel-s:~3.5.0" -vvv
# 确保你的composer.lock文件是在版本控制中

[program:laravel-s-test]
command=/user/local/bin/php /opt/www/laravel-s-test/bin/laravels start -i
numprocs=1
autostart=true
autorestart=true
startretries=3
user=www-data
redirect_stderr=true
stdout_logfile=/opt/www/laravel-s-test/storage/logs/supervisord-stdout.log

gzip on;
gzip_min_length 1024;
gzip_comp_level 2;
gzip_types text/plain text/css text/javascript application/json application/javascript application/x-javascript application/xml application/x-httpd-php image/jpeg image/gif image/png font/ttf font/otf image/svg+xml;
gzip_vary on;
gzip_disable "msie6";
upstream swoole {
    # 通过 IP:Port 连接
    server 127.0.0.1:5200 weight=5 max_fails=3 fail_timeout=30s;
    # 通过 UnixSocket Stream 连接，小诀窍：将socket文件放在/dev/shm目录下，可获得更好的性能
    #server unix:/xxxpath/laravel-s-test/storage/laravels.sock weight=5 max_fails=3 fail_timeout=30s;
    #server 192.168.1.1:5200 weight=3 max_fails=3 fail_timeout=30s;
    #server 192.168.1.2:5200 backup;
    keepalive 16;
}
server {
    listen 80;
    # 别忘了绑Host哟
    server_name laravels.com;
    root /xxxpath/laravel-s-test/public;
    access_log /yyypath/log/nginx/$server_name.access.log  main;
    autoindex off;
    index index.html index.htm;
    # Nginx处理静态资源(建议开启gzip)，LaravelS处理动态资源。
    location / {
        try_files $uri @laravels;
    }
    # 当请求PHP文件时直接响应404，防止暴露public/*.php
    #location ~* \.php$ {
    #    return 404;
    #}
    location @laravels {
        # proxy_connect_timeout 60s;
        # proxy_send_timeout 60s;
        # proxy_read_timeout 120s;
        proxy_http_version 1.1;
        proxy_set_header Connection "";
        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header X-Real-PORT $remote_port;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
        proxy_set_header Host $http_host;
        proxy_set_header Scheme $scheme;
        proxy_set_header Server-Protocol $server_protocol;
        proxy_set_header Server-Name $server_name;
        proxy_set_header Server-Addr $server_addr;
        proxy_set_header Server-Port $server_port;
        proxy_pass http://swoole;
    }
}

 1 LoadModule proxy_module /yyypath/modules/mod_deflate.so
 2 <IfModule deflate_module>
 3     SetOutputFilter DEFLATE
 4     DeflateCompressionLevel 2
 5     AddOutputFilterByType DEFLATE text/html text/plain text/css text/javascript application/json application/javascript application/x-javascript application/xml application/x-httpd-php image/jpeg image/gif image/png font/ttf font/otf image/svg+xml
 6 </IfModule>
 7 
 8 <VirtualHost *:80>
 9     # 别忘了绑Host哟
10     ServerName www.laravels.com
11     ServerAdmin hhxsv5@sina.com
12 
13     DocumentRoot /xxxpath/laravel-s-test/public;
14     DirectoryIndex index.html index.htm
15     <Directory "/">
16         AllowOverride None
17         Require all granted
18     </Directory>
19 
20     LoadModule proxy_module /yyypath/modules/mod_proxy.so
21     LoadModule proxy_module /yyypath/modules/mod_proxy_balancer.so
22     LoadModule proxy_module /yyypath/modules/mod_lbmethod_byrequests.so.so
23     LoadModule proxy_module /yyypath/modules/mod_proxy_http.so.so
24     LoadModule proxy_module /yyypath/modules/mod_slotmem_shm.so
25     LoadModule proxy_module /yyypath/modules/mod_rewrite.so
26 
27     ProxyRequests Off
28     ProxyPreserveHost On
29     <Proxy balancer://laravels>  
30         BalancerMember http://192.168.1.1:5200 loadfactor=7
31         #BalancerMember http://192.168.1.2:5200 loadfactor=3
32         #BalancerMember http://192.168.1.3:5200 loadfactor=1 status=+H
33         ProxySet lbmethod=byrequests
34     </Proxy>
35     #ProxyPass / balancer://laravels/
36     #ProxyPassReverse / balancer://laravels/
37 
38     # Apache处理静态资源，LaravelS处理动态资源。
39     RewriteEngine On
40     RewriteCond %{DOCUMENT_ROOT}%{REQUEST_FILENAME} !-d
41     RewriteCond %{DOCUMENT_ROOT}%{REQUEST_FILENAME} !-f
42     RewriteRule ^/(.*)$ balancer://laravels/%{REQUEST_URI} [P,L]
43 
44     ErrorLog ${APACHE_LOG_DIR}/www.laravels.com.error.log
45     CustomLog ${APACHE_LOG_DIR}/www.laravels.com.access.log combined
46 </VirtualHost>

 1 namespace App\Services;
 2 use Hhxsv5\LaravelS\Swoole\WebSocketHandlerInterface;
 3 use Swoole\Http\Request;
 4 use Swoole\WebSocket\Frame;
 5 use Swoole\WebSocket\Server;
 6 /**
 7  * @see https://wiki.swoole.com/wiki/page/400.html
 8  */
 9 class WebSocketService implements WebSocketHandlerInterface
10 {
11     // 声明没有参数的构造函数
12     public function __construct()
13     {
14     }
15     public function onOpen(Server $server, Request $request)
16     {
17         // 在触发onOpen事件之前，建立WebSocket的HTTP请求已经经过了Laravel的路由，
18         // 所以Laravel的Request、Auth等信息是可读的，Session是可读写的，但仅限在onOpen事件中。
19         // \Log::info('New WebSocket connection', [$request->fd, request()->all(), session()->getId(), session('xxx'), session(['yyy' => time()])]);
20         $server->push($request->fd, 'Welcome to LaravelS');
21         // throw new \Exception('an exception');// 此时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理
22     }
23     public function onMessage(Server $server, Frame $frame)
24     {
25         // \Log::info('Received message', [$frame->fd, $frame->data, $frame->opcode, $frame->finish]);
26         $server->push($frame->fd, date('Y-m-d H:i:s'));
27         // throw new \Exception('an exception');// 此时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理
28     }
29     public function onClose(Server $server, $fd, $reactorId)
30     {
31         // throw new \Exception('an exception');// 此时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理
32     }
33 }

 1 // ...
 2 'websocket'      => [
 3     'enable'  => true, // 看清楚，这里是true
 4     'handler' => \App\Services\WebSocketService::class,
 5 ],
 6 'swoole'         => [
 7     //...
 8     // dispatch_mode只能设置为2、4、5，https://wiki.swoole.com/wiki/page/277.html
 9     'dispatch_mode' => 2,
10     //...
11 ],
12 // ...

 1 map $http_upgrade $connection_upgrade {
 2     default upgrade;
 3     ''      close;
 4 }
 5 upstream swoole {
 6     # 通过 IP:Port 连接
 7     server 127.0.0.1:5200 weight=5 max_fails=3 fail_timeout=30s;
 8     # 通过 UnixSocket Stream 连接，小诀窍：将socket文件放在/dev/shm目录下，可获得更好的性能
 9     #server unix:/xxxpath/laravel-s-test/storage/laravels.sock weight=5 max_fails=3 fail_timeout=30s;
10     #server 192.168.1.1:5200 weight=3 max_fails=3 fail_timeout=30s;
11     #server 192.168.1.2:5200 backup;
12     keepalive 16;
13 }
14 server {
15     listen 80;
16     # 别忘了绑Host哟
17     server_name laravels.com;
18     root /xxxpath/laravel-s-test/public;
19     access_log /yyypath/log/nginx/$server_name.access.log  main;
20     autoindex off;
21     index index.html index.htm;
22     # Nginx处理静态资源(建议开启gzip)，LaravelS处理动态资源。
23     location / {
24         try_files $uri @laravels;
25     }
26     # 当请求PHP文件时直接响应404，防止暴露public/*.php
27     #location ~* \.php$ {
28     #    return 404;
29     #}
30     # Http和WebSocket共存，Nginx通过location区分
31     # !!! WebSocket连接时路径为/ws
32     # Javascript: var ws = new WebSocket("ws://laravels.com/ws");
33     location =/ws {
34         # proxy_connect_timeout 60s;
35         # proxy_send_timeout 60s;
36         # proxy_read_timeout：如果60秒内被代理的服务器没有响应数据给Nginx，那么Nginx会关闭当前连接；同时，Swoole的心跳设置也会影响连接的关闭
37         # proxy_read_timeout 60s;
38         proxy_http_version 1.1;
39         proxy_set_header X-Real-IP $remote_addr;
40         proxy_set_header X-Real-PORT $remote_port;
41         proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
42         proxy_set_header Host $http_host;
43         proxy_set_header Scheme $scheme;
44         proxy_set_header Server-Protocol $server_protocol;
45         proxy_set_header Server-Name $server_name;
46         proxy_set_header Server-Addr $server_addr;
47         proxy_set_header Server-Port $server_port;
48         proxy_set_header Upgrade $http_upgrade;
49         proxy_set_header Connection $connection_upgrade;
50         proxy_pass http://swoole;
51     }
52     location @laravels {
53         # proxy_connect_timeout 60s;
54         # proxy_send_timeout 60s;
55         # proxy_read_timeout 60s;
56         proxy_http_version 1.1;
57         proxy_set_header Connection "";
58         proxy_set_header X-Real-IP $remote_addr;
59         proxy_set_header X-Real-PORT $remote_port;
60         proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
61         proxy_set_header Host $http_host;
62         proxy_set_header Scheme $scheme;
63         proxy_set_header Server-Protocol $server_protocol;
64         proxy_set_header Server-Name $server_name;
65         proxy_set_header Server-Addr $server_addr;
66         proxy_set_header Server-Port $server_port;
67         proxy_pass http://swoole;
68     }
69 }

 1 use Hhxsv5\LaravelS\Swoole\Task\Event;
 2 class TestEvent extends Event
 3 {
 4     private $data;
 5     public function __construct($data)
 6     {
 7         $this->data = $data;
 8     }
 9     public function getData()
10     {
11         return $this->data;
12     }
13 }

 1 use Hhxsv5\LaravelS\Swoole\Task\Task;
 2 use Hhxsv5\LaravelS\Swoole\Task\Event;
 3 use Hhxsv5\LaravelS\Swoole\Task\Listener;
 4 class TestListener1 extends Listener
 5 {
 6     // 声明没有参数的构造函数
 7     public function __construct()
 8     {
 9     }
10     public function handle(Event $event)
11     {
12         \Log::info(__CLASS__ . ':handle start', [$event->getData()]);
13         sleep(2);// 模拟一些慢速的事件处理
14         // 监听器中也可以投递Task，但不支持Task的finish()回调。
15         // 注意：
16         // 1.参数2需传true
17         // 2.config/laravels.php中修改配置task_ipc_mode为1或2，参考 https://wiki.swoole.com/wiki/page/296.html
18         $ret = Task::deliver(new TestTask('task data'), true);
19         var_dump($ret);
20         // throw new \Exception('an exception');// handle时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理
21     }
22 }

 1 // 在"config/laravels.php"中绑定事件与监听器，一个事件可以有多个监听器，多个监听器按顺序执行
 2 [
 3     // ...
 4     'events' => [
 5         \App\Tasks\TestEvent::class => [
 6             \App\Tasks\TestListener1::class,
 7             //\App\Tasks\TestListener2::class,
 8         ],
 9     ],
10     // ...
11 ];

1 // 实例化TestEvent并通过fire触发，此操作是异步的，触发后立即返回，由Task进程继续处理监听器中的handle逻辑
2 use Hhxsv5\LaravelS\Swoole\Task\Event;
3 $success = Event::fire(new TestEvent('event data'));
4 var_dump($success);//判断是否触发成功

 1 use Hhxsv5\LaravelS\Swoole\Task\Task;
 2 class TestTask extends Task
 3 {
 4     private $data;
 5     private $result;
 6     public function __construct($data)
 7     {
 8         $this->data = $data;
 9     }
10     // 处理任务的逻辑，运行在Task进程中，不能投递任务
11     public function handle()
12     {
13         \Log::info(__CLASS__ . ':handle start', [$this->data]);
14         sleep(2);// 模拟一些慢速的事件处理
15         // throw new \Exception('an exception');// handle时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理
16         $this->result = 'the result of ' . $this->data;
17     }
18     // 可选的，完成事件，任务处理完后的逻辑，运行在Worker进程中，可以投递任务
19     public function finish()
20     {
21         \Log::info(__CLASS__ . ':finish start', [$this->result]);
22         Task::deliver(new TestTask2('task2')); // 投递其他任务
23     }
24 }

1 // 实例化TestTask并通过deliver投递，此操作是异步的，投递后立即返回，由Task进程继续处理TestTask中的handle逻辑
2 use Hhxsv5\LaravelS\Swoole\Task\Task;
3 $task = new TestTask('task data');
4 // $task->delay(3);// 延迟3秒投放任务
5 $ret = Task::deliver($task);
6 var_dump($ret);//判断是否投递成功

 1 namespace App\Jobs\Timer;
 2 use App\Tasks\TestTask;
 3 use Swoole\Coroutine;
 4 use Hhxsv5\LaravelS\Swoole\Task\Task;
 5 use Hhxsv5\LaravelS\Swoole\Timer\CronJob;
 6 class TestCronJob extends CronJob
 7 {
 8     protected $i = 0;
 9     // !!! 定时任务的`interval`和`isImmediate`有两种配置方式（二选一）：一是重载对应的方法，二是注册定时任务时传入参数。
10     // --- 重载对应的方法来返回配置：开始
11     public function interval()
12     {
13         return 1000;// 每1秒运行一次
14     }
15     public function isImmediate()
16     {
17         return false;// 是否立即执行第一次，false则等待间隔时间后执行第一次
18     }
19     // --- 重载对应的方法来返回配置：结束
20     public function run()
21     {
22         \Log::info(__METHOD__, ['start', $this->i, microtime(true)]);
23         // do something
24         // sleep(1); // Swoole < 2.1
25         Coroutine::sleep(1); // Swoole>=2.1 run()方法已自动创建了协程。
26         $this->i++;
27         \Log::info(__METHOD__, ['end', $this->i, microtime(true)]);
28 
29         if ($this->i >= 10) { // 运行10次后不再执行
30             \Log::info(__METHOD__, ['stop', $this->i, microtime(true)]);
31             $this->stop(); // 终止此任务
32             // CronJob中也可以投递Task，但不支持Task的finish()回调。
33             // 注意：
34             // 1.参数2需传true
35             // 2.config/laravels.php中修改配置task_ipc_mode为1或2，参考 https://wiki.swoole.com/wiki/page/296.html
36             $ret = Task::deliver(new TestTask('task data'), true);
37             var_dump($ret);
38         }
39         // throw new \Exception('an exception');// 此时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理
40     }
41 }

 1 // 在"config/laravels.php"注册定时任务类
 2 [
 3     // ...
 4     'timer'          => [
 5         'enable' => true, // 启用Timer
 6         'jobs'   => [ // 注册的定时任务类列表
 7             // 启用LaravelScheduleJob来执行`php artisan schedule:run`，每分钟一次，替代Linux Crontab
 8             // \Hhxsv5\LaravelS\Illuminate\LaravelScheduleJob::class,
 9             // 两种配置参数的方式：
10             // [\App\Jobs\Timer\TestCronJob::class, [1000, true]], // 注册时传入参数
11             \App\Jobs\Timer\TestCronJob::class, // 重载对应的方法来返回参数
12         ],
13         'max_wait_time' => 5, // Reload时最大等待时间
14     ],
15     // ...
16 ];

/**
 * 如果启用WebSocket server，$swoole是`Swoole\WebSocket\Server`的实例，否则是是`Swoole\Http\Server`的实例
 * @var \Swoole\WebSocket\Server|\Swoole\Http\Server $swoole
 */
$swoole = app('swoole');
var_dump($swoole->stats());// 单例

 1 // 在"config/laravels.php"配置
 2 [
 3     // ...
 4     'swoole_tables'  => [
 5         // 场景：WebSocket中UserId与FD绑定
 6         'ws' => [// Key为Table名称，使用时会自动添加Table后缀，避免重名。这里定义名为wsTable的Table
 7             'size'   => 102400,//Table的最大行数
 8             'column' => [// Table的列定义
 9                 ['name' => 'value', 'type' => \Swoole\Table::TYPE_INT, 'size' => 8],
10             ],
11         ],
12         //...继续定义其他Table
13     ],
14     // ...
15 ];

 1 namespace App\Services;
 2 use Hhxsv5\LaravelS\Swoole\WebsocketHandlerInterface;
 3 use Swoole\Http\Request;
 4 use Swoole\WebSocket\Frame;
 5 use Swoole\WebSocket\Server;
 6 class WebSocketService implements WebSocketHandlerInterface
 7 {
 8     /**@var \Swoole\Table $wsTable */
 9     private $wsTable;
10     public function __construct()
11     {
12         $this->wsTable = app('swoole')->wsTable;
13     }
14     // 场景：WebSocket中UserId与FD绑定
15     public function onOpen(Server $server, Request $request)
16     {
17         // var_dump(app('swoole') === $server);// 同一实例
18         /**
19          * 获取当前登录的用户
20          * 此特性要求建立WebSocket连接的路径要经过Authenticate之类的中间件。
21          * 例如：
22          * 浏览器端：var ws = new WebSocket("ws://127.0.0.1:5200/ws");
23          * 那么Laravel中/ws路由就需要加上类似Authenticate的中间件。
24          */
25         // $user = Auth::user();
26         // $userId = $user ? $user->id : 0; // 0 表示未登录的访客用户
27         $userId = mt_rand(1000, 10000);
28         $this->wsTable->set('uid:' . $userId, ['value' => $request->fd]);// 绑定uid到fd的映射
29         $this->wsTable->set('fd:' . $request->fd, ['value' => $userId]);// 绑定fd到uid的映射
30         $server->push($request->fd, "Welcome to LaravelS #{$request->fd}");
31     }
32     public function onMessage(Server $server, Frame $frame)
33     {
34         // 广播
35         foreach ($this->wsTable as $key => $row) {
36             if (strpos($key, 'uid:') === 0 && $server->isEstablished($row['value'])) {
37                 $content = sprintf('Broadcast: new message "%s" from #%d', $frame->data, $frame->fd);
38                 $server->push($row['value'], $content);
39             }
40         }
41     }
42     public function onClose(Server $server, $fd, $reactorId)
43     {
44         $uid = $this->wsTable->get('fd:' . $fd);
45         if ($uid !== false) {
46             $this->wsTable->del('uid:' . $uid['value']); // 解绑uid映射
47         }
48         $this->wsTable->del('fd:' . $fd);// 解绑fd映射
49         $server->push($fd, "Goodbye #{$fd}");
50     }
51 }

 1 namespace App\Events;
 2 use Hhxsv5\LaravelS\Swoole\Events\ServerStartInterface;
 3 use Swoole\Atomic;
 4 use Swoole\Http\Server;
 5 class ServerStartEvent implements ServerStartInterface
 6 {
 7     public function __construct()
 8     {
 9     }
10     public function handle(Server $server)
11     {
12         // 初始化一个全局计数器(跨进程的可用)
13         $server->atomicCount = new Atomic(2233);
14 
15         // 控制器中调用：app('swoole')->atomicCount->get();
16     }
17 }
18 namespace App\Events;
19 use Hhxsv5\LaravelS\Swoole\Events\WorkerStartInterface;
20 use Swoole\Http\Server;
21 class WorkerStartEvent implements WorkerStartInterface
22 {
23     public function __construct()
24     {
25     }
26     public function handle(Server $server, $workerId)
27     {
28         // 初始化一个数据库连接池对象
29         // DatabaseConnectionPool::init();
30     }
31 }

1 // 修改文件 config/laravels.php
2 'event_handlers' => [
3     'ServerStart' => \App\Events\ServerStartEvent::class,
4     'WorkerStart' => \App\Events\WorkerStartEvent::class,
5 ],