Notepad++

如何对api接口做限流

Fri, 09 Dec 2022 10:14:16 +0800

什么是接口限流
那么什么是限流呢？顾名思义，限流就是限制流量，包括并发的流量和一定时间内的总流量，就像你宽带包了1个G的流量，用完了就没了，所以控制你的使用频率和单次使用的总消耗。

通过限流，我们可以很好地控制系统的qps，从而达到保护系统或者接口服务器稳定的目的。

接口限流的常用算法
计数器法
计数器法是限流算法里最简单也是最容易实现的一种算法。

比如我们规定，对于A接口来说，我们1分钟的访问次数不能超过100个。那么我们可以这么做：在一开始的时候，我们可以设置一个计数器counter，每当一个请求过来的时候，counter就加1，如果counter的值大于100并且该请求与第一个请求的间隔时间还在1分钟之内，那么说明请求数过多；

如果该请求与第一个请求的间隔时间大于1分钟，且counter的值还在限流范围内，那么就重置counter。

代码如下

class CounterDemo{
    private $first_request_time;
    private $request_count = 0; //已请求的次数
    public $limit = 100; //时间窗口内的最大请求数
    public $interval = 60; //时间窗口 s
    public function __construct() {
        $this->first_request_time = time();
    }
    public function grant(){
        $now = time();
        if($now < $this->first_request_time + $this->interval){
            //时间窗口内
            if($this->request_count < $this->limit) {
                $this->request_count++;
                return true;
            }else{
                return false;
            }
        }else{
            //超出前一个时间窗口后, 重置第一次请求时间和请求总次数
            $this->first_request_time = $now;
            $this->request_count = 1;
            return true;
        }
    }
}
$m = new CounterDemo();
$n_success = 0;
for($i=0; $i < 200; $i++){
    $rt = $m->grant();
    if($rt){
        $n_success ++;
    }
}
echo '成功请求 '.$n_success.' 次';

计数器算法很简单，但是有个严重的bug：

一个恶意用户在0:59时瞬间发送了100个请求，然后再1:00时又瞬间发送了100个请求，那么这个用户在2秒内发送了200个请求。

上面我们规定1分钟最多处理100个请求，也就是每秒1.7个请求。用户通过在时间窗口的重置节点处突发请求，可以瞬间超过系统的承载能力，导致系统挂起或宕机。

上面的问题，其实是因为我们统计的精度太低造成的。那么如何很好地处理这个问题呢？或者说，如何将临界问题的影响降低呢？我们可以看下面的滑动窗口算法。

我们把一个时间窗口（一分钟）分成6份，每份（小格）代表10秒。每过10秒钟我们就把时间窗口往右滑动一格，每一个格子都有自己独立的计数器。

比如一个请求在0:35秒到达的时候，就会落在0:30-0:39这个区间，并将此区间的计数器加1。

从上图可以看出, 0:59到达的100个请求会落在0:50-0:59这个灰色的格子中, 而1:00到达的100个请求会落在黄色的格子中。

而在1:00时间统计时，窗口会往右移动一格，那么此时的时间窗口内的请求数量一共是200个，超出了限制的100个，触发了限流，后面的100个请求被抛弃或者等待。

如果我们把窗口时间划分越多，比如60格，每格1s，那么限流统计会更精确。

漏桶算法 (Leaky Bucket)

漏桶算法(Leaky Bucket): 平滑网络上的突发流量。使其整流为一个稳定的流量。

有一个固定容量的桶，有水流进来，也有水流出去。对于流进来的水来说，我们无法预计一共有多少水会流进来，也无法预计水流的速度。但是对于流出去的水来说，这个桶可以固定水流出的速率。当桶满了之后，多余的水将会溢出(多余的请求会被丢弃)。

简单的算法实现:

class LeakyBucketDemo{
    private $last_req_time; //上一次请求的时间
    public $capacity; //桶的容量
    public $rate; //水漏出的速度(个/秒)
    public $water; //当前水量(当前累积请求数)
    public function __construct(){
        $this->last_req_time = time();
        $this->capacity = 100;
        $this->rate = 20;
        $this->water = 0;
    }
    public function grant(){
        $now = time();
        $water = max(0,$this->water - ($now - $this->last_req_time) * $this->rate);// 先执行漏水，计算剩余水量
        $this->water = $water;
        $this->last_req_time = $now;
        if($water < $this->capacity){
            // 尝试加水,并且水还未满
            $this->water += 1;
            return true;
        }else{
            // 水满，拒绝加水
            return false;
        }
    }
}
$m = new LeakyBucketDemo();
$n_success = 0;
for($i=0; $i < 500; $i++){
    $rt = $m->grant();
    if($rt){
        $n_success ++;
    }
    if($i > 0 && $i % 100 == 0){//每发起100次后暂停1s
        echo '已发送',$i,', 成功 ', $n_success,', sleep'.PHP_EOL;
        sleep(1);
    }
}
echo '成功请求 '.$n_success.' 次';

令牌桶算法 (Token Bucket)

令牌桶算法比漏桶算法稍显复杂。首先，我们有一个固定容量的桶，桶里存放着令牌（token）。桶一开始是空的(可用token数为0)，token以一个固定的速率r往桶里填充，直到达到桶的容量，多余的令牌将会被丢弃。每当一个请求过来时，就会尝试从桶里移除一个令牌，如果没有令牌的话，请求无法通过。

代码实现如下:

class TokenBucketDemo{
    private $last_req_time; //上次请求时间
    public $capacity; //桶的容量
    public $rate; //令牌放入的速度(个/秒)
    public $tokens; //当前可用令牌的数量
    public function __construct(){
        $this->last_req_time = time();
        $this->capacity = 100;
        $this->rate = 20;
        $this->tokens = 100; //开始给100个令牌
    }
    public function grant(){
        $now = time();
        $tokens = min($this->capacity,$this->tokens + ($now - $this->last_req_time) * $this->rate);// 计算桶里可用的令牌数
        $this->tokens = $tokens;
        $this->last_req_time = $now;
        if($this->tokens < 1){
            // 若剩余不到1个令牌,则拒绝
            return false;
        }else{
            // 还有令牌，领取1个令牌
            $this->tokens -= 1;
            return true;
        }
    }
}
$m = new TokenBucketDemo();
$n_success = 0;
for($i=0; $i < 500; $i++){
    $rt = $m->grant();
    if($rt){
        $n_success ++;
    }
    if($i > 0 && $i % 100 == 0){//每发起100次后暂停1s
        echo '已发送',$i,', 成功 ', $n_success,', sleep'.PHP_EOL;
        sleep(1);
    }
}
echo '成功请求 '.$n_success.' 次';

我们可以使用redis的队列作为令牌桶容器使用，使用lPush（入队），rPop（出队），实现令牌加入与消耗的操作。
TokenBucket.php

<?php
/**
 * PHP基于Redis使用令牌桶算法实现接口限流，使用redis的队列作为令牌桶容器，入队（lPush）出队（rPop)作为令牌的加入与消耗操作。
 * public  add     加入令牌
 * public  get     获取令牌
 * public  reset   重设令牌桶
 * private connect 创建redis连接
 */
class TokenBucket{ // class start

    private $_config; // redis设定
    private $_redis;  // redis对象
    private $_queue;  // 令牌桶
    private $_max;    // 最大令牌数

    /**
     * 初始化
     * @param Array $config redis连接设定
     */
    public function __construct($config, $queue, $max){
        $this->_config = $config;
        $this->_queue = $queue;
        $this->_max = $max;
        $this->_redis = $this->connect();
    }

    /**
     * 加入令牌
     * @param  Int $num 加入的令牌数量
     * @return Int 加入的数量
     */
    public function add($num=0){

        // 当前剩余令牌数
        $curnum = intval($this->_redis->lSize($this->_queue));

        // 最大令牌数
        $maxnum = intval($this->_max);

        // 计算最大可加入的令牌数量，不能超过最大令牌数
        $num = $maxnum>=$curnum+$num? $num : $maxnum-$curnum;

        // 加入令牌
        if($num>0){
            $token = array_fill(0, $num, 1);
            $this->_redis->lPush($this->_queue, ...$token);
            return $num;
        }

        return 0;

    }

    /**
     * 获取令牌
     * @return Boolean
     */
    public function get(){
        return $this->_redis->rPop($this->_queue)? true : false;
    }

    /**
     * 重设令牌桶，填满令牌
     */
    public function reset(){
        $this->_redis->delete($this->_queue);
        $this->add($this->_max);
    }

    /**
     * 创建redis连接
     * @return Link
     */
    private function connect(){
        try{
            $redis = new Redis();
            $redis->connect($this->_config['host'],$this->_config['port'],$this->_config['timeout'],$this->_config['reserved'],$this->_config['retry_interval']);
            if(empty($this->_config['auth'])){
                $redis->auth($this->_config['auth']);
            }
            $redis->select($this->_config['index']);
        }catch(RedisException $e){
            throw new Exception($e->getMessage());
            return false;
        }
        return $redis;
    }


} 
?>

令牌的假如与消耗

<?php
/**
 * 演示令牌加入与消耗
 */
require 'TokenBucket.php';

// redis连接设定
$config = array(
    'host' => 'localhost',
    'port' => 6379,
    'index' => 0,
    'auth' => '',
    'timeout' => 1,
    'reserved' => NULL,
    'retry_interval' => 100,
);

// 令牌桶容器
$queue = 'mycontainer';

// 最大令牌数
$max = 5;

// 创建TrafficShaper对象
$tokenBucket = new TokenBucket($config, $queue, $max);

// 重设令牌桶，填满令牌
$tokenBucket->reset();

// 循环获取令牌，令牌桶内只有5个令牌，因此最后3次获取失败
for($i=0; $i<8; $i++){
    var_dump($tokenBucket->get());
}

// 加入10个令牌，最大令牌为5，因此只能加入5个
$add_num = $tokenBucket->add(10);

var_dump($add_num);

// 循环获取令牌，令牌桶内只有5个令牌，因此最后1次获取失败
for($i=0; $i<6; $i++){
    var_dump($tokenBucket->get());
}

?>

用laravel 实现地址自动识别

Tue, 26 Jul 2022 15:07:35 +0800

地址自动识别现在普遍，特别是用在快递填写地址，姓名，手机号码的时候，会把这些按照一定的规范填写后，点击自动识别后，会自动填写到各自的input。

最近也简单的实现了这个功能，给后台添加用户的时候，自动识别地址。其实就是先定下规则吧。以下是效果图

具体问题具体分析！代码实现基于laravel完成。一个laravel完整的功能得具备这些：路由route，Model, View, Controller, 我这里用的有依赖注入服务容器等功能，当然，用到地址，你首先要有地址库。。。

下面来看看是如何实现的，这里我只贴出核心代码

UsersController控制器

在这里新建构造函数，实现容器的依赖注入UsersRepository

/** @var  UserRepository */
private $userRepository;
public function __construct(UsersRepository $userRepo)
{
    $this->userRepository = $userRepo;
}

接下来就新建地址识别的方法， $discernDel 接收的数据是从前端传过来的，后面再贴前端代码。业务代码处理交给容器UsersRepository里的方法getDiscern处理

/**
 * Function:地址识别
 * Author:磊丰
 * @param Request $request
 * @return \Illuminate\Contracts\Routing\ResponseFactory|\Illuminate\Http\Response|
 * \Laravel\Lumen\Http\ResponseFactory|\Symfony\Component\HttpFoundation\Response
 */
public function getDiscern(Request $request)
{
    $discernDel = $request->input('discernDel');
    try{
       DB::beginTransaction();
       $address = $this->userRepository->getDiscern($discernDel);
       DB::commit();

    }catch (\Exception $e){
        DB::rollBack();
        $msg = "信息提示:".$e->getMessage()."，行:".$e->getLine();
        return response(['code' => 0, 'msg'=>$msg]);
    }

    return response(['code'=>1,'msg'=>$address]);   //地址识别完成

}

来看看userRepository容器处理地址识别的各种业务代码

/**
 * Function:识别地址
 * Author:磊丰
 */
public function getDiscern($discernDel)
{
    if (empty($discernDel)) {
        throw new  \Exception("请传入要识别的地址");
    }

    $discernDel_left = explode ('[', $discernDel);
    if (!isset($discernDel_left[1])) {
        throw new  \Exception("你填写的地址规则错误,手机号码应该用[]");
    }
    $discernDel_right = explode (']', $discernDel_left[1]);
    if (!isset($discernDel_right[1]) || empty($discernDel_right[1])) {
        throw new  \Exception("你填写的地址规则错误,手机号码应该用[]");
    }

    $name = $discernDel_left[0];
    if (empty($name)) {
        throw new  \Exception("你填写的姓名有误！");
    }
    $mobile = $discernDel_right[0];
    if (empty($mobile) || checkMobile($mobile) == 0) {
        throw new  \Exception("你填写的手机号码格式有误！");
    }
    $address = trim ($discernDel_right[1]);
    if (empty($address)) {
        throw new  \Exception("你填写的地址不能为空");
    }

    $var_address = $this->getAddressArrar($address);
    $var_address['name'] = $name;
    $var_address['mobile'] = $mobile;

    return $var_address;

}

