队列服务

队列的用处就不用多说了,v2.5.11中封装了统一的队列接口。目前封装了Redis驱动。默认使用default_cache中配置的redis。

驱动配置

//v2.7+
\Cml::getContainer()->singleton('cml_queue', \Cml\Queue\Redis::class);

用法

\Cml\Quene::getQueue();获取驱动实例
\Cml\Quene::getQueue('default_cache');获取驱动实例并指定使用的缓存配置

可通过修改配置文件中'queue_use_cache' => 'default_cache',修改只有在该缓存的驱动为redis的时候才有效,否则会报错。

目前封装的api:

/**
 * 从列表头入队
 *
 * @param string $name
 * @param mixed $data
 *
 * @return mixed
 */
public function lPush($name, $data)
/**
 * 从列表头出队
 *
 * @param string $name
 *
 * @return mixed
 */
public function lPop($name)
/**
 * 从列表尾入队
 *
 * @param string $name
 * @param mixed $data
 *
 * @return mixed
 */
public function rPush($name, $data)
/**
 * 从列表尾出队
 *
 * @param string $name
 *
 * @return mixed
 */
public function rPop($name)
/**
 * 弹入弹出
 *
 * @param string $from
 * @param string $to
 *
 * @return mixed
 */
public function rPopLpush($from, $to)

results matching ""

    No results matching ""