ãƒã‚¿ã•ã‚“ã®ãƒ–ãƒã‚°(復刻版) : PHPカンファレンス2009「Q4Mã¨Flareを使ã£ã¦ スケーラブルãªã‚µãƒ¼ãƒ“スを作るï¼ã€ã®è³‡æ–™
ã™ã„ã¾ã›ã‚“ã€é…ããªã£ã¦ã„ã¾ã—ãŸãŒã€ã¨ã‚Šã‚ãˆãšã“ã“ã«ç½®ã„ã¦ãŠãã¾ã™ã€‚ ref - http://www.slideshare.net/nowelium/building-highscalable-web-applications-using-q4m-and-flare Building High-Scalable Web Applications Using Q4M and Flare View more documents from nowelium. Ustreamã¯ã“ã®è¾º ref - http://www.ustream.tv/recorded/2107541 ã„ãã¤ã‹è³ªå•ãŒã‚ã£ãŸã‚‚ã®ã¯ã€åˆ¥é€”書ãã¾ã™
ãƒã‚¿ã•ã‚“ã®ãƒ–ãƒã‚° : Q4Mã‚’PHP(PDO)ã§
Q4MãŒç„¡äº‹ã‚¤ãƒ³ã‚¹ãƒˆãƒ¼ãƒ«ã§ããŸã®ã§ã€PHPã‹ã‚‰è§¦ã£ã¦ã¿ã‚‹ã€‚詳細ãªã“ã¨ã¯ä»Šåº¦æ›¸ã。ã¨ã‚Šã‚ãˆãšè§¦ã‚Šã ã‘ã§ã‚‚ テーブル定義 drop table if exists hoge_queue; create table hoge_queue( id int not null, name varchar(25) not null ) engine=queue; ã“ã‚“ãªã‚¹ã‚¯ãƒªãƒ—トをガンガン回ã—ã¦ã€ç›£è¦– $conn = new PDO('mysql:host=localhost; dbname=hogetest', 'user', 'password'); $wait = $conn->prepare('SELECT queue_wait("hoge_queue", 10)'); $abort = $conn->prepare('SELECT queue_abort()'); $e = $conn->pr
棚ã‹ã‚‰ãƒ‘ルãƒãƒ£ã‚®
$queue = new Net_Q4M(); $queue->connect('mysql://user:pass@localhost:3306/database'); $row = $queue->dequeue('my_queue'); if (process_row($row)) { $queue->end(); } else { $queue->abort(); } $queue->disconnect(); dequeue()を呼ã¶ã¨ã‚ューã®ãƒ¬ã‚³ãƒ¼ãƒ‰æƒ…å ±ãŒè¿”ã‚Šã¾ã™ã€‚ 内部的ã«ã¯queue_wait()を発行ã—ã¦ã„ã‚‹ã®ã§ã€å–å¾—ã—ãŸã‚ューã®å€¤ã¯ã“ã®æŽ¥ç¶šã®ã¿ãŒæ‰±ãˆã‚‹ã“ã¨ã«ãªã‚Šã¾ã™(OWNERモード)。 ã‚ューã®å€¤ã¯é…列ã§è¿”ã‚‹ã®ã§é©å½“ã«å‡¦ç†ã—ã¾ã™(上ã®ã‚µãƒ³ãƒ—ルã ã¨process_row()ã®ã¨ã“ã‚)。 処ç†ã«æˆåŠŸã—ãŸå ´åˆã¯end()を呼ã¶ã“ã¨ã§ã‚ューã‹ã‚‰å€¤ã‚’削除ã—ã¾ã™ã€‚ 逆ã«å¤±æ•—ã—ãŸå ´
1
ランã‚ング
ãŠçŸ¥ã‚‰ã›
ランã‚ング
リリースã€éšœå®³æƒ…å ±ãªã©ã®ã‚µãƒ¼ãƒ“スã®ãŠçŸ¥ã‚‰ã›
最新ã®äººæ°—エントリーã®é…ä¿¡
処ç†ã‚’実行ä¸ã§ã™
j次ã®ãƒ–ックマーク
kå‰ã®ãƒ–ックマーク
lã‚ã¨ã§èªã‚€
eコメント一覧を開ã
oページを開ã
{{#tags}}- {{label}}
{{/tags}}