加载中...

Workerman


Workerman

Workerman是一款纯PHP开发的开源高性能的PHP socket 服务器框架。被广泛的用于手机app、手游服务端、网络游戏服务器、聊天室服务器、硬件通讯服务器、智能家居、车联网、物联网等领域的开发。 支持TCP长连接,支持Websocket、HTTP等协议,支持自定义协议。基于workerman开发者可以更专注于业务逻辑开发,不必再为PHP Socket底层开发而烦恼。

首先通过 composer 安装

  1. composer require topthink/think-worker

如果需要在window下做服务端,还需要

  1. composer require workerman/workerman-for-win

服务端使用示例如下:

新增启动服务文件server.php,在项目根目录

  1. #!/usr/bin/env php
  2. <?php
  3. define('APP_PATH', __DIR__ . '/application/');
  4. define('BIND_MODULE','push/Worker');
  5. // 加载框架引导文件
  6. require __DIR__ . '/thinkphp/start.php';

新增服务处理类,push.app是我本地测试域名

  1. <?php
  2. namespace app\push\controller;
  3. use think\worker\Server;
  4. class Worker extends Server
  5. {
  6. protected $socket = 'websocket://push.app:2346';
  7. /**
  8. * 收到信息
  9. * @param $connection
  10. * @param $data
  11. */
  12. public function onMessage($connection, $data)
  13. {
  14. $connection->send('我收到你的信息了');
  15. }
  16. /**
  17. * 当连接建立时触发的回调函数
  18. * @param $connection
  19. */
  20. public function onConnect($connection)
  21. {
  22. }
  23. /**
  24. * 当连接断开时触发的回调函数
  25. * @param $connection
  26. */
  27. public function onClose($connection)
  28. {
  29. }
  30. /**
  31. * 当客户端的连接上发生错误时触发
  32. * @param $connection
  33. * @param $code
  34. * @param $msg
  35. */
  36. public function onError($connection, $code, $msg)
  37. {
  38. echo "error $code $msg\n";
  39. }
  40. /**
  41. * 每个进程启动
  42. * @param $worker
  43. */
  44. public function onWorkerStart($worker)
  45. {
  46. }
  47. }

在命令行下运行,启动监听服务

  1. php server.php

打开chrome浏览器,先打开push.app域名下的网页(js跨域不能通讯),按F12打开调试控制台,在Console一栏输入(或者把下面代码放入到html页面用js运行)

  1. ws = new WebSocket("ws://push.app:2346");
  2. ws.onopen = function() {
  3. alert("连接成功");
  4. ws.send('tom');
  5. alert("给服务端发送一个字符串:tom");
  6. };
  7. ws.onmessage = function(e) {
  8. alert("收到服务端的消息:" + e.data);
  9. };

继续测试

  1. ws.send('保持连接,发第二次信息,查看服务器回应');

第 1-1 条, 共 1 条.
王梦蛟-外汇通 2017-12-04 17:38:11
学习回复