Starling: trabalhando com filas em Ruby

OStarling
é, basicamente, um servidor de filas implementado sob o protocolo do MemCache. O MemCache é
um servidor de cache distribuído de altíssima performance e é largamente
usado, principalmente em clusters de aplicações web.

Para usar o Starling é muito simples. Os primeiros passos são:

Instalação

1) Instalar o servidor MemCache

jeveaux@kamael ~ $ sudo apt-get -y install memcached

2) Instalar a gem
do MemCache e

jeveaux@kamael ~ $ sudo gem install memcache-client

3) Instalar a gem do Starling.

jeveaux@kamael ~ $ sudo gem install starling

E pronto, isso é tudo para começarmos a usar o Starling.
Se você achou a instalação simples se prepare, pois a utilização é
ainda mais simples.

Usando o Starling

Se você já usou o MemCache, vai sentir-se familiarizado com o Starling.
A diferença é apenas na implementação do protocolo, ou seja, a
utilização em código será igual a do MemCache, só que ao fazer set
e get as coisas acontecerão de uma forma um pouco diferente.
Por enquanto, a diferença maior que percebi foi em relação do método get,
que quando usado no MemCache apenas retorna um valor do cache e o
mantém lá, já no caso do Starling
o get retorna o valor e o remove da memória. Analisando com
calma isso faz sentido, afinal não estamos mais falando de cache e sim
de filas, mesmo que a implementação da fila seja feita usando cache.

Mas antes de irmos para os exemplos de código, precisamos fazer com o
que o servidor de filas duh, Starling
esteja disponível e rodando. Vamos iniciar o Starling
na porta 22122 (-p) e como um daemon (-d):

jeveaux@kamael ~ $ sudo starling -p 22122 -d

Isso já basta para iniciar o servidor do Starling
e deixá-lo disponível para uso. Agora então vamos alimentar a fila,
crie o arquivo: alimentar_fila.rb.

#alimentar_fila.rb<br />
require 'rubygems'<br />
require 'memcache'<br />
starling = MemCache.new 'localhost:22122'<br />
starling.set 'fila', 'qualquer objeto'

Ao executar este arquivo (ruby alimenta_fila.rb) não teremos nenhum
resultado visual, mas acredite, a fila chamada de‘fila’ no
exemplo está recebendo objetos. Agora o trabalho será para como dizem
consumir a fila. Vamos ao consumir_fila.rb.

[code]#consumir_fila.rb<br />require 'rubygems'<br />require 'memcache'<br />starling = MemCache.new 'localhost:22122'<br />loop {<br />  objeto_fila = starling.get 'fila'<br />  if !objeto_fila.nil?<br />    puts 'recuperado da fila:' + objeto_fila<br />  end<br />}[/code]

E agora, sim, estamos prontos para colocar e remover objetos em uma
fila. O exemplo para consumir os objetos ficará em loop, então
você pode executá-lo numa janela do bash e, em outra janela, executar o exemplo para alimentar a fila com objetos e acompanhar o
comportamento dos procedimentos de alimentar e consumir a fila. A
recuperação da fila será imediata, instantânea, afinal, assim como o
MemCache, o Starling está preparado para receber milhares de
operações por segundo.

E é isso, o seu servidor de filas já está rodando e sendo
alimentado/consumido. Agora é aplicar para o que você está precisando.

Problemas

Há um probleminha chato com a gravação de log em disco que o Starling
faz das filas. Todo o set feito gera o objeto na memória e
também em disco geralmente em /var/spool/starling/. O
problema é que o get somente remove o objeto da memória e não
do disco. Aparentemente isso foi feito pra ser assim mesmo e segundo o próprio Blaine Cook este arquivo de log
não ficará sendo incrementado para sempre, pois, depois de um certo
tamanho (o engraçado é que ele não fala esse certo tamanho)
ele será rotacionado, mas por enquanto ainda não descobri este certo
tamanho e o arquivo tem crescido infinitamente.

E apenas uma observação: quanto ao consumir_fila.rb: Não
deixe-o executando por muito tempo e nem muito menos esqueça de
finalizá-lo, pois como ele fica em loop infinito poderá ocupar o
seu processador à toa.