WorkerMan Connection类的使用(附代码)

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

WorkerMan Connection类的使用(附代码)

一、TcpConnection类 的使用

 1、简单的TCP测试

Server.php

<?php require_once __DIR__.&#39;/Workerman/Autoloader.php&#39;; use WorkermanWorker; $worker = new Worker(&#39;websocket://0.0.0.0:80&#39;);// 连接回调 $worker->onConnect = function ($connection){      echo "connection successn"; }; // 接受发送消息 $worker-&gt;onMessage = function ($conn,$data){     $conn-&gt;send("Hello World"); }; // 关闭连接 $worker-&gt;onClose = function ($connection){     echo "connection close n"; }; $worker::runAll();

测试结果:

WorkerMan Connection类的使用(附代码)

服务端输出:

WorkerMan Connection类的使用(附代码)

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

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>http://wiki.workerman.net/Error1</a> for detail.Connection closed by foreign host.

2、黑白名单的访问

Server.php

<?php require_once __DIR__.&#39;/Workerman/Autoloader.php&#39;; use WorkermanWorker; $worker = new Worker(&#39;tcp://0.0.0.0:8085&#39;); // 连接回调 $worker->onConnect = function ($connection){     // IP 白名单验证     if($connection-&gt;getRemoteIP() != '127.0.0.1'){         $connection-&gt;close("IP Address Forbidden");     } }; // 接受发送消息 $worker-&gt;onMessage = function ($conn,$data){     $conn-&gt;send("Hello World"); }; // 关闭连接 $worker-&gt;onClose = function ($connection){     echo "connection close n"; }; $worker::runAll();

开启Workerman服务

WorkerMan Connection类的使用(附代码)

正确的访问:

WorkerMan Connection类的使用(附代码)

WorkerMan Connection类的使用(附代码)

非本地地址访问:

WorkerMan Connection类的使用(附代码)

 二、AsyncTcpConnection类 的使用

Server.php

<?php require_once __DIR__.&#39;/Workerman/Autoloader.php&#39;; use WorkermanWorker; $worker = new Worker(&#39;websocket://0.0.0.0:443&#39;); // Workerman 启动的回调,这里传递的是Worker对象 $worker->onWorkerStart = function ($worker){     echo "onWorkerStart success"; }; // 连接回调 $worker-&gt;onConnect = function ($connection){     $connection_baidu = new WorkermanConnectionAsyncTcpConnection('tcp://www.baidu.com:443');     // 百度的数据发送给浏览器。返回数据后,使用的数据要use 进来,     $connection_baidu-&gt;onMessage = function ($connection_baidu,$data) use ($connection){         $connection-&gt;send($data);     };     // 浏览器接受的数据发送给百度     $connection-&gt;onMessage = function ($connection,$data) use ($connection_baidu){         $connection_baidu-&gt;send($data);     };     $connection_baidu-&gt;connect(); }; // 接受发送消息 $worker-&gt;onMessage = function ($conn,$data){     $conn-&gt;send("Hello World"); }; // 关闭连接 $worker-&gt;onClose = function ($connection){     echo "connection close n"; };  //Workerman 停止回调 $worker-&gt;onWorkerStop = function ($worker){     echo "onWorkerStop success"; }; $worker::runAll();

更多WorkerMan相关文章请关注workerman教程栏目。

© 版权声明
THE END
喜欢就支持一下吧
点赞11 分享