MemcachedSessionHandler.php 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119
  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. * * expiretime: 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'])) {
  43. throw new \InvalidArgumentException(sprintf('The following options are not supported "%s".', implode(', ', $diff)));
  44. }
  45. $this->ttl = isset($options['expiretime']) ? (int) $options['expiretime'] : 86400;
  46. $this->prefix = $options['prefix'] ?? 'sf2s';
  47. }
  48. /**
  49. * @return bool
  50. */
  51. public function close()
  52. {
  53. return $this->memcached->quit();
  54. }
  55. /**
  56. * {@inheritdoc}
  57. */
  58. protected function doRead(string $sessionId)
  59. {
  60. return $this->memcached->get($this->prefix.$sessionId) ?: '';
  61. }
  62. /**
  63. * @return bool
  64. */
  65. public function updateTimestamp($sessionId, $data)
  66. {
  67. $this->memcached->touch($this->prefix.$sessionId, time() + $this->ttl);
  68. return true;
  69. }
  70. /**
  71. * {@inheritdoc}
  72. */
  73. protected function doWrite(string $sessionId, string $data)
  74. {
  75. return $this->memcached->set($this->prefix.$sessionId, $data, time() + $this->ttl);
  76. }
  77. /**
  78. * {@inheritdoc}
  79. */
  80. protected function doDestroy(string $sessionId)
  81. {
  82. $result = $this->memcached->delete($this->prefix.$sessionId);
  83. return $result || \Memcached::RES_NOTFOUND == $this->memcached->getResultCode();
  84. }
  85. /**
  86. * @return bool
  87. */
  88. public function gc($maxlifetime)
  89. {
  90. // not required here because memcached will auto expire the records anyhow.
  91. return true;
  92. }
  93. /**
  94. * Return a Memcached instance.
  95. *
  96. * @return \Memcached
  97. */
  98. protected function getMemcached()
  99. {
  100. return $this->memcached;
  101. }
  102. }