[B! queue] udzuraã®ãƒ–ãƒƒã‚¯ãƒžãƒ¼ã‚¯

udzura id:udzura

queueã«é–¢ã™ã‚‹udzuraã®ãƒ–ãƒƒã‚¯ãƒžãƒ¼ã‚¯ (7)

${{author_name}}$

{{{comment_expanded}}}

{{label}}

{{#is_bookmark}}ãƒªã‚¹ãƒˆ{{/is_bookmark}}{{^is_bookmark}}ãƒªãƒ³ã‚¯{{/is_bookmark}}

${{author_name}}$
{{author_name}}{{created}}
{{ #comment }}{{ comment }}{{ /comment }}
- {{ label }}

${{author_name}}$

{{{comment_expanded}}}

{{label}}

{{#is_bookmark}}ãƒªã‚¹ãƒˆ{{/is_bookmark}}{{^is_bookmark}}ãƒªãƒ³ã‚¯{{/is_bookmark}}

ãƒ¡ãƒ¢: Redisã‚’ã‚¸ãƒ§ãƒ–ã‚ãƒ¥ãƒ¼ã¨ã—ã¦ä½¿ã† - ã”ã‚ãã“æ—¥è¨˜
Redisã«ã¤ã„ã¦ Redisã¯ã„ã‚ã‚†ã‚‹ã‚ªãƒ³ãƒ¡ãƒ¢ãƒªã§å‹•ä½œã—ã¦æ°¸ç¶šåŒ–ã‚‚ã—ã¦ãã‚Œã‚‹é«˜é€Ÿãªã‚ãƒ¼ãƒãƒªãƒ¥ãƒ¼ã‚¹ãƒˆã‚¢ã§ã™ãŒã€ãƒŽãƒ†ã‚£ãƒ•ã‚£ã‚±ãƒ¼ã‚·ãƒ§ãƒ³ã®ã‚ˆã†ãªæ©Ÿèƒ½ã‚‚ã‚‚ã£ã¦ã¾ã™ã€‚ å®Ÿã¯ã‚¸ãƒ§ãƒ–ã‚ãƒ¥ãƒ¼ã®ã‚ˆã†ãªã‚‚ã®ã¯ç„¡ã„ã‹ãªã¨æœ€åˆã¯RabbitMQã‚’èª¿ã¹ã¦ã„ãŸã®ã§ã™ãŒã€ãã†ã„ã‚„Redisã«ãã†ã„ã†ä½¿ã„æ–¹ã§ããã†ãªã‚³ãƒžãƒ³ãƒ‰ãŒã‚ã£ãŸã‚ˆã†ãªã€‚ã¨æ€ã£ã¦ã¿ã¦ã¿ãŸã‚‰ã‚ã‚Šã¾ã—ãŸã€‚ ã‚³ãƒžãƒ³ãƒ‰ è©²å½“ã®ã‚³ãƒžãƒ³ãƒ‰ã¯PUBLISHã¨SUBSCRIBEã§ã™ã€‚ SUBSCRIBEã¯ç¾åœ¨ã®ã‚³ãƒã‚¯ã‚·ãƒ§ãƒ³ã§ç‰¹å®šã®ã‚ãƒ¼ãƒ¯ãƒ¼ãƒ‰ã®é€šçŸ¥ãŒæ¥ã‚‹ã®ã‚’å¾…æ©Ÿé–‹å§‹ã™ã‚‹ã‚³ãƒžãƒ³ãƒ‰ PUBLISHã¯é€šçŸ¥ã‚’é€ä¿¡ã™ã‚‹ã‚³ãƒžãƒ³ãƒ‰ ã§ã™ã€‚ å…·ä½“çš„ã«ã¯ SUBSCRIBE fooã¨ã™ã‚‹ã¨ã‚ãƒ¼ãƒ¯ãƒ¼ãƒ‰fooã§é€šçŸ¥ã‚’å¾…ã¡å—ã‘ã€ PUBLISH foo hogeã¨ã™ã‚‹ã¨hogeã¨ã„ã†ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ã¨ã¨ã‚‚ã«SUBSCRIBEã—ã¦ã„ã‚‹ã‚³ãƒã‚¯ã‚·ãƒ§ãƒ³ã«ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ã‚’é€ã‚Šã¾ã™ã€‚ å®Ÿéš›ã«ã‚³ãƒžãƒ³ãƒ‰ãƒ©ã‚¤ãƒ³ã‹ã‚‰ã‚„ã£ã¦
udzura 2016/11/02
redis

queue
ãƒªãƒ³ã‚¯
ã‚¹ãƒˆãƒªãƒ¼ãƒ å‡¦ç†ã‚’æ”¯ãˆã‚‹ã‚ãƒ¥ãƒ¼ã‚¤ãƒ³ã‚°ã‚·ã‚¹ãƒ†ãƒ ã®é¸ã³æ–¹
This document discusses messaging queues and platforms. It begins with an introduction to messaging queues and their core components. It then provides a table comparing 8 popular open source messaging platforms: Apache Kafka, ActiveMQ, RabbitMQ, NATS, NSQ, Redis, ZeroMQ, and Nanomsg. The document discusses using Apache Kafka for streaming and integration with Google Pub/Sub, Dataflow, and BigQuery
udzura 2016/10/27
å‹‰å¼·ã«ãªã‚‹

kafka

queue

mq
ãƒªãƒ³ã‚¯
Goã¨MySQLã‚’ç”¨ã„ãŸã‚¸ãƒ§ãƒ–ã‚ãƒ¥ãƒ¼ã‚·ã‚¹ãƒ†ãƒ ã‚’ä½œã‚‹ã¨ãã«è€ƒãˆãŸã“ã¨ - ã‚†ã†ã†ããƒ–ãƒã‚°
ã€è¿½è¨˜ã€‘2023å¹´3æœˆ21æ—¥ YAPC::Kyoto 2023ã§ã€ã‚¸ãƒ§ãƒ–ã‚ãƒ¥ãƒ¼ã‚·ã‚¹ãƒ†ãƒ Fireworqã®è¨è¨ˆã¨é‹ç”¨å®Ÿç¸¾ã‚‚å«ã‚ã¦ç™ºè¡¨ã•ã‚Œã¾ã—ãŸã€‚id:tarao ++ ã€åŠ ç†ä¿®æ£ã€‘ 2020å¹´2æœˆ16æ—¥ åŸ·ç†æ™‚ã‹ã‚‰6å¹´ã‚‚çµŒéŽã—ã¦ã„ã¾ã™ãŒã€ãŸã¾ãŸã¾ã“ã®è¨˜äº‹ã‚’æŒ¯ã‚Šè¿”ã‚‹æ©Ÿä¼šãŒã‚ã£ãŸã®ã§ã€æ—¥æœ¬èªžãŒãŠã‹ã—ã„ã¨ã“ã‚ã‚’ä¸€éƒ¨ä¿®æ£ã—ãŸã‚Šã€ä¸€ç·’ã«å–ã‚Šçµ„ã‚“ã æ–¹ã€…ã®åå‰ãŒæ›¸ã‹ã‚Œã¦ã„ãªã‹ã£ãŸã¨ã“ã‚ã‚’ä¿®æ£ã—ã¾ã—ãŸã€‚ ã€è¿½è¨˜ã€‘2017å¹´12å¹´24æ—¥ ã“ã®ã‚¨ãƒ³ãƒˆãƒªã®ã‚¸ãƒ§ãƒ–ã‚ãƒ¥ãƒ¼å®Ÿè£…ãŒFireworqã¨ã„ã†åã§OSSã¨ã—ã¦å…¬é–‹ã•ã‚Œã¾ã—ãŸã€‚id:tarao ++ github.com ã“ã®è¨˜äº‹ã¯ã¯ã¦ãª ã‚¨ãƒ³ã‚¸ãƒ‹ã‚¢ã‚¢ãƒ‰ãƒ™ãƒ³ãƒˆã‚«ãƒ¬ãƒ³ãƒ€ãƒ¼2014ã®4æ—¥ç›®ã§ã™ã€‚ å‰å›žã¯ Mackerelã§æŽ¡ç”¨ã—ã¦ã„ã‚‹æŠ€è¡“ä¸€è¦§ã¨ãã®ç´¹ä»‹ - Hatena Developer Blog ã§ã—ãŸã€‚ ç¤¾å†…ã®é–‹ç™ºåˆå®¿ã§ã€ id:taraoã•ã‚“ã€id:hakobe
udzura 2014/12/05
golang

mysql

queue
ãƒªãƒ³ã‚¯
channel lock - é³©èˆŽ
channel ã§ãƒ–ãƒãƒƒã‚¯ã™ã‚‹ã‚ˆã†ãªã‚³ãƒ¼ãƒ‰ãŒæ›¸ã‘ã‚‹ã€‚ä¾‹ãˆã°ã‚¹ãƒ¬ãƒƒãƒ‰ã®ä¸¦åˆ—æ•°ã‚’åˆ¶é™ã—ãŸã„ã¨ã‹ã€ãã†ã„ã†ç°¡å˜ãªç”¨é€”ã§ä½¿ã†ã®ã«å–ã‚Šå›žã—ãŒã„ã„ã€‚ package main import ( "fmt" "time" ) func main() { go func() { for { fmt.Printf(".") time.Sleep(100 * time.Millisecond) } }() queue := make(chan int, 3) time.Sleep(1 * time.Second) queue <- 1 fmt.Println(1) time.Sleep(1 * time.Second) queue <- 2 fmt.Println(2) time.Sleep(1 * time.Second) queue <- 3 fmt.Println(3) go func() { time
udzura 2013/09/26
Rubyã®SizedQueueã«ä¼¼ã¦ã‚‹ï¼Ÿ http://doc.ruby-lang.org/ja/2.0.0/class/SizedQueue.html

queue

go-lang
ãƒªãƒ³ã‚¯
Rubyã‚’ç”¨ã„ãŸãƒžãƒ«ãƒã‚¹ãƒ¬ãƒƒãƒ‰å¯¾å¿œQueueã®ä½œã‚Šæ–¹ - M-Tea
ã¯ã˜ã‚ã« ãƒžãƒ«ãƒã‚¹ãƒ¬ãƒƒãƒ‰ã¨ã‚ãƒ¥ãƒ¼ã«ã¤ã„ã¦ã„ã‚ã„ã‚æ›¸ã„ã¦ãã¦ã„ã‚‹ã€‚ã¨ã‚Šã‚ãˆãšä»Šå›žã¯ã€Rubyã§ãƒžãƒ«ãƒã‚¹ãƒ¬ãƒƒãƒ‰å¯¾å¿œãªQueueã‚’è€ƒãˆã¦ã¿ã‚‹ã€‚ ã„ã‚ã„ã‚ãªã”æ„è¦‹ çš†æ§˜ã‹ã‚‰ã„ã‚ã„ã‚ãªã”æ„è¦‹ã‚’é ‚ã„ãŸã®ã§ã€è¨˜è¼‰ã—ã¦ãŠã ãƒ»ã‚ãƒ¥ãƒ¼ã®ä¸Šé™ãŒå¿…è¦ãªã‚±ãƒ¼ã‚¹ãŒã‚ˆãã‚ã‹ã‚‰ãªã‹ã£ãŸ ãƒ»ãƒ‡ã‚£ãƒ¼ãƒ—ã‚¯ãƒãƒ¼ãƒ³ãŒç™ºç”Ÿã™ã‚‹ã¨ãƒ‘ãƒ•ã‚©ãƒ¼ãƒžãƒ³ã‚¹ãŒæ‚ªããªã‚‹ ãƒ»lock-freeãªã‚¢ãƒ«ã‚´ãƒªã‚ºãƒ ãŒã‚ã‚‹ã®ã§ã¯ ã“ã‚Œã‚‰ã«ã¤ã„ã¦ã¯ã€ä»Šå¾Œã¾ãŸæ›¸ããŸã„ rubyã®ãƒžãƒ«ãƒã‚¹ãƒ¬ãƒƒãƒ‰å¯¾å¿œã‚ãƒ¥ãƒ¼ Rubyã§ãƒžãƒ«ãƒã‚¹ãƒ¬ãƒƒãƒ‰å¯¾å¿œQueueãŒæ¬²ã—ã‘ã‚Œã°ã€ä»¥ä¸‹ã®ã‚ˆã†ã«ã™ã‚Œã°ã„ã„ã€‚ require 'thread' q = Queue.new q.enq( '123' ) q.deq() æ—¢ã«ã‚¯ãƒ©ã‚¹ãŒã‚ã‚‹ã®ã§ã€ãã‚Œã‚’åˆ©ç”¨ã™ã‚Œã°ã„ã„... è‡ªåˆ†ã§ä½œã‚‹ ã„ã‚„ã€ã‚ãˆã¦ä½œã‚‹å¿…è¦ãŒãªã„ã®ã§ã‚ã‚‹ãŒã€ä½œã£ã¦ã¿ã‚‹ require 'thread' class MyQueue def
udzura 2013/02/19
queue

ruby

thread
ãƒªãƒ³ã‚¯
tokuhirom blog
Blog Search when-present<#else>when-missing. (These only cover the last step of the expression; to cover the whole expression, use parenthesis: (myOptionalVar.foo)!myDefault, (myOptionalVar.foo)?? ---- ---- FTL stack trace ("~" means nesting-related): - Failed at: ${entry.path} [in template "__entry.ftlh" at line 3, column 25] - Reached through: #include "__entry.ftlh" [in template "entry.ftlh" at
udzura 2011/07/07
[for:@twitter]

queue

job

programming

development
ãƒªãƒ³ã‚¯
Kue
Kue is a feature rich priority job queue for node.js backed by redis. A key feature of Kue is it's clean user-interface for viewing and managing queued, active, failed, and completed jobs. At any point in the job's life-time you can view verbose details, including the job's arbitrary data, creation, update, failure, and completion times. Jobs may update their progress in increments, providing vita
udzura 2011/07/05
[for:@twitter]

redis

nodejs

javascript

queue

job
ãƒªãƒ³ã‚¯
1