記錄 thinkphp5.0.24 啟用workerman擴展的方法


Workerman是一款純PHP開發的開源高性能的PHP socket 服務器框架。被廣泛的用於手機app、手游服務端、網絡游戲服務器、聊天室服務器、硬件通訊服務器、智能家居、車聯網、物聯網等領域的開發。 支持TCP長連接,支持Websocket、HTTP等協議,支持自定義協議。基於workerman開發者可以更專注於業務邏輯開發,不必再為PHP Socket底層開發而煩惱。這些都是thinkphp5開發文檔里面的資料,但是文檔里面有些事沒有寫清楚的,下面小編自身從頭到尾寫一個完整的案例。

首先通過 composer 安裝,切換到項目根目錄,輸入命令

composer require topthink/think-worker
 
         
         
        

如果需要在window下做服務端,還需要

composer require workerman/workerman-for-win
 
        

首先要明白composer之后workerman是安裝到哪去了,安裝到tp5項目下vendor目錄中

運行出現錯誤PHP Fatal error: Call to undefined function Workerman\Lib\pcntl_signal(),需要刪除vendor\workerman\workerman,防止命名覆蓋
服務端使用示例如下:

新增啟動服務文件server.php,在項目根目錄(和application同級目錄,不要放入public中)

<?php
#!/usr/bin/env php
define('APP_PATH', __DIR__ . '/application/');
define('BIND_MODULE','push/Worker');
// 加載框架引導文件
require __DIR__ . '/thinkphp/start.php';

關於server.php 文檔說,放到項目根目錄,其實這個文件放到哪個目錄並沒有什么關系。通過命令行訪問到這個文件,然后執行它就可以了。關鍵是要確保每一行代碼中訪問的目錄都是可以正常訪問到。不然執行中會提示找不到控制器或者模塊之類的信息。

 

新增服務處理類,在tp5目錄中application\push\controller\Worker.php中新建worker.php控制器,其中127.0.0.1:2346為服務器的私有ip地址和端口,查看服務器私有ip地址可以通過ifconfig來查看inet addr就是私有ip地址。

端口這塊很多人都會出錯,因為服務器再默認情況下是不會打開你要配置的2346端口的,所有為保證配置成功,你首先需要去服務器防火牆添加一個允許訪問2346的端口的規則。下面是詳細控制器代碼

 

<?php
namespace app\push\controller;

use think\worker\Server;
use Workerman\Lib\Timer;

class Worker extends Server{
    protected $socket = 'websocket://127.0.0.1:2346';
    /**
     * 收到信息
     * @param $connection
     * @param $data
     */
    public function onMessage($connection, $data)
    {
        $connection->send('我收到你的信息了');
        $connection->send('你給我發送了'.$data);
//        $timer_id = Timer::add(1, function () use ($connection, $data, &$timer_id) {
//            $connection->send('timer_id=' . $timer_id);
//        });
    }

    /**
     * 當連接建立時觸發的回調函數
     * @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)
    {

    }


}

  

在命令行下運行,啟動監聽服務

php server.php start
 
        

開啟了服務后,如果成功的話我們可以看到,start success!

最后客戶端代碼需要注意的是127.0.0.1為你服務器的公網ip地址,這個地址就是通常域名需要解析的ip地址。搞清楚了這點以后我們再打開chrome瀏覽器,再打開項目的任一網頁(js跨域不能通訊),按F12打開調試控制台,在Console一欄輸入(我建議大家把下面代碼放入到html頁面用js運行)

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Websocket 測試</title>
</head>
<body>
<h1>Websocket 測試</h1>
</body>
<script>
    ws = new WebSocket("ws://127.0.0.1:2346");
    ws.onopen = function() {
        console.log("連接成功");
        ws.send('tom');
        console.log("給服務端發送一個字符串:tom");
    };
    ws.onmessage = function(e) {
        console.log("收到服務端的消息:" + e.data);
    };
    // ws.send('保持連接,發第二次信息,查看服務器回應');
</script>
</html>

  

最后都配置成功的話,我們切換到那個有js代碼的html頁面可以看到調用成功了。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM