首页    技术博客    PHP教程    数据库技术    前端开发   HTML5    Nginx    php论坛
新用户注册 | 会员登录
加入会员，解锁专属内容
取消
热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

怎么在workerman中使用laravel开发一个在线聊天应用

作者：gu油漆装修 | 来源：互联网 | 2023-07-18 20:10
怎么在workerman中使用laravel开发一个在线聊天应用？相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章

怎么在workerman中使用laravel开发一个在线聊天应用？相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。

什么是Workerman？

Workerman是一款 开源 高性能异步 PHP socket即时通讯框架 。支持高并发，超高稳定性，被广泛的用于手机app、移动通讯，微信小程序，手游服务端、网络游戏、PHP聊天室、硬件通讯、智能家居、车联网、物联网等领域的开发。 支持TCP长连接，支持Websocket、HTTP等协议，支持自定义协议。拥有异步Mysql、异步Redis、异步Http、MQTT物联网客户端、异步消息队列等众多高性能组件。

开始实战吧！

1.第一步我们先把workerman里需要用到的扩展composer下来吧

"workerman/gateway-worker": "^3.0",
"workerman/gatewayclient": "^3.0",
"workerman/workerman": "^3.5",

2.第二步我们到官方网站把demo全部下载下来，然后放到我们项目中的目录

怎么在workerman中使用laravel开发一个在线聊天应用

图片中我就把整个项目都放在了HTTP/Controller/Workerman中。

3.第三步我们需要把把以下3个文件的引用部分修改为以下。不然会报路径错误

start_businessworker，start_gateway，start_register

require_once __DIR__ . &＃39;/../../../../../vendor/autoload.php&＃39;;

4.修改完成后我们就可以在liunx直接运行对应的启动文件

php start.php start -d

如果你是在window下就双击start_for_win.bat运行

5.运行成功后，你就应该可以看到以下的界面

怎么在workerman中使用laravel开发一个在线聊天应用

到此我们搭建基于workerman的通信环境就已经完成。接下来我们就可以根据自己的项目需求进行开发。在此向大家重点说明。我们所有的聊天是逻辑都在目录中的Events.php进行修改。

---------------------------------华丽分割线---------------------------------------------------

下面我给大家贴一下我编写的部分份代码。

Event.php


 * @copyright walkor
 * @link http://www.workerman.net/
 * @license http://www.opensource.org/licenses/mit-license.php MIT License
 */

/**
 * 用于检测业务代码死循环或者长时间阻塞等问题
 * 如果发现业务卡死，可以将下面declare打开（去掉//注释），并执行php start.php reload
 * 然后观察一段时间workerman.log看是否有process_timeout异常
 */
//declare(ticks=1);

/**
 * 聊天主逻辑
 * 主要是处理 onMessage onClose
 */
use \GatewayWorker\Lib\Gateway;

class Events
{
  /**
   * 作者:何志伟
   * 当客户端连接上来的时候
   * 创建时间：2018/10/25
   * @param $client_id 此ID为gatewayworker 自动生成ID
   */
  public static function onConnect($client_id)
  {
    Gateway::sendToClient($client_id, json_encode(array(
      &＃39;type&＃39;   => &＃39;init&＃39;,
      &＃39;client_id&＃39; => $client_id
    )));
  }


