朱纯树博客
VPS测评推荐网站
cloudacead cloudacead

Laravel Redis发布与订阅

背景

  • 搭建一个电商数据中台,统一管理各个平台的商品,订单等基本数据。

需求

  • 日后可能会有很多订单。上传的商品也可能会一次性上传很多个。

方案

  • 使用 redis 发布订阅模式,让上传商品,下载订单异步执行
  • 记录发布的任务,以及任务的执行情况,避免某一平台上传失败时,发生漏上传的错误,或者是未接收到订阅消息,任务执行失败。
  • 对未执行的任务,或者执行失败的任务,进行重发任务。

具体实现

  1. 发布消息

消息体可以根据自己业务具体定义

/**
     * 推送广播
     *
     * @param  array  $message  = [
     *      'event' => 'upload_goods',
     *      'data' => [],
     *      'broadcast_id' => '1',
     * ]
     *
     * @time  : 2020/9/11
     */
    public function publish(array $message)
    {

        $log = $this->createLog($message['event'], $message['pid']);

        $message['broadcast_id'] = $log->id;

        $this->message = $message;

        //发送广播消息
        $this->sendMessage();

    }

    /**
     * 发送消息
     *
     * @time  : 2020/9/11
     */
    protected function sendMessage()
    {
        Redis::publish('test', json_encode($this->message, JSON_UNESCAPED_UNICODE));
    }
  1. 接受消息

新建命令

class Subscriber extends Command
{
    protected $signature = 'redis:sub';

    protected $description = '消息订阅监听器,需要开启常驻进程 以及 用进程守护工具进行守护';

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

    /**
     * 逻辑处理
     * @return mixed
     */
    public function handle()
    {
        ini_set("default_socket_timeout", -1);

        Redis::psubscribe(['*'], function ($message, $channel) {
            echo $message;
        });
    }
}
  1. 定义规划平台接口
  2. 集成几口,各自实现各个功能接口代码
  3. 记录好任务执行结果,如果原纪录的全部平台都已经成功执行,则标记改广播任务已完成。
赞(0) 打赏
未经允许不得转载:VPS测评推荐网站 - 朱纯树博客 » Laravel Redis发布与订阅

评论 1

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址
  1. #0

    学习了

    碧海青天2年前 (2020-09-13)回复