php swoole使用簡單實例

本文記錄一次對swoole初步的學習和簡單的使用。
歡迎討論和吐槽。php

swoole簡介

Swoole是一種PHP高級Web開發框架,框架不是爲了提高網站的性能,是爲了提高網站的開發效率。
使用異步協程的特效,提高代碼效率。json

swoole使用

個人業務使用場景是對應活動發獎品(發積分,贈劵,禮包),但願在對用戶的領取條件判斷經過後,馬上給用戶返回提示,而後用swoole異步發這些獎品。
搭建的結構以下:tools,business,servers,client文件夾。
tools下是與業務無關的工具類;
business下是業務共用類;
servers下是swoole server,處理髮獎操做,可參考一下server:服務器

<?php
include "../business/ScoreService.php";
use business\ScoreService;
$serv = new swoole_server("127.0.0.1", 9501);
//設置異步任務的工做進程數量
$serv->set(array('task_worker_num' => 4));
$serv->on('receive', function($serv, $fd, $from_id, $data) {
    //投遞異步任務
    $task_id = $serv->task($data);
    echo "receive";
});
//處理異步任務
$serv->on('task', function ($serv, $task_id, $from_id, $data) {
    sendScore($data);
    //返回任務執行的結果
    $serv->finish($data);
});
//處理異步任務的結果
$serv->on('finish', function ($serv, $task_id, $data) {
    echo "finish";
});
$serv->start();

function sendScore($data){
    //獲取到$data
    $arr = json_decode($data,true);
    //判斷數據是否異常
    //業務發獎代碼
    return true;
}

client下,創建client class,鏈接server操做,業務使用的時候,不須要關注swoole的細節,只須要使用client提供的接口便可,樣例以下:swoole

<?php
namespace client;
class ScoreClient
{
    public function send($msg){
        $client = new \swoole_client(\SWOOLE_SOCK_TCP);
        //鏈接到服務器
        if (!$client->connect('127.0.0.1', 9501, 1)){
            //
        }
        //向服務器發送數據
        if (!$client->send($msg)){
           //
        }
        //關閉鏈接
        $client->close();
    }
}

而後在業務機器上啓動swoole server,就能夠調用client中的方法去執行對應的功能。框架

思考和優化

  1. 建議除此server執行外,還有個定時任務server去處理執行失敗的任務。異步

  2. 能夠參考騰訊的tsf框架,用異步和協程的特性處理部分業務。工具

相關文章
相關標籤/搜索