上面的方法处理手机，名称，和地址处理，地址处理有些繁杂，因为有时候填写的地址有不一样的，比如广西省，有些就填写广西壮族自治区，所以getAddressArrar方法处理地址匹配信息，根据自己的业务做调整，如下

/**
 * Function:地址的处理
 * Author:磊丰
 * @param $address
 * @return array
 * @throws \Exception
 */
function getAddressArrar($address){
    // 获取所有地址递归列表
    $regions = $this->getRegions();
    // 初始化数据
    $province = $city = $district = [];
    // 先查找省份-第一级地区
    $province = $this->checkAddress($address, $regions);
    if($province){

        $province_arr = ['110000','300000','404100','310000'];  //4个市辖区如果地址不存在二级（市辖区，县），则特殊处理
        if(!isset($province['region_code'])){
            throw new \Exception("请正确填写省份(市辖区)");
        }
        // 查找城市-第二级地区
        $city = $this->checkAddress($address, $province['list']);
        //这里只处理4个市辖区，可能还有多种情况，待发现
        if(in_array($province['region_code'],$province_arr)  && count($city['list']) == 0){
            $city = $this->checkAddress('市辖区', $province['list']);
            if($city){
                // 查找地区-第三级地区
                $district = $this->checkAddress($address, $city['list']);
                //如果没有找到，则查找另外一个二级地区
                if(!isset($district['region_code'])){
                    $city = $this->checkAddress('县', $province['list']);
                    // 查找地区-第三级地区
                    $district = $this->checkAddress($address, $city['list']);
                }
            }
        }else{

            if($city){
                // 查找地区-第三级地区
                $district = $this->checkAddress($address, $city['list']);
            }
        }

    }else{
        //省份不填，报错误
        throw new \Exception("省份没填写，请检查");
    }

    return $this->getAddressInfo($address, $province, $city, $district);
}

/**
 * 匹配正确的城市地址
 * @param $address
 * @param $city_list
 * @param int $force
 * @param int $str_len
 * @return array
 **/
function checkAddress($address, $city_list, $force=false, $str_len=2){
    $num = 0;
    $list = array();
    $result = array();
    // 遍历所有可能存在的城市
    foreach ($city_list as $city_key=>$city){
        $city_name = mb_substr($city['region_name'], 0, $str_len,'utf-8');
        // 判断是否存包含当前地址字符
        $city_arr = explode($city_name, $address);


        // 如果存在相关字眼，保存该地址的所有子地址
        if(count($city_arr) >= 2){
            // 必须名称长度同时达到当前比对长度
            if(strlen($city['region_name']) < $str_len){
                continue;
            }
            $num ++;
            if(isset($city['child'])){
                $list = $list + $city['child'];
            }

            $result[] = array(
                'region_code' => $city_key,
                'region_name' => $city['region_name'],
                'list' =>$list,
            );
        }
    }

    // 如果有多个存在，则加大字符匹配长度
    if($num > 1 || $force){
        $region_name1 = $result[0]['region_name'];
        $region_name2 = $result[1]['region_name'];

        if(strlen($region_name1) == strlen($region_name2) && strlen($region_name1) == $str_len){
            $region_id1 = $result[0]['region_code'];
            $region_id2 = $result[1]['region_code'];
            $index = $region_id1 > $region_id2 ? 1 : 0;
            $result = $result[$index];
            return $result;
        }
        return $this->checkAddress($address, $city_list, $force, $str_len+1);
    } else {
        $result[0]['list'] = $list;
        return $result[0];
    }
}

/**
 * 根据原地址返回详细信息
 * @param $address
 * @param $province
 * @param $city
 * @param $area
 * @return array
 **/
function getAddressInfo($address, $province, $city, $district){
    // 查找最后出现的地址 - 截取详细信息
    if(!isset($province['region_name'])){
        throw new \Exception("请检查并正确填写省份(市辖区)");
    }
    if(!isset($city['region_name'])){
        throw new \Exception("请检查并正确填写城市");
    }
    if(!isset($district['region_name'])){
        throw new \Exception("请检查并正确填写区域(县/区/镇)");
    }
    $find_str = '';
    if($province['region_name']){
        $find_str = $province['region_name'];
        if($city['region_name']){
            $find_str = $city['region_name'];
            if(isset($district['region_name']) && $district['region_name']){
                $find_str = $district['region_name'];
            }
        }
    }
    // 截取详细的信息
    $find_str_len = mb_strlen($find_str,'utf-8');
    for($i=0; $i<$find_str_len-1; $i++){
        $substr = mb_substr($find_str,0,$find_str_len - $i, 'utf-8');
        $end_index = mb_strpos($address, $substr);
        if ($end_index){
            $address = mb_substr($address, $end_index + mb_strlen($substr) , mb_strlen($address) - $end_index);
        }
    }
    !empty($find_str) && $find_str = '|\S*' . $find_str;
    $area['info'] = preg_replace("/\s*|,|，|:|：{$find_str}/i", '', $address);
    if(empty($area['info'])){
        throw new \Exception("详细地址不存在，请检查");
    }

    return $address = [
        'province' => $province['region_code'],
        'city'     => $city['region_code'],
        'district' => $district['region_code'],
        'info'     => $area['info']
    ];
}

前端html部分代码

基本上能看得懂的。jquery用到 getDiscern();方法，手机号码，姓名，地址等input这里就不一一列出了。大家根据下面的jquery都能想象到

<div class="form-group">
   {!! Form::label('discern', '自动识别地址:',['class' => 'control-label col-sm-2']) !!}
   <div class="col-sm-5">
      {!! Form::textarea('discern', '', ['class' => 'form-textarea form-control form-discern','rows' => 3]) !!}
   </div>
   <div class="col-sm-3" style="height: 75px;">
      <button type="button" class="btn btn-info btn-sm discern" onclick="getDiscern();" >提交识别</button>
      <small class="ruleGet" style="color: #676a74;">*查看模板</small>
   </div>

</div>

jquery代码部分

ajax post后交给url：getDiscern 处理，这个就是上面controller的方法，success返回的数据后再追加到每个input里，最后再清除掉自动识别地址框的数据

/**
 * 地址识别
 * @returns {boolean}
 */
function getDiscern(){
    var discernDel = $(".form-discern").val();
    if(!discernDel){
        alert("请输入要识别的地址");
        return false;
    }

    $.ajax({
        type: 'POST',
        url: "{!! route('admin.user.getDiscern') !!}",
        data: {
            '_token': csrf_token(),
            'discernDel': discernDel
        },
        dataType: 'json',
        timeout: 50000,
        success: function (res) {
            if (res.code == 1) {
                $("input[name='addr[linkman]']").val(res.msg.name);
                $("input[name='user_name']").val(res.msg.mobile);
                $("input[name='addr[address]']").val(res.msg.info);

                //触发change事件
         $('#province').val(res.msg.province).trigger('change');
                $('#city').val(res.msg.city).trigger('change');
                $('#area').val(res.msg.district).trigger('change');

                //识别后清除
         $(".form-discern").val("");

            } else {
                alert(res.msg);
            }
        }
    })

}

