WorkerMan Connection类的使用(附代码)
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了WorkerMan Connection类的使用(附代码),小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含2665字,纯文字阅读大概需要4分钟。
内容图文
![WorkerMan Connection类的使用(附代码)](/upload/InfoBanner/zyjiaocheng/277/831cc7d0cc9b4ebaa6669358c994ce6a.jpg)
![WorkerMan Connection类的使用(附代码) - 文章图片](/upload/getfiles/0001/2021/4/22/20210422033556619.jpg)
一、TcpConnection类 的使用
1、简单的TCP测试
Server.php
<?php require_once __DIR__.'/Workerman/Autoloader.php'; use Workerman\Worker; $worker = new Worker('websocket://0.0.0.0:80');// 连接回调 $worker->onConnect = function ($connection){ echo "connection success\n"; }; // 接受发送消息 $worker->onMessage = function ($conn,$data){ $conn->send("Hello World"); }; // 关闭连接 $worker->onClose = function ($connection){ echo "connection close \n"; }; $worker::runAll();
测试结果:
服务端输出:
以下错误表示,里面的连接协议没有修改掉原因。
www@iZ23s8agtagZ:~$ telnet 127.0.0.1 8085 Trying 127.0.0.1... Connected to 127.0.0.1. Escape character is '^]'. ^[[A^[[A HTTP/1.1 400 Bad Request <b>400 Bad Request</b><br>Invalid handshake data for websocket. <br> See <a href="http://wiki.workerman.net/Error1">http://wiki.workerman.net/Error1</a> for detail.Connection closed by foreign host.
2、黑白名单的访问
Server.php
<?php require_once __DIR__.'/Workerman/Autoloader.php'; use Workerman\Worker; $worker = new Worker('tcp://0.0.0.0:8085'); // 连接回调 $worker->onConnect = function ($connection){ // IP 白名单验证 if($connection->getRemoteIP() != '127.0.0.1'){ $connection->close("IP Address Forbidden"); } }; // 接受发送消息 $worker->onMessage = function ($conn,$data){ $conn->send("Hello World"); }; // 关闭连接 $worker->onClose = function ($connection){ echo "connection close \n"; }; $worker::runAll();
开启Workerman服务
正确的访问:
非本地地址访问:
二、AsyncTcpConnection类 的使用
Server.php
<?php require_once __DIR__.'/Workerman/Autoloader.php'; use Workerman\Worker; $worker = new Worker('websocket://0.0.0.0:443'); // Workerman 启动的回调,这里传递的是Worker对象 $worker->onWorkerStart = function ($worker){ echo "onWorkerStart success"; }; // 连接回调 $worker->onConnect = function ($connection){ $connection_baidu = new \Workerman\Connection\AsyncTcpConnection('tcp://www.baidu.com:443'); // 百度的数据发送给浏览器。返回数据后,使用的数据要use 进来, $connection_baidu->onMessage = function ($connection_baidu,$data) use ($connection){ $connection->send($data); }; // 浏览器接受的数据发送给百度 $connection->onMessage = function ($connection,$data) use ($connection_baidu){ $connection_baidu->send($data); }; $connection_baidu->connect(); }; // 接受发送消息 $worker->onMessage = function ($conn,$data){ $conn->send("Hello World"); }; // 关闭连接 $worker->onClose = function ($connection){ echo "connection close \n"; }; //Workerman 停止回调 $worker->onWorkerStop = function ($worker){ echo "onWorkerStop success"; }; $worker::runAll();
更多WorkerMan相关文章请关注WorkerMan教程栏目。
以上就是WorkerMan Connection类的使用(附代码)的详细内容。
内容总结
以上是互联网集市为您收集整理的WorkerMan Connection类的使用(附代码)全部内容,希望文章能够帮你解决WorkerMan Connection类的使用(附代码)所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。