use redis connection pool on http
This commit is contained in:
parent
565a0bd35e
commit
2efff977e0
2 changed files with 6 additions and 12 deletions
|
@ -230,13 +230,12 @@ $register->set('redisPool', function () {
|
||||||
|
|
||||||
return $pool;
|
return $pool;
|
||||||
});
|
});
|
||||||
$register->set('cache', function () { // Register cache connection
|
$register->set('cache', function () use ($register) { // Register cache connection
|
||||||
$redis = new Redis();
|
$redis = $register->get('redisPool')->get();
|
||||||
$redis->pconnect(App::getEnv('_APP_REDIS_HOST', ''), App::getEnv('_APP_REDIS_PORT', ''));
|
|
||||||
$redis->setOption(Redis::OPT_READ_TIMEOUT, -1);
|
$redis->setOption(Redis::OPT_READ_TIMEOUT, -1);
|
||||||
|
|
||||||
return $redis;
|
return $redis;
|
||||||
});
|
}, true);
|
||||||
$register->set('smtp', function () {
|
$register->set('smtp', function () {
|
||||||
$mail = new PHPMailer(true);
|
$mail = new PHPMailer(true);
|
||||||
|
|
||||||
|
|
|
@ -5,6 +5,8 @@ require_once __DIR__ . '/init.php';
|
||||||
use Appwrite\Network\Validator\Origin;
|
use Appwrite\Network\Validator\Origin;
|
||||||
use Appwrite\Realtime\Realtime;
|
use Appwrite\Realtime\Realtime;
|
||||||
use Appwrite\Utopia\Response;
|
use Appwrite\Utopia\Response;
|
||||||
|
use Swoole\Database\RedisConfig;
|
||||||
|
use Swoole\Database\RedisPool;
|
||||||
use Swoole\Process;
|
use Swoole\Process;
|
||||||
use Swoole\Http\Request;
|
use Swoole\Http\Request;
|
||||||
use Swoole\Http\Response as SwooleResponse;
|
use Swoole\Http\Response as SwooleResponse;
|
||||||
|
@ -34,13 +36,6 @@ $register->set('db', function () use ($register) {
|
||||||
return $pdo;
|
return $pdo;
|
||||||
}, true);
|
}, true);
|
||||||
|
|
||||||
$register->set('cache', function () use ($register) { // Register cache connection
|
|
||||||
$redis = $register->get('redisPool')->get();
|
|
||||||
$redis->setOption(Redis::OPT_READ_TIMEOUT, -1);
|
|
||||||
|
|
||||||
return $redis;
|
|
||||||
}, true);
|
|
||||||
|
|
||||||
$server = new Server('0.0.0.0', 80);
|
$server = new Server('0.0.0.0', 80);
|
||||||
|
|
||||||
$server->set([
|
$server->set([
|
||||||
|
@ -128,7 +123,7 @@ $server->on('start', function (Server $server) {
|
||||||
});
|
});
|
||||||
|
|
||||||
$server->on('open', function (Server $server, Request $request) use (&$connections, &$subscriptions, &$register) {
|
$server->on('open', function (Server $server, Request $request) use (&$connections, &$subscriptions, &$register) {
|
||||||
$app = new App('America/New_York');
|
$app = new App('UTC');
|
||||||
$connection = $request->fd;
|
$connection = $request->fd;
|
||||||
$request = new SwooleRequest($request);
|
$request = new SwooleRequest($request);
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue