centos7+laravel7+swooletw/laravel-swoole扩展包的使用流程步骤及简单的websocket服务测试

Laravel  /  管理员 发布于 1年前   900

centos7+laravel7+swooletw/laravel-swoole扩展包的使用流程步骤及简单的websocket服务测试

这篇也是可以接上一篇的，因为我测试都是用同一个环境，使用之前的文章都可以无缝连接

这边是centos7+laravel7+swooletw/laravel-swoole扩展的使用，了解一下长连接，并搭建websocket服务器测试，

看过之前的文章的都知道swoole等依赖都安装好了

开始安装swooletw/laravel-swoole

[root@www laraveltest]# composer require swooletw/laravel-swoole -vvv
Reading ./composer.json
Loading config file /root/.config/composer/config.json
Loading config file /root/.config/composer/auth.json
Loading config file ./composer.json
。。。。
Discovered Package: swooletw/laravel-swoole
Package manifest generated successfully.

我们创建一个服务 自定义Artisan Commnad自行搜索

在 app\Console\Command\ 目录下生成 Swoole 文件

[root@www laraveltest]# php artisan make:command Swoole
Console command created successfully.

App\Console\Commands\Swoole.php

<?php
namespace App\Console\Commands;
use Illuminate\Console\Command;
use swoole_websocket_server;
class Swoole extends Command
{
    /**
     * The name and signature of the console command.
     * @var string
     */
    protected $signature = 'swoole {action}';
    /**
     * The console command description.
     * @var string
     */
    protected $description = 'Command description';
    /**
     * Create a new command instance.
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }
    /**
     * Execute the console command.
     * 服务命令
     * @return mixed
     */
    public function handle()
    {
        $action = $this->argument('action');
        switch ($action) {
            case 'close':
                break;
            default:
                $this->start();
                break;
        }
    }
    /**
     * 创建websocket服务器对象，监听0.0.0.0:9502端口
     * 具体可参考 https://wiki.swoole.com/#/start/start_tcp_server
     */
    public function start()
    {
        // 这里是监听的服务端口号
        $this->ws = new swoole_websocket_server("0.0.0.0", 9502);
        //监听WebSocket连接打开事件
        $this->ws->on('open', function ($ws, $request) {
            var_dump($request->fd, $request->get, $request->server);
            $ws->push($request->fd, "hello, welcome\n:我的博客：https://www.zongscan.com/\n");
        });
        //监听WebSocket消息事件
        $this->ws->on('message', function ($ws, $frame) {
            $this->info("client is SendMessage:172.18.1.230\n" . $frame);
        });
        //监听WebSocket主动推送消息事件
        $this->ws->on('request', function ($request, $response) {
            $scene = $request->post['scene'];
            foreach ($this->ws->connections as $fd) {
                if ($this->ws->isEstablished($fd)) {
                    $this->ws->push($fd, $scene);
                }
            }
        });
        //监听WebSocket连接关闭事件
        $this->ws->on('close', function ($ws, $fd) {
            $this->info("client is close\n");
        });
        $this->ws->start();
    }
}

在App\Console\Kernel.php文件中注册Swoole.php里面的Swoole类

<?php
namespace App\Console;
use Illuminate\Console\Scheduling\Schedule;
use Illuminate\Foundation\Console\Kernel as ConsoleKernel;
class Kernel extends ConsoleKernel
{
    /**
     * The Artisan commands provided by your application.
     * @var array
     */
    protected $commands = [
        //
        \App\Console\Commands\Swoole::class,
    ];
    /**
     * Define the application's command schedule.
     * @param  \Illuminate\Console\Scheduling\Schedule  $schedule
     * @return void
     */
    protected function schedule(Schedule $schedule)
    {
        // $schedule->command('inspire')->hourly();
    }
    /**
     * Register the commands for the application.
     *
     * @return void
     */
    protected function commands()
    {
        $this->load(__DIR__.'/Commands');
        require base_path('routes/console.php');
    }
}

这Swoole服务就写好了，我们去启动它：php artisan swoole start

看一下进程启动了没（0 0.0.0.0:9502）

[root@www ~]# netstat -lntp
Active Internet connections (only servers)
Proto Recv-Q Send-Q Local Address           Foreign Address         State       PID/Program name    
tcp        0      0 0.0.0.0:3306            0.0.0.0:*               LISTEN      16451/mysqld        
tcp        0      0 127.0.0.1:6379          0.0.0.0:*               LISTEN      4460/redis-server 1 
tcp        0      0 0.0.0.0:80              0.0.0.0:*               LISTEN      8462/nginx: master  
tcp        0      0 0.0.0.0:22              0.0.0.0:*               LISTEN      4420/sshd           
tcp        0      0 0.0.0.0:9502            0.0.0.0:*               LISTEN      1696/php            
tcp6       0      0 :::22                   :::*                    LISTEN      4420/sshd

测试

添加路由：

Route::get('/sock', 'SockController@index');

创建控制器：SockController.php

<?php
namespace App\Http\Controllers;
use Illuminate\Http\Request;
class SockController extends Controller
{
    public function index(){
        return view('sock');
    }
}

创建模板：sock.blade.php

<!doctype html>
<html>
<head>
<title>测试WebSocket</title>
</head>
<div id="WebSocket"></div>
<body>
<script src="https://cdn.bootcss.com/jquery/2.1.1/jquery.min.js"></script>
<script>
    (function(){
        var ws = new WebSocket("ws://172.18.1.230:9502");
        ws.onopen = function(event) {
            console.log("客户端已连接上!");
            ws.send("hello server,this is client!"); //客户端给服务端推送消息
        };
        ws.onmessage = function(event) {
            var parent = document.getElementById('WebSocket');
            var div = document.createElement("div");
            div.innerHTML = event.data
            parent.appendChild(div);
            console.log("服务器传过来的数据是：" + event.data);
        }
        ws.onclose = function(event) {
            console.log("连接已关闭");
        };
    })()
</script>
</body>

看看效果