Exemple détaillé de code source php-msf

Cet article présente principalement la signification du code source de php-msf et les problèmes liés à son utilisation. Les amis dans le besoin peuvent le suivre pour référence et étude. J'espère que cela aide tout le monde.

Je fais de l'interprétation de code source depuis un certain temps. Laissez-moi résumer mon expérience :

Saisissez le cycle de vie et laissez le code s'exécuter dans votre esprit

Architecture d'analyse, isolation des limites en couches par mots clés

Un bon cadre, clarifiez le cycle de vie et l'architecture, en gros, vous avez atteint un état familier, puis remplissez les détails et maîtrisez le codage

Voici quelques informations supplémentaires importantes :

Comprenez en quoi cet outil est bon et à quoi il convient. Ces informations sont également très faciles à obtenir. La documentation de l'outil est généralement indiquée bien en évidence, et vous pouvez le faire. utilisez ces fonctions/caractéristiques, essayez de répondre aux points

Regardez ce projet d'un point de vue technique, qui se distingue principalement de l'architecture ci-dessus en plus de gérer le cœur de métier, c'est-à-dire le. au-dessus des fonctions/fonctionnalités, l'ingénierie implique également En termes de sécurité/tests/normes de codage/fonctionnalités linguistiques, etc., ce sont aussi les parties auxquelles je pense généralement moins et que je pratique moins lors de l'écriture de code commercial

L'utilisation des outils, je recommande la combinaison que j'utilise actuellement : phpstorm + Baidu mind map + Markdown notes + l'origine du blog et php-msf, etc. pour écrire des blogs liés à la vie technique Parlons à nouveau à tout le monde et servons directement. .

Cycle de vie et architecture

Le document officiel a produit une très bonne image : Organigramme de traitement des demandes. Je recommande à mes collègues de faire des images similaires lorsqu'ils ont du temps libre. , ce qui est très utile pour réfléchir.

Basé sur cette image En pensant au cycle de vie et à l'architecture, je n'entrerai pas dans les détails ici voici une analyse de quelques points techniques dans msf :

Connaissances liées aux coroutines

Extraits de points techniques dans msf

Coroutines

Je vous l'expliquerai à ma manière Si vous avez besoin de savoir. pour en savoir plus, vous pourrez lire les ressources que je recommande plus tard.

Classe vs objet est un groupe très important. Le concept de classe représente notre abstraction des choses. Nous continuerons à utiliser cette capacité abstraite à l'avenir. cultiver consciemment cette conscience, qui peut au moins fournir une analogie. Les objets sont des classes instanciées, qui sont les vraies choses à faire, la coroutine dont nous allons discuter est un tel rôle qui fonctionne vraiment.

Où. est-ce que la coroutine vient, où va-t-elle et que fait-elle ?

Réfléchissez En pensant à ces questions simples, peut-être que votre compréhension des coroutines sera plus profonde :

<.>Génération. Il doit y avoir un endroit pour générer des coroutines, et vous n'avez peut-être pas besoin de connaître les détails, mais vous devez savoir quand

la planification se produit. Il doit y avoir de nombreuses coroutines travaillant ensemble, donc. une planification est nécessaire. Comment planifier ?

Détruit ? Quand sera-t-il détruit ?

Maintenant, regardons la comparaison de la manière dont ? les coroutines sont utilisées. Notez ici que je n'ai pas comparé l'implémentation des coroutines, car souvent, les besoins réels sont comme ça :

Je me fiche de comment l'implémenter, je choisis la meilleure. 🎜>

// msf - 单次协程调度
$response = yield $this->getRedisPool('tw')->get('apiCacheForABCoroutine');
// msf - 并发协程调用
$client1 = $this->getObject(Client::class, ['http://www.baidu.com/']);
yield $client1->goDnsLookup();
$client2 = $this->getObject(Client::class, ['http://www.qq.com/']);
yield $client2->goDnsLookup();
$result[] = yield $client1->goGet('/');
$result[] = yield $client2->goGet('/');

C'est à peu près une équation comme celle-ci : utilisez des coroutines = ajouter du rendement, alors déterminez simplement où vous devez ajouter du rendement - il y a des endroits qui bloquent les IO , tels que les E/S de fichiers, les E/S de réseau (redis/mysql/http), etc.

