本文記錄一次對swoole初步的學習和簡單的使用。
歡迎討論和吐槽。php
Swoole是一種PHP高級Web開發框架,框架不是爲了提高網站的性能,是爲了提高網站的開發效率。
使用異步協程的特效,提高代碼效率。json
個人業務使用場景是對應活動發獎品(發積分,贈劵,禮包),但願在對用戶的領取條件判斷經過後,馬上給用戶返回提示,而後用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中的方法去執行對應的功能。框架
建議除此server執行外,還有個定時任務server去處理執行失敗的任務。異步
能夠參考騰訊的tsf框架,用異步和協程的特性處理部分業務。工具