使用swoole进行消息推送通知，配合vb.net进行客户端开发一样爽[开发篇]

　　在以前的项目中，就曾听说过swoole的大名，想用来进行消息推送，但是当时只是有了初步的了解，并不敢大胆的运用到线上产品。所谓识不足则多虑，威不足则多怒、所以就是怕，只能跟领导说了运用极光的推送功能，而且还说出了一定的理由，领导自然也只有相信了，那就用极光推送吧！

　　最近闲来无事，又重新温习了一下swoole的消息通知功能，虽然在项目开发当时，也曾实现过简单的操作的，但是这次温习更加深了学习，配合vb.net进行开发，感觉还是棒棒哒，下面是一套实现过程，如有需要参考，请拿去，不谢！

　　首先，我的开发平台是windows，虽然本人也装有virtual box虚拟机，但是那玩意儿太耗内存cpu了，开起来搞实在不想搞。所以，就用了cygwin进行配置开发环境搭建，这里我就不说具体安装步骤了，给个链接吧，一步步按着操作就行了。查看php在window下安装swoole扩展的方法请点击。 ps: 如果你win系统里已经安装了一套wamp环境，在cygwin中使用php或其他和win有相同名称命令时，请记得使用全路径如：/bin/php index.php , /bin/find / -name "init*"

　　第二步、编写php服务端程序,命名 test_tcp_server.php , 代码如下：

<?php

    $serv = new swoole_server("127.0.0.1", 9501);

    $serv->set(array(

        'worker_num' => 2,       //工作进程数量

        // 'daemonize' => true, //是否作为守护进程,玩玩就不要开启这东西了，不然你都不知道跑到哪里去了

    ));

    $serv->on('connect', 'my_onConnect');

    $serv->on('receive', 'my_onReceive');

    $serv->on('close', 'my_onClose');

    echo "swoole_server is running on 127.0.0.1 9501 \n";

    $serv->start();

    //receive msg respond

    function my_onReceive ($serv, $fd, $from_id, $data) {

        // var_dump($serv);

        $data = trim($data);

        // 发送给谁, 如:@id msg...  , 最好的当然是使用redis或者数据库存入号码并生成一个映射了，不过玩玩就不要认真了

        if(substr($data, 0, 1) == '@'){

            $splitStart = strpos($data, ' ');

            $toUserId = substr($data, 1, $splitStart - 1);

            echo 'Send to:' . $toUserId . ';';

            $content = substr($data, $splitStart + 1);

            if(is_numeric($toUserId)){

                $serv->send($toUserId, "From Client[$fd@$from_id]:" . $content);

            }elseif(strtolower($toUserId) == 'all'){

                broadcast($serv, $fd, $content);

            }else{

                $serv->send($fd, 'Swoole: Unkown to user ' . strtolower($toUserId) . ' infomation.');

            }

        }else{

            echo "From Client[$fd@$from_id],received data: " . $data . PHP_EOL;

            $serv->send($fd, 'Swoole: '.$data);

        }

        // $serv->close($fd);

    }

    //connect action

    function my_onConnect ($serv, $fd){

        echo "Client:Connect. id:{$fd}\n";

    }

    //close action

    function my_onClose ($serv, $fd) {

        echo "Client: Close. id:{$fd}\n";

    }

    //broadcast except me, 只会广播from_id相同的用户,再研究了

    function broadcast(swoole_server $serv, $fd = 0, $data = "hello")

    {

        $start_fd = 0;

        $sendNum = 0;

        echo "broadcast to ";

        $from = "From Client[$fd]:";

        while(true)

        {

            $conn_list = $serv->connection_list($start_fd, 10);

            if($conn_list === false)

            {

                break;

            }

            var_dump($conn_list);

            $start_fd = end($conn_list);

            foreach($conn_list as $conn)

            {

                if($conn === $fd) continue;

                $ret1 = $serv->send($conn, $from . $data);

                $sendNum ++;

            }

        }

        echo $sendNum . ' numbers.';

    }

　　记得把它跑起来哦

/bin/php test_tcp_server.php

　　第三步，你可以编写一个客户端程序，也可以不用编写，因为其他工具也完全可以连接进行的呢！如果要定，可以参考swoole官网的tcp_client代码，如下：

<?php

    $client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);

    //设置事件回调函数

    $client->on("connect", function($cli) {

        $cli->send("hello world\n");

    });

    $client->on("receive", function($cli, $data){

        echo "Received: ".$data."\n";

    });

    $client->on("error", function($cli){

        echo "Connect failed\n";

    });

    $client->on("close", function($cli){

        echo "Connection close\n";

    });

    //发起网络连接

    $client->connect('127.0.0.1', 9501, 0.5);

　　正常的话，运行这个脚本，你就可以收到消息了如： 'From Client[1@0],received data: hello,world'

　　第四步、你肯定不满足于使用php语言去连接服务器端，你当然不应该满足！你还可以使用windows的cmd命令行嘛，如下：

telnet 127.0.0.1