Bien sûr, il y a généralement des choses auxquelles il faut prêter attention

Ordre de planification des coroutines si vous. n'y prêtez pas attention, cela peut dégénérer en appels synchrones.

Chaîne d'appels : utiliser la chaîne d'appels de rendement Ci-dessus, vous devez ajouter du rendement. Par exemple, comme suit :

<.>

Comparez la solution coroutine de swoole2.0 :

function a_test() {
  return yield $this->getRedisPool('tw')->get('apiCacheForABCoroutine');
}
$res = yield a_test(); // 如果不加 yield, 就变成了同步执行

Utilisation de la solution coroutine swoole2.0 , les avantages sont évidents :

$server = new Swoole\Http\Server("127.0.0.1", 9502, SWOOLE_BASE);
$server->set([
  'worker_num' => 1,
]);
// 需要在协程 server 的异步回调函数中
$server->on('Request', function ($request, $response) {
  $tcpclient = new Swoole\Coroutine\Client(SWOOLE_SOCK_TCP); // 需要配合使用协程客户端
  $tcpclient->connect('127.0.0.1', 9501，0.5)
  $tcpclient->send("hello world\n");
  $redis = new Swoole\Coroutine\Redis();
  $redis->connect('127.0.0.1', 6379);
  $redis->setDefer(); // 标注延迟收包, 实现并发调用
  $redis->get('key');
  $mysql = new Swoole\Coroutine\MySQL();
  $mysql->connect([
    'host' => '127.0.0.1',
    'user' => 'user',
    'password' => 'pass',
    'database' => 'test',
  ]);
  $mysql->setDefer();
  $mysql->query('select sleep(1)');
  $httpclient = new Swoole\Coroutine\Http\Client('0.0.0.0', 9599);
  $httpclient->setHeaders(['Host' => "api.mp.qq.com"]);
  $httpclient->set([ 'timeout' => 1]);
  $httpclient->setDefer();
  $httpclient->get('/');
  $tcp_res = $tcpclient->recv();
  $redis_res = $redis->recv();
  $mysql_res = $mysql->recv();
  $http_res = $httpclient->recv();
  $response->end('Test End');
});
$server->start();

Pas besoin d'ajouter du rendement

Pas besoin de vous soucier des appels simultanés. Faites attention à l'ordre de rendement. Utilisez defer() pour retarder la collecte des paquets <.>

Cependant, il n'y a aucun moyen d'utiliser directement une équation simple comme coroutine = plus rendement. L'exemple ci-dessus doit être coordonné. Utilisez le serveur swoole coroutine + le client swoole coroutine :

le serveur génère. coroutine lorsque le rappel asynchrone est déclenché

le client déclenche la planification de la coroutine

asynchrone La coroutine

est détruite à la fin de l'exécution du rappel. à 2 problèmes : Que dois-je faire si

n'est pas dans le rappel asynchrone du serveur de coroutine swoole : Utilisez SwooleCoroutine::create() pour afficher Que dois-je faire si j'ai besoin d'utiliser d'autres clients coroutine pour générer coroutines

 : C'est le but de Swoole3.0 peut envisager d'utiliser des tâches de coroutine pour se déguiser

comme ceci. Il semble qu'il soit plus simple d'utiliser coroutine = plus. rendement ? Je ne pense pas. J'ajouterai quelques avis que tout le monde pourra prendre en compte :

Utiliser la méthode de rendement, basée sur le générateur PHP + implémenter la coroutine PHP par vous-même. Si vous souhaitez utiliser le planificateur sans faire d'erreurs, comme la séquence de planification de coroutine ci-dessus, vous devez toujours comprendre l'implémentation de cette pièce

La méthode native de Swoole2.0 est en fait plus facile à comprendre, il vous suffit de connaître le timing de la coroutine génération/planification/destruction pour faire bon usage de

Swoole2.0. La création et la destruction fréquentes de coroutines dans les rappels asynchrones consommeront-elles des performances -- Non, en fait, ce sont des opérations de mémoire, beaucoup plus petites ? que les processus/objets

Extraits de points techniques dans msf

msf possède de nombreuses fonctionnalités exceptionnelles en matière de conception, et de nombreux codes valent la peine d'être appris.

Demander contextContext

这是从 fpm 到 swoole http server 非常重要的概念. fpm 是多进程模式, 虽然 $_POST 等变量, 被称之为超全局变量, 但是, 这些变量在不同 fpm 进程间是隔离的. 但是到了 swoole http server 中, 一个 worker 进程, 会异步处理多个请求, 简单理解就是下面的等式:

fpm worker : http request = 1 : 1
swoole worker : http request = 1 : n

所以, 我们就需要一种新的方式, 来进行 request 间的隔离.

在编程语言里, 有一个专业词汇 scope(作用域). 通常会使用 scope/生命周期, 所以我一直强调的生命周期的概念, 真的很重要.

swoole 本身是实现了隔离的:

$http = new swoole_http_server("127.0.0.1", 9501);
$http->on('request', function ($request, $response) {
  $response->end("<h1>Hello Swoole. #".rand(1000, 9999)."</h1>");
});
$http->start();

msf 在 Context 上还做了一层封装, 让 Context 看起来 为所欲为:

// 你几乎可以用这种方式, 完成任何需要的逻辑
$this->getContext()->xxxModule->xxxModuleFunction();

细节可以查看 src/Helpers/Context.php 文件

对象池

对象池这个概念, 大家可能比较陌生, 目的是减少对象的频繁创建与销毁, 以此来提升性能, msf 做了很好的封装, 使用很简单:

// getObject() 就可以了
/** @var DemoModel $demoModel */
$demoModel = $this->getObject(DemoModel::class, [1, 2]);

对象池的具体代码在 src/Base/Pool.php 下:

底层使用反射来实现对象的动态创建

public function get($class, ...$args)
{
  $poolName = trim($class, '\\');

  if (!$poolName) {
    return null;
  }

  $pool   = $this->map[$poolName] ?? null;
  if ($pool == null) {
    $pool = $this->applyNewPool($poolName);
  }

  if ($pool->count()) {
    $obj = $pool->shift();
    $obj->__isConstruct = false;
    return $obj;
  } else {
    // 使用反射
    $reflector     = new \ReflectionClass($poolName);
    $obj        = $reflector->newInstanceWithoutConstructor();

    $obj->__useCount  = 0;
    $obj->__genTime  = time();
    $obj->__isConstruct = false;
    $obj->__DSLevel  = Macro::DS_PUBLIC;
    unset($reflector);
    return $obj;
  }
}

使用 SplStack 来管理对象

private function applyNewPool($poolName)
{
  if (array_key_exists($poolName, $this->map)) {
    throw new Exception('the name is exists in pool map');
  }
  $this->map[$poolName] = new \SplStack();

  return $this->map[$poolName];
}
// 管理对象
$pool->push($classInstance);
$obj = $pool->shift();

连接池 & 代理

连接池 Pools

连接池的概念就不赘述了, 我们来直接看 msf 中的实现, 代码在 src/Pools/AsynPool.php 下:

public function __construct($config)
{
  $this->callBacks = [];
  $this->commands = new \SplQueue();
  $this->pool   = new \SplQueue();
  $this->config  = $config;
}

这里使用的 SplQueue 来管理连接和需要执行的命令. 可以和上面对比一下, 想一想为什么一个使用 SplStack, 一个使用 SplQueue.

代理 Proxy

代理是在连接池的基础上进一步的封装, msf 提供了 2 种封装方式:

主从 master slave

集群 cluster

查看示例 App\Controllers\Redis 中的代码:

