zoukankan      html  css  js  c++  java
  • swoole实战1-初识swoole

    原文地址:https://www.jianshu.com/p/008d5702d01f

    安装swoole

    以mac操作系统为例,如果你是mac新手,推荐阅读 程序员如何优雅使用mac

    环境要求:php版本大于7.0

    ☁  swoole  php -v
    PHP 7.1.19 (cli) (built: Jun 25 2018 10:42:21) ( NTS )
    Copyright (c) 1997-2018 The PHP Group
    Zend Engine v3.1.0, Copyright (c) 1998-2018 Zend Technologies
        with Zend OPcache v7.1.19, Copyright (c) 1999-2018, by Zend Technologies
    

    使用pecl安装swoole,安装过程中,会提示你是否需要安装某些扩展,可自主选择yes或no,如果是选择安装redis扩展,本机需要安装redis环境

    pecl install swoole
    

    选择redis扩展需要先安装相应的库

    brew install redis
    brew install hiredis
    

    ide自动提示

    默认情况下,phpstorm并不会自动提示swoole扩展包的相关函数,需要借助 swoole-ide-helper 实现自动提示

    安装方法:

    在项目的根目录执行:

    composer require --dev "eaglewu/swoole-ide-helper:dev-master"
    

    对于compoesr不熟悉的同学,请参阅这一次,真正掌握composer

    接下来使用swoole搭建tcp,udp, http, websocket 服务,体验swoole的基本使用

    tcp 服务

    新建server.php

    <?php
    // 创建Server对象,监听 127.0.0.1:9501 端口
    $serv = new swoole_server("127.0.0.01", 9501);
    
    // 监听连接进入事件
    $serv->on('connect', function ($serv, $fd) {
        echo "Client: Connect.
    ";
    });
    
    // 监听数据接收事件
    $serv->on('receive', function ($serv, $fd, $from_id, $data) {
        $serv->send($fd, "Server: " . $data);
    });
    
    // 监听连接关闭事件
    $serv->on('close', function ($serv, $fd) {
        echo "Client: Close.
    ";
    });
    
    // 启动服务器
    $serv->start();
    

    服务端启动:

    ☁  server [master] ⚡ php server.php
    [2018-04-26 09:08:59 @96245.0]  TRACE   Create swoole_server host=127.0.0.01, port=9501, mode=3, type=1
    

    telnet 测试连接

    ☁  ~  telnet 127.0.0.1 9501
    Trying 127.0.0.1...
    Connected to localhost.
    Escape character is '^]'.
    hello
    Server: hello
    

    退出telnet的方式:ctrl+], 然后再按 ctrl+d

    udp 服务

    新建udp_server.php

    <?php
    // 创建UDP Server对象
    $serv = new swoole_server('127.0.0.1', 9502, SWOOLE_PROCESS, SWOOLE_SOCK_UDP);
    
    // 监听数据接收事件
    $serv->on('Packet', function ($serv, $data, $clientInfo) {
        $serv->sendto($clientInfo['address'], $clientInfo['port'], 'Server ' . $data);
        var_dump($clientInfo);
    });
    
    // 启动服务器
    $serv->start();
    
    ☁  server [master] ⚡ php udp_server.php
    [2018-04-26 09:18:10 @97828.0]  TRACE   Create swoole_server host=127.0.0.1, port=9502, mode=3, type=2
    
    ☁  ~  netcat -u 127.0.0.1 9502
    hello
    Server hello
    

    http 服务

    <?php
    $http = new swoole_http_server('0.0.0.0', 9502);
    
    $http->on('request', function ($request, $response) {
    $response->header("Content-Type", "text/html; charset=utf-8");
    $time = date('Y-m-d H:i:s', time());
    $response->end("<h1>{$time}--这是swoole提供的http服务,修改代码后要重启服务才能生效</h1>");
    });
    
    $http->start();
    
    ☁  http  php http_server.php
    [2018-07-27 09:25:05 @53999.0]  TRACE   Create swoole_server host=0.0.0.0, port=9502, mode=3, type=1
    

    浏览器访问:http://127.0.0.1:9502/

     
    swoole-http

    websocket 服务

    ws 服务端

    新建server.php文件

    <?php
    class Ws {
        CONST HOST = "0.0.0.0";
        CONST PORT = 8812;
    
        public $ws = null;
    
        public function __construct()
        {
            $this->ws = new swoole_websocket_server(self::HOST, self::PORT);
            $this->ws->set(
                [
                    'worker_num' => 2,
                ]
            );
    
            $this->ws->on('open', [$this, 'onOpen']);
            $this->ws->on('message', [$this, 'onMessage']);
            $this->ws->on('close', [$this, 'onClose']);
    
            $this->ws->start();
        }
    
    
        /**
         * 监听连接事件
         * @param $ws
         * @param $request
         */
        public function onOpen($ws, $request)
        {
            echo "建立连接,客户端id:{$request->fd}
    ";
        }
    
    
        /**
         * 监听消息事件
         * @param $ws
         * @param $frame
         */
        public function onMessage($ws, $frame)
        {
            echo "客户端发送的数据: {$frame->data}
    ";
            $pushData = date("Y-m-d H:i:s");
            $ws->push($frame->fd, "服务端推送的数据: {$pushData}");
        }
    
        /**
         * 监听关闭事件
         * @param $ws
         * @param $fd
         */
        public function onClose($ws, $fd)
        {
            echo "客户端:{$fd} 关闭了连接
    ";
        }
    }
    
    $ws = new Ws();
    

    ws 客户端

    新建client.html

    <!doctype html>
    <html lang="en">
    <head>
        <meta charset="UTF-8">
        <meta name="viewport"
              content="width=device-width, user-scalable=no, initial-scale=1.0, maximum-scale=1.0, minimum-scale=1.0">
        <meta http-equiv="X-UA-Compatible" content="ie=edge">
        <title>websocket client</title>
    </head>
    <body>
        <h1>swoole-websocket测试</h1>
        <script>
            var wsUrl = "ws://127.0.0.1:8812";
            var websocket = new WebSocket(wsUrl);
    
            websocket.onopen = function(evt) {
                websocket.send("我是客户端,我要连接服务端");
                console.log('连接成功');
            }
    
            websocket.onmessage = function(evt) {
                console.log("接收到的服务端信息: " + evt.data);
            }
    
            websocket.onclose = function(evt) {
                console.log("服务端关闭了");
            }
    
            websocket.onerror = function(evt, e) {
                console.log("出错了: " + evt.data);
            }
        </script>
    
    </body>
    </html>
    

    结果显示

    开启ws服务:

     
    ws server

    浏览器打开ws_client.html文件:

     
    ws client

    如果觉得本文对你有所帮助,点个赞,或者赏杯咖啡钱,你的认可对我很重要



    作者:塞亚猫
    链接:https://www.jianshu.com/p/008d5702d01f
    来源:简书
    简书著作权归作者所有,任何形式的转载都请联系作者获得授权并注明出处。
  • 相关阅读:
    jar包的MANIFEST.MF文件
    Spring AOP无法拦截Controller中的方法
    强制更新 Maven缓存库
    【转】深入理解Java:注解(Annotation)--注解处理器
    Java-Method类常用方法详解
    MySQL下查看用户和建立用户
    【转】从零开始玩转logback
    【转】Java日志框架:logback详解
    【转】配置不当引起高危漏洞?看加密货币交易所如何正确用Spring Boot Actuaotr框架
    Spring MVC Junit4 单元測试 JunitTest
  • 原文地址:https://www.cnblogs.com/phpk/p/10930493.html
Copyright © 2011-2022 走看看