Starling是一个使用Memcached协议的,轻量级的消息队列服务器,从它被开发至今已经有一段时间了。Starling使得为多个进程和多个主机之间的并行作业编写一个可通过网络访问的消息队列(或多个消息队列),变得极其容易。Starling由Twitter开发,并用于处理其系统内的产生的大量的消息队列。Starling 在实际应用中已经得到了验证,并且不仅仅只有Twitter自己在使用,另一家公司FiveRuns也在使用Starling。FiveRuns 甚至创建了他们自己的Starling 版本,按照他们的说法,Starling是非常快速的。所以Starling用于生产环境中的稳定性和访问速度是不用怀疑的。
队列(Queue)是一种特殊的线性表,它只允许在表的前端(front)进行删除操作,而在表的后端(rear)进行插入操作。进行插入操作的端称为队尾,进行删除操作的端称为队头。队列中没有元素时,称为空队列。 在队列这种数据结构中,最先插入在元素将是最先被删除;反之最后插入的元素将最后被删除,因此队列又称为“先进先出”(FIFO—first in first out)的线性表。
队列可以很好地异步处理数据传送和存储,当你频繁地向数据库中插入数据、频繁地向搜索引擎提交数据,就可采取队列来异步插入。另外,还可以将较慢的处理逻辑、有并发数量限制的处理逻辑,通过消息队列放在后台处理,例如FLV视频转换、发送手机短信、发送电子邮件等。
———————————————————-(以上摘自网络)
Starling:http://github.com/starling/starling
安装Starling服务器:
#starling是用ruby写的,所以先要下载ruby #wget ftp://ftp.ruby-lang.org//pub/ruby/1.9/ruby-1.9.2-p0.tar.gz #解压缩 #tar zxvf ruby-1.9.2-p0.tar.gz #cd ruby-1.9.2-p0 #安装 #./configure --prefix=/usr/local/ruby #make #make install #下载rubygems #wget http://rubyforge.org/frs/download.php/70696/rubygems-1.3.7.tgz #tar zxvf rubygems-1.3.7.tgz #cd rubygems-1.3.7 #安装 #/usr/local/ruby/bin/ruby setup.rb #安装starling #gem install starling #启动starling #-h 主机ip #-d 守护进程启动 #-p 端口 #-P /tmp/starling.pid pid文件 #starling --help 查看Starling帮助和使用信息 #/usr/local/ruby/bin/ruby /usr/local/ruby/bin/starling -h 127.0.0.1 -d -p 22122
至此,Starling队列服务器安装成功,用 ps ax | grep starling 就可以看到 Starling 进程了。
下面我们就要访问 Starling。因为它是基于Memcached协议,那就可以用现有的php memcached客户端访问 Starling。安装PHP的memcached客户端请参考网络资料。
<?php $memcache = new Memcache; $memcache->addServer('127.0.0.1', 22122); // 向队列中写入值,数字1..100 for($i=1; $i<=100; $i++) { // queue为队列名称 $memcache->set('queue', $i); } // 取出队列中的值 while($value = $memcache->get('queue')) { echo $value."<br />"; } ?>
不知有没有一次从队列中取出多条值的接口,用 /usr/local/ruby/bin/starling_top 可以查看 Starling 的运行状态。