Homestesd中更换PHP版本

Thu, 02 Jun 2022 17:02:45 +0800

CLI 执行环境的 PHP 版本切换。

很多教程都是使用两个命令即可：

update-alternatives --display php //查看所有 php 版本和当前版本

update-alternatives --config php //执行后，会列出当前 php 所有版本和编号，输入编号，切换到执行的版本

假设我把 PHP 版本从 7.3 切换成了 7.4，是否可以直接通过 pecl 安装 PHP 扩展了呢，没那么简单！(需要直接正确更改 PHP 版本的直接跳到最后看步骤)。现在我要使用 pecl 安装 swoole 扩展，直接执行命令：

pecl install swoole

然后发现编译采用的 api 版本依然是 php7.3 的:

376 source files, building

running: phpize

Configuring for:

PHP Api Version: 20180731

Zend Module Api No: 20180731

Zend Extension Api No: 320180731

这当然不行了。直接 Ctrl + C 结束安装。

其实主要问题出在 PHP 编译环境上，编译环境默认还是 php7.3 的。

所以除了切换 PHP 本身的版本，PHP 扩展的编译环境也要相应切换。

所以更换 CLI 运行模式下的 PHP 版本完整的步骤如下

切换 cli 运行模式默认的 PHP 版本：

sudo update-alternatives --config php

选择 PHP7.4 即可

切换 phpize 版本：

sudo update-alternatives --config phpize

选择 7.4 版本

切换 php-config 版本

sudo update-alternatives --config php-config

同样选择 7.4 版本

切换 phpdbg 版本

sudo update-alternatives --config phpdbg

同样选择 7.4 版本

现在重新看一下跟 php 有关的环境变量：

ls -lha /etc/alternatives | grep php

php导入大批量csv

Thu, 19 May 2022 09:11:45 +0800

很多时候，因为数据统计，我们需要将数据库的数据导出到Excel等文件中，以供数据人员进行查看，如果数据集不大，其实很容易；但是如果对于大数集的导出，将要考虑各种性能的问题，这里以导出数据库一百万条数据为例，导出时间不过20秒，值得学习的一种大数据导出方式。

导出思路

需要考虑服务器内存

需要考虑程序运行的最大时间

缺少BOM头导致乱码的处理

如果导出数量过大，推荐使用循环导出，每次循环这里以导出一万条为例，循环100次即可全部导出

 <?php
    //让程序一直运行
    set_time_limit(0);
    //设置程序运行内存
    ini_set('memory_limit', '128M');

    $fileName = '测试导出数据';
    header('Content-Encoding: UTF-8');
    header("Content-type:application/vnd.ms-excel;charset=UTF-8");
    header('Content-Disposition: attachment;filename="' . $fileName . '.csv"');

    //打开php标准输出流
    $fp = fopen('php://output', 'a');

    //添加BOM头，以UTF8编码导出CSV文件，如果文件头未添加BOM头，打开会出现乱码。
    fwrite($fp, chr(0xEF).chr(0xBB).chr(0xBF));
    //添加导出标题
    fputcsv($fp, ['姓名', '年龄', '地区']);

    //链接数据库
    $dsn = "mysql:host=127.0.0.1;port=3306;dbname=db_www;charset=utf8";
    $pdo = new PDO($dsn, 'root', '');

    $step = 100; //循环次数
    $nums = 10000; //每次导出数量

    for($i = 0; $i < $step; $i++) {
        $start = $i * 10000;
        $sql = "SELECT uname,age,city FROM `hd_test` ORDER BY `id` LIMIT {$start},{$nums}";
        $pdostatement = $pdo->query($sql);
        $result = $pdostatement->fetchAll(PDO::FETCH_ASSOC);
        foreach ($result as $item) {
            fputcsv($fp, $item);
        }
        //每1万条数据就刷新缓冲区
        ob_flush();
        flush();
    }

精品域名出售

Tue, 17 May 2022 10:21:07 +0800

以下好米出售

看房直通车开发直通车 www.kfztc.cn

看房直通车开发直通车 www.kfztc.com

在线直播装修直播在线招标 www.zxzb.com.cn

中信大学中心大学找小点心中兴电信 www.zxdx.cn

重庆001 www.cq001.com

联系邮箱 xpxw#xpxw.com （替换#为@）

api开发签名验证

Wed, 29 Dec 2021 09:10:06 +0800

开发过程中，我们经常会与接口打交道，有的时候是调取别人网站的接口，有的时候是为他人提供自己网站的接口，但是在这调取的过程中都离不开签名验证。

我们在设计签名验证的时候，请注意要满足以下几点：

可变性：每次的签名必须是不一样的。
时效性：每次请求的时效，过期作废等。
唯一性：每次的签名是唯一的。
完整性：能够对传入数据进行验证，防止篡改。

这里介绍一种方式，是目前国内互联网公司常用的一种方式，其中淘宝的支付宝支付接口、淘宝开放平台接口、腾讯开放平台等应用的一种方式。

一、签名参数sign生成的方法

第1步: 将所有参数（注意是所有参数），除去sign本身，以及值是空的参数，按参数名字母升序排序。

第2步: 然后把排序后的参数按参数1值1参数2值2…参数n值n（这里的参数和值必须是传输参数的原始值，不能是经过处理的，如不能将"转成”后再拼接）的方式拼接成一个字符串。

第3步: 把分配给接入方的验证密钥key拼接在第2步得到的字符串前面。

第2步: 在上一步得到的字符串前面加上验证密钥key(这里的密钥key是接口提供方分配给接口接入方的)，然后计算md5值，得到32位字符串，然后转成大写.

第4步: 计算第3步字符串的md5值(32位)，然后转成大写,得到的字符串作为sign的值。

举例：

假设传输的数据是/interface.php?sign=sign_value&p2=v2& p1=v1&method=cancel&p3=&pn=vn（实际情况最好是通过post方式发送），其中sign参数对应的sign_value就是签名的值。

第一步，拼接字符串，首先去除sign参数本身，然后去除值是空的参数p3，剩下p2=v2&p1=v1&method=cancel& amp;pn=vn，然后按参数名字符升序排序，method=cancel&p1=v1&p2=v2&pn=vn.

第二步，然后做参数名和值的拼接，最后得到methodcancelp1v1p2v2pnvn
第三步，在上面拼接得到的字符串前加上验证密钥key，我们假设是abc，得到新的字符串abcmethodcancelp1v1p2v2pnvn

