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

Home

PHP Framework

Workerman

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

青灯夜游

Feb 03, 2021 pm 06:26 PM

workerman

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!

Statement of this Website

The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn

Hot AI Tools

Undresser.AI Undress

AI-powered app for creating realistic nude photos

AI Clothes Remover

Online AI tool for removing clothes from photos.

Undress AI Tool

Undress images for free

Clothoff.io

AI clothes remover

AI Hentai Generator

Generate AI Hentai for free.

Hot Article

R.E.P.O. Energy Crystals Explained and What They Do (Yellow Crystal)

4 weeks ago By 尊渡假赌尊渡假赌尊渡假赌

R.E.P.O. Best Graphic Settings

4 weeks ago By 尊渡假赌尊渡假赌尊渡假赌

Assassin's Creed Shadows: Seashell Riddle Solution

2 weeks ago By DDD

R.E.P.O. How to Fix Audio if You Can't Hear Anyone

4 weeks ago By 尊渡假赌尊渡假赌尊渡假赌

WWE 2K25: How To Unlock Everything In MyRise

1 months ago By 尊渡假赌尊渡假赌尊渡假赌

Hot Tools

Notepad++7.3.1

Easy-to-use and free code editor

SublimeText3 Chinese version

Chinese version, very easy to use

Zend Studio 13.0.1

Powerful PHP integrated development environment

Dreamweaver CS6

Visual web development tools

SublimeText3 Mac version

God-level code editing software (SublimeText3)

Hot Topics

Where is the login entrance for gmail email?

7507

CakePHP Tutorial

1378

What is the format of the account name of steam

win11 activation key permanent

nyt connections hints and answers

Related knowledge

Implement file upload and download in Workerman documents Nov 08, 2023 pm 06:02 PM

To implement file upload and download in Workerman documents, specific code examples are required. Introduction: Workerman is a high-performance PHP asynchronous network communication framework that is simple, efficient, and easy to use. In actual development, file uploading and downloading are common functional requirements. This article will introduce how to use the Workerman framework to implement file uploading and downloading, and give specific code examples. 1. File upload: File upload refers to the operation of transferring files on the local computer to the server. The following is used

Which one is better, swoole or workerman? Apr 09, 2024 pm 07:00 PM

Swoole and Workerman are both high-performance PHP server frameworks. Known for its asynchronous processing, excellent performance, and scalability, Swoole is suitable for projects that need to handle a large number of concurrent requests and high throughput. Workerman offers the flexibility of both asynchronous and synchronous modes, with an intuitive API that is better suited for ease of use and projects that handle lower concurrency volumes.

How to implement the basic usage of Workerman documents Nov 08, 2023 am 11:46 AM

Introduction to how to implement the basic usage of Workerman documents: Workerman is a high-performance PHP development framework that can help developers easily build high-concurrency network applications. This article will introduce the basic usage of Workerman, including installation and configuration, creating services and listening ports, handling client requests, etc. And give corresponding code examples. 1. Install and configure Workerman. Enter the following command on the command line to install Workerman: c

Workerman development: How to implement real-time video calls based on UDP protocol Nov 08, 2023 am 08:03 AM

Workerman development: real-time video call based on UDP protocol Summary: This article will introduce how to use the Workerman framework to implement real-time video call function based on UDP protocol. We will have an in-depth understanding of the characteristics of the UDP protocol and show how to build a simple but complete real-time video call application through code examples. Introduction: In network communication, real-time video calling is a very important function. The traditional TCP protocol may have problems such as transmission delays when implementing high-real-time video calls. And UDP

How to use Workerman to build a high-availability load balancing system Nov 07, 2023 pm 01:16 PM

How to use Workerman to build a high-availability load balancing system requires specific code examples. In the field of modern technology, with the rapid development of the Internet, more and more websites and applications need to handle a large number of concurrent requests. In order to achieve high availability and high performance, the load balancing system has become one of the essential components. This article will introduce how to use the PHP open source framework Workerman to build a high-availability load balancing system and provide specific code examples. 1. Introduction to Workerman Worke

How to implement the reverse proxy function in the Workerman document Nov 08, 2023 pm 03:46 PM

How to implement the reverse proxy function in the Workerman document requires specific code examples. Introduction: Workerman is a high-performance PHP multi-process network communication framework that provides rich functions and powerful performance and is widely used in Web real-time communication and long connections. Service scenarios. Among them, Workerman also supports the reverse proxy function, which can realize load balancing and static resource caching when the server provides external services. This article will introduce how to use Workerman to implement the reverse proxy function.

How to implement the timer function in the Workerman document Nov 08, 2023 pm 05:06 PM

How to implement the timer function in the Workerman document Workerman is a powerful PHP asynchronous network communication framework that provides a wealth of functions, including the timer function. Use timers to execute code within specified time intervals, which is very suitable for application scenarios such as scheduled tasks and polling. Next, I will introduce in detail how to implement the timer function in Workerman and provide specific code examples. Step 1: Install Workerman First, we need to install Worker

How to implement TCP/UDP communication in Workerman documentation Nov 08, 2023 am 09:17 AM

How to implement TCP/UDP communication in the Workerman document requires specific code examples. Workerman is a high-performance PHP asynchronous event-driven framework that is widely used to implement TCP and UDP communication. This article will introduce how to use Workerman to implement TCP and UDP-based communication and provide corresponding code examples. 1. Create a TCP server for TCP communication. It is very simple to create a TCP server using Workerman. You only need to write the following code: <?ph

See all articles