Ruby

Ruby

Github https://github.com/zeromq/rbzmq
gem https://rubygems.org.cn/gems/zmq
文档 http://zeromq.github.io/rbzmq/

安装

安装 libzmq.

gem install zmq

如果 gem 安装时提示找不到 libzmq 或头文件，只需将你的 libzmq 安装路径传递给 gem install 命令即可

gem install zmq -- --with-zmq-dir=/opt/local

在 Windows 上，为库添加一个参数。例如

gem install zmq -- --with-zmq-dir=c:/src/zeromq-4.3.2 --with-zmq-lib=c:/src/zeromq-4.3.2/src/.libs

示例

require "zmq"

context = ZMQ::Context.new(1)

puts "Opening connection for READ"
inbound = context.socket(ZMQ::UPSTREAM)
inbound.bind("tcp://127.0.0.1:9000")

outbound = context.socket(ZMQ::DOWNSTREAM)
outbound.connect("tcp://127.0.0.1:9000")
p outbound.send("Hello World!")
p outbound.send("QUIT")

loop do
  data = inbound.recv
  p data
  break if data == "QUIT"
end