zeroless 1.0.0

推拉

用于在一组工人之间分配工作负载。普通人 流处理领域的模式，是 例如apache storm之类的应用程序。而且，它可以被看作 地图缩减模式的概括。

# Binds the pull server to port 12345# And assigns an iterable to wait for incoming messageslisten_for_push=Server(port=12345).pull()formsginlisten_for_push:print(msg)

# Connects the client to as many servers as desiredclient=Client()client.connect_local(port=12345)# Initiate a push client# And assigns a callable to push messagespush=client.push()formsgin[b"Msg1",b"Msg2",b"Msg3"]:push(msg)

发布者订阅服务器

用于向一组对等方广播消息。一种常见的模式 在客户端允许实时通知，而不必 采用一些不成熟的方法，比如共用。在线服务，如 pubnub或像mqtt这样的物联网协议就是这种模式使用的例子。

# Binds the publisher server to port 12345# And assigns a callable to publish messages with the topic 'sh'pub=Server(port=12345).pub(topic=b'sh',embed_topic=True)# Gives publisher some time to get initial subscriptionssleep(1)formsgin[b"Msg1",b"Msg2",b"Msg3"]:pub(msg)

# Connects the client to as many servers as desiredclient=Client()client.connect_local(port=12345)# Initiate a subscriber client# Assigns an iterable to wait for incoming messages with the topic 'sh'listen_for_pub=client.sub(topics=[b'sh'])fortopic,msginlisten_for_pub:print(topic,' - ',msg)

注意：自zmq 3.0以来，zmq的主题过滤功能是发布者端的。

最后但并非最不重要的是，绑定的子套接字在 首先通过提供的生成器请求，因此如果 丢失一些消息不是一个选项。

配对

通常，这种模式是不必要的，正如上面的那些 或者它们的混合足以满足分布式计算中的大多数用例。 就其功能而言，这种模式是最相似的替代方案 到上述模式中的常用posix套接字。因此， 期望一对一和双向通信。

# Binds the pair server to port 12345# And assigns a callable and an iterable# To both transmit and wait for incoming messagespair,listen_for_pair=Server(port=12345).pair()formsginlisten_for_pair:print(msg)pair(msg)

# Connects the client to a single serverclient=Client()client.connect_local(port=12345)# Initiate a pair client# And assigns a callable and an iterable# To both transmit and wait for incoming messagespair,listen_for_pair=client.pair()formsgin[b"Msg1",b"Msg2",b"Msg3"]:pair(msg)response=next(listen_for_pair)print(response)