搜索到
43
篇与
后端
的结果
-
Redis的一大场景：排行榜实时更新 Redis 有序集合和集合一样也是 string 类型元素的集合，且不允许重复的成员。不同的是每个元素都会关联一个 double 类型的分数。redis 正是通过分数来为集合中的成员进行从小到大的排序。有序集合的成员是唯一的，但分数 (score) 却可以重复。集合是通过哈希表实现的，所以添加，删除，查找的复杂度都是 O (1)。集合中最大的成员数为 2^32 - 1^ (4294967295, 每个集合可存储 40 多亿个成员)。有序集合首先是集合，其成员（member）具有唯一性，其次，每个成员关联了一个分数（score），使得成员可以按照分数排序。需求描述设想在一个游戏中，有上百万的玩家数据，如果现在需要你根据玩家的经验值整理一个前 10 名的排行榜，你会怎么做呢？一般的做法是写一条类似下面这条 sql 语句的方式来获取：select * from game_socre order by score desc limit 0,20这种方式在数据量较小的情况下可行，但是在数据量大的情况下查询速度将变慢，特别是还需要联表查询时，速度下降的就更明显了。实现这时你可以考虑使用 redis 来实现这个功能。实现这个功能主要用到的 redis 数据类型是 redis 的有序集合 zset。zset 是 set 类型的一个扩展，比原有的类型多了一个顺序属性。此属性在每次插入数据时会自动调整顺序值，保证 value 值按照一定顺序连续排列。主要的实现思路是：1、在一个新的玩家参与到游戏中时，在 redis 中的 zset 中新增一条记录（记录内容看具体的需求）score 为 02、当玩家的经验值发生变化时，修改该玩家的 score 值3、使用 redis 的 ZREVRANGE 方法获取排行榜返回有序集 key 中，指定区间内的成员。其中成员的位置按 score 值递减 (从大到小) 来排列。具有相同 score 值的成员按字典序的反序排列。除了成员按 score 值递减的次序排列这一点外，ZREVRANGE 命令的其他方面和 ZRANGE 命令一样。redis 127.0.0.1:6379> ZADD KEY_NAME SCORE1 VALUE1.. SCOREN VALUEN1、数据准备2、获取 score 高分 top8 排名 (ZREVRANGE 为降序，ZRANGE 为升序)3、查看用户 ee 的实际排名 (ZREVRANK 为降序，ZRANK 为升序)、实时分数进一步需求需要实现最近的 24 小时用户积分排行榜，并统计前 10 名的玩家和积分实现主要的实现思路是：利用 ZADD 按小时划分添加用户的积分信息，然后用 ZUNIONSTORE 并集实现 24 小时的游戏积分总和，实现 “24 小时排行榜”；（如果有更好的思路，能够在下方留言不吝赐教一下就更好了）ZUNIONSTORE destination numkeys key [key ...]Redis Zunionstore 命令计算给定的一个或多个有序集的并集，其中给定 key 的数量必须以 numkeys 参数指定，并 ? ? 将该并集(结果集)储存到 destination 。默认情况下，结果集中某个成员的分数值是所有给定集下该成员分数值之和 。可能碰到的问题1、相同分数问题Redis 在遇到分数相同时是按照集合成员自身的字典顺序来排序，这里即是按照”user2″和”user3″这两个字符串进行排序，以逆序排序的话 user3 自然排到了前面。要解决这个问题，我们可以考虑在分数中加入时间戳，计算公式为：带时间戳的分数 = 实际分数*10000000000 + (9999999999 – timestamp)timestamp 我们采用系统提供的 time () 函数，也就是 1970 年 1 月 1 日以来的秒数，我们采用 32 位的时间戳（这能坚持到 2038 年），由于 32 位时间戳是 10 位十进制整数（最大值 4294967295）;所以我们让时间戳占据低 10 位（十进制整数），实际分数则扩大 10^10 倍，然后把两部分相加的结果作为 zset 的分数。考虑到要按时间倒序排列，所以时间戳这部分需要颠倒一下，这便是用 9999999999 减去时间戳的原因。当我们要读取玩家实际分数时，只需去掉后 10 位即可。初步看起来这个方案还不错，但这里面有两个问题。第一个问题是小问题，采用秒为时间戳可能区分度还不够，如果同一秒出现两个分数相同的仍然会出现前面的问题，当然我们可以选择精度更高的时间戳，但在实际场景中，同一秒谁排前面已经无关紧要。第二个问题是大问题，因为 Redis 的分数类型采用的是 double，64 位双精度浮点数只有 52 位有效数字，它能精确表达的整数范围为 - 2^53 到 2^53，最高只能表示 16 位十进制整数（最大值为 9007199254740992，其实连 16 位也不能完整表示）。这就是说，如果前面时间戳占了 10 位的话，分数就只剩下 6 位了，这对于某些排行榜分数来说是不够用的。我们可以考虑缩减时间戳位数，比如从 2015 年 1 月 1 日开始计时，但这仍然增加不了几位。或者减少区分度，以分钟、小时来作为时间戳单位。如果 Redis 的分数类型为 int64，我们就没有上面的烦恼。说到这里，其实 Redis 真应该再额外提供一个 int64 类型的 ZSet，但目前只能是幻想，除非自己改其源码。 -
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
