Featured image of post Zend_Queue_Adapter_Phpredisを作りました

Zend_Queue_Adapter_Phpredisを作りました

Twitter ツイート Hatena Bookmark ブックマーク

Zend_QueueでRedisを使いたくなったので、Zend_Queue_Adapter_Phpredis作りました。
まあほぼmemcacheqのアダプターと構成は同じですがcountとかもちゃんとサポートできている感じです。

まあちゃんとテストも書いてないのでバグがあるかもしれませんが、良かったら使ってみてください。

ちなみにZend_Queue_Adapter_Phpredisの使用例はこんな感じです。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
<?php
require_once 'Zend/Loader/Autoloader.php';
$autoloader = Zend_Loader_Autoloader::getInstance();

try {
	$queue = new Zend_Queue('Phpredis',array(
		'name' => 'test_queue',
		'driverOptions' => array(
			'host' => '127.0.0.1', // default 127.0.0.1
			'port' => 6379,			// default 6379
		),
	));


	// send message
	$queue->send('job 1');
	$queue->send('job 2');
	echo "send end\n\n";

	// get message
	$messages = $queue->receive(3);
	foreach ( $messages as $message ) {
		echo $message->body . "\n";
	}

} catch ( Zend_Queue_Exception $e ) {
	echo $e->getMessage();
}
comments powered by Disqus
Built with Hugo
テーマ StackJimmy によって設計されています。