weigot/swoole

lumen framework by swoole

v0.1.4 2021-02-22 06:36 UTC

Requires

• php: >=7.0
• ext-swoole: *
• illuminate/redis: *
• laravel/lumen-framework: >=5.5

MIT

• caowei

README

公司使用lumen框架做项目较多，所以集合swoole来实现websocket供大家使用

使用文档

环境和依赖

1. "php": ">=7.0"

2. "ext-swoole": "*"

3. "laravel/lumen-framework": ">=5.5"

4. "illuminate/redis": "*"

使用方法

1.安装依赖包

$ composer require weigot/swoole

2.操作命令

$ php artisan weigot-ws start | restart | reload | stop | status   // 运行 | 重启 | 重新加载 | 停止 | 状态

3.使用supervisor守护进程

[program:${program-name}]        # 项目名称
directory= ${project-directory}  # 项目路径
process_name=%(program_name)s_%(process_num)02d
command=php artisan weigot-sw start  # 运行命令
autostart=true
autorestart=true
stopasgroup=true
killasgroup=true
user=root
numprocs=4
redirect_stderr=false
stdout_logfile=${log-file}  # 日志记录文件

4.nginx配置

map $http_upgrade $connection_upgrade {
    default upgrade;
    ''      close;
}

upstream websocket {
    #ip_hash;
    #转发到服务器上相应的ws端口
    server 0.0.0.0:9601;
}

server {
    #listen后面的端口号改为你自己需要的端口号
    listen 80;
    #server_name改为你自己的外网ip。server_name默认为localhost即127.0.0.1
    server_name sw.vm.com;

    root /var/www/html/works/lumenChat/public;
    index index.php index.html index.htm;

    location / {
         try_files $uri $uri/ /index.php$is_args$args;
    }

    location ~ \.php$ {
       fastcgi_pass unix:/var/run/php/php7.2-fpm.sock;
       fastcgi_split_path_info ^(.+\.php)(/.+)$;
       fastcgi_index /index.php;
       fastcgi_param  SCRIPT_FILENAME  $document_root$fastcgi_script_name;
       include fastcgi_params;
    }
    location /ws {
        #转发到http://websocket
        proxy_pass http://websocket;
        proxy_read_timeout 300s;
        proxy_send_timeout 300s;

        proxy_set_header Host $host;
        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
        #升级http1.1到 websocket协议
        proxy_http_version 1.1;
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection  $connection_upgrade;
    }
}

5.前端调用demo

数据结构

1. 消息结构

{
    "action":"",        // 行为code
    "data":{            // 消息
        "type":"",      // 消息类型
        "content":{     // 内容
            "message":"",
            "userList":[
                {
                    "fd":"",
                    "username":"",
                    ...
                },
                ...
            ],
            "userInfo":{
                "fd":"",
                "username":"",
                ...
            }
        }
    },
    "endTime":""
}

2.服务端action枚举

3.信息类型

4.客户端action枚举