微服务Swoole（1）- 初识swoole，安装swoole

客官°小女子只卖身不卖艺 2022-02-02 05:27 465阅读 0赞

现在微服务Saas比较热门。那么微服务必然会选择Swoole。小编从零开始研究Swoole。

# 安装swoole #

以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不熟悉的同学，自己可以从网上找点资料看下、

接下来使用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.\n";
    });
    
    // 监听数据接收事件
    $serv->on('receive', function ($serv, $fd, $from_id, $data) {
        $serv->send($fd, "Server: " . $data);
    });
    
    // 监听连接关闭事件
    $serv->on('close', function ($serv, $fd) {
        echo "Client: Close.\n";
    });
    
    // 启动服务器
    $serv->start();

服务端启动：swoft

☁  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/

![Image 1][]

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}\n";
        }
    
    
        /**
         * 监听消息事件
         * @param $ws
         * @param $frame
         */
        public function onMessage($ws, $frame)
        {
            echo "客户端发送的数据: {$frame->data}\n";
            $pushData = date("Y-m-d H:i:s");
            $ws->push($frame->fd, "服务端推送的数据: {$pushData}");
        }
    
        /**
         * 监听关闭事件
         * @param $ws
         * @param $fd
         */
        public function onClose($ws, $fd)
        {
            echo "客户端：{$fd} 关闭了连接\n";
        }
    }
    
    $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服务：

![Image 1][]

ws server

浏览器打开`ws_client.html`文件:

![Image 1][]

ws client

> 如果觉得本文对你有所帮助，请给个赞，

[swoole-ide-helper]: https://github.com/eaglewu/swoole-ide-helper
[Image 1]: