|
@@ -235,10 +235,10 @@ class HttpServerSettelement
|
|
|
go(function () use ($data, $redisconfig) {
|
|
go(function () use ($data, $redisconfig) {
|
|
|
$redis = new Swoole\Coroutine\Redis();
|
|
$redis = new Swoole\Coroutine\Redis();
|
|
|
$redis->connect($redisconfig['host'], $redisconfig['port']);
|
|
$redis->connect($redisconfig['host'], $redisconfig['port']);
|
|
|
- if (!empty($redis['passwd'])) {
|
|
|
|
|
- $redis->auth($redis['passwd']);
|
|
|
|
|
|
|
+ if (!empty($redisconfig['passwd'])) {
|
|
|
|
|
+ $redis->auth($redisconfig['passwd']);
|
|
|
}
|
|
}
|
|
|
- $redis->select($redis['db']);
|
|
|
|
|
|
|
+ $redis->select($redisconfig['db']);
|
|
|
|
|
|
|
|
$redis->lpush(self::TASKQNUM, $data);
|
|
$redis->lpush(self::TASKQNUM, $data);
|
|
|
return;
|
|
return;
|