swoole是如何实现任务定时自动化调度的?

swoole是如何实现任务定时自动化调度的?

https://www.muzilong.cn/article/117

开发环境

环境:lnmp下进行试验。

框架:laravel5

 

问题描述

这几天做银行对帐接口时,踩了一个坑,具体需求大致描述一下。

银行每天凌晨后,会开始准备昨天的交易流水数据,需要我们这边请求拿到。

因为他们给的是一个base64加密的zip压缩流,解开以后可以得到txt文件,里面就是我们需要的数据了。

业务程序写好以后,随手丢了一个定时任务就去睡觉了。

哪知道第二天上班的时候,检查。发现并没有拿到数据,查询一下日志的时候发现,凌晨服务端请求的时候,银行接口返回了:系统错误信息。

咨询银行那边后,银行那边相关人员建议我们多请求几次,但是在多次请求中,我发现银行那边是有频率限制的,最后得知,此接口只能半个小时才能请求一次。这就比较尴尬了,因为我不知道银行那边什么时候能返回数据给我。

于是这个问题怎么解决呢?理想的情况是,服务端请求数据,银行那边没有返回。然后程序等半个小时后,再请求一次,这样一直到银行那边返回正确的数据中止。

 

问题分析

这个功能换作别的语言也许不难,但是通过php实现的话,那就比较麻烦了。通常的话,我们可以搭配linux下的cron来实现,比如我们可以在凌晨到6:00之间做一个定时任务,每半个小时扫描一次php脚本,如果发现银行那边的状态依旧为失败的话,我们就执行一次php脚本去请求数据。直到请求到正确的数据,然后把状态更新为成功。

这不失为一种方法,但太傻了。比如说银行那边比较正常,凌晨,也就是第一次请求的时候,就已经返回了正确的数据,那么我们的cron脚本还傻傻的每个半个小时执行一次,好蠢!~

或者我们可以尝试使用linux下的at命令,但感觉还是不够优雅。

解决问题

于是决定给laravel扩展一个swoole插件来解决此问题,swoole的定时任务很完美的解决了我们目前的问题。

首先我们需要把swoole扩展安装好,具体过程略。
装好以后,我们写一个swoole简易的服务端测试脚本,注意,此脚本是放在app/Console/Commands/下的,笔者是放在了app/Console/Commands/Swoole/swoole.php下,具体代码为

<?php

namespace App\Console\Commands\Swoole;

use Illuminate\Console\Command;

class swoole extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'swoole {action}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = "Let's use swoole !";

    private $serv;

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        $arg = $this->argument('action');
        switch ($arg) {
            case 'start':
                $this->info('swoole server started');
                $this->start();
                break;
            case 'stop':
                $this->info('stoped');
                $this->stop();
                break;
            case 'restart':
                $this->info('restarted');
                break;
        }
    }

    private function start()
    {
        $this->serv = new \swoole_server("127.0.0.1", 9501);
        $this->serv->set(array(
            'worker_num' => 8,
            'daemonize' => false,
            'max_request' => 10000,
            'dispatch_mode' => 2,
            'task_worker_num' => 8,
            'task_ipc_mode' => 3,
            'log_file' => storage_path('logs/taskqueue.log'),
        ));

        $this->serv->on('Receive', array($this, 'onReceive'));
        $this->serv->on('Task', array($this, 'onTask'));
        $this->serv->on('Finish', array($this, 'onFinish'));
        $this->serv->start();

    }

    public function onReceive(\swoole_server $serv, $fd, $from_id, $data)
    {
        $serv->task($data);
    }

    public function onTask($serv, $task_id, $from_id, $data)
    {
        $timeon = (3) * 1000;
        if ($timeon > 0) {
            $serv->after($timeon, function () {
                //业务逻辑处
                exec('php /path/to/root/artisan Test:Command');
            });
        }
        return date('Y-m-d H:i:s') . "第一次执行";
    }

    public function onFinish($serv, $task_id, $data)
    {

        echo "Task finish\n";
    }

    private function stop()
    {
        exec('/usr/bin/killall php');
    }

}

 

 

这是服务端,我们主要用到了after方法,模拟的话,是三秒一执行。实际应该是三十分钟

然后我们随便写一个客户端连接类

