????warden:??????????????м???warden-aggr????socket connect???????zeromq sub???????????????????print????????????? send ?? recv????multipart??????????warden???????????????????????.

????sample code:
????class Warden:

    _sock = None

    def __init__(self?? connectInfo):
        context = zmq.Context()
        self._sock = context.socket(zmq.SUB)
        self._sock.setsockopt(zmq.SUBSCRIBE?? '')
        self._sock.connect(connectInfo)

    def loop(self?? filter):
        while 1:
            msg = self._sock.recv_multipart()
            if cmp(msg[0]?? filter) != -1:
                print zlib.decompress(msg[1])??

????????:

????-?????淶identity ?????????????????????????????????к?????????????????????????identity?????????????.

????-????? ????????????warden?????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????.

??????:

?????????warden???????????????????????????????.

????This entry was posted in ?????? by sdhou. Bookmark the permalink.