142.2. ZeroMQ

简介:
$ sudo apt-get install zeromq-bin libzmq0 libzmq-dev libzmq-dbg
	

142.2.1. python-zeromq

sudo add-apt-repository ppa:chris-lea/zeromq
sudo apt-get update
        
sudo apt-get install python-zeromq
        

142.2.1.1. pyzmq

http://zeromq.github.com/pyzmq/

$ sudo apt-get install autoconf automake
$ sudo pip install pyzmq
		    
$ git clone git://github.com/zeromq/pyzmq.git
$ cd pyzmq
$ python setup.py configure --zmq=/path/to/zmq/prefix
$ python setup.py install
            
easy_install pyzmq
            

142.2.1.2. example

例 142.2. server.py

$ cat server.py
import zmq
context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://127.0.0.1:5000")

while True:
    msg = socket.recv()
    print "Got", msg
    socket.send(msg)
                

例 142.3. client.py

$ cat client.py
import zmq
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://127.0.0.1:5000")

for i in range(10):
    msg = "msg %s" % i
    socket.send(msg)
    print "Sending", msg
    msg_in = socket.recv()
                

142.2.2. ruby zmq

sudo gem install zmq
        




原文出处:Netkiller 系列 手札
本文作者:陈景峯
转载请与作者联系,同时请务必标明文章原始出处和作者信息及本声明。

目录
相关文章
|
消息中间件 存储 网络协议
ZMQ/ZeroMQ简介
ZMQ/ZeroMQ简介
|
9月前
|
消息中间件 Java 微服务
RabbitMQ入门指南(七):生产者可靠性
RabbitMQ是一个高效、可靠的开源消息队列系统,广泛用于软件开发、数据传输、微服务等领域。本文主要介绍了消息丢失的可能性、生产者可靠性中的生产者重试机制和生产者确认机制等内容。
266 0
RabbitMQ入门指南(七):生产者可靠性
|
消息中间件 负载均衡 网络协议
ZMQ/ZeroMQ的三种消息模式
ZMQ/ZeroMQ的三种消息模式
ZMQ/ZeroMQ的三种消息模式
|
9月前
|
消息中间件 存储 Java
RabbitMQ是如何实现消息传递的?
RabbitMQ是如何实现消息传递的?
143 0
|
消息中间件 网络协议 网络性能优化
ZeroMQ:不一样的套接字。
这就是为什么在服务器使用订阅服务模式或者请求应答模式绑定对应端口后,使用NetAssist 以客户端访问可以发送数据,但是在服务端和客户端都没有收到污染。
265 0
|
消息中间件 网络架构
ZeroMQ:疯狂的套接字。
正是因为套接字可以使用不同的方式进行连接,才构成了ZMQ最基本的消息队列系统。我们还可以在此基础之上建立更为复杂的装置、路由机制等,下文会详述。总的来说,ZMQ为你提供了一套组件,供你在网络架构中拼装和使用。
84 0
|
消息中间件 存储 安全
zeromq无锁队列的原理与实现
zeromq无锁队列的原理与实现
237 0
|
消息中间件 网络协议 PHP
|
消息中间件 Java
ActiveMQ点对点消息传递
上篇文章中详细介绍了ActiveMQ。本文继续介绍ActiveMQ的具体操作
ActiveMQ点对点消息传递
|
存储 消息中间件 监控
消息中间件系列四、认识AMQP和RabbiyMq的简单使用
AMQP AMQP(advanced message queuing protocol)是一个提供统一消息服务的应用层标准协议,基于此协议的客户端与消息中间件可传递消息,并不受客户端/中间件不同产品,不同开发语言等条件的限制 。
3471 13