  /**
   * 有消息时
   * @param int $client_id
   * @param mixed $message
   */
  public static function onMessage($client_id, $message)
  {
    // debug
    echo "client:{$_SERVER[&＃39;REMOTE_ADDR&＃39;]}:{$_SERVER[&＃39;REMOTE_PORT&＃39;]} gateway:{$_SERVER[&＃39;GATEWAY_ADDR&＃39;]}:{$_SERVER[&＃39;GATEWAY_PORT&＃39;]} client_id:$client_id session:".json_encode($_SESSION)." onMessage:".$message."\n";

    // 客户端传递的是json数据
    $message_data = json_decode($message, true);
    if(!$message_data)
    {
      return ;
    }

    // 根据类型执行不同的业务
    switch($message_data[&＃39;type&＃39;])
    {
      // 客户端回应服务端的心跳
      case &＃39;pong&＃39;:
        return;
      // 客户端登录 message格式: {type:login, name:xx, room_id:1} ，添加到客户端，广播给所有客户端xx进入聊天室
      case &＃39;login&＃39;:
        // 判断是否有房间号
        if(!isset($message_data[&＃39;room_id&＃39;]))
        {
          throw new \Exception("\$message_data[&＃39;room_id&＃39;] not set. client_ip:{$_SERVER[&＃39;REMOTE_ADDR&＃39;]} \$message:$message");
        }

        // 把房间号昵称放到session中
        $room_id = $message_data[&＃39;room_id&＃39;];
        $client_name = htmlspecialchars($message_data[&＃39;client_name&＃39;]);
        $_SESSION[&＃39;room_id&＃39;] = $room_id;
        $_SESSION[&＃39;client_name&＃39;] = $client_name;


        // 获取房间内所有用户列表
        $clients_list = Gateway::getClientSessionsByGroup($room_id);
        foreach($clients_list as $tmp_client_id=>$item)
        {
          $clients_list[$tmp_client_id] = $item[&＃39;client_name&＃39;];
        }
//        $clients_list[$client_id] = $client_name;

        // 转播给当前房间的所有客户端，xx进入聊天室 message {type:login, client_id:xx, name:xx}
        $new_message = array(&＃39;type&＃39;=>$message_data[&＃39;type&＃39;], &＃39;client_id&＃39;=>$client_id, &＃39;client_name&＃39;=>htmlspecialchars($client_name), &＃39;time&＃39;=>date(&＃39;Y-m-d H:i:s&＃39;),&＃39;to&＃39;=>$message_data[&＃39;to&＃39;],&＃39;room_id&＃39;=>$message_data[&＃39;room_id&＃39;],
          &＃39;from&＃39;=>$message_data[&＃39;from&＃39;],&＃39;tag&＃39;=>$message_data[&＃39;tag&＃39;]);
        Gateway::sendToGroup($room_id, json_encode($new_message));
        Gateway::joinGroup($client_id, $room_id);

        // 给当前用户发送用户列表
        $new_message[&＃39;client_list&＃39;] = $clients_list;
        Gateway::sendToCurrentClient(json_encode($new_message));
        return;

      // 客户端发言 message: {type:say, to_client_id:xx, content:xx}
      case &＃39;say&＃39;:
        // 非法请求
        if(!isset($_SESSION[&＃39;room_id&＃39;]))
        {
          throw new \Exception("\$_SESSION[&＃39;room_id&＃39;] not set. client_ip:{$_SERVER[&＃39;REMOTE_ADDR&＃39;]}");
        }
        $room_id = $_SESSION[&＃39;room_id&＃39;];
        $client_name = $_SESSION[&＃39;client_name&＃39;];

        // 私聊
//        if($message_data[&＃39;to_client_id&＃39;] != &＃39;all&＃39;)
//        {
//          $new_message = array(
//            &＃39;type&＃39;=>&＃39;say&＃39;,
//            &＃39;from_client_id&＃39;=>$client_id,
//            &＃39;from_client_name&＃39; =>$client_name,
//            &＃39;to_client_id&＃39;=>$message_data[&＃39;to_client_id&＃39;],
//            &＃39;content&＃39;=>"对你说: ".nl2br(htmlspecialchars($message_data[&＃39;content&＃39;])),
//            &＃39;time&＃39;=>date(&＃39;Y-m-d H:i:s&＃39;),
//          );
//          Gateway::sendToClient($message_data[&＃39;to_client_id&＃39;], json_encode($new_message));
//          $new_message[&＃39;content&＃39;] = "你对".htmlspecialchars($message_data[&＃39;to_client_name&＃39;])."说: ".nl2br(htmlspecialchars($message_data[&＃39;content&＃39;]));
//          return Gateway::sendToCurrentClient(json_encode($new_message));
//        }

        $new_message = array(
          &＃39;type&＃39;=>&＃39;say&＃39;,
          &＃39;from_client_id&＃39;=>$client_id,
          &＃39;from_client_name&＃39; =>$client_name,
          &＃39;to_client_id&＃39;=>&＃39;all&＃39;,
          &＃39;content&＃39;=>nl2br(htmlspecialchars($message_data[&＃39;content&＃39;])),
          &＃39;time&＃39;=>date(&＃39;Y-m-d H:i:s&＃39;),

        );
        return Gateway::sendToGroup($room_id ,json_encode($new_message));
    }
  }
  /**
   * 当客户端断开连接时
   * @param integer $client_id 客户端id
   */
  public static function onClose($client_id)
  {
    // debug
    echo "client:{$_SERVER[&＃39;REMOTE_ADDR&＃39;]}:{$_SERVER[&＃39;REMOTE_PORT&＃39;]} gateway:{$_SERVER[&＃39;GATEWAY_ADDR&＃39;]}:{$_SERVER[&＃39;GATEWAY_PORT&＃39;]} client_id:$client_id onClose:&＃39;&＃39;\n";

    // 从房间的客户端列表中删除
    if(isset($_SESSION[&＃39;room_id&＃39;]))
    {
      $room_id = $_SESSION[&＃39;room_id&＃39;];
      $new_message = array(&＃39;type&＃39;=>&＃39;logout&＃39;, &＃39;from_client_id&＃39;=>$client_id, &＃39;from_client_name&＃39;=>$_SESSION[&＃39;client_name&＃39;], &＃39;time&＃39;=>date(&＃39;Y-m-d H:i:s&＃39;));
      Gateway::sendToGroup($room_id, json_encode($new_message));
    }
  }

}

