MemcachedSessionHandler.php 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122
  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, time() + (int) ($this->ttl ?? \ini_get('session.gc_maxlifetime')));
  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, time() + (int) ($this->ttl ?? \ini_get('session.gc_maxlifetime')));
  78. }
  79. /**
  80. * {@inheritdoc}
  81. */
  82. protected function doDestroy(string $sessionId)
  83. {
  84. $result = $this->memcached->delete($this->prefix.$sessionId);
  85. return $result || \Memcached::RES_NOTFOUND == $this->memcached->getResultCode();
  86. }
  87. /**
  88. * @return int|false
  89. */
  90. #[\ReturnTypeWillChange]
  91. public function gc($maxlifetime)
  92. {
  93. // not required here because memcached will auto expire the records anyhow.
  94. return 0;
  95. }
  96. /**
  97. * Return a Memcached instance.
  98. *
  99. * @return \Memcached
  100. */
  101. protected function getMemcached()
  102. {
  103. return $this->memcached;
  104. }
  105. }