Client.php 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406
  1. <?php
  2. /*
  3. * This file is part of the Predis package.
  4. *
  5. * (c) Daniele Alessandri <suppakilla@gmail.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 Predis;
  11. use Predis\Command\CommandInterface;
  12. use Predis\Option\ClientOptionsInterface;
  13. use Predis\Connection\ConnectionInterface;
  14. use Predis\Connection\AggregatedConnectionInterface;
  15. use Predis\Profile\ServerProfileInterface;
  16. use Predis\Option\ClientOptions;
  17. use Predis\Profile\ServerProfile;
  18. use Predis\PubSub\PubSubContext;
  19. use Predis\Monitor\MonitorContext;
  20. use Predis\Pipeline\PipelineContext;
  21. use Predis\Transaction\MultiExecContext;
  22. use Predis\Command\ScriptedCommand;
  23. /**
  24. * Main class that exposes the most high-level interface to interact with Redis.
  25. *
  26. * @author Daniele Alessandri <suppakilla@gmail.com>
  27. */
  28. class Client implements ClientInterface
  29. {
  30. const VERSION = '0.8.0-dev';
  31. private $options;
  32. private $profile;
  33. private $connection;
  34. private $connections;
  35. /**
  36. * Initializes a new client with optional connection parameters and client options.
  37. *
  38. * @param mixed $parameters Connection parameters for one or multiple servers.
  39. * @param mixed $options Options that specify certain behaviours for the client.
  40. */
  41. public function __construct($parameters = null, $options = null)
  42. {
  43. $this->options = $this->filterOptions($options);
  44. $this->profile = $this->options->profile;
  45. $this->connections = $this->options->connections;
  46. $this->connection = $this->initializeConnection($parameters);
  47. }
  48. /**
  49. * Creates an instance of Predis\Option\ClientOptions from various types of
  50. * arguments (string, array, Predis\Profile\ServerProfile) or returns the
  51. * passed object if it is an instance of Predis\Option\ClientOptions.
  52. *
  53. * @param mixed $options Client options.
  54. * @return ClientOptions
  55. */
  56. protected function filterOptions($options)
  57. {
  58. if ($options === null) {
  59. return new ClientOptions();
  60. }
  61. if (is_array($options)) {
  62. return new ClientOptions($options);
  63. }
  64. if ($options instanceof ClientOptionsInterface) {
  65. return $options;
  66. }
  67. throw new \InvalidArgumentException("Invalid type for client options");
  68. }
  69. /**
  70. * Initializes one or multiple connection (cluster) objects from various
  71. * types of arguments (string, array) or returns the passed object if it
  72. * implements Predis\Connection\ConnectionInterface.
  73. *
  74. * @param mixed $parameters Connection parameters or instance.
  75. * @return ConnectionInterface
  76. */
  77. protected function initializeConnection($parameters)
  78. {
  79. if ($parameters instanceof ConnectionInterface) {
  80. return $parameters;
  81. }
  82. if (is_array($parameters) && isset($parameters[0])) {
  83. $replication = isset($this->options->replication) && $this->options->replication;
  84. $connection = $this->options->{$replication ? 'replication' : 'cluster'};
  85. return $this->connections->createAggregated($connection, $parameters, $this->profile);
  86. }
  87. return $this->connections->create($parameters, $this->profile);
  88. }
  89. /**
  90. * {@inheritdoc}
  91. */
  92. public function getProfile()
  93. {
  94. return $this->profile;
  95. }
  96. /**
  97. * {@inheritdoc}
  98. */
  99. public function getOptions()
  100. {
  101. return $this->options;
  102. }
  103. /**
  104. * Returns the connection factory object used by the client.
  105. *
  106. * @return ConnectionFactoryInterface
  107. */
  108. public function getConnectionFactory()
  109. {
  110. return $this->connections;
  111. }
  112. /**
  113. * Returns a new instance of a client for the specified connection when the
  114. * client is connected to a cluster. The new instance will use the same
  115. * options of the original client.
  116. *
  117. * @return Client
  118. */
  119. public function getClientFor($connectionAlias)
  120. {
  121. if (($connection = $this->getConnection($connectionAlias)) === null) {
  122. throw new \InvalidArgumentException("Invalid connection alias: '$connectionAlias'");
  123. }
  124. return new Client($connection, $this->options);
  125. }
  126. /**
  127. * Opens the connection to the server.
  128. */
  129. public function connect()
  130. {
  131. $this->connection->connect();
  132. }
  133. /**
  134. * Disconnects from the server.
  135. */
  136. public function disconnect()
  137. {
  138. $this->connection->disconnect();
  139. }
  140. /**
  141. * Disconnects from the server.
  142. *
  143. * This method is an alias of disconnect().
  144. */
  145. public function quit()
  146. {
  147. $this->disconnect();
  148. }
  149. /**
  150. * Checks if the underlying connection is connected to Redis.
  151. *
  152. * @return Boolean True means that the connection is open.
  153. * False means that the connection is closed.
  154. */
  155. public function isConnected()
  156. {
  157. return $this->connection->isConnected();
  158. }
  159. /**
  160. * {@inheritdoc}
  161. */
  162. public function getConnection($id = null)
  163. {
  164. if (isset($id)) {
  165. if (!$this->connection instanceof AggregatedConnectionInterface) {
  166. throw new NotSupportedException(
  167. 'Retrieving connections by alias is supported only with aggregated connections (cluster or replication)'
  168. );
  169. }
  170. return $this->connection->getConnectionById($id);
  171. }
  172. return $this->connection;
  173. }
  174. /**
  175. * Dinamically invokes a Redis command with the specified arguments.
  176. *
  177. * @param string $method The name of a Redis command.
  178. * @param array $arguments The arguments for the command.
  179. * @return mixed
  180. */
  181. public function __call($method, $arguments)
  182. {
  183. $command = $this->profile->createCommand($method, $arguments);
  184. $response = $this->connection->executeCommand($command);
  185. if ($response instanceof ResponseErrorInterface) {
  186. $response = $this->onResponseError($command, $response);
  187. }
  188. return $response;
  189. }
  190. /**
  191. * {@inheritdoc}
  192. */
  193. public function createCommand($method, $arguments = array())
  194. {
  195. return $this->profile->createCommand($method, $arguments);
  196. }
  197. /**
  198. * {@inheritdoc}
  199. */
  200. public function executeCommand(CommandInterface $command)
  201. {
  202. $response = $this->connection->executeCommand($command);
  203. if ($response instanceof ResponseErrorInterface) {
  204. return $this->onResponseError($command, $response);
  205. }
  206. return $response;
  207. }
  208. /**
  209. * Handles -ERR responses returned by Redis.
  210. *
  211. * @param CommandInterface $command The command that generated the error.
  212. * @param ResponseErrorInterface $response The error response instance.
  213. * @return mixed
  214. */
  215. protected function onResponseError(CommandInterface $command, ResponseErrorInterface $response)
  216. {
  217. if ($command instanceof ScriptedCommand && $response->getErrorType() === 'NOSCRIPT') {
  218. $eval = $this->createCommand('eval');
  219. $eval->setRawArguments($command->getEvalArguments());
  220. return $this->executeCommand($eval);
  221. }
  222. if ($this->options->exceptions === true) {
  223. $message = $response->getMessage();
  224. throw new ServerException($message);
  225. }
  226. return $response;
  227. }
  228. /**
  229. * Calls the specified initializer method on $this with 0, 1 or 2 arguments.
  230. *
  231. * TODO: Invert $argv and $initializer.
  232. *
  233. * @param array $argv Arguments for the initializer.
  234. * @param string $initializer The initializer method.
  235. * @return mixed
  236. */
  237. private function sharedInitializer($argv, $initializer)
  238. {
  239. switch (count($argv)) {
  240. case 0:
  241. return $this->$initializer();
  242. case 1:
  243. list($arg0) = $argv;
  244. return is_array($arg0) ? $this->$initializer($arg0) : $this->$initializer(null, $arg0);
  245. case 2:
  246. list($arg0, $arg1) = $argv;
  247. return $this->$initializer($arg0, $arg1);
  248. default:
  249. return $this->$initializer($this, $argv);
  250. }
  251. }
  252. /**
  253. * Creates a new pipeline context and returns it, or returns the results of
  254. * a pipeline executed inside the optionally provided callable object.
  255. *
  256. * @param mixed $arg,... Options for the context, a callable object, or both.
  257. * @return PipelineContext|array
  258. */
  259. public function pipeline(/* arguments */)
  260. {
  261. return $this->sharedInitializer(func_get_args(), 'initPipeline');
  262. }
  263. /**
  264. * Pipeline context initializer.
  265. *
  266. * @param array $options Options for the context.
  267. * @param mixed $callable Optional callable object used to execute the context.
  268. * @return PipelineContext|array
  269. */
  270. protected function initPipeline(Array $options = null, $callable = null)
  271. {
  272. $executor = isset($options['executor']) ? $options['executor'] : null;
  273. if (is_callable($executor)) {
  274. $executor = call_user_func($executor, $this, $options);
  275. }
  276. $pipeline = new PipelineContext($this, $executor);
  277. $replies = $this->pipelineExecute($pipeline, $callable);
  278. return $replies;
  279. }
  280. /**
  281. * Executes a pipeline context when a callable object is passed.
  282. *
  283. * @param array $options Options of the context initialization.
  284. * @param mixed $callable Optional callable object used to execute the context.
  285. * @return PipelineContext|array
  286. */
  287. private function pipelineExecute(PipelineContext $pipeline, $callable)
  288. {
  289. return isset($callable) ? $pipeline->execute($callable) : $pipeline;
  290. }
  291. /**
  292. * Creates a new transaction context and returns it, or returns the results of
  293. * a transaction executed inside the optionally provided callable object.
  294. *
  295. * @param mixed $arg,... Options for the context, a callable object, or both.
  296. * @return MultiExecContext|array
  297. */
  298. public function multiExec(/* arguments */)
  299. {
  300. return $this->sharedInitializer(func_get_args(), 'initMultiExec');
  301. }
  302. /**
  303. * Transaction context initializer.
  304. *
  305. * @param array $options Options for the context.
  306. * @param mixed $callable Optional callable object used to execute the context.
  307. * @return MultiExecContext|array
  308. */
  309. protected function initMultiExec(Array $options = null, $callable = null)
  310. {
  311. $transaction = new MultiExecContext($this, $options ?: array());
  312. return isset($callable) ? $transaction->execute($callable) : $transaction;
  313. }
  314. /**
  315. * Creates a new Publish / Subscribe context and returns it, or executes it
  316. * inside the optionally provided callable object.
  317. *
  318. * @param mixed $arg,... Options for the context, a callable object, or both.
  319. * @return MultiExecContext|array
  320. */
  321. public function pubSub(/* arguments */)
  322. {
  323. return $this->sharedInitializer(func_get_args(), 'initPubSub');
  324. }
  325. /**
  326. * Publish / Subscribe context initializer.
  327. *
  328. * @param array $options Options for the context.
  329. * @param mixed $callable Optional callable object used to execute the context.
  330. * @return PubSubContext
  331. */
  332. protected function initPubSub(Array $options = null, $callable = null)
  333. {
  334. $pubsub = new PubSubContext($this, $options);
  335. if (!isset($callable)) {
  336. return $pubsub;
  337. }
  338. foreach ($pubsub as $message) {
  339. if (call_user_func($callable, $pubsub, $message) === false) {
  340. $pubsub->closeContext();
  341. }
  342. }
  343. }
  344. /**
  345. * Returns a new monitor context.
  346. *
  347. * @return MonitorContext
  348. */
  349. public function monitor()
  350. {
  351. return new MonitorContext($this);
  352. }
  353. }