嗯,ZeroMQ 读作 socket-"counterparty" 有点棘手(它不是)
为什么?
Classical socket 是免费资源。
ZeroMQ 是一个相当复杂的思想和行为原则(更好的分布式行为)层次结构,有助于设计智能分布式计算系统,而无需触及控制实际事件流的低级(ZeroMQ 抽象良好)细节在恶劣条件下的风暴中,所有分布式计算系统都是开放的(并且必须相应地在低级别进行处理,如果 ZeroMQ“承诺”要保留的高级抽象要实现并让设计人员的思想集中注意力而不是在他/她的核心应用程序部分,而不是重新设计轮子(通过所有试验和错误)来拉动 O/S 资源和摇动系统服务以收集一些低垂的水果)。
由于这些原因最好直接忘记 ZeroMQ 是“类似的东西-socket”
ZeroMQ 层次结构不到五秒
1:
ZeroMQ 承诺可以轻松重用一些简单的可扩展正式通信模式archetypes,提供特定的分布式行为{ PUB/SUB | PUSH/PULL | PAIR/PAIR | XPUB/XSUB | ... | REQ/REP }。
2:
除了只使用 device-less inproc:// 传输类的情况外,在所有其他情况下,ZeroMQ 需要一个或多个可调“引擎" - Context( nIOthreads = N )、N >= 1。
3:
有了这个,任何(未来的socket)接入点都可以被实例化,从出生的那一刻起就具有行为原型:
aSubscribeCHANNEL = aLocalCONTEXT.socket( zmq.SUB ) # this is NOT a <SOCKET>
# ^^^^^^__________________ even it was typed in
4:
在本地“引擎”“内部”准备好“Access Point”实例后,可以使用一个或多个(是,更多...哇!意味着更多的传入拉弦进入/从单个接入点“行为节点”吹出的哨声)调用以下任一方法:
.bind( @ 987654330@ )
或
.connect( <transport-class>://<a-class-specific-address> )
5:
当且仅当 .bind()-RTO-ready 接入点 A“被访问”由具有任何匹配行为配对的第一个实时 .connect()-RTO-ready 接入点 B,ZeroMQ-消息传递/信令原型开始生效(将其命名为 socket 可能是出于历史原因,以便及时解释)
(PUB/PUB 永远不适合,原因很明显,而PUB/SUB 和许多其他行为原型对将非常匹配并形成相互“兼容”的行为,最终将上线并保持这样)
那么,
如果给定一台具有多个地址的机器,我该如何使用 Python ZeroMQ 套接字做同样的事情?
只需在对
.bind( "{ tcp | pgm | epgm }://<ip>:<port#>" ) 方法的调用中使用完全限定的规范,您就完成了。
就这么简单。
很酷,不是吗?
在性能调整、延迟削减和安全调整的背后还有许多令人惊喜的惊喜。