您的位置 首页 技术

WorkerMan Connection类的使用(附代码)

下面由workerman教程栏目给大家介绍WorkerMan Connection类的使用,希望对需要的朋友有所帮助! 一、TcpConnection类 的使用 1、简单的TCP测…

下面由workerman教程栏目给大家介绍WorkerMan Connection类的使用,希望对需要的朋友有所帮助!

一、TcpConnection类 的使用

1、简单的TCP测试

Server.php

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

测试结果:

1.jpg

服务端输出:

2.jpg

以下错误表示,里面的连接协议没有修改掉原因。

www@iZ23s8agtagZ:~$ telnet 127.0.0.1 8085Trying 127.0.0.1...Connected to 127.0.0.1.Escape character is '^]'.^[[A^[[AHTTP/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

<?phprequire_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服务

3.jpg

正确的访问:

4.jpg

5.jpg

非本地地址访问:

6.JPG

二、AsyncTcpConnection类 的使用

Server.php

<?phprequire_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类的使用(附代码)的详细内容,更多请关注24课堂在线网其它相关文章!

本文来自网络,不代表24小时课堂在线立场,转载请注明出处:https://www.24ketang.cn/12871.html

为您推荐

返回顶部