laravel中redis发布订阅相关问题处理

redis拥有发布订阅的功能，但是使用过程中发现如下若干问题:
 1. 心跳保活问题(done)
 2. 客户端只管publish后没有人subscribe，在subscribe的时候会重新接收 (代码逻辑)
 3. 检查进程是否存在，或者当发布时返回0时候即为失败(done)
 4. 当本文件的回调中的方法变动以后需要及时杀死进程并重启(done)
 5. redis发布订阅必须是redis的独有的一个库链接，如果持久化发布订阅的是设置的0库，则无法在订阅闭包中操作0库的数据，切记切记！！！(done)

### 心跳保活问题处理
如果不间隔几秒就心跳一次，服务端会自动断开，导致接收不到publish的消息

* 创建以下保活命令

```php
 <?php

namespace App\Console\Commands;

use Illuminate\Support\Facades\Redis;

/**
 * redis发布订阅保活
 * 本命令需要使用supervisor进行守护
 * Class TestSecondCommand
 * @package App\Console\Commands
 */
class RedisSubPubKeepAlive extends LumenCommand
{
    public $sleep;
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature='redisSubPub:keepAlive {--sleep=5}';

/**
     * The console command description.
     *
     * @var string
     */
    protected $description='redis发布订阅保活';

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

/**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        $this->sleep=$this->option('sleep');//redis发布订阅心跳包间隔时间(秒)
        while (true) {
            try {
                Redis::connection('sub_pub')->publish('ORDERID', 'ping;'.time());
                sleep($this->sleep);
            } catch (\Exception $ex) {
                sleep($this->sleep);
            }
        }
    }
}
 ```
*  将该命令放入supervisor守护

## 处理publish过来的消息

```php
<?php

namespace App\Console\Commands;

use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Redis;

/**
 * 处理客户端传来的发布订阅
 * 本命令需要使用supervisor进行守护
 * Class TestSecondCommand
 * @package App\Console\Commands
 */
class RedisSubPubHandle extends LumenCommand
{
    public $sleep;
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    public $signature='redisSubPub:handle';

/**
     * The console command description.
     *
     * @var string
     */
    protected $description='处理客户端传来的发布订阅';

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

/**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        Log::info('订阅重启');
        Redis::connection('sub_pub')->psubscribe('ORDERID*', function ($message, $channel) {
            $key='ORDERIDIncrementTEST:'.date('Y-m-d');
            Cache::increment($key);
        });
    }
}
```

*  将该命令放入supervisor守护

## 杀死守护的进程

如果不杀死，在上面修改过的代码是不会生效的,每次部署代码后执行以下该命令，如果使用deployer可以直接将该命令放入到deploy.php文件中每次部署自动执行文件
```php
<?php

namespace App\Console\Commands;

use Illuminate\Support\Facades\Redis;

/**
 * 每次deploy(自动执行)或者更新线上代码后需要执行的脚本
 * redis杀死进程，否则handle方法里面的不会生效
 * 本命令需要使用supervisor进行守护
 * Class TestSecondCommand
 * @package App\Console\Commands
 */
class RedisSubPubKill extends LumenCommand
{
    public $sleep;
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature='redisSubPub:kill';

/**
     * The console command description.
     *
     * @var string
     */
    protected $description='redis发布订阅保活';

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

/**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        $run_command='sudo ps aux | grep redisSubPub:handle | awk \'{print $2;}\' |  xargs kill';
        exec($run_command);
        $this->info('执行杀死订阅进程:'.$run_command);

$kill_keepalive_command='sudo ps aux | grep redisSubPub:keepAlive | awk \'{print $2;}\' |  xargs kill';
        exec($kill_keepalive_command);
        $this->info('执行杀死保活进程:'.$kill_keepalive_command);
    }
}
```

laravel中redis发布订阅相关问题处理

添加新评论

最新文章

最新回复

标签

归档

友情链接