Parlons de la façon d'utiliser Workerman pour implémenter la fonction de chat instantané-Workerman-php.cn

Parlons de la façon d'utiliser Workerman pour implémenter la fonction de chat instantané

青灯夜游

Libérer： 2021-02-22 17:57:33

avant

5364 Les gens l'ont consulté

Cet article vous présentera comment utiliser workerman pour mettre en œuvre le chat instantané. Il a une certaine valeur de référence. Les amis dans le besoin peuvent s'y référer. J'espère qu'il sera utile à tout le monde.

Parlons de la façon d'utiliser Workerman pour implémenter la fonction de chat instantané

Recommandations associées : "tutoriel Workerman"

Documentation de développement : http://doc2.workerman.net/

Téléchargez le fichier d'installation côté serveur :

Il existe deux versions : la version Windows et la version Linux. La version Linux que j'ai téléchargée peut également fonctionner sous Windows.

Après ouverture, il y a ces fichiers :

Vous pouvez mettre ce fichier sur le serveur ou dans le projet. Ce qui doit être exécuté est le dernier. Fichier start_for_win.bat .

Exécuter avec succès.

Modifiez le fichier start_gateway.php :

<?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();
}

Copier après la connexion

Ligne 24, changez le protocole TCP en protocole websocket

Lignes 38 et 40, définissez la direction du serveur. temps de pulsation envoyé par le client pour détecter si le client est connecté. S'il n'est pas connecté, il sera déconnecté.

Le contenu suivant est commenté par défaut. Vous pouvez l'ouvrir ou le modifier selon vos besoins.

Exécutez à nouveau le fichier start_for_win.bat :

Le protocole deviendra le protocole websocket, et vous pourrez désormais effectuer des opérations au sein du projet.

Vous devez également télécharger un fichier supplémentaire : https://github.com/walkor/GatewayClient

Mettez ces fichiers dans le fichier d'extension thinkphp Fold it (j'utilise la version thinkphp5.0) :

Presque toutes les méthodes sont écrites dans le fichier Gateway.php.

Écrivez une page frontale simple :

<!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>

Copier après la connexion

Les lignes 42 à 52 transmettent le client_id à l'arrière-plan et le lient à l'utilisateur dans la table utilisateur .

Code backend :

<?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;;
    }

}

Copier après la connexion

Envoyez le message et stockez-le dans la base de données, et la page s'affichera.