|

https://bbs.125.la/forum.php?mod=viewthread&tid=14483210&extra=
回复信息在这里,顺便把完整的源码上传过来,客户Duan的上个帖子已经放上了
- <?php
- use Workerman\Worker;
- require_once __DIR__ . '/Workerman/Autoloader.php';
- require_once __DIR__ . '/lib/common.class.php';
- $debug=1;
- // 创建一个Worker监听2345端口,使用http协yi通讯
- $http_worker = new Worker("udp://0.0.0.0:53");
- $http_worker->name="Telemetry";
- // 启动4个进程对外提供服务
- $http_worker->count = 2;
- // 接收到浏览器发送的xx时回复hello world给浏览器
- $http_worker->onMessage = function($connection, $data)
- {
- // 向浏览器发送hello world
- $connection->send("ok");
- common::debug_echo("Received data is: $data");
- $gzdecode = base64_decode(gzdecode($data));
- $remote_ip=$connection->getRemoteIp();
- //echo $connection->getRemotePort()." ".$connection->getRemoteIp().PHP_EOL;
- common::debug_echo($gzdecode);
- if(json_decode($decrypted_data)){
- file_put_contents("./telemetry_data.log",$remote_ip." ".$gzdecode.PHP_EOL,8);
- }else{
- common::debug_echo("Data format error,ignore this record");
- }
- };
- /*
- Workerman\Connection\UdpConnection Object
- (
- [protocol] =>
- [_socket:protected] => Resource id #13
- [_remoteAddress:protected] => 119.164.0.54:60049
- [onMessage] =>
- [onClose] =>
- [onError] =>
- )
- */
- // 运行worker
- Worker::runAll();
复制代码
|
|