PROSAGA码农传奇-zeromq-ZMQ连接和推送

<div class =“post-text”itemprop =“text”>
  
    你可以得到
     <code>
 zmq.error
 </code>
     使用以下代码段：
  
   <pre>
 <code>
 import zmq
import time

zcontext = zmq.Context()
zsock = zcontext.socket(zmq.PUSH)
zsock.connect("tcp://localhost:12345")

try:
    with open(sys.argv[1]) as f:
        for line in f:
            zsock.send(line, flags=NOBLOCK)
            time.sleep(.1)

except zmq.ZMQError as exc:
    print(exc)

</code>
 </pre>
  <HR />
  
    [
    的
      注意
    </强>
    ]：
  
  <UL>
    <LI>
      
        你可以改变
         <code>
 .connect()
 </code>
         方法用
         <code>
 .bind()
 </code>
         在上面的代码中，也改变了另一面
         <code>
 bind
 </code>
         至
         <code>
 connect
 </code>
         对于测试用例。
      
    </LI>
    <LI>
      
        在
         <code>
 .bind()
 </code>
         应该使用方法
         <code>
 127.0.0.1
 </code>
         代替
         <code>
 localhost
 </code>
        。
      
    </LI>
  </UL>
  <HR />
  
    [
    的
      UPDATE
    </强>
    ]：
  
  <UL>
    <LI>
      检查
      <a href="https://stackoverflow.com/a/52353685/3702377">
        Limiting_ZeroMQ_Queue
      </A>
    </LI>
  </UL>
  <BLOCKQUOTE>
    <UL>
      <LI>
        
          同
           <code>
 flags=NOBLOCK
 </code>
           在
           <code>
 .send()
 </code>
           方法，这引起了
           <code>
 ZMQError
 </code>
           如果
          的
            队列已满;
          </强>
           否则，等待空间可用。
  因此，在这种情况下，将如下所示：
        
        
           <code>
 zsock.send(line, flags=NOBLOCK)
 </code>
        
      </LI>
    </UL>
  </BLOCKQUOTE>
</DIV>

ZMQ连接和推送 - 如何确定它是否失败