本文共 763 字，大约阅读时间需要 2 分钟。
running on 127.0.0.1 (localhost) on port 5672 (standard AMQP port).
$ sudo apt-get install rabbitmq-server
rabbitmqctl status
sudo apt-get install python-setuptools python-pip git-coresudo pip install pikasudo easy_install pika
$ sudo gem install amqp
例 54.1. Ruby on RabbitMQ
subscriber.rb
$ cat subscriber.rbrequire 'rubygems'require 'amqp'EM.run { amq = MQ.new amq.queue("logins").subscribe do |login| puts login end} producer.rb
$ cat producer.rb require 'rubygems'require 'amqp'EM.run { amq = MQ.new queue = amq.queue("logins") %w[scott nic robi].each { |login| queue.publish(login) }} test
$ ruby subscriber.rb$ ruby producer.rb
转载地址：http://tlfna.baihongyu.com/