MemcachedSessionHandler.php 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135
  1. <?php
  2. /*
  3. * This file is part of the Symfony package.
  4. *
  5. * (c) Fabien Potencier <fabien@symfony.com>
  6. *
  7. * For the full copyright and license information, please view the LICENSE
  8. * file that was distributed with this source code.
  9. */
  10. namespace Symfony\Component\HttpFoundation\Session\Storage\Handler;
  11. /**
  12. * Memcached based session storage handler based on the Memcached class
  13. * provided by the PHP memcached extension.
  14. *
  15. * @see https://php.net/memcached
  16. *
  17. * @author Drak <drak@zikula.org>
  18. */
  19. class MemcachedSessionHandler extends AbstractSessionHandler
  20. {
  21. private $memcached;
  22. /**
  23. * @var int Time to live in seconds
  24. */
  25. private $ttl;
  26. /**
  27. * @var string Key prefix for shared environments
  28. */
  29. private $prefix;
  30. /**
  31. * Constructor.
  32. *
  33. * List of available options:
  34. * * prefix: The prefix to use for the memcached keys in order to avoid collision
  35. * * ttl: The time to live in seconds.
  36. *
  37. * @throws \InvalidArgumentException When unsupported options are passed
  38. */
  39. public function __construct(\Memcached $memcached, array $options = [])
  40. {
  41. $this->memcached = $memcached;
  42. if ($diff = array_diff(array_keys($options), ['prefix', 'expiretime', 'ttl'])) {
  43. throw new \InvalidArgumentException(sprintf('The following options are not supported "%s".', implode(', ', $diff)));
  44. }
  45. $this->ttl = $options['expiretime'] ?? $options['ttl'] ?? null;
  46. $this->prefix = $options['prefix'] ?? 'sf2s';
  47. }
  48. /**
  49. * @return bool
  50. */
  51. #[\ReturnTypeWillChange]
  52. public function close()
  53. {
  54. return $this->memcached->quit();
  55. }
  56. /**
  57. * {@inheritdoc}
  58. */
  59. protected function doRead(string $sessionId)
  60. {
  61. return $this->memcached->get($this->prefix.$sessionId) ?: '';
  62. }
  63. /**
  64. * @return bool
  65. */
  66. #[\ReturnTypeWillChange]
  67. public function updateTimestamp($sessionId, $data)
  68. {
  69. $this->memcached->touch($this->prefix.$sessionId, $this->getCompatibleTtl());
  70. return true;
  71. }
  72. /**
  73. * {@inheritdoc}
  74. */
  75. protected function doWrite(string $sessionId, string $data)
  76. {
  77. return $this->memcached->set($this->prefix.$sessionId, $data, $this->getCompatibleTtl());
  78. }
  79. private function getCompatibleTtl(): int
  80. {
  81. $ttl = (int) ($this->ttl ?? \ini_get('session.gc_maxlifetime'));
  82. // If the relative TTL that is used exceeds 30 days, memcached will treat the value as Unix time.
  83. // We have to convert it to an absolute Unix time at this point, to make sure the TTL is correct.
  84. if ($ttl > 60 * 60 * 24 * 30) {
  85. $ttl += time();
  86. }
  87. return $ttl;
  88. }
  89. /**
  90. * {@inheritdoc}
  91. */
  92. protected function doDestroy(string $sessionId)
  93. {
  94. $result = $this->memcached->delete($this->prefix.$sessionId);
  95. return $result || \Memcached::RES_NOTFOUND == $this->memcached->getResultCode();
  96. }
  97. /**
  98. * @return int|false
  99. */
  100. #[\ReturnTypeWillChange]
  101. public function gc($maxlifetime)
  102. {
  103. // not required here because memcached will auto expire the records anyhow.
  104. return 0;
  105. }
  106. /**
  107. * Return a Memcached instance.
  108. *
  109. * @return \Memcached
  110. */
  111. protected function getMemcached()
  112. {
  113. return $this->memcached;
  114. }
  115. }