<?php
/**
 * Created by PhpStorm.
 * User: nosay
 * Date: 4/13/18
 * Time: 9:27 PM
 */

namespace App\Extension\php\Swoole;


class swoole{

    private $data;
    private $client;

    public function __construct($data){
        $this->data = $data;
        $this->client = new \swoole_client(SWOOLE_SOCK_TCP);
    }

    public function connect(){


        if( !$this->client->connect("127.0.0.1", 9501 , 1) ) {
            echo "Error";
        }


        $this->client->send($this->data);
    }



}

于是我们在银行脚本中就可以去执行了

<?php

namespace App\Console\Commands\Test;

use App\Extension\php\Swoole\swoole;
use Illuminate\Console\Command;

class TestCommand extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'Test:Command';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Command Test';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        //这里是业务逻辑
        //如果银行那边返回的为false的话,那么我们把他交给swoole的定时脚本
        $status = false;

        if(!$status)
        {
            $swoole = new swoole("hehe");
            $swoole->connect();
        }



    }
}

https://mp.weixin.qq.com/s/e_ophgURO6qRvfKd3YDJXQ

 
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/112700.html原文链接:https://javaforall.net

(0)
上一篇 2021年10月31日 下午11:00
下一篇 2021年11月3日 上午6:00


相关推荐

  • ZIP 压缩解压命令

    ZIP 压缩解压命令压缩一个文件,打开cmd窗口 zip f:\wenjian.zip f:\wenjian.txt压缩一种格式的文件 zip f:\wenjian.zip f:\*.txt压缩文件夹及里面的内容 -r表示压缩文件夹wenjian及里面的内容 zip-rf:\wenjian.zip wenjian  移除压缩包里的一

    2022年5月16日
    58
  • 【尚硅谷】JavaScript基础&实战丨JS入门到精通_01-06

    【尚硅谷】JavaScript基础&实战丨JS入门到精通_01-061.JavaScript–ECMAScript–DOM–BOM2.JS基础JS代码需要编写到<scripttype=”text/javascript”> console.log(“HelloWorld”);</script>

    2025年8月8日
    5
  • MySQL字符串截取_mysql删除字符串后的字符

    MySQL字符串截取_mysql删除字符串后的字符先给你们看看表数据is_type:0不推荐|1首页广告推荐 | 2 商品页广告推荐 | 3 列表页广告推荐 4:购物车广告推荐sort_num:0,0,0,0  第一个对呀1   |    第二个对应2   |  第三个对应3 | 第四个对呀4id   name     is_type     sort_num     is_show

    2022年10月2日
    4
  • 测试用例模板案例

    测试用例模板案例qq账号:用例编号 所属模块 用例标题 优先级 前置条件 输入数据 操作步骤 预期结果 实际结果 是否通过 测试人员 测试时间 qq_dl_001 登录 账号为六位自然数组成 高 输入账号和密码点击登录 账号:123456密码:abcd12 1:输入账号 2:输入密码 3:点击”登录” 1:账号被填充 2:密码被填充 3:登录成功,跳转主界面 1:账号被填充

    2022年7月17日
    26
  • 此工作站和主域间的信任关系失败 原因及解决办法[通俗易懂]

    此工作站和主域间的信任关系失败 原因及解决办法[通俗易懂]原因:域控服务器没有客户端的主机名(可能删除了,或重装系统后没添加到域控)处理:在域控上确认客户端主机名是否被禁用,如已禁用,启动即可。转载于:https://www.cnblogs.com/sjdn/p/5923669.html…

    2022年10月19日
    7
  • 微信公众号开发流程指南

    微信公众号开发流程指南微信公众号开发流程指南一 物料准备二 开发须知 0 接入验证 1 消息类型概括 MsgType 2 申请服务号的原因为账号类型所支持功能不同 职能不同 3 当开启服务器配置后 公众号的原始菜单将会失效 会以自定义菜单为准 4 如下文介绍 Api 中出现 Token 字样 则统一为通过 AppId 和 AppSecret 获取到的临时令牌三 开发流程及业务场景 持续补充 1 关注 订阅公众号实现登录功能 2 生成带参数的二维码 2 1 创建二维码 2 2 获取二维码 2 3 前端通过返回的 url 直接显示二维码即可一 物料准备微信公众平

    2026年3月17日
    3

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号