1
BingoXuan OP 贴一下服务器的部分代码
class ZPub(Pub): def __init__(self, identity): super().__init__(identity) ctx = zmq.Context() self.pub_socket = ctx.socket(zmq.PUB) self.pub_socket.setsockopt_string(zmq.IDENTITY, self.identity) self.pub_socket.bind('tcp://127.0.0.1:8099') self.lock = threading.Lock() def _send(self, ts, msg, id_str): self.lock.acquire() self.pub_socket.send_multipart([bytes(m, encoding='ascii') for m in [ts, msg, id_str]]) self.lock.release() |
2
BingoXuan OP 问题已解决:绑定 tcp://*8099
有谁知道具体原因呢? |
3
ThirdFlame 2018-07-04 16:58:13 +08:00 1
127.0.0.1 不是仅允许本机连接么。
|
4
xcai 2018-07-04 16:58:50 +08:00 via Android 1
腾讯云安全组放行端口
|
5
tempdban 2018-07-04 17:02:09 +08:00 via Android 1
self.pub_socket.bind('tcp://0.0.0.0:8099')
|
6
mosliu 2018-07-04 17:05:20 +08:00 1
127.0.0.1 是本机 loopback 网卡吧。。。
|
7
BingoXuan OP |