配合 Supervisor,在 Laravel 里使用 Swoole 创建一个 websocket 服务器

# 1、swoole 安装请参考官网文档

请参考https://wiki.swoole.com/

# 2、参考最近手册在 laravel 里创建一个新的命令 swoole

http://laravelacademy.org/post/6842.html 创建一个名叫 swoole 的命令

php artisan make:command Swoole

在 Kernel.php 里增加命令列表

protected $commands = [
        Commands\Swoole::Class
];

修改 swoole 文件如下:

<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;

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 = 'swoole';

    /**
     * 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;
        }

    }
    public function start()
    {
        //创建websocket服务器对象,监听0.0.0.0:9502端口
        $ws = new \swoole_websocket_server("0.0.0.0", 9502);

        //监听WebSocket连接打开事件
        $ws->on('open', function ($ws, $request) {
            // var_dump($request->fd, $request->get, $request->server);
            $ws->push($request->fd, "hello, welcome\n");
        });

        //监听WebSocket消息事件
        $ws->on('message', function ($ws, $frame) {
            echo "Message: {$frame->data}\n";
            $ws->push($frame->fd, "server: {$frame->data}");
        });

        //监听WebSocket连接关闭事件
        $ws->on('close', function ($ws, $fd) {
            echo "client-{$fd} is closed\n";
        });

        $ws->start();
    }
}
php artisan list

这个时候就可以在里查到 swoole 命令了,具体看手册。

3、详细解读

a、start () 函数里调用了 swoole 的 swoole_websocket_server 类创建一个 websocket 服务器,监听 9502 端口 b、几个事件请看 swoole 的官方手册,其实就是监听一个 socket 连接并响应消息。这是一个聊天室的雏形,可以在里使用 laravel 的任意功能来完成用户聊天室的定位,并给所有人发消息,形成实时聊天功能 c、比如用户登陆后发送消息时附带一个 rid(聊天室)过来,程序把 fd 与 rid 对应,并给所有 rid 对应的 fd 广播消息

4、最好使用 supervisor 来守护 swoole 命令,使其在后台一直运行 我的配置如下:

[program:swoole-worker]
process_name=%(program_name)s_%(process_num)02d
command=php /path/artisan swoole
autostart=true
autorestart=true
user=apache
numprocs=1 //注意这里一定只有一个,端口的问题~~
redirect_stderr=true
stdout_logfile=/path/worker.log

5、在 html 里实现聊天功能,只能自己跟自己聊,试试长连接,要结合程序请自己尝试~

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
<div id="msg"></div>
<input type="text" id="text">
<input type="submit" value="发送数据" onclick="song()">
<p>adfssa</p>
</body>
<script>
    document.querySelector("body").style.fontSize = '28px';
    var msg = document.getElementById("msg");
    var wsServer = 'ws://100.100.100.100:9502/'
    //调用websocket对象建立连接:
    //参数:ws/wss(加密)://ip:port (字符串)
    var websocket = new WebSocket(wsServer);
    //onopen监听连接打开
    websocket.onopen = function (evt) {
        //websocket.readyState 属性:
        /*
        CONNECTING    0    The connection is not yet open.
        OPEN    1    The connection is open and ready to communicate.
        CLOSING    2    The connection is in the process of closing.
        CLOSED    3    The connection is closed or couldn't be opened.
        */
        msg.innerHTML = websocket.readyState;
    };

    function song(){
        var text = document.getElementById('text').value;
        document.getElementById('text').value = '';
        //向服务器发送数据
        websocket.send(text);
    }
      //监听连接关闭
//    websocket.onclose = function (evt) {
//        console.log("Disconnected");
//    };

    //onmessage 监听服务器数据推送
    websocket.onmessage = function (evt) {
        msg.innerHTML += evt.data +'<br>';
//        console.log('Retrieved data from server: ' + evt.data);
    };
//监听连接错误信息
//    websocket.onerror = function (evt, e) {
//        console.log('Error occured: ' + evt.data);
//    };

</script>
</html>

代码鱼社区资源论坛博客
请先登录后发表评论
  • latest comments
  • 总共0条评论