wokerman 搭配thinkphp5.0实现socket长连接

痛定思痛。 2022-02-23 03:14 913阅读 0赞

一.**安装wokerman到tp5.0**  
1.

composer require topthink/think-worker

如果需要在window下做服务端，还需要

composer require workerman/workerman-for-win

如果一切顺利,成功之后  
此时composer自动就把workerman安装到tp5.0中 application同级的vendor目录中了  
2.  
在thinkphp5根目录（即与application同级目录）  
创建server.php，编辑一下内容。

<?php
    efine('APP_PATH', __DIR__ . '/application/');
    //push模块
    define('BIND_MODULE','push/Worker');
    // 加载框架引导文件
    require __DIR__ . '/thinkphp/start.php';

在application下中新建在application/push/controller文件夹,然后新建控制器Worker.php  
内容如下:  
127.0.0.1为socket服务器所在的ip地址。此处监听本机的2346端口

<?php
    namespace app\push\controller;
     
    use think\worker\Server;
     
    class Worker extends Server
    {
        protected $socket = 'websocket://www.abc.com:2346';
     
        /**
         * 收到信息
         * @param $connection
         * @param $data
         */
        public function onMessage($connection, $data)
        {
            $connection->send('我收到你的信息了');
        }
     
        /**
         * 当连接建立时触发的回调函数
         * @param $connection
         */
        public function onConnect($connection)
        {
     
        }
     
        /**
         * 当连接断开时触发的回调函数
         * @param $connection
         */
        public function onClose($connection)
        {
            
        }
     
        /**
         * 当客户端的连接上发生错误时触发
         * @param $connection
         * @param $code
         * @param $msg
         */
        public function onError($connection, $code, $msg)
        {
            echo "error $code $msg\n";
        }
     
        /**
         * 每个进程启动
         * @param $worker
         */
        public function onWorkerStart($worker)
        {
     
        }
    }

在cmd命令行中,运行server.php

php server.php start

新建一个html文档  
1.html  
如下内容:

<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
            "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
    <html xmlns="http://www.w3.org/1999/xhtml">
    
    <head>
        <meta http-equiv="Content-Type" content="text/html;charset=utf-8"/>
    
    </head>
    <body>
    <p>socket测试实例</p>
    </body>
    <script>
        ws = new WebSocket("ws://localhost:2346");
        ws.onopen = function() {
            alert("连接成功");
            ws.send('tom');
            alert("给服务端发送一个字符串：tom");
        };
        ws.onmessage = function(e) {
            alert("收到服务端的消息：" + e.data);
        };
    </script>
    </html>

测试  
[www.test.com][] 是我的测试域名  
打开浏览器 [www.test.com/1.html][www.test.com_1.html]  
弹出:连接成功

参考: [https://blog.csdn.net/qq\_14913213/article/details/77184074][https_blog.csdn.net_qq_14913213_article_details_77184074]

[www.test.com]: http://www.test.com
[www.test.com_1.html]: http://www.test.com/1.html
[https_blog.csdn.net_qq_14913213_article_details_77184074]: https://blog.csdn.net/qq_14913213/article/details/77184074