Let's talk about how to use Workerman to implement instant chat function-Workerman-php.cn

Let's talk about how to use Workerman to implement instant chat function

青灯夜游

Release： 2021-02-22 17:57:33

forward

5404 people have browsed it

This article will introduce to you how to use workerman to implement instant chat. It has certain reference value. Friends in need can refer to it. I hope it will be helpful to everyone.

Let's talk about how to use Workerman to implement instant chat function

##Related recommendations: "

workerman Tutorial"

Development documentation: http://doc2.workerman.net/

Download the server-side installation file:

There are two versions: windows version and linux version. The linux version I downloaded can also run on windows.

After opening, there are these files:

You can put this file on the server or in the project. What needs to be run is the last start_for_win.bat file .

Run successfully.

Modify the start_gateway.php file:

<?php
/**
 * This file is part of workerman.
 *
 * Licensed under The MIT License
 * For full copyright and license information, please see the MIT-LICENSE.txt
 * Redistributions of files must retain the above copyright notice.
 *
 * @author walkor<walkor@workerman.net>
 * @copyright walkor<walkor@workerman.net>
 * @link http://www.workerman.net/
 * @license http://www.opensource.org/licenses/mit-license.php MIT License
 */
use \Workerman\Worker;
use \Workerman\WebServer;
use \GatewayWorker\Gateway;
use \GatewayWorker\BusinessWorker;
use \Workerman\Autoloader;

// 自动加载类
require_once __DIR__ . &#39;/../../vendor/autoload.php&#39;;

// gateway 进程，这里使用Text协议，可以用telnet测试
$gateway = new Gateway("websocket://0.0.0.0:8282");
// gateway名称，status方便查看
$gateway->name = &#39;YourAppGateway&#39;;
// gateway进程数
$gateway->count = 4;
// 本机ip，分布式部署时使用内网ip
$gateway->lanIp = &#39;127.0.0.1&#39;;
// 内部通讯起始端口，假如$gateway->count=4，起始端口为4000
// 则一般会使用4000 4001 4002 4003 4个端口作为内部通讯端口
$gateway->startPort = 2900;
// 服务注册地址
$gateway->registerAddress = &#39;127.0.0.1:1238&#39;;

// 心跳间隔
$gateway->pingInterval = 60;
// 心跳数据
$gateway->pingData = &#39;{"type":"ping"}&#39;;

/*
// 当客户端连接上来时，设置连接的onWebSocketConnect，即在websocket握手时的回调
$gateway->onConnect = function($connection)
{
    $connection->onWebSocketConnect = function($connection , $http_header)
    {
        // 可以在这里判断连接来源是否合法，不合法就关掉连接
        // $_SERVER[&#39;HTTP_ORIGIN&#39;]标识来自哪个站点的页面发起的websocket链接
        if($_SERVER[&#39;HTTP_ORIGIN&#39;] != &#39;http://kedou.workerman.net&#39;)
        {
            $connection->close();
        }
        // onWebSocketConnect 里面$_GET $_SERVER是可用的
        // var_dump($_GET, $_SERVER);
    };
};
*/