class Redis extends Controller
{
  // Redis连接池读写示例
  public function actionPoolSetGet()
  {
    yield $this->getRedisPool('p1')->set('key1', 'val1');
    $val = yield $this->getRedisPool('p1')->get('key1');

    $this->outputJson($val);
  }
  // Redis代理使用示例（分布式）
  public function actionProxySetGet()
  {
    for ($i = 0; $i <= 100; $i++) {
      yield $this->getRedisProxy(&#39;cluster&#39;)->set(&#39;proxy&#39; . $i, $i);
    }
    $val = yield $this->getRedisProxy(&#39;cluster&#39;)->get(&#39;proxy22&#39;);
    $this->outputJson($val);
  }

  // Redis代理使用示例（主从）
  public function actionMaserSlaveSetGet()
  {
    for ($i = 0; $i <= 100; $i++) {
      yield $this->getRedisProxy(&#39;master_slave&#39;)->set(&#39;M&#39; . $i, $i);
    }

    $val = yield $this->getRedisProxy(&#39;master_slave&#39;)->get(&#39;M66&#39;);
    $this->outputJson($val);
  }
}

代理就是在连接池的基础上进一步 搞事情. 以 主从 模式为例:

主从策略: 读主库, 写从库
代理做的事情:

判断是读操作还是写操作, 选择相应的库去执行
公共库

msf 推行 公共库 的做法, 希望不同功能组件可以做到 可插拔, 这一点可以看 laravel 框架和 symfony 框架, 都由框架核心加一个个的 package 组成. 这种思想我是非常推荐的, 但是仔细看 百度脑图 - php-msf 源码解读 这张图的话, 就会发现类与类之间的依赖关系, 分层/边界 做得并不好. 如果看过我之前的 blog - laravel源码解读 / blog - yii源码解读, 进行对比就会感受很明显.

但是, 这并不意味着 代码不好, 至少功能正常的代码, 几乎都能算是好代码. 从功能之外建立的 优越感, 更多的是对 美好生活的向往 -- 还可以更好一点.

AOP

php AOP 扩展: http://pecl.php.net/package/aop

PHP-AOP扩展介绍 | rango: http://rango.swoole.com/archives/83

AOP, 面向切面编程, 韩老大 的 blog - PHP-AOP扩展介绍 | rango 可以看看.

需不需要了解一个新事物, 先看看这个事物有什么作用:

AOP, 将业务代码和业务无关的代码进行分离, 场景有 日志记录 / 性能统计 / 安全控制 / 事务处理 / 异常处理 / 缓存 等等.
这里引用一段 程序员DD - 翟永超的公众号 文章里的代码, 让大家感受下:

同样是 CRUD, 不使用 AOP

＠PostMapping("/delete")
public Map<String, Object> delete(long id, String lang) {
 Map<String, Object> data = new HashMap<String, Object>();
 boolean result = false;
 try {
  // 语言（中英文提示不同）
  Locale local = "zh".equalsIgnoreCase(lang) ? Locale.CHINESE : Locale.ENGLISH;
  result = configService.delete(id, local);
  data.put("code", 0);
 } catch (CheckException e) {
  // 参数等校验出错，这类异常属于已知异常，不需要打印堆栈，返回码为-1
  data.put("code", -1);
  data.put("msg", e.getMessage());
 } catch (Exception e) {
  // 其他未知异常，需要打印堆栈分析用，返回码为99
  log.error(e);

  data.put("code", 99);
  data.put("msg", e.toString());
 }
 data.put("result", result);
 return data;
}

使用 AOP

＠PostMapping("/delete")
public ResultBean<Boolean> delete(long id) {
 return new ResultBean<Boolean>(configService.delete(id));
}

代码只用一行, 需要的特性一个没少, 你是不是也想写这样的 CRUD 代码?

配置文件管理

先明确一下配置管理的痛点:

是否支撑热更新, 常驻内存需要考虑

考虑不同环境: dev test production

方便使用

热更其实可以算是常驻内存服务器的整体需求, 目前 php 常用的解决方案是 inotify, 可以参考我之前的 blog - swoft 源码解读 .

msf 使用第三方库来解析处理配置文件, 这里着重提一个 array_merge() 的细节:

$a = ['a' => [
  'a1' => 'a1',
]];
$b = ['a' => [
  'b1' => 'b1',
]];
$arr = array_merge($a, $b); // 注意, array_merge() 并不会循环合并
var_dump($arr);
// 结果
array(1) {
 ["a"]=>
 array(1) {
  ["b1"]=>
  string(2) "b1"
 }
}

msf 中使用配置:

$ids = $this->getConfig()->get('params.mock_ids', []);
// 对比一下 laravel
$ids = cofnig('params.mock_ids', []);

看起来 laravel 中要简单一些, 其实是通过 composer autoload 来加载函数, 这个函数对实际的操作包装了一层. 至于要不要这样做, 就看自己需求了.

写在最后

msf 最复杂的部分在 服务启动阶段, 继承也很长:

Child -> Server -> HttpServer -> MSFServer -> AppServer, 有兴趣可以挑战一下.

另外一个比较难的点, 是 MongoDbTask 实现原理.

msf 还封装了很多有用的功能, RPC / 消息队列 / restful, 大家根据文档自己探索即可。

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!