ChannelTest.py 文件源码

def client_behavior(settings, logger):

    internal_channel = InternalChannel(addr="127.0.0.1", port=settings.getIntPort(), logger=logger)

    try:
        internal_channel.generate_internal_channel_client_side()
    except ZMQError as e:
        logger.debug(e)

    message = Message()
    message.priority = ALIVE
    message.source_flag = INT
    message.source_id = '1'
    message.target_id = '1'
    message.target_addr = '192.168.1.1'
    message.target_key = '{}:{}'.format(0, 19)

    internal_channel.send_first_internal_channel_message(dumps(message))

    msg = internal_channel.wait_int_message(dont_wait=False)

    logger.debug("msg : " + msg)

    external_channel = ExternalChannel(addr="127.0.0.1", port=settings.getExtPort(), logger=logger)
    external_channel.generate_external_channel_client_side()
    external_channel.external_channel_subscribe()

    logger.debug(loads(external_channel.wait_ext_message()).printable_message())

    logger.debug("try_to_connect TEST COMPLETED")

    stop = False
    while not stop:
        try:
            logger.debug(loads(external_channel.wait_ext_message()).printable_message())
            sleep(1)
        except Again:
            logger.debug("my master is DEAD")
            stop = True