python-pynng

安装

pip3 install pynng

使用样例

from pynng import Pair0

with Pair0(dial=address) as s1:
    s1.send(b'python login')
    while True:
        msg = s1.recv().decode(encoding='utf-8')
        print('python:' + msg)
        log.info('receive: ' + msg)
        if msg == 'exit':
            s1.send(b'python bye')
            time.sleep(0.5)
            log.info('exit nng loop')
            break
        elif msg.startswith('datas') or msg.startswith('ready'):
            log.info('receive ' + msg)
            # datas,12332 后面是共享内存数据大小
            # load data process by memory mapping  mmap file
            # 收到的数据格式："datas,size,cur index, all count"
            param_list = msg.split(',')
            if len(param_list) >= 4:
                # 获取数据大小
                data_size = int(param_list[1])
                # 读取共享内存数据放到 share_df_list 里面
                load_share_data(shm, data_size)
                # 最后一组数据，接收完毕后可以处理
                if param_list[2] == param_list[3]:
                    log.info('get last group data')
                    ret = proc_raw_data(share_df_list)
                    print('Python datas_RESULT,' + ''.join(ret))
                    log.info('datas_RESULT,' + ''.join(ret))
                    s1.send(bytes('datas_RESULT,' + ''.join(ret), encoding='gbk'))
                else:
                    s1.send(b'datas_OK')
                    pass

接收数据不全

发送的数据中有中文