第四步，然后将这个字符串进行md5计算，假设得到的是abcdef，然后转为大写，得到ABCDEF这个值即为sign签名值。

注意，计算md5之前请确保接口与接入方的字符串编码一致，如统一使用utf-8编码或者GBK编码，如果编码方式不一致则计算出来的签名会校验失败。

二、签名验证方法：

根据前面描述的签名参数sign生成的方法规则，计算得到参数的签名值，和参数中通知过来的sign对应的参数值进行对比，如果是一致的，那么就校验通过，如果不一致，说明参数被修改过。

三、下面直接看代码

<?php

// 设置一个公钥(key)和私钥(secret)，公钥用于区分用户，私钥加密数据，不能公开
$key = "c4ca4238a0b923820dcc509a6f75849b";
$secret = "28c8edde3d61a0411511d3b1866f0636";

// 待发送的数据包
$data = array(
    'username' => 'abc@qq.com',
    'sex' => '1',
    'age' => '16',
    'addr' => 'guangzhou',
    'key' => $key,
    'timestamp' => time(),
);

// 获取sign
function getSign($secret, $data) {
    // 对数组的值按key排序
    ksort($data);
    // 生成url的形式
    $params = http_build_query($data);
    // 生成sign
    $sign = md5($params . $secret);
    return $sign;
}

// 发送的数据加上sign
$data['sign'] = getSign($secret, $data);

/**
 * 后台验证sign是否合法
 * @param  [type] $secret [description]
 * @param  [type] $data   [description]
 * @return [type]         [description]
 */
function verifySign($secret, $data) {
    // 验证参数中是否有签名
    if (!isset($data['sign']) || !$data['sign']) {
        echo '发送的数据签名不存在';
        die();
    }
    if (!isset($data['timestamp']) || !$data['timestamp']) {
        echo '发送的数据参数不合法';
        die();
    }
    // 验证请求， 10分钟失效
    if (time() - $data['timestamp'] > 600) {
        echo '验证失效， 请重新发送请求';
        die();
    }
    $sign = $data['sign'];
    unset($data['sign']);
    ksort($data);
    $params = http_build_query($data);
    // $secret是通过key在api的数据库中查询得到
    $sign2 = md5($params . $secret);
    if ($sign == $sign2) {
        die('验证通过');
    } else {
        die('请求不合法');
    }
}
?>

巧用Python脚本解决自动化图形验证码

Fri, 19 Nov 2021 08:37:17 +0800

解决UI自动化过程中的图文验证码问题，过程大致分为两个步骤：

1. 自动下载网页上指定的图片
2. 识别图片上的文本内容

本文以“识别页面上指定图片的文本“为例。

代码实现效果

环境准备

Pytesseract
Tesseract-OCR
Pillow

手动安装pytesseract库

命令：

pip install pytesseract

安装Tesseract-OCR.exe

下载地址

http://8rr.co/Krrw

双击exe程序直接安装即可

配置环境变量

校验安装成功

安装Pillow包

Python自带的图文简单处理模块，正常安装Python的时候会自动安装，故无需另外手动安装。（若没自动安装则可手动安装：pip install Pillow）

代码正文

初始化浏览器和元素定位方式

初始化并放大浏览器初始化元素定位方式：本文使用CSS选择器方式定位

获取图片

页面全屏截图截图转为Image对象获取指定图片的大小和位置裁剪图片

识别图片上的文本

识别裁剪后的图片上的文本内容

问题：

Python脚本运行报错：

解决方案：

修改tesseract文件的默认路径

Python生成遍历暴力破解密码

Fri, 19 Nov 2021 08:36:16 +0800

是暴力破解，是把所有的密码进行的遍历，也就是从1到。。。。无穷的列举出来

import itertools as its ##这个库，python自带的

import rarfile #这个是操作rar压缩包的，如果你需要破解别的密码的话，比如pdf，那么请你安装下pdf的第三方库

### 这个根据需要来，这边测试的是破解rar压缩包

path1 = "E:\\python2\\rar\\1.rar" # 需要解压的文件路径及地址

path2 = "E:\\python2\\rar" # 需要解压到的文件夹地址

##下面的是你的密码可能用的字符#

words = "1234567890abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ!#$%&'( )*+,-./:;<=>?@[]^_`{|}~" ##密码里面含有大小写字母，数字以及特殊符号

re=4 ##这个是与下面的repeat相对应的，代表你需要生成几位的数组。这里是4，代表生成4位的数组。

while 2>1:

r = its.product(words,repeat=re)

for i in r:

# print(type(i))

a ="".join(i) ##通过.join将数组里面的元素转换成字符串

print("当前测试密码:",a)

###尝试测试密码，如果错误continue，进入下一次循环

try:

rf = rarfile.RarFile(path1) # pwd为解压密码

rf.extractall(path=path2, pwd=a)

print('密码破解成功:',a)

exit(0)

except Exception as e:

print(e)

continue

else:

re+=1 ###如果将所有的4位字符组合尝试完成后，还是没有破解到密码，那么会将4再加上1，进行5位数的破解（这里没有具体写出，为了代码的整洁，没有写出如何循环到5位数密码）

SCRAPY爬虫框架的使用

Fri, 19 Nov 2021 08:32:51 +0800

对于初学者来说还是需要有一定的基础作为铺垫的学习。我将从下方的思维导图中进行逐步的解析讲述。

实验工具即环境：

　　笔记本:Y9000X 2020

　　系统：win10

　　Python版本：python3.8.6

　　pycharm版本：pycharm 2021.1.2(Professional Edition)

一、安装

下载tiwisted，此处位下载地址：http://www.lfd.uci.edu/~gohlke/pythonlibs/#twisted

下载好后打开终端进行安装scrapy的必要模块　　

安装tiwisted，pip install tiwisted-xxxx

安装pywin32：pip install pywin32　

安装scrapy：pip install scrapy

安装完成后在终端输入scrapy如果没有报错即安装成功。

二、创建scrapy的工程

在pycharm中创建好的项目中的中终端输入

scrapy startproject SDFDQPRO

检查下项目目录即可发现多出了如下的工程目录

三、创建一个爬虫目录

在终端找到之前所创建的工程目录，在此目录下输入scrapy genspider sdfdq_cj http://www.csrc.gov.cn/pub/shandong/

后方网站为中国证券监督管理委员会山东监管局。

运行后可发现工程目录中多出一个名为sdfdq_cj.py的爬虫文件。

进入到爬虫文件中可以看到如下代码

import scrapy

class SdfdqCjSpider(scrapy.Spider):

name = 'sdfdq_cj'

# 表示被允许的url