// 如果不是在根目录启动，则运行runAll方法
if(!defined(&#39;GLOBAL_START&#39;))
{
    Worker::runAll();
}

Copy after login

Line 24, change the tcp protocol to websocket protocol;

Lines 38 and 40, set the server direction The heartbeat time sent by the client to detect whether the client is connected. If not connected, it will be disconnected.

The following content is commented out by default. You can open or modify it according to your needs.

Run the start_for_win.bat file again:

The protocol will change to the websocket protocol, and you can now perform operations within the project.

You need to download another file: https://github.com/walkor/GatewayClient

Put these files into the thinkphp extend file Fold it (I am using thinkphp5.0 version):

Almost all the methods have been written in the Gateway.php file.

Write a simple front-end page:

<!DOCTYPE html>
<html>
    <head>
        <meta charset="UTF-8">
        <meta name="viewport" content="width=device-width, initial-scale=1.0">
        <meta http-equiv="X-UA-Compatible" content="ie=edge">
        <title></title>
    </head>
    <body>
        <ul id="msgUl">
            <li>ws://127.0.0.1:8282</li>
        </ul>
        <input type="" name="" id="sendValue" value="" />
        <button type="button" id="sendButton">发送</button>

        <div style="margin-top: 100px">
            {volist name="msg" id="vo" empty="这里没有数据" key =&#39;s&#39;}
                    <br/>
            　　　　<span>{$vo.user_name}：</span>
            　　　　<span>{$vo.msg}</span>
            　　　　<span>{$vo.createtime}</span>
                    <br/>
            　　{/volist}
        </div>

        <script src="http://www.zhihuapinpai.com/static/index/js/jquery-1.11.3.min.js"></script>
        <script>
            // var ws = new WebSocket("ws://123.56.216.232:8282");
            var ws = new WebSocket("ws://127.0.0.1:8282");

            ws.onopen = function() {
                $(&#39;#msgUl&#39;).append(&#39;<li>已连接上...</li>&#39;)
                sendValue();
            };

            ws.onmessage = function(evt) {
                $(&#39;#msgUl&#39;).append(&#39;<li>接收到：&#39; + evt.data + &#39;</li>&#39;)
                var obj = JSON.parse(evt.data);
                if (obj.type == &#39;onConnect&#39;) {
                    // 连接成功
                    $(&#39;#msgUl&#39;).append(&#39;<li>client_id：&#39; + obj.client_id + &#39;</li>&#39;)
                    $.ajax({
                        type:"POST",
                        url:"/index.php/api/Index/user_bind",
                        data:{
                            client_id:obj.client_id
                        },
                        dataType: "html",
                        success: function(data){
                            console.log(&#39;成功&#39;)
                        }
                    });
                } else if (obj.type == &#39;ping&#39;) {
                    // 心跳检测 不做任何处理
                } else if (obj.type == &#39;chatGroup&#39;) {
                    // 群组聊天
                    $(&#39;#msgUl&#39;).append(&#39;<li>接收到：&#39; + evt.data + &#39;</li>&#39;)
                }
            };

            ws.onclose = function() {
                // console.log(&#39;连接已关闭...&#39;);
                $(&#39;#msgUl&#39;).append(&#39;<li>连接已关闭...</li>&#39;)
            };

            function sendValue() {
                $(&#39;#sendButton&#39;).click(function() {
                    var thisValue = $(&#39;#sendValue&#39;).val();
                    if (thisValue) {
                        ws.send(thisValue);
                        $(&#39;#msgUl&#39;).append(&#39;<li>发送数据：&#39; + thisValue + &#39;</li>&#39;)
                        $.get("/index.php/api/Index/send_msg/msg/"+thisValue,function (data,status) {
                            console.log(&#39;成功：&#39;+thisValue)
                        });
                    }
                })
            }
        </script>
    </body>
</html>

Copy after login

Lines 42-52 pass the client_id to the background and bind it to the user in the user table.

Backend code:

<?php
namespace app\api\controller;
use think\Controller;
use GatewayClient\Gateway;
use think\Db;


class Index extends Controller
{

    public function websocket(){
        $where=[];
        $user_id=1;
        $where[&#39;from_id|to_id&#39;]=$user_id;
        $msg=Db::name(&#39;msg&#39;)->where($where)->select();
        foreach ($msg as $key=>$val){
            $msg[$key][&#39;createtime&#39;]=date(&#39;Y-m-d H:i:s&#39;,$val[&#39;createtime&#39;]);
            $msg[$key][&#39;user_name&#39;]=Db::name(&#39;user&#39;)->where([&#39;id&#39;=>$val[&#39;from_id&#39;]])->value(&#39;name&#39;);
        }
        $this->assign(&#39;msg&#39;,$msg);
        return view();
    }

    //绑定用户
    public function user_bind($user_id=1){
        //$user_id=1; //发送人用户id
        $client_id = input(&#39;post.client_id&#39;);
//        $user=Db::name(&#39;user&#39;)->where([&#39;id&#39;=>$user_id])->find();
        Gateway::bindUid($client_id, 1);
        return $client_id;
    }

    //发送信息
    public function send_msg(){
        $msg=input(&#39;msg&#39;);
        if($msg){
            $data=[
              &#39;msg&#39;=>$msg,
              &#39;from_id&#39;=>1,
              &#39;to_id&#39;=>2,
              &#39;createtime&#39;=>time()
            ];
            Db::name(&#39;msg&#39;)->insert($data);
            Gateway::sendToUid(1,$msg);
            Gateway::sendToUid(2,$msg);
        }
        return &#39;success&#39;;
    }

}

Copy after login

Send the message and store it in the database, and the page will be displayed.

For more computer programming related knowledge, please visit:

Programming Video! !

The above is the detailed content of Let's talk about how to use Workerman to implement instant chat function. For more information, please follow other related articles on the PHP Chinese website!