客户端页面



  
  
  
  
  
  
  
  
  

  {{----}}





  
    {{--对话窗口头部--}}
    

      
        heading}}" width="80px" height="40px">
      

      
        {{$to->name}}
      
    
    {{--//对话窗口内容--}}            {{--对方的头像与文字--}}       {{----}}         {{----}}           {{--heading}}" width="50px" height="50px">--}}         {{--
--}}         {{--dsadsadsadsadsa--}}       {{----}}       {{--我的头像与文字--}}       {{----}}         {{----}}           {{--heading}}" width="50px" height="50px">--}}         {{----}}         {{--dsadsadsadsadsa--}}       {{----}}          {{--对话发送窗口--}}            id}}">       id}}">                                              发表                 房间号{{$room}}   

看完上述内容，你们掌握怎么在workerman中使用laravel开发一个在线聊天应用的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎关注编程笔记行业资讯频道，感谢各位的阅读！


推荐阅读
  • mqtt

    如何实现织梦DedeCms全站伪静态

    如何实现织梦DedeCms全站伪静态
    本文介绍了如何通过修改织梦DedeCms源代码来实现全站伪静态，以提高管理和SEO效果。全站伪静态可以避免重复URL的问题，同时通过使用mod_rewrite伪静态模块和.htaccess正则表达式，可以更好地适应搜索引擎的需求。文章还提到了一些相关的技术和工具，如Ubuntu、qt编程、tomcat端口、爬虫、php request根目录等。 ... [详细]
  • get

    搭建Windows Server 2012 R2 IIS8.5+PHP（FastCGI）+MySQL环境的详细步骤

    搭建Windows Server 2012 R2 IIS8.5+PHP（FastCGI）+MySQL环境的详细步骤
    本文详细介绍了搭建Windows Server 2012 R2 IIS8.5+PHP（FastCGI）+MySQL环境的步骤，包括环境说明、相关软件下载的地址以及所需的插件下载地址。 ... [详细]
  • java

    Java工具类库Hutool介绍及功能概述

    本文介绍了Java工具类库Hutool，该工具包封装了对文件、流、加密解密、转码、正则、线程、XML等JDK方法的封装，并提供了各种Util工具类。同时，还介绍了Hutool的组件，包括动态代理、布隆过滤、缓存、定时任务等功能。该工具包可以简化Java代码，提高开发效率。 ... [详细]
  • java

    Voicewo在线语音识别转换jQuery插件的特点和示例

    Voicewo在线语音识别转换jQuery插件的特点和示例
    本文介绍了一款名为Voicewo的在线语音识别转换jQuery插件，该插件具有快速、架构、风格、扩展和兼容等特点，适合在互联网应用中使用。同时还提供了一个快速示例供开发人员参考。 ... [详细]
  • java

    PHPMailer邮件类邮件发送功能的使用教学及注意事项

    PHPMailer邮件类邮件发送功能的使用教学及注意事项
    本文介绍了使用国外开源码PHPMailer邮件类实现邮件发送功能的简单教学，同时提供了一些注意事项。文章涵盖了字符集设置、发送HTML格式邮件、群发邮件以及避免类的重定义等方面的内容。此外，还提供了一些与PHP相关的资源和服务，如传奇手游游戏源码下载、vscode字体调整、数据恢复、Ubuntu实验环境搭建、北京爬虫市场、进阶PHP和SEO人员需注意的内容。 ... [详细]
  • dll

    如何在Windows环境下配置php+apache环境

    本文介绍了在Windows环境下如何配置php+apache环境，包括下载php7和apache2.4、安装vc2015运行时环境、启动php7和apache2.4等步骤。希望对需要搭建php7环境的读者有一定的参考价值。摘要长度为169字。 ... [详细]
  • java

    从零基础到精通的前台学习路线

    从零基础到精通的前台学习路线
    随着互联网的发展，前台开发工程师成为市场上非常抢手的人才。本文介绍了从零基础到精通前台开发的学习路线，包括学习HTML、CSS、JavaScript等基础知识和常用工具的使用。通过循序渐进的学习，可以掌握前台开发的基本技能，并有能力找到一份月薪8000以上的工作。 ... [详细]
  • dll

    Windows下配置PHP5.6的方法及注意事项

    Windows下配置PHP5.6的方法及注意事项
    本文介绍了在Windows系统下配置PHP5.6的步骤及注意事项，包括下载PHP5.6、解压并配置IIS、添加模块映射、测试等。同时提供了一些常见问题的解决方法，如下载缺失的msvcr110.dll文件等。通过本文的指导，读者可以轻松地在Windows系统下配置PHP5.6，并解决一些常见的配置问题。 ... [详细]
  • dll

    Metasploit攻击渗透实践

    Metasploit攻击渗透实践
    本文介绍了Metasploit攻击渗透实践的内容和要求，包括主动攻击、针对浏览器和客户端的攻击，以及成功应用辅助模块的实践过程。其中涉及使用Hydra在不知道密码的情况下攻击metsploit2靶机获取密码，以及攻击浏览器中的tomcat服务的具体步骤。同时还讲解了爆破密码的方法和设置攻击目标主机的相关参数。 ... [详细]
  • java

    Mac OS 升级到11.2.2 Eclipse打不开了，报错Failed to create the Java Virtual Machine

    Mac OS 升级到11.2.2 Eclipse打不开了，报错Failed to create the Java Virtual Machine
    本文介绍了在Mac OS升级到11.2.2版本后，使用Eclipse打开时出现报错Failed to create the Java Virtual Machine的问题，并提供了解决方法。 ... [详细]
  • java

    知识图谱——机器大脑中的知识库

    知识图谱——机器大脑中的知识库
    本文介绍了知识图谱在机器大脑中的应用，以及搜索引擎在知识图谱方面的发展。以谷歌知识图谱为例，说明了知识图谱的智能化特点。通过搜索引擎用户可以获取更加智能化的答案，如搜索关键词"Marie Curie"，会得到居里夫人的详细信息以及与之相关的历史人物。知识图谱的出现引起了搜索引擎行业的变革，不仅美国的微软必应，中国的百度、搜狗等搜索引擎公司也纷纷推出了自己的知识图谱。 ... [详细]
  • list

    Perl的测试框架Test::Base简介及使用方法

    本文介绍了Perl的测试框架Test::Base，它是一个数据驱动的测试框架，可以自动进行单元测试，省去手工编写测试程序的麻烦。与Test::More完全兼容，使用方法简单。以plural函数为例，展示了Test::Base的使用方法。 ... [详细]
  • list

    Android系统移植与调试之如何修改Android设备状态条上音量加减键在横竖屏切换的时候的显示于隐藏

    Android系统移植与调试之如何修改Android设备状态条上音量加减键在横竖屏切换的时候的显示于隐藏
    本文介绍了如何修改Android设备状态条上音量加减键在横竖屏切换时的显示与隐藏。通过修改系统文件system_bar.xml实现了该功能，并分享了解决思路和经验。 ... [详细]
  • list

    HTML学习02 图像标签的使用和属性

    HTML学习02 图像标签的使用和属性
    本文介绍了HTML中图像标签的使用和属性，包括定义图像、定义图像地图、使用源属性和替换文本属性。同时提供了相关实例和注意事项，帮助读者更好地理解和应用图像标签。 ... [详细]
  • list

    开发笔记中的gulp技巧总结及使用方法

    本文总结了在开发中使用gulp时的一些技巧，包括如何使用gulp.dest自动创建目录、如何使用gulp.src复制具名路径的文件以及保留文件夹路径的方法等。同时介绍了使用base选项和通配符来保留文件夹路径的技巧，并提到了解决带文件夹的复制问题的方法，即使用gulp-flatten插件。 ... [详细]
author-avatar
gu油漆装修
这个家伙很懒，什么也没留下！
Tags | 热门标签
RankList | 热门文章
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有