Laravel Redis发布与订阅

736 阅读 0 评论 486 点赞

我是靠谱客的博主洁净绿茶，最近开发中收集的这篇文章主要介绍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));
}
```

2. 接受消息

新建命令

```
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;
});
}
}
```

3. 定义规划平台接口

4. 集成几口，各自实现各个功能接口代码

5. 记录好任务执行结果，如果原纪录的全部平台都已经成功执行，则标记改广播任务已完成。