gx

+<?php
+
+namespace App\Broadcasting;
+
+use App\Models\User\User;
+
+class WebSocketChannel
+{
+    /**
+     * Create a new channel instance.
+     *
+     * @return void
+     */
+    public function __construct()
+    {
+        //
+    }
+
+    /**
+     * Authenticate the user's access to the channel.
+     *
+     * @param  \App\Models\User\User  $user
+     * @return array|bool
+     */
+    public function join(User $user)
+    {
+        //
+    }
+}

@@ -3,13 +3,16 @@
 namespace App\Events;
 namespace App\Events;
 
 
 use Illuminate\Broadcasting\Channel;
 use Illuminate\Broadcasting\Channel;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Broadcasting\PresenceChannel;
+use Illuminate\Broadcasting\PrivateChannel;
 use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
 use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
 use Illuminate\Foundation\Events\Dispatchable;
 use Illuminate\Foundation\Events\Dispatchable;
 use Illuminate\Queue\SerializesModels;
 use Illuminate\Queue\SerializesModels;
 
 
-class WebSocketMessageSent implements ShouldBroadcast
+class WebSocketMessage implements ShouldBroadcast
 {
 {
-    use Dispatchable, SerializesModels;
+    use Dispatchable, InteractsWithSockets, SerializesModels;
 
 
     public $message;
     public $message;
 
 

@@ -10,6 +10,7 @@
 namespace App\Http\Controllers\Bside;
 namespace App\Http\Controllers\Bside;
 
 
 use App\Enums\Common\Code;
 use App\Enums\Common\Code;
+use App\Events\WebSocketMessage;
 use App\Events\WebSocketMessageSent;
 use App\Events\WebSocketMessageSent;
 use App\Helper\Common;
 use App\Helper\Common;
 use App\Helper\Translate;
 use App\Helper\Translate;
@@ -146,7 +147,7 @@ class LoginController extends BaseController
 //        $message = file_get_contents("php://input");
 //        $message = file_get_contents("php://input");
 //        $message = simplexml_load_string($message, 'SimpleXMLElement', LIBXML_NOCDATA | LIBXML_NOERROR);
 //        $message = simplexml_load_string($message, 'SimpleXMLElement', LIBXML_NOCDATA | LIBXML_NOERROR);
 //        @file_put_contents(storage_path('logs/lyh_error.log'), $message . PHP_EOL, FILE_APPEND);
 //        @file_put_contents(storage_path('logs/lyh_error.log'), $message . PHP_EOL, FILE_APPEND);
-        event(new WebSocketMessageSent('New message from server'));
+        event(new WebSocketMessage('Hello, WebSocket!'));
         $this->response('success');
         $this->response('success');
     }
     }
 
 

