README

surf 是一个对Swoole扩展库的封装，它可以像传统MVC一样编写 Http,Tcp 应用.

Installation

使用Composer来安装框架.

$ composer require meshell/surf "^1.0.5"

Usage

一个简单的http应用，创建一个配置文件config.php.

# config.php

return [
    'host' => '0.0.0.0',
    'port' => 9527,
    'setting' => [
        'reactor_num' => 8,
        'worker_num' => 10,
    ]
];

创建一个http.php文件.

require __DIR__ . '/vendor/autoload.php';

$app = new \Surf\Application(__DIR__, [
    'app.config' => __DIR__ . '/config.php'
]);

$app->addGet('/', function() {
    return "Hello world";    
});
$app->register(new \Surf\Provider\PoolServiceProvider());
$app->run();

启动服务.

$ php http.php

浏览器打开http://127.0.0.1:9527/ 显示 "Hello world", 你也可以使用curl.

$ curl http://127.0.0.1:9527/

查看事例http

一个简单的tcp应用, 配置文件还是使用上面的config.php, 创建一个tcp.php. tcp需要设置protocol解析类. 一般tcp服务端和客户端使需要约定消息格式才能解析出正确的数据. 在surf中我们使用的默认解析格式是包头，包长，包体(unpack(A64header/Nlen/A*data))作为消息格式。调用每条协议我们是定义在包头中.

include __DIR__ . '/vendor/autoload.php';

$config = include __DIR__ . '/config.php';

$config['server'] = 'tcp';
$config['protocol'] = \Surf\Server\Tcp\Protocol\JsonProtocol::class;

$app = new \Surf\Application(__DIR__, [
    'app.config' => $config
]);
$app->addProtocol('user.name', Examples\TestTcpController::class . ':name');
$app->run();

编写客户端程序client.php.

$client = new Swoole\Client(SWOOLE_SOCK_TCP);

if (!$client->connect('127.0.0.1', 9527, -1)) {
    exit("connection failed");
}

$message = json_encode([
    'name' => 'meShell',
    'age'  => 18,
    'job' => 'engineer'
]);
$hex = pack('A64NA*', "name=user.name;format=json", strlen($message), $message);

$client->send($hex);

echo $client->recv();

$client->close();

启动服务

$ php tcp.php

连接服务

$ php client.php

打印服务返回内容: "my name is meShell, my age is 18, My job is an engineer";

查看事例tcp

Connection pool

在surf中使用连接池功能.

#config.php
return [
    ...
    'database' => [
        'default' => [
            'driver' => 'mysql',
            'host'   => 'localhost',
            'database' => 'test',
            'username' => 'root',
            'password' => "123456",
            'options'  => [],
        ],
    ],
    'cache' => [
        'default' => [
            'driver' => 'redis',
            'host'   => '127.0.0.1',
            'port'   => 6379,
            // 'prefix' => 'SURF:'
            // 'auth' => 'password'
        ],
    ],
    'pool' => [
        'interval' => 100, //心跳检测时间，以毫秒为单位
        'database' => [
            'default' => [
                'start_number' => 10 //默认开启
            ],
        ],
        'cache' => [
            'default' => [
                'start_number' => 10 //默认开启
            ],
        ],
    ],
];

在启动文件里注册provider.

$app->register(new \Surf\Provider\PoolServiceProvider());

在Controller中获取连接池中的对象.

/**
* @var $pool PoolManager
*/
$pool = $this->container->get('pool'); //获取连接池管理对象
/**
* @var $pdo \Surf\Pool\Connection 获取一个数据库对象
*/
$pdo  = $pool->pop('database.default'); //从database.default池子中获取当前对象

/**
* 获取一个缓存对象 需要注册 
* $app->register(new \Surf\Provider\CacheServiceProvider());
*/
$redis = $pool->pop('cache.default'); //从cache.default池子中获取当前对象

查看事例pool

Usage Session and Cookie

session 和 cookie 在web开发中是经常需要使用的保存一些登录信息, 登录状态等等.

在匿名函数中使用. 在回调函数时候框架会自动将路由变量, request, cookies 这几个参数填充到函数.

use Surf\Server\Http\Cookie\CookieAttributes;

$app->addGet('/', function($routeVars, Request $request, Cookies $cookies) {

    $session = $request->session; //获取session 对象
    $session->set('userInfo', ['id' => 1]);
    //使用cookie, 传入一个CookieAttributes对象
    $cookies->set(CookieAttributes::create('name', 'value', 0));
});

在HttpController中使用.

use Surf\Server\Http\Cookie\CookieAttributes;

$app->addGet('/', 'SessionController:index');


...

class SessionController extends HttpController
{
    ...

    public function index($routeVars)
    {
        $session = $this->request->session; // or $this->session; 获取session 对象
        $session->set('userInfo', ['id' => 1]);
        //使用cookie       
        $this->cookies->set(CookieAttributes::create('name', 'value', 0));
    }
}

查看事例session

任务

在控制器中使用$this->task(), 这个是异步, 想使用同步可以$this->syncTask().

    ...
    public function taskTest()
    {
        $taskId = $this->task('push all message worker' . $this->workerId, PushTaskHandle::class);
        //$status = $this->syncTask('sync push all message', PushTaskHandle::class);
        //var_dump($status);
        return "task push id:" . $taskId . ", workId:" . $this->workerId;
    }

查看事例task

全局定时器

在有些业务中我们可能会有这样的需求，比如每隔两小时需要读取下订单数.但你也可以用crontab实现. 相同时间的定时器会被最后一次添加的定时器覆盖,定时器时间单位为毫秒.

...

$app->addTicker(100, \Surf\Examples\HeartbeatTicker::class);

try {
    $app->run();
} catch (\Surf\Exception\ServerNotFoundException $e) {

}

查看事例ticker

License

LICENSE