Karait目前提供Python和Ruby的客戶端操作包，也就是說你可以使用Python或Ruby來寫消息，用Python或Ruby來讀隊列。下面學步園小編來講解下Karait怎麼用python寫隊列?Karait怎麼用Ruby讀隊列?
Karait怎麼用python寫隊列
importtime
fromkaraitimportMessage,Queue
print'Startingpythonwriter.'
messages_written=0
start=time.time()
queue=Queue()
whileTrue:
queue.write({
'messages_written':messages_written,
'sender':'writer.py',
'started_running':start,
'messages_written_per_second':(messages_written/(time.time()-start))
},routing_key='for_ruby_reader_writer')
messages_written+=1
Karait怎麼用Ruby讀隊列
require'rubygems'
require'karait'
require'yaml'
puts"Startingrubyreader/writer"
messages_read=0.0
start_time=Time.now().to_f
queue=Karait::Queue.new
whiletrue
messages=queue.read:routing_key=>'for_ruby_reader_writer',:messages_read=>15
messages.eachdo|message|
messages_read+=1.0
message.messages_read=messages_read
message.messages_read_per_second=messages_read/(Time.now().to_f-start_time)
if(messages_read%250)==0.0
puts"MessageRead:\n#{message.to_hash.to_yaml}"
end
end
queue.delete_messagesmessages
end
輸出結果：
---
sender:writer.py
messages_read_per_second:1653.29212369982
started_running:1314790290.33488
messages_written_per_second:1900.18564215637
messages_written:106199
messages_read:110250.0
以上就是關於「Karait怎麼用python寫隊列?Karait怎麼用Ruby讀隊列」的內容，希望對大家有用。更多資訊請關注學步園。學步園，您學習IT技術的優質平台!