# allowed_domains = ['http://www.csrc.gov.cn/pub/shandong/']

# 起始url列表:该列表中存放的url会被scrapy自动进行请求的发送

start_urls = ['http://www.csrc.gov.cn/pub/shandong/sdfdqyxx/']

# 用作于数据解析：response参数表示的就是请求成功后对应的响应对象

def parse(self, response):

pass

接下来对网站解析选取需要获取的内容

四、数据解析

通过对网站的查看可以看出我们需要的是辅导期中的企业基本情况、工作进展报告、工作总结总的标题，日期以及链接。

scrapy对网站的解析沿用了xpath的解析方式。

import scrapy

class SdfdqCjSpider(scrapy.Spider):

name = 'sdfdq_cj'

# 表示被允许的url

# allowed_domains = ['http://www.csrc.gov.cn/pub/shandong/']

# 起始url列表:该列表中存放的url会被scrapy自动进行请求的发送

start_urls = ['http://www.csrc.gov.cn/pub/shandong/sdfdqyxx/']

# 用作于数据解析：response参数表示的就是请求成功后对应的响应对象

def parse(self, response):

li_list = response.xpath('//div[@class="zi_er_right"]//div[@class="fl_list"]//li')

for li in li_list:

# xpath返回的是列表，但是列元素一定是Selector类型的对象

# extract可以将Selector对象中的data参数存储的字符串提取出来

# 列表调用了extract之后则表示将列表中每一个data参数存储的字符串提取出来

title = li.xpath('./a//text()')[0].extract()

date = li.xpath('./span/text()')[0].extract()

url = 'http://www.csrc.gov.cn/pub/shandong/sdfdqyxx'+li.xpath('./a/@href').extract_first()

print('title',title)

print('url',url)

print('date',date)

对网站的内容解析后运行scrapy 终端输入 scrapy crawl sdfdq_cj 注意：此语句的运行目录

可以看到我们想获取的内容：

内容获取到我们必须要将其持久化存储才有意义：
五、scrapy的持久化存储

1）基于指令的持久化存储：

要求：只可以将parse的方法返回值存储到本地的文本文件中

def parse(self, response):

# 创建一个列表接收获取的数据

all_data = []

li_list = response.xpath('//div[@class="zi_er_right"]//div[@class="fl_list"]//li')

for li in li_list:

# xpath返回的是列表，但是列元素一定是Selector类型的对象

# extract可以将Selector对象中的data参数存储的字符串提取出来

# 列表调用了extract之后则表示将列表中每一个data参数存储的字符串提取出来

title = li.xpath('./a//text()')[0].extract()

date = li.xpath('./span/text()')[0].extract()

url = 'http://www.csrc.gov.cn/pub/shandong/sdfdqyxx'+li.xpath('./a/@href').extract_first()

# 基于终端指令的持久化存储操作

dic = {

'title':title,

'url':url,

'date':date

}

all_data.append(dic)

return all_data

接下来在终端中输入 scrapy crawl sdfdq_cj -o ./sdfdq.csv

将获取的文本内容存储到对应路径下的sdfdq.csv文本文件中

-----第二更-----

补充下知识点在进行scrapy时需要对配置文件settings的权限进行一定的修改：

BOT_NAME = 'SDFDQPRO'

# 日志输出

LOG_LEVEL = 'ERROR'

SPIDER_MODULES = ['SDFDQPRO.spiders']

NEWSPIDER_MODULE = 'SDFDQPRO.spiders'

# UA伪装

USER_AGENT ='Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/92.0.4515.131 Safari/537.36 Edg/92.0.902.73'

# Crawl responsibly by identifying yourself (and your website) on the user-agent

#USER_AGENT = 'SDFDQPRO (+http://www.yourdomain.com)'

# Obey robots.txt rules

# ROBOTSTXT_OBEY协议此条分享严格遵守此协议/可根据个人的需求将True 改为FALSE

ROBOTSTXT_OBEY = True

2）基于管道的持久化存储

数据解析的步骤昨天已经分享好了接下来按照上方流程图来进行基于管道的存储方式

一、在Item中定义相关属性：

在项目目录下打来items文件进行配置

import scrapy

class SdfdqproItem(scrapy.Item):

# define the fields for your item here like:

title = scrapy.Field()

url = scrapy.Field()

date = scrapy.Field()

二、将数据封存到item类型对象中

将数据封存到item类型对象中我们需要在爬虫文件中引用到配置好的items文件中的类的方法SdfdqprItem

#应用item中的方法

from SDFDQPRO.items import SdfdqproItem

#将解析后数据封装到Item中

item['title'] = title

item['url'] = url

item['date'] = date

三、Item类型的对象提交给管道进行持久化存储：

yield item

四、在管道接收Item数据进行存储

在pipelines.py文件中进行管道接收Item的操作，

因为我们获取数据的方式基于管道所以没传输一次管道都会运行一次，故需要自己写两个方法（open_spider,close_spider）在里面

class SdfdqproPipeline:

fp = None

# 开始只会被调用一次

def open_spider(self,spider):

print('spider_start')

self.fp=open('fdq.txt','w',encoding='utf-8')

# 用来处理Item类型对象

# 此方法可接收爬虫文件提交过来的Item对象

# 没接收一次item就会被调用一次

def process_item(self, item, spider):

title = item['title']

url = item['url']

date = item['date']

self.fp.write(title+','+url+','+date+'\n')

return item

# 结束只会被调用一次

def close_spider(self,spider):

self.fp.close()

print('spider_end')

五、开启管道

在配置文件中找到下方的代码取消注释即可开启管道

