LaravelS

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=1autostart=trueautorestart=truestartretries=3user=www-data
redirect_stderr=truestdout_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:5200backup;
    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 namespaceAppServices;
2 use Hhxsv5LaravelSSwooleWebSocketHandlerInterface;
3 use SwooleHttpRequest;
4 use SwooleWebSocketFrame;
5 use SwooleWebSocketServer;
6 /**
7 * @see https://wiki.swoole.com/wiki/page/400.html
8  */
9 classWebSocketService implements WebSocketHandlerInterface
10 {
11     //声明没有参数的构造函数
12     publicfunction __construct()
13 {
14 }
15     publicfunction 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     publicfunction 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     publicfunction 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' => AppServicesWebSocketService::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     defaultupgrade;
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:5200backup;
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 Hhxsv5LaravelSSwooleTaskEvent;
2 classTestEvent extends Event
3 {
4     private$data;
5     publicfunction __construct($data)
6 {
7         $this->data =$data;
8 }
9     publicfunction getData()
10 {
11         return $this->data;
12 }
13 }

1 use Hhxsv5LaravelSSwooleTaskTask;
2 use Hhxsv5LaravelSSwooleTaskEvent;
3 use Hhxsv5LaravelSSwooleTaskListener;
4 classTestListener1 extends Listener
5 {
6     //声明没有参数的构造函数
7     publicfunction __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         AppTasksTestEvent::class =>[
6             AppTasksTestListener1::class,
7             //AppTasksTestListener2::class,
8 ],
9 ],
10     //...
11 ];

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

1 use Hhxsv5LaravelSSwooleTaskTask;
2 classTestTask extends Task
3 {
4     private$data;
5     private$result;
6     publicfunction __construct($data)
7 {
8         $this->data =$data;
9 }
10     //处理任务的逻辑，运行在Task进程中，不能投递任务
11     publicfunction 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     publicfunction 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 Hhxsv5LaravelSSwooleTaskTask;
3 $task = new TestTask('task data');
4 //$task->delay(3);//延迟3秒投放任务
5 $ret =Task::deliver($task);
6 var_dump($ret);//判断是否投递成功

1 namespaceAppJobsTimer;
2 use AppTasksTestTask;
3 use SwooleCoroutine;
4 use Hhxsv5LaravelSSwooleTaskTask;
5 use Hhxsv5LaravelSSwooleTimerCronJob;
6 classTestCronJob extends CronJob
7 {
8     protected $i = 0;
9     //!!! 定时任务的`interval`和`isImmediate`有两种配置方式（二选一）：一是重载对应的方法，二是注册定时任务时传入参数。
10     //--- 重载对应的方法来返回配置：开始
11     publicfunction interval()
12 {
13         return 1000;//每1秒运行一次
14 }
15     publicfunction isImmediate()
16 {
17         return false;//是否立即执行第一次，false则等待间隔时间后执行第一次
18 }
19     //--- 重载对应的方法来返回配置：结束
20     publicfunction 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             //Hhxsv5LaravelSIlluminateLaravelScheduleJob::class,
9             //两种配置参数的方式：
10             //[AppJobsTimerTestCronJob::class, [1000, true]], //注册时传入参数
11             AppJobsTimerTestCronJob::class, //重载对应的方法来返回参数
12 ],
13         'max_wait_time' => 5, //Reload时最大等待时间
14 ],
15     //...
16 ];

/**
 * 如果启用WebSocket server，$swoole是`SwooleWebSocketServer`的实例，否则是是`SwooleHttpServer`的实例
 * @var SwooleWebSocketServer|SwooleHttpServer $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' => SwooleTable::TYPE_INT, 'size' => 8],
10 ],
11 ],
12         //...继续定义其他Table
13 ],
14     //...
15 ];

1 namespaceAppServices;
2 use Hhxsv5LaravelSSwooleWebsocketHandlerInterface;
3 use SwooleHttpRequest;
4 use SwooleWebSocketFrame;
5 use SwooleWebSocketServer;
6 classWebSocketService implements WebSocketHandlerInterface
7 {
8     /**@var SwooleTable $wsTable */
9     private$wsTable;
10     publicfunction __construct()
11 {
12         $this->wsTable = app('swoole')->wsTable;
13 }
14     //场景：WebSocket中UserId与FD绑定
15     publicfunction 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     publicfunction 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     publicfunction 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 namespaceAppEvents;
2 use Hhxsv5LaravelSSwooleEventsServerStartInterface;
3 use SwooleAtomic;
4 use SwooleHttpServer;
5 classServerStartEvent implements ServerStartInterface
6 {
7     publicfunction __construct()
8 {
9 }
10     publicfunction handle(Server $server)
11 {
12         //初始化一个全局计数器(跨进程的可用)
13         $server->atomicCount = new Atomic(2233);
14 
15         //控制器中调用：app('swoole')->atomicCount->get();
16 }
17 }
18 namespaceAppEvents;
19 use Hhxsv5LaravelSSwooleEventsWorkerStartInterface;
20 use SwooleHttpServer;
21 classWorkerStartEvent implements WorkerStartInterface
22 {
23     publicfunction __construct()
24 {
25 }
26     publicfunction handle(Server $server, $workerId)
27 {
28         //初始化一个数据库连接池对象
29         //DatabaseConnectionPool::init();
30 }
31 }

1 //修改文件 config/laravels.php
2 'event_handlers' =>[
3     'ServerStart' => AppEventsServerStartEvent::class,
4     'WorkerStart' => AppEventsWorkerStartEvent::class,
5 ],