@@ -5,7 +5,7 @@
     "keywords": ["framework", "laravel"],
     "keywords": ["framework", "laravel"],
     "license": "MIT",
     "license": "MIT",
     "require": {
     "require": {
-        "php": "^7.4|^8.1",
+        i
         "bensampo/laravel-enum": "^4.2",
         "bensampo/laravel-enum": "^4.2",
         "beyondcode/laravel-websockets": "^1.14",
         "beyondcode/laravel-websockets": "^1.14",
         "doctrine/dbal": "^3.6",
         "doctrine/dbal": "^3.6",

+<?php
+
+return [
+    /*
+    |--------------------------------------------------------------------------
+    | HTTP server configurations.
+    |--------------------------------------------------------------------------
+    |
+    | @see https://www.swoole.co.uk/docs/modules/swoole-server/configuration
+    |
+    */
+    'server' => [
+        'host' => env('SWOOLE_HTTP_HOST', '127.0.0.1'),
+        'port' => env('SWOOLE_HTTP_PORT', '1215'),
+        'public_path' => base_path('public'),
+        // Determine if to use swoole to respond request for static files
+        'handle_static_files' => env('SWOOLE_HANDLE_STATIC', true),
+        'access_log' => env('SWOOLE_HTTP_ACCESS_LOG', false),
+        // You must add --enable-openssl while compiling Swoole
+        // Put `SWOOLE_SOCK_TCP | SWOOLE_SSL` if you want to enable SSL
+        'socket_type' => SWOOLE_SOCK_TCP,
+        'process_type' => SWOOLE_PROCESS,
+        'options' => [
+            '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),
+            // Normally this value should be 1~4 times larger according to your cpu cores.
+            'reactor_num' => env('SWOOLE_HTTP_REACTOR_NUM', swoole_cpu_num()),
+            'worker_num' => env('SWOOLE_HTTP_WORKER_NUM', swoole_cpu_num()),
+            'task_worker_num' => env('SWOOLE_HTTP_TASK_WORKER_NUM', swoole_cpu_num()),
+            // The data to receive can't be larger than buffer_output_size.
+            'package_max_length' => 20 * 1024 * 1024,
+            // The data to send can't be larger than buffer_output_size.
+            'buffer_output_size' => 10 * 1024 * 1024,
+            // Max buffer size for socket connections
+            'socket_buffer_size' => 128 * 1024 * 1024,
+            // Worker will restart after processing this number of requests
+            'max_request' => 3000,
+            // Enable coroutine send
+            'send_yield' => true,
+            // You must add --enable-openssl while compiling Swoole
+            'ssl_cert_file' => null,
+            'ssl_key_file' => null,
+        ],
+    ],
+
+    /*
+    |--------------------------------------------------------------------------
+    | Enable to turn on websocket server.
+    |--------------------------------------------------------------------------
+    */
+    'websocket' => [
+        'enabled' => env('SWOOLE_HTTP_WEBSOCKET', true),
+    ],
+
+    /*
+    |--------------------------------------------------------------------------
+    | Hot reload configuration
+    |--------------------------------------------------------------------------
+    */
+    'hot_reload' => [
+        'enabled' => env('SWOOLE_HOT_RELOAD_ENABLE', false),
+        'recursively' => env('SWOOLE_HOT_RELOAD_RECURSIVELY', true),
+        'directory' => env('SWOOLE_HOT_RELOAD_DIRECTORY', base_path()),
+        'log' => env('SWOOLE_HOT_RELOAD_LOG', true),
+        'filter' => env('SWOOLE_HOT_RELOAD_FILTER', '.php'),
+    ],
+
+    /*
+    |--------------------------------------------------------------------------
+    | Console output will be transferred to response content if enabled.
+    |--------------------------------------------------------------------------
+    */
+    'ob_output' => env('SWOOLE_OB_OUTPUT', true),
+
+    /*
+    |--------------------------------------------------------------------------
+    | Pre-resolved instances here will be resolved when sandbox created.
+    |--------------------------------------------------------------------------
+    */
+    'pre_resolved' => [
+        'view', 'files', 'session', 'session.store', 'routes',
+        'db', 'db.factory', 'cache', 'cache.store', 'config', 'cookie',
+        'encrypter', 'hash', 'router', 'translator', 'url', 'log',
+    ],
+
+    /*
+    |--------------------------------------------------------------------------
+    | Instances here will be cleared on every request.
+    |--------------------------------------------------------------------------
+    */
+    'instances' => [
+        'auth',
+    ],
+
+    /*
+    |--------------------------------------------------------------------------
+    | Providers here will be registered on every request.
+    |--------------------------------------------------------------------------
+    */
+    'providers' => [
+        Illuminate\Pagination\PaginationServiceProvider::class,
+    ],
+
+    /*
+    |--------------------------------------------------------------------------
+    | Resetters for sandbox app.
+    |--------------------------------------------------------------------------
+    */
+    'resetters' => [
+        SwooleTW\Http\Server\Resetters\ResetConfig::class,
+        SwooleTW\Http\Server\Resetters\ResetSession::class,
+        SwooleTW\Http\Server\Resetters\ResetCookie::class,
+        SwooleTW\Http\Server\Resetters\ClearInstances::class,
+        SwooleTW\Http\Server\Resetters\BindRequest::class,
+        SwooleTW\Http\Server\Resetters\RebindKernelContainer::class,
+        SwooleTW\Http\Server\Resetters\RebindRouterContainer::class,
+        SwooleTW\Http\Server\Resetters\RebindViewContainer::class,
+        SwooleTW\Http\Server\Resetters\ResetProviders::class,
+    ],
+
+    /*
+    |--------------------------------------------------------------------------
+    | Define your swoole tables here.
+    |
+    | @see https://www.swoole.co.uk/docs/modules/swoole-table
+    |--------------------------------------------------------------------------
+    */
+    'tables' => [
+        // 'table_name' => [
+        //     'size' => 1024,
+        //     'columns' => [
+        //         ['name' => 'column_name', 'type' => Table::TYPE_STRING, 'size' => 1024],
+        //     ]
+        // ],
+    ],
+];

+<?php
+
+return [
+    /*
+    |--------------------------------------------------------------------------
+    | Websocket handler for onOpen and onClose callback
+    | Replace this handler if you want to customize your websocket handler
+    |--------------------------------------------------------------------------
+    */
+    'handler' => SwooleTW\Http\Websocket\SocketIO\WebsocketHandler::class,
+
+    /*
+    |--------------------------------------------------------------------------
+    | Default frame parser
+    | Replace it if you want to customize your websocket payload
+    |--------------------------------------------------------------------------
+    */
+    'parser' => SwooleTW\Http\Websocket\SocketIO\SocketIOParser::class,
+
+    /*
+    |--------------------------------------------------------------------------
+    | Websocket route file path
+    |--------------------------------------------------------------------------
+    */
+    'route_file' => base_path('routes/websocket.php'),
+
+    /*
+    |--------------------------------------------------------------------------
+    | Default middleware for on connect request
+    |--------------------------------------------------------------------------
+    */
+    'middleware' => [
+        // SwooleTW\Http\Websocket\Middleware\DecryptCookies::class,
+        // SwooleTW\Http\Websocket\Middleware\StartSession::class,
+        // SwooleTW\Http\Websocket\Middleware\Authenticate::class,
+    ],
+
+    /*
+    |--------------------------------------------------------------------------
+    | Websocket handler for customized onHandShake callback
+    |--------------------------------------------------------------------------
+    */
+    'handshake' => [
+        'enabled' => false,
+        'handler' => SwooleTW\Http\Websocket\HandShakeHandler::class,
+    ],
+
+    /*
+    |--------------------------------------------------------------------------
+    | Default websocket driver
+    |--------------------------------------------------------------------------
+    */
+    'default' => 'table',
+
+    /*
+    |--------------------------------------------------------------------------
+    | Websocket client's heartbeat interval (ms)
+    |--------------------------------------------------------------------------
+    */
+    'ping_interval' => 25000,
+
+    /*
+    |--------------------------------------------------------------------------
+    | Websocket client's heartbeat interval timeout (ms)
+    |--------------------------------------------------------------------------
+    */
+    'ping_timeout' => 60000,
+
+    /*
+    |--------------------------------------------------------------------------
+    | Room drivers mapping
+    |--------------------------------------------------------------------------
+    */
+    'drivers' => [
+        'table' => SwooleTW\Http\Websocket\Rooms\TableRoom::class,
+        'redis' => SwooleTW\Http\Websocket\Rooms\RedisRoom::class,
+    ],
+
+    /*
+    |--------------------------------------------------------------------------
+    | Room drivers settings
+    |--------------------------------------------------------------------------
+    */
+    'settings' => [
+
+        'table' => [
+            'room_rows' => 4096,
+            '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:',
+        ],
+    ],
+];