ITEM_PIPELINES = {   'SDFDQPRO.pipelines.SdfdqproPipeline': 300,#    数值表示优先级 越小优先级越大}

截止至2021.11.10爬虫文件的全部代码在下面啦！！

import scrapy

from SDFDQPRO.items import SdfdqproItem

class SdfdqCjSpider(scrapy.Spider):

name = 'sdfdq_cj'

# 表示被允许的url

# allowed_domains = ['http://www.csrc.gov.cn/pub/shandong/']

# 起始url列表:该列表中存放的url会被scrapy自动进行请求的发送

start_urls = ['http://www.csrc.gov.cn/pub/shandong/sdfdqyxx/']

# 用作于数据解析：response参数表示的就是请求成功后对应的响应对象

def parse(self, response):

# 创建一个列表接收获取的数据

all_data = []

li_list = response.xpath('//div[@class="zi_er_right"]//div[@class="fl_list"]//li')

for li in li_list:

# xpath返回的是列表，但是列元素一定是Selector类型的对象

# extract可以将Selector对象中的data参数存储的字符串提取出来

# 列表调用了extract之后则表示将列表中每一个data参数存储的字符串提取出来

title = li.xpath('./a//text()')[0].extract()

date = li.xpath('./span/text()')[0].extract()

url = 'http://www.csrc.gov.cn/pub/shandong/sdfdqyxx'+li.xpath('./a/@href').extract_first()

# 基于终端指令的持久化存储操作

dic = {

'title':title,

'url':url,

'date':date

}

all_data.append(dic)

# 封装管道

item = SdfdqproItem()

item['title'] = title

item['url'] = url

item['date'] = date

# 将item提交给管道

yield item

--------第三更--------

基于管道将数据存储到数据库

python链接数据库的方法：

安装：pymsql pip install pymysql

一、新建一个数据库来存储即将接收的数据

注意：在表中需要和我们获取的数据的字段保持一致

CREATE TABLE `fdq` (
  `title` varchar(255) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL,
  `url` varchar(255) COLLATE utf8_bin DEFAULT NULL,
  `date` datetime DEFAULT NULL) ENGINE=InnoDB DEFAULT CHARSET=utf8mb3 COLLATE=utf8_bin

在piplines.py中设置数据库的连接和存储操作

import pymysql

class SdfdqproPipeline(object):

conn = None

cursor = None

def open_spider(self,spider):

print('write_start')

# 设置数据库接口

self.conn = pymysql.Connect(host='127.0.0.1', port=3306, user='root', password='123', db='fdq',charset='utf8')

def process_item(self,item,spider):

# 设置数据游标

self.cursor = self.conn.cursor()

try:

self.cursor.execute('insert into fdq values("%s","%s","%s")'%(item["title"],item["url"],item['date']))

self.conn.commit()

# 如果数据存储异常就回滚

except Exception as e:

print(e)

self.conn.rollback()

return item

def close_spider(self,spider):

# 关闭数据库链接

self.conn.close()

self.cursor.close()

print('write_over')

然后开始运行 scrapy crawl sdfdq_cj j 完成后就可以在我们的数据库中看到获取后的数据了：

PHP通过jwt实现接口验证

Fri, 19 Nov 2021 08:31:12 +0800

1、先定义controller控制器基类Base.php，作用是继承改类的，都需要进行token验证；

2、在定义一个前端api基类IndexBase.php，作为一个中间层，里面存放验证后token里面的用户信息

3、书写PHP实现jwt基类PhpJwt.php，改类主要是获取token，和验证token;

上面三者的关系是，IndexBase.php继承Base.php继承PhpJwt.php。

前端与后端验证逻辑如下：

1、前端请求接口，后台验证token;

2、没有token，给出提示，前端输入账号密码（微信公众号类，直接通过非静默授权，获取用户openid）,进行验证用户信息。验证通过后，将用户uid加载到jwt载荷中，生成token。一个验证toekn（过期时间比较短），一个刷新token（过期时间较长，用于避免每次段时间内，用户重复登录）。

3、前端通过登录拿到两个token后，存起来。然后在请求需要验证的接口时，在header头部加入参数authorization：用户toekn；来进行验证，后台通过token来解析出当前请求用户的信息。

核心代码

　　　　1、PhpJwt.php

<?php

namespace lib;

class PhpJwt {

//头部

private static $header = array(

'alg'=>'HS256', //生成signature的算法

'typ'=>'JWT' //类型

);

//使用HMAC生成信息摘要时所使用的密钥 md5('jjgw2021')

private static $key = '99dc2d62ab85bcd9185f3e9324db5567';

//md5('jjgw2021admin')

private static $admin_key = '12d44e568140bf62d84d9cb3e20b1103';

//请求jwt 过期时间 2小时（上线后改为10分钟）

private static $request_expect = 3600;

//刷新jwt 过期时间 24小时

private static $refresh_expect = 86400;

private static $admin_request_expect = 1800;

private static $admin_refresh_expect = 7200;

//判断是否后端token

private static $is_admin = 'is_admin';

/*** 获取jwt token

* @param array $payload jwt载荷格式如下非必须

* [

* 'iss'=>'jwt_admin', //该JWT的签发者

* 'iat'=>time(), //签发时间

* 'exp'=>time()+7200, //过期时间

* 'nbf'=>time()+60, //该时间之前不接收处理该Token

* 'sub'=>'www.admin.com', //面向的用户

* 'jti'=>md5(uniqid('JWT').time()) //该Token唯一标识

* ]

* @param int $refresh 是否刷新token 1是

* @param int $is_admin 是否后台调用 1是 0 admin

* @return string

public static function getToken(array $payload, $refresh = 0, $is_admin = 0)

{

$exp = $refresh ? ($is_admin ? self::$admin_refresh_expect : self::$refresh_expect) : ($is_admin ? self::$admin_request_expect : self::$request_expect);

$load = [

'iat' => time(),

'exp' => time() + $exp,

'jti' => md5(uniqid('JWT').time())

];

$payload = array_merge($load, $payload);

$key = ($is_admin == 1 ? self::$admin_key : self::$key);

$base64header = self::base64UrlEncode(json_encode(self::$header,JSON_UNESCAPED_UNICODE));

$base64payload = self::base64UrlEncode(json_encode($payload,JSON_UNESCAPED_UNICODE));

$token = $base64header.'.'.$base64payload.'.'.self::signature($base64header.'.'.$base64payload,$key,self::$header['alg']);

return $token;

}

/**

* 验证token是否有效,默认验证exp,nbf,iat时间

* @param string $Token 需要验证的token

* @return array

public static function verifyToken($Token)

{

$tokens = explode('.', $Token);

if (count($tokens) != 3){

return [

'code' => 100,

'msg' => '验证失败'

];

}

list($base64header, $base64payload, $sign) = $tokens;

//获取jwt算法

$base64decodeheader = json_decode(self::base64UrlDecode($base64header), JSON_OBJECT_AS_ARRAY);

if (empty($base64decodeheader['alg'])){

return [

'code' => 100,

'msg' => '验证失败'

];

}

$payload = json_decode(self::base64UrlDecode($base64payload), JSON_OBJECT_AS_ARRAY);

$key = !empty($payload[self::$is_admin]) ? self::$admin_key : self::$key;

//签名验证

if (self::signature($base64header . '.' . $base64payload, $key, $base64decodeheader['alg']) !== $sign){

return [

'code' => 100,

'msg' => '签名验证失败'

];

}

//签发时间大于当前服务器时间验证失败

if (isset($payload['iat']) && $payload['iat'] > time()) {

return [

'code' => 100,

'msg' => '签发时间大于当前服务器时间,验证失败'

];

}

//过期时间小宇当前服务器时间验证失败

if (isset($payload['exp']) && $payload['exp'] < time()) {

return [

'code' => 200,

'msg' => '已过期'

];

}

//该nbf时间之前不接收处理该Token

if (isset($payload['nbf']) && $payload['nbf'] > time()) {

return [

'code' => 100,

'msg' => '验证失败'

];

}

return [

'code' => 0,

'msg' => '验证成功',

'data' =>$payload

];

}

/**

* base64UrlEncode https://jwt.io/ 中base64UrlEncode编码实现

* @param string $input 需要编码的字符串

* @return string

private static function base64UrlEncode($input)

{

return str_replace('=', '', strtr(base64_encode($input), '+/', '-_'));

}

/**

* base64UrlEncode https://jwt.io/ 中base64UrlEncode解码实现

* @param string $input 需要解码的字符串

* @return bool|string

private static function base64UrlDecode($input)

{

$remainder = strlen($input) % 4;

if ($remainder) {

$addlen = 4 - $remainder;

$input .= str_repeat('=', $addlen);

}

return base64_decode(strtr($input, '-_', '+/'));

}

/**

* HMACSHA256签名 https://jwt.io/ 中HMACSHA256签名实现

* @param string $input 为base64UrlEncode(header).".".base64UrlEncode(payload)

* @param string $key

* @param string $alg 算法方式

* @return mixed

private static function signature($input, $key, $alg )

{

$alg_config = array(

'HS256'=>'sha256'

);

return self::base64UrlEncode(hash_hmac($alg_config[$alg], $input, $key,true));

}

复制代码

　　　　2、Base.php

复制代码

<?php

* @Fun: 控制器基类

* @User: JessieK

* @Date: 2021-08-19 18:06:47

namespace app\controller;

use app\BaseController;

use think\facade\Request;

use lib\PhpJwt;

class Base extends BaseController

{

//会员uid

protected $uid;

//会员unionid

protected $unionid;

//会员openid

protected $openid;

//jwt

protected $payload;

public function __construct()

{

//更新中

// $this->apiResult(-100, '网站正在火速更新中，请稍后---');

// $controller = strtolower(Request::controller());

$action = strtolower(Request::action());

if(!in_array($action, ['wechatlogin', 'index', 'coc', 'arealist', 'uploadimg', 'uploadimgstring'])){

//验证token

$this->checkToken();

}

if(!in_array($action, ['wechatlogin', 'index', 'coc', 'arealist', 'uploadimg', 'getjwt', 'uploadimgstring'])){

//验证sign

// $this->verifySign();

}

/**

* 验证token

public function checkToken()

{

$token = empty(Request::header()['authorization']) ? '' : Request::header()['authorization'];

if(!$token){

$this->apiResult(-100, 'Authorization不能为空');

}

$get_payload = PhpJwt::verifyToken($token);

switch($get_payload['code']){

case 100:

$this->apiResult(-100, 'token验证失败');

break;

case 200:

$this->apiResult(1000, 'token已过期');

}

$this->uid = $get_payload['data']['uid'];

$this->unionid = $get_payload['data']['unionid'];

$this->openid = $get_payload['data']['openid'];

$this->payload = $get_payload['data'];

}

/**

* @name: 验证签名

* @param {*}

* @return {*}

public function verifySign()

{

$token = Request::header()['authorization'];

list($base64header, $base64payload, $jwtsign) = explode('.', $token);

$params = Request::post();

if(empty($params['sign'])){

$this->apiResult(-100 ,'sign不能为空');

}

if(empty($params['timestamp'])){

$this->apiResult(-100, 'timestamp不能为空');

}

//10分钟有效毫秒级

if (time() * 1000 - $params['timestamp'] > 600000) {

// $this->apiResult(-100, '请求过期');

}

$request_sign = $params['sign'];

//对关联数组按照键名进行升序排序

unset($params['sign']);

ksort($params);

$param_str = '';

foreach ($params as $k => $v) {

$v = is_array($v) ? json_encode($v, JSON_UNESCAPED_SLASHES|JSON_UNESCAPED_UNICODE) : $v;

$param_str .= $k.$v;

}

$restr = $param_str.$jwtsign;

$sign = md5($restr);

if (strtolower($request_sign) != strtolower($sign)) {

$this->apiResult(-100, '签名验证失败');

}

public function apiResult($code, $msg, $data = [])

{

$result = [

'code' => $code,

'msg' => $msg,

'data' => $data,

];

exit(json_encode($result, JSON_UNESCAPED_UNICODE));

}

　　　　3、IndexBase.php

<?php

* @Fun: 前台api基类

namespace app\controller;

use app\model\Member;

use think\facade\Request;

class IndexBase extends Base

{

//会员信息

protected $member_info;

public function __construct()

{

parent::__construct();

if(!$this->openid){

$this->apiResult(-100, '缺少参数', ['msg' => 'openid为空']);

}

$memberModel = new Member();

$member_info = $memberModel->getUserInfoGather($this->openid);

if(!$member_info){

$this->apiResult(1001, '会员信息不存在');

}

//锁粉操作

$from_uid = Request::get('from_uid');

if(empty($member_info['from_uid']) && !empty($from_uid)){

$memberModel->setFromUid($member_info['uid'], $from_uid, Request::url(true));

}

// addlog('errorlog/request/', 'pro', '请求url='.json_encode(request()->get(), JSON_UNESCAPED_UNICODE));

$this->member_info = $member_info;

}

最后书写业务代码

　　　　1、对于需要验证token的，只需要继承IndexBase.php即可，基类里面直接对前端传过来的token进行验证是否合法。

　　　　2、用户在登录后，获取到请求token，进行接口验证；请求token过期后，不用重新登录，用户用刷新token刷新，获取到新的请求token，既可以重新获取验证，拿到用户信息，避免频繁登录。

　　　　3、上述代码，还附带verfySign签名，这个主要是可以配合token进行一起使用。jwt实现验证用户身份，签名实现接口请求是否合法。大致逻辑，在每次请求接口时带上签名和时间戳，具体签名逻辑可看上述代码。

Notepad++

如何对api接口做限流

漏桶算法 (Leaky Bucket)

令牌桶算法 (Token Bucket)

用laravel 实现 地址自动识别

Homestesd中更换PHP版本

php导入大批量csv

精品域名出售

api开发签名验证

巧用Python脚本解决自动化图形验证码

代码实现效果

环境准备

手动安装pytesseract库

安装Tesseract-OCR.exe

下载地址

配置环境变量

校验安装成功

安装Pillow包

代码正文

初始化浏览器和元素定位方式

获取图片

识别图片上的文本

问题：

Python脚本运行报错：

解决方案：

Python生成遍历暴力破解密码

SCRAPY爬虫框架的使用

PHP通过jwt实现接口验证

用laravel 实现地址自动识别