python - 如何停止等待客户端.connect() 的线程？

Question

基本上我有这个问题:

我使用 ZMQ 使用 PUB/SUB 形式模式将一些数据发布到其他程序。第一类，即服务器等待客户端 .connect()，当客户端连接时，服务器将数据发送给客户端。

我使用 ZMQ REQ/REP 来同步服务器和客户端。

这是Server.py:

class PublishThread (threading.Thread):
def __init__(self):
    threading.Thread.__init__(self)
    socketPub.bind("tcp://127.0.0.1:4002")
    syncservice.bind('tcp://127.0.0.1:5001')
def run(self):
    while True:
        subscribers = 0
        topic = b"PHONEBOOK"
        while subscribers < 1:
            # Here we wait for client to connect. If the client doesn't 
            #connect, this is where this thread will "hang"
            syncservice.recv()
            # Send response to client
            syncservice.send(b'')
            subscribers += 1

        socketPub.send_multipart([topic, data1])
        subscribers = 0

Q1:当我想退出我的程序时如何停止这个线程？
因为当我想退出我的程序时，程序“挂起”，因为线程仍在运行并等待为客户。
Q2:您认为最好的实现方式是什么？
Q3:除了REQ/REP还有其他方法吗？

Answer 1

ZeroMQ 是一套非常强大的工具，用于智能分布式应用程序，具有消息和信号功能，随时可以“使用”(如果有人知道如何 - 无论如何，do not hesitate to follow the book)。

---

A1:首先，您需要开始以非阻塞、异步模式设计您的代码单元，这样您仍然可以独立于任何内部/外部阻塞程序来控制您的线程代码.作为第 1 课，必须忘记只使用裸体 .recv() 并在心理上切换到 zmq.NOBLOCK 和/或循环控制的 .poll( nMSECs ) 在必要时(不是所有的 ZeroMQ 包装器都有这样的安慰 pyzmq有，所以一定要从这个奖金中受益)。

---

A2: 根据经验，可以使用多个额外的 SIG 和 DIAG 消息传递 ZeroMQ - 添加到任何线程代码单元的核心逻辑的模式。这有助于您在任何类型的内部设置中进行测试和临时更改(有效地向您的代码单元添加分布式 CLI 接口(interface)是其很酷的副产品，不是吗？)和/或线程终止。

---

A3: 哦，当然有。每当有人觉得 REQ/REP 正式沟通模式是正确的时，再次检查这本书并重新设计代码，以便它能够在 REQ/REP 无法获得的情况下幸存下来一旦它悄无声息地进入去同步状态，它自己就会从去同步的分布式-FSA-步进中消失。许多帖子都提到了这个主要问题。

---

结语:强烈建议不要在线程中共享 ZeroMQ 套接字实例。