欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

PHP程序员简单的开展服务治理架构操作详解(一)

程序员文章站 2022-06-30 10:19:10
本文实例讲述了php程序员简单的开展服务治理架构操作。分享给大家供大家参考,具体如下:不涉及其他的语言及工具,我们从php本身来谈如何实现服务治理本猿人已经写好的服务治理 https://github...

本文实例讲述了php程序员简单的开展服务治理架构操作。分享给大家供大家参考,具体如下:

不涉及其他的语言及工具,我们从php本身来谈如何实现服务治理

本猿人已经写好的服务治理 https://github.com/crazycodes/service-govern.git

治理什么?

这个专业名词很容易发现治理的是服务,而服务则是我们的项目。管理这些服务方案则叫服务治理。

现在在server上有四项服务,分别为

  • userservice
  • shopservice
  • goodsservice
  • liveservice

这些服务我们叫它服务提供者(既提供对内服务的应用)

调用服务的应用我们称它为服务消费者,例如

  • user-api
  • shop-api
  • goods-api
  • live-api

service 是对内服务的而api是对外服务的

PHP程序员简单的开展服务治理架构操作详解(一)

服务治理考虑的问题就是如何管理这四项服务,让它们如何对外服务,如何监控服务进程

依托实现

在实现服务治理之前,需要了解以下几块知识点

  • thrift
  • rpc
  • swoole

thrift

暂时大可理解为可以通过它去调用其他开发语言的方法

rpc

rpc(remote procedure call)—远程过程调用,它是一种通过网络从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。rpc协议假定某些传输协议的存在,如tcp或udp,为通信程序之间携带信息数据。在osi网络通信模型中,rpc跨越了传输层和应用层。rpc使得开发包括网络分布式多程序在内的应用程序更加容易。
rpc采用客户机/服务器模式。请求程序就是一个客户机,而服务提供程序就是一个服务器。首先,客户机调用进程发送一个有进程参数的调用信息到服务进程,然后等待应答信息。在服务器端,进程保持睡眠状态直到调用信息到达为止。当一个调用信息到达,服务器获得进程参数,计算结果,发送答复信息,然后等待下一个调用信息,最后,客户端调用进程接收答复信息,获得进程结果,然后调用执行继续进行。

服务与服务之间通信可以通过rpc通信,当然也可以选择udp等

swoole

php圈内跨世纪的产物,使用他的原因是因为swoole本身支持rpc通信,所以我们本章通过swoole rpc的方法去实现消费者与服务提供者之间的通信

实现rpc通信

服务治理非常重要的一个环节,要在无感知的情况让消费者a调用服务提供者a,b,c,当然实际情况下,这是永远不可能的,根本不在一个内存空间中,我们需要自己模拟出来这种使用方式

$userserivce = $client->client ('userservice');
$result = $userserivce->getuserinfo (['user_id' => 100]);
var_dump($result);

在消费者内没有userservice,更没有getuserinfo 方法,这些都在服务提供者的应用中,如何去调用它们?

首先通过php的__call 方法去截取一个不存在的方法

public function __call($name, $arguments)
{
  $client = new clientrpc($this->servicename);
      
  $response = $client->send ($this->servicename, $name, $arguments);
      
  return (json_decode ($response, true));
      
}

获取后调用自己写的send 方法,swoole出场

class clientrpc
{
  protected $client;
    
  public function __construct($service_name, $centerconfig)
  {
    $this->client = new \swoole_client(swoole_sock_tcp);
      
    $center = dispatcher::loadbalance ($service_name, $centerconfig);
    $this->client->connect ($center['ip'], $center['port'], 0.5);
  }
    
  public function send($service, $action, $arguments)
  {
    $request = new request();
    
    $request->setservice ($service);
    $request->setaction ($action);
    $request->setparameters ($arguments[0]);
    // 重组参数,组合成你希望的格式,最后转成json发送到服务提供者
    $this->client->send (json_encode ((array)$request));
      
    return $this->client->recv ();
  }
    
  public function __destruct()
  {
    $this->client->close ();
    unset($this->client);
  }
}