搜索到
57
篇与
quhe.net
的结果
-
PHP实现简单的RPC 1.什么是rpcRPC全称为Remote Procedure Call，翻译过来为“远程过程调用”。目前，主流的平台中都支持各种远程调用技术，以满足分布式系统架构中不同的系统之间的远程通信和相互调用。远程调用的应用场景极其广泛，实现的方式也各式各样。2.从通信协议的层面基于HTTP协议的（例如基于文本的SOAP（XML）、Rest（JSON），基于二进制Hessian（Binary））基于TCP协议的（通常会借助Mina、Netty等高性能网络框架）3.从不同的开发语言和平台层面单种语言或平台特定支持的通信技术(例如Java平台的RMI、.NET平台Remoting)支持跨平台通信的技术（例如HTTP Rest、Thrift等）4.从调用过程来看同步通信调用（同步RPC）异步通信调用（MQ、异步RPC）5.常见的几种通信方式远程数据共享（例如：共享远程文件，共享数据库等实现不同系统通信）消息队列RPC（远程过程调用）6.php实现简单的rpc目录结构rpc服务端<?php /** * User: xietao * Description: Rpc服务端 */ class RpcServer { /** * User: xietao * Description: Rpc服务端 * @var array * Description: 此类的基本配置 */ private $params = [ 'host' => '', // ip地址，列出来的目的是为了友好看出来此变量中存储的信息 'port' => '', // 端口 'path' => '' // 服务目录 ]; /** * @var array * Description: 本类常用配置 */ private $config = [ 'real_path' => '', 'max_size' => 2048 // 最大接收数据大小 ]; /** * @var nul * Description: */ private $server = null; /** * Rpc constructor. */ public function __construct($params) { $this->check(); $this->init($params); } /** * Description: 必要验证 */ private function check() { $this->serverPath(); } /** * Description: 初始化必要参数 */ private function init($params) { // 将传递过来的参数初始化 $this->params = $params; // 创建tcpsocket服务 $this->createServer(); } /** * Description: 创建tcpsocket服务 */ private function createServer() { $this->server = stream_socket_server("tcp://{$this->params['host']}:{$this->params['port']}", $errno,$errstr); if (!$this->server) exit([ $errno,$errstr ]); } /** * Description: rpc服务目录 */ public function serverPath() { $path = $this->params['path']; $realPath = realpath(__DIR__ . $path); if ($realPath === false ||!file_exists($realPath)) { exit("{$path} error!"); } $this->config['real_path'] = $realPath; } /** * Description: 返回当前对象 */ public static function instance($params) { return new RpcServer($params); } /** * Description: 运行 */ public function run() { while (true) { $client = stream_socket_accept($this->server); if ($client) { echo "有新连接\n"; $buf = fread($client, $this->config['max_size']); print_r('接收到的原始数据:'.$buf."\n"); // 自定义协议目的是拿到类方法和参数(可改成自己定义的) $this->parseProtocol($buf,$class, $method,$params); // 执行方法 $this->execMethod($client, $class, $method, $params); //关闭客户端 fclose($client); echo "关闭了连接\n"; } } } /** * @param $class * @param $method * @param $params * Description: 执行方法 */ private function execMethod($client, $class, $method, $params) { if($class && $method) { // 首字母转为大写 $class = ucfirst($class); $file = $this->params['path'] . '/' . $class . '.php'; //判断文件是否存在，如果有，则引入文件 if(file_exists($file)) { require_once $file; //实例化类，并调用客户端指定的方法 $obj = new $class(); //如果有参数，则传入指定参数 if(!$params) { $data = $obj->$method(); } else { $data = $obj->$method($params); } // 打包数据 $this->packProtocol($data); //把运行后的结果返回给客户端 fwrite($client, $data); } } else { fwrite($client, 'class or method error'); } } /** * Description: 解析协议 */ private function parseProtocol($buf, &$class, &$method, &$params) { $buf = json_decode($buf, true); $class = $buf['class']; $method = $buf['method']; $params = $buf['params']; } /** * @param $data * Description: 打包协议 */ private function packProtocol(&$data) { $data = json_encode($data, JSON_UNESCAPED_UNICODE); } } RpcServer::instance([ 'host' => '127.0.0.1', 'port' => 8888, 'path' => './api' ])->run();rpc客户端<?php /** * Description: Rpc客户端 */ class RpcClient { /** * @var array * Description: 调用的地址 */ private $urlInfo = array(); /** * RpcClient constructor. */ public function __construct($url) { $this->urlInfo = parse_url($url); } /** * Description: 返回当前对象 */ public static function instance($url) { return new RpcClient($url); } public function __call($name, $arguments) { // TODO: Implement __call() method. //创建一个客户端 $client = stream_socket_client("tcp://{$this->urlInfo['host']}:{$this->urlInfo['port']}", $errno, $errstr); if (!$client) { exit("{$errno} : {$errstr} \n"); } $data = [ 'class' => basename($this->urlInfo['path']), 'method' => $name, 'params' => $arguments ]; //向服务端发送我们自定义的协议数据 fwrite($client, json_encode($data)); //读取服务端传来的数据 $data = fread($client, 2048); //关闭客户端 fclose($client); return $data; } } $cli = new RpcClient('http://127.0.0.1:8888/test'); echo $cli->tuzisir1()."\n"; echo $cli->tuzisir2(array('name' => 'tuzisir', 'age' => 23));提供服务的文件<?php /** * User: xietao * Description: */ class Test { public function tuzisir1() { return '我是无参方法'; } public function tuzisir2($params) { return $params; } }效果如图RPC的注意事项性能:影响RPC性能的主要在几个方面：1.序列化/反序列化的框架2.网络协议，网络模型，线程模型等安全RPC安全的主要在于服务接口的鉴权和访问控制支持。跨平台跨不同的操作系统，不同的编程语言和平台。{callout color="#f0ad4e"}RPC与微服务{/callout}什么是微服务所谓的微服务就是说，把一个应用分解成一组小的服务，每个服务运行在自己的进程中。每个服务都可以单独部署，可以用自己的语言编写，使用自己的数据库。微服务和rpc之间的关系微服务之间通过rpc进行通信。微服务的好处服务化的好处是不限定服务的提供方使用什么技术，实现跨团队的技术解耦。微服务难在服务的分解，重要之处也是服务的分解。 -
PHP中实现四舍五入的方法有哪些 ？ 在PHP开发中，有时候我们会遇到将数据进行四舍五入的运算情况，下面分享用PHP实现数据四舍五入的3种方法，分别通过number_format()函数、round()函数和sprintf()格式化输出的方法实现四舍五入。1、number_format() 方法实现四舍五入number_format() 函数通过千位分组来格式化数字。//定义一个float型的变量 $number = 1234.5678; //English Notation (defult) $number_format_english = number_format($number); //1,235 $number_format_english = number_format($number, 2, '.', ''); //1234.57 //French Notation $number_format_francais = number_format($number, 2, ',', ''); //1234,57 $number_format_francais = number_format($number, 3, ',', ''); //1234,568 echo $number_format_english; //1234.57 echo $number_format_francais; //1234,5682、round()方法实现四舍五入round() 函数对浮点数进行四舍五入。//定义一个float型的变量 $number = 1234.5678; //不保留小数 echo round($number); //1235 //保留两位小数 echo round($number,2); //1234.57 echo ""; $number = 12345678; //在千分位进行四舍五入 echo round($number,-4); //123500003、sprintf() 格式化输出实现四舍五入字符串格式化命令，主要功能是把格式化的数据写入某个字符串中。sprintf 是个变参函数。//定义一个正整数 $n = 43951789; //定义一个负整数 $u = -43951789; // ASCII 65 is 'A' $c = 65; printf("%%b = '%b'\n", $n); //%b = '10100111101010011010101101' printf("%%c = '%c'\n", $c); //%c = 'A' printf("%%d = '%d'\n", $n); //%d = '43951789' printf("%%e = '%e'\n", $n); //%e = '4.395179e+7' printf("%%u = '%u'\n", $n); //%u = '43951789' printf("%%u = '%u'\n", $u); //%u = '4251015507' printf("%%f = '%f'\n", $n); //%f = '43951789.000000' printf("%%o = '%o'\n", $n); //%o = '247523255' printf("%%s = '%s'\n", $n); //%s = '43951789' printf("%%x = '%x'\n", $n); //%x = '29ea6ad' printf("%%X = '%X'\n", $n); //%X = '29EA6AD' printf("%%+d = '%+d'\n", $n); //%+d = '+43951789' printf("%%+d = '%+d'\n", $u); //%+d = '-43951789'指定小数位数四舍五入的同时补0最近项目遇到问题了.用方法2对于四舍五入后的补零处理的不好比如$num =1.696; echo round($num,2); //结果1.7可以看出上面没有对数字进行补零于是终极办法出现了echo sprintf("%.2f", round($num,2)); //输出 1.70
