The following column workerman tutorial will introduce to you how to integrate TP5 with WorkerMan and GatewayWorker. I hope it will be helpful to friends in need!

TP5 integrates GatewayWorker

Windows version installation

a) Use composer create -project topthink/think testTG to install thinkphp5.

b) Enter the directory of thinkphp5, here is testTG, and use composer require workerman/gateway-worker-for-win to install the Windows version of gateway.

c) Go to the official website to download the Windows version of gateway-worker, which contains a demo. http://www.workerman.net/download

d) Unzip the downloaded compressed package and copy all the files in Applications/Yourapp to any folder in the thinkphp5 directory application, here named push .

e) Copy start_for_win.bat in the decompressed folder to the root directory of thinkphp5, which is the directory at the same level as application.

f) Right-click start_for_win.bat, click Edit, change the directory inside to your own directory, here it is changed to

php application\push\start_register.php application\push\start_gateway.php application\push\start_businessworker.php
Pause

g) Save and exit. Double click to run.

Linux version installation

a) Use composer create-project topthink/think testTG to install thinkphp5.

b) Enter the directory of thinkphp5, Here is testTG. Use composer require workerman/gateway-worker to install the Linux version of gateway.

c) Go to the official website to download the Linux version of gateway-worker, which contains a demo. http://www.workerman.net/download

d) Unzip the downloaded compressed package and copy all the files in Applications/Yourapp to any folder in the thinkphp5 directory application, here named push .

e) Copy start.php in the decompressed folder to the root directory of thinkphp5, which is a directory at the same level as application.

f) Change the path in the forearch loop brackets in the last part of the start.php file to your correct path.

Start on the command line php start.php start.

TP5 integrationWrokerMan

Windows version installation

a) Use composer create-project topthink /think testTW to install thinkphp5.

b) Enter the thinkphp5 root directory, which is testTW. First use composer require topthink/think-worker,

and then use composer require workerman/workerman-for-win to install workererman. After successful installation, delete vendor\workerman\workerman.

c) Create server.php in the thinkphp5 root directory (that is, the directory at the same level as application) and edit the content.

<?php
efine(&#39;APP_PATH&#39;, __DIR__ . &#39;/application/&#39;);
define(&#39;BIND_MODULE&#39;,&#39;push/Worker&#39;);
// 加載框架引導(dǎo)文件
require __DIR__ . &#39;/thinkphp/start.php&#39;;

d) Create workerman’s controller and name it Worker.php. In application/push/controller, the directory does not exist and is created by itself. Add the following content:

protected $socket = 'websocket://127.0.0.1:2346' where 127.0.0.1 is the IP address of the socket server. Listen here to port 2346 of this machine.

<?php
namespace app\push\controller;
use think\worker\Server;
class Worker extends Server
{
    protected $socket = &#39;websocket://127.0.0.1:2346&#39;;
    /**
     * 收到信息
     * @param $connection
     * @param $data
     */
    public function onMessage($connection, $data)
    {
        $connection->send(&#39;我收到你的信息了&#39;);
    }
    /**
     * 當(dāng)連接建立時觸發(fā)的回調(diào)函數(shù)
     * @param $connection
     */
    public function onConnect($connection)
    {
    }
    /**
     * 當(dāng)連接斷開時觸發(fā)的回調(diào)函數(shù)
     * @param $connection
     */
    public function onClose($connection)
    {
        
    }
    /**
     * 當(dāng)客戶端的連接上發(fā)生錯誤時觸發(fā)
     * @param $connection
     * @param $code
     * @param $msg
     */
    public function onError($connection, $code, $msg)
    {
        echo "error $code $msg\n";
    }
    /**
     * 每個進(jìn)程啟動
     * @param $worker
     */
    public function onWorkerStart($worker)
    {
    }
}

e) Run from the command line and start the listening service php server.php

f) Create a new html file at any location. The content is:

<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
<script>
ws = new WebSocket("ws://localhost:2346");
ws.onopen = function() {
    alert("連接成功");
    ws.send(&#39;tom&#39;);
    alert("給服務(wù)端發(fā)送一個字符串：tom");
};
ws.onmessage = function(e) {
    alert("收到服務(wù)端的消息：" + e.data);
};
</script>

g) Save it and open it with a browser, you can see that the link is successful.

Linux version installation

a) Just execute the composer command in step b) of Windows version installation: composer require topthink/think-worker. That’s it, the rest of the steps remain unchanged.

Simple use of GatewayWorker

<script type="text/javascript">
/**
 * 與GatewayWorker建立websocket連接，域名和端口改為你實際的域名端口，
 * 其中端口為Gateway端口，即start_gateway.php指定的端口。
 * start_gateway.php 中需要指定websocket協(xié)議，像這樣
 * $gateway = new Gateway(websocket://0.0.0.0:7272);
 */
ws = new WebSocket("ws://127.0.0.1:8282");
// 服務(wù)端主動推送消息時會觸發(fā)這里的onmessage
ws.onmessage = function(e){
    // json數(shù)據(jù)轉(zhuǎn)換成js對象
    var bindUrl = "{:url(&#39;push/BindClientId&#39;)}";
    var data = e.data;
    var type = data.type || &#39;&#39;;
    switch(type){
        // Events.php中返回的init類型的消息，將client_id發(fā)給后臺進(jìn)行uid綁定
        case &#39;init&#39;:
            // 利用jquery發(fā)起ajax請求，將client_id發(fā)給后端進(jìn)行uid綁定
            $.post(bindUrl, {client_id: data.client_id}, function(data){
            }, &#39;json&#39;);
            break;
        // 當(dāng)mvc框架調(diào)用GatewayClient發(fā)消息時直接alert出來
        default :
        var text = e.data;
            var str = &#39;<li style="width:100%; height:60px; border:1px solid #000">&#39; +text +&#39;</li>&#39;;
            $(&#39;#message_box&#39;).append();
           // alert(e.data);
    }
};
</script>
class Push{
   
    public function helloAction () {
        $uid = $_GET[&#39;uid&#39;];
        session(&#39;uid&#39;, $uid);
        $view = new View;
        return $view->fetch();
    }
    public function BindClientIdAction () {
        
        $client_id = $_POST[&#39;client_id&#39;];
        // 設(shè)置GatewayWorker服務(wù)的Register服務(wù)ip和端口，請根據(jù)實際情況改成實際值
        Gateway::$registerAddress = &#39;127.0.0.1:1238&#39;;
        $bindUid = session(&#39;uid&#39;);
        // 假設(shè)用戶已經(jīng)登錄，用戶uid和群組id在session中
        // client_id與uid綁定
        Gateway::bindUid($client_id, $bindUid);
        // 加入某個群組（可調(diào)用多次加入多個群組）
        // Gateway::joinGroup($client_id, $group_id);
    }
    public function AjaxSendMessageAction () {
        $message = $_POST[&#39;message&#39;];
        // 設(shè)置GatewayWorker服務(wù)的Register服務(wù)ip和端口，請根據(jù)實際情況改成實際值
        Gateway::$registerAddress = &#39;127.0.0.1:1238&#39;;
        GateWay::sendToAll($message);
    }
}

The above is the detailed content of How TP5 integrates WorkerMan and GatewayWorker. For more information, please follow other related articles on the PHP Chinese website!