Develop

composer.json

@@ -18,7 +18,8 @@
         "illuminate/console": "~5.1",
         "illuminate/contracts": "~5.1",
         "illuminate/http": "~5.1",
-        "illuminate/support": "~5.1"
+        "illuminate/support": "~5.1",
+        "predis/predis": "^1.1"
     },
     "require-dev": {
         "laravel/lumen-framework": "~5.1",
@@ -36,5 +37,18 @@
             "SwooleTW\\Http\\Tests\\": "tests",
             "SwooleTW\\Http\\Tests\\Fixtures\\Laravel\\App\\": "tests/fixtures/laravel/app"
         }
+    },
+    "extra": {
+        "laravel": {
+            "providers": [
+                "SwooleTW\\Http\\LaravelServiceProvider"
+            ],
+            "aliases": {
+                "Server": "SwooleTW\\Http\\Server\\Facades\\Server",
+                "Table": "SwooleTW\\Http\\Server\\Facades\\Table",
+                "Room": "SwooleTW\\Http\\Websocket\\Facades\\Room",
+                "Websocket": "SwooleTW\\Http\\Websocket\\Facades\\Websocket"
+            }
+        }
     }
 }

config/swoole_http.php

@@ -8,7 +8,7 @@
     | HTTP server configurations.
     |--------------------------------------------------------------------------
     |
-    | @see https://wiki.swoole.com/wiki/page/274.html
+    | @see https://www.swoole.co.uk/docs/modules/swoole-server/configuration
     |
     */
     'server' => [
@@ -18,21 +18,60 @@
             'pid_file' => env('SWOOLE_HTTP_PID_FILE', base_path('storage/logs/swoole_http.pid')),
             'log_file' => env('SWOOLE_HTTP_LOG_FILE', base_path('storage/logs/swoole_http.log')),
             'daemonize' => env('SWOOLE_HTTP_DAEMONIZE', false),
-            'task_worker_num' => env('SWOOLE_HTTP_TASK_WORKER_NUM', 4)
+            'task_worker_num' => env('SWOOLE_HTTP_TASK_WORKER_NUM', 4),
+            // The data to send can't be larger than buffer_output_size.
+            'buffer_output_size' => 10 * 1024 * 1024
         ],
     ],
 
+    /*
+    |--------------------------------------------------------------------------
+    | Enable to turn on websocket server.
+    |--------------------------------------------------------------------------
+    */
     'websocket' => [
         'enabled' => env('SWOOLE_HTTP_WEBSOCKET', false),
     ],
 
+    /*
+    |--------------------------------------------------------------------------
+    | Laravel app will be cloned on every requset.
+    |--------------------------------------------------------------------------
+    */
+    'sandbox_mode' => env('SWOOLE_SANDBOX_MODE', false),
+
+    /*
+    |--------------------------------------------------------------------------
+    | Console output will be transfered to response content if enabled.
+    |--------------------------------------------------------------------------
+    */
+    'ob_output' => env('SWOOLE_OB_OUTPUT', true),
+
     /*
     |--------------------------------------------------------------------------
     | Providers here will be registered on every request.
     |--------------------------------------------------------------------------
     */
     'providers' => [
-        // App\Providers\AuthServiceProvider::class,
+        // Illuminate\Auth\AuthServiceProvider::class,
+    ],
+
+    /*
+    |--------------------------------------------------------------------------
+    | Resolved facades here will be cleared on every request.
+    |--------------------------------------------------------------------------
+    */
+    'facades' => [
+        'auth', 'auth.driver', 'auth.password', 'request'
+    ],
+
+    /*
+    |--------------------------------------------------------------------------
+    | Instances here will be cleared on every request.
+    |--------------------------------------------------------------------------
+    */
+    'instances' => [
+        //
     ],
 
     /*

config/swoole_websocket.php

@@ -7,16 +7,14 @@
     | Replace this handler before you start it
     |--------------------------------------------------------------------------
     */
-    'handler' => SwooleTW\Http\Websocket\WebsocketHandler::class,
+    'handler' => SwooleTW\Http\Websocket\SocketIO\WebsocketHandler::class,
 
     /*
     |--------------------------------------------------------------------------
-    | Websocket handlers mapping for onMessage callback
+    | Websocket route file path
     |--------------------------------------------------------------------------
     */
-    'handlers' => [
-        // 'event_name' => 'App\Handlers\ExampleHandler@function',
-    ],
+    'route_file' => base_path('routes/websocket.php'),
 
     /*
     |--------------------------------------------------------------------------
@@ -27,11 +25,25 @@
 
     /*
     |--------------------------------------------------------------------------
-    | Default message formatter
+    | Default frame parser
     | Replace it if you want to customize your websocket payload
     |--------------------------------------------------------------------------
     */
-    'formatter' => SwooleTW\Http\Websocket\Formatters\DefaultFormatter::class,
+    'parser' => SwooleTW\Http\Websocket\SocketIO\SocketIOParser::class,
+
+    /*
+    |--------------------------------------------------------------------------
+    | Heartbeat interval (ms)
+    |--------------------------------------------------------------------------
+    */
+    'ping_interval' => 25000,
+
+    /*
+    |--------------------------------------------------------------------------
+    | Heartbeat interval timeout (ms)
+    |--------------------------------------------------------------------------
+    */
+    'ping_timeout' => 60000,
 
     /*
     |--------------------------------------------------------------------------
@@ -40,6 +52,7 @@
     */
     'drivers' => [
         'table' => SwooleTW\Http\Websocket\Rooms\TableRoom::class,
+        'redis' => SwooleTW\Http\Websocket\Rooms\RedisRoom::class,
     ],
 
     /*
@@ -54,6 +67,20 @@
             'room_size' => 2048,
             'client_rows' => 8192,
             'client_size' => 2048
+        ],
+
+        'redis' => [
+            'server' => [
+                'host' => env('REDIS_HOST', '127.0.0.1'),
+                'password' => env('REDIS_PASSWORD', null),
+                'port' => env('REDIS_PORT', 6379),
+                'database' => 0,
+                'persistent' => true,
+            ],
+            'options' => [
+                //
+            ],
+            'prefix' => 'swoole:',
         ]
     ],
 ];

routes/laravel_routes.php

@@ -0,0 +1,17 @@
+<?php
+
+use Illuminate\Support\Facades\Route;
+
+/*
+|--------------------------------------------------------------------------
+| Web Routes
+|--------------------------------------------------------------------------
+|
+| Here is where you can register socket.io routes for your application.
+|
+*/
+
+Route::group(['namespace' => 'SwooleTW\Http\Controllers'], function () {
+    Route::get('socket.io', 'SocketIOController@upgrade');
+    Route::post('socket.io', 'SocketIOController@reject');
+});

routes/lumen_routes.php

@@ -0,0 +1,20 @@
+<?php
+
+/*
+|--------------------------------------------------------------------------
+| Socket.io Routes
+|--------------------------------------------------------------------------
+|
+| Here is where you can register all of the routes for an application.
+| It is a breeze. Simply tell Lumen the URIs it should respond to
+| and give it the Closure to call when that URI is requested.
+|
+*/
+
+$app->get('socket.io', [
+    'as' => 'io.get', 'uses' => 'SocketIOController@upgrade'
+]);
+
+$app->post('socket.io', [
+    'as' => 'io.post', 'uses' => 'SocketIOController@reject'
+]);

routes/websocket.php

@@ -0,0 +1,18 @@
+<?php
+
+use SwooleTW\Http\Websocket\Facades\Websocket;
+
+/*
+|--------------------------------------------------------------------------
+| Websocket Routes
+|--------------------------------------------------------------------------
+|
+| Here is where you can register websocket events for your application.
+|
+*/
+
+Websocket::on('example', function ($websocket, $data) {
+    $websocket->emit('message', $data);
+});
+
+// Websocket::on('test', 'ExampleController@method');

src/Controllers/SocketIOController.php

@@ -0,0 +1,41 @@
+<?php
+
+namespace SwooleTW\Http\Controllers;
+
+use Illuminate\Http\Request;
+
+class SocketIOController
+{
+    protected $transports = ['polling', 'websocket'];
+
+    public function upgrade(Request $request)
+    {
+        if (! in_array($request->input('transport'), $this->transports)) {
+            return response()->json([
+                'code' => 0,
+                'message' => 'Transport unknown'
+            ], 400);
+        }
+
+        if ($request->has('sid')) {
+            return '1:6';
+        }
+
+        $payload = json_encode([
+            'sid' => base64_encode(uniqid()),
+            'upgrades' => ['websocket'],
+            'pingInterval' => config('swoole_websocket.ping_interval'),
+            'pingTimeout' => config('swoole_websocket.ping_timeout')
+        ]);
+
+        return '97:0' . $payload . '2:40';
+    }
+
+    public function reject(Request $request)
+    {
+        return response()->json([
+            'code' => 3,
+            'message' => 'Bad request'
+        ], 400);
+    }
+}

src/HttpServiceProvider.php

@@ -33,6 +33,13 @@ public function register()
      */
     abstract protected function registerManager();
 
+    /**
+     * Boot routes.
+     *
+     * @return void
+     */
+    abstract protected function bootRoutes();
+
     /**
      * Boot the service provider.
      *
@@ -42,8 +49,10 @@ public function boot()
     {
         $this->publishes([
             __DIR__ . '/../config/swoole_http.php' => base_path('config/swoole_http.php'),
-            __DIR__ . '/../config/swoole_websocket.php' => base_path('config/swoole_websocket.php')
-        ], 'config');
+            __DIR__ . '/../config/swoole_websocket.php' => base_path('config/swoole_websocket.php'),
+            __DIR__ . '/../routes/websocket.php' => base_path('routes/websocket.php')
+        ], 'laravel-swoole');
+        $this->bootRoutes();
     }
 
     /**

src/LaravelServiceProvider.php

@@ -17,4 +17,14 @@ protected function registerManager()
             return new Manager($app, 'laravel');
         });
     }
+
+    /**
+     * Boot routes.
+     *
+     * @return void
+     */
+    protected function bootRoutes()
+    {
+        require __DIR__.'/../routes/laravel_routes.php';
+    }
 }

src/LumenServiceProvider.php

@@ -17,4 +17,24 @@ protected function registerManager()
             return new Manager($app, 'lumen');
         });
     }
+
+    /**
+     * Boot routes.
+     *
+     * @return void
+     */
+    protected function bootRoutes()
+    {
+        $app = $this->app;
+
+        if (property_exists($app, 'router')) {
+            $app->router->group(['namespace' => 'SwooleTW\Http\Controllers'], function ($app) {
+                require __DIR__ . '/../routes/lumen_routes.php';
+            });
+        } else {
+            $app->group(['namespace' => 'App\Http\Controllers'], function ($app) {
+                require __DIR__ . '/../routes/lumen_routes.php';
+            });
+        }
+    }
 }