server接收dtu透传代码_Swoole学习笔记三：初探server与client（Client异步）

<?php
//创建Server对象，监听 127.0.0.1:9501端口
$serv = new swoole_server("127.0.0.1", 9501); 
//监听连接进入事件
$serv->on('connect', function ($serv, $fd) {  
    echo "Client: 客户端握手成功.n";
});
//监听数据接收事件
$serv->on('receive', function ($serv, $fd, $from_id, $data) {
    echo 'Client：接收到客户端发送过来的数据包：'.$data."n";
    // 这里使用send，反推回去
    $serv->send($fd, "Server: ".$data);
});
//监听连接关闭事件
$serv->on('close', function ($serv, $fd) {
    echo "Client: 客户端主动断开连接.n";
});
//启动服务器
$serv->start();

<?php
//打开异步socket
$client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);
//注册连接成功回调
$client->on("connect", function($cli) {
    // 向服务器发送数据
    $cli->send("小黄牛真他妈帅！");
    // 3秒后执行
    swoole_timer_after(3000, function() use($cli) {
        // 主动关闭连接
        $cli->close();
    });
});
//注册数据接收回调
$client->on("receive", function($cli, $data){
    echo "接收到回调数据: ".$data."n";
});
//注册连接失败回调
$client->on("error", function($cli){
    echo "服务端连接失败n";
});
//注册连接关闭回调
$client->on("close", function($cli){
    echo "与服务端关闭了连接n";
});
//发起连接
$client->connect('127.0.0.1', 9501, 0.5);