##process_master.py

import queue,time
from multiprocessing.managers import BaseManager

q = queue.Queue()

def send_message(msg):
    q.put(msg)

def get_queue():
    return q


if __name__=='__main__':

    print('++++++++    欢迎来到一问一答系统   +++++++++++++++')
    BaseManager.register('get_queue',callable=get_queue)

    master = BaseManager(address=(' you ip address ',5000),authkey=b'abc')
    master.start()

    accept_queue = master.get_queue()
    while True:
        accept_msg = accept_queue.get(True)
        print('Java：',accept_msg)
        me_msg = input('我：')
        accept_queue.put(me_msg)
        time.sleep(0.5)

##process_worker.py

from multiprocessing.managers import BaseManager
import time

if __name__=='__main__':

    print('++++++++    欢迎来到一问一答系统   +++++++++++++++')
    BaseManager.register('get_queue')

    worker = BaseManager(address=(' you ip address ',5000),authkey=b'abc')
    worker.connect()

    accept_queue = worker.get_queue()
    first_msg = '不好意思来迟了，我是JAVA!'
    accept_queue.put(first_msg)
    print('我：',first_msg)
    time.sleep(0.5)
    while True:
        accept_msg = accept_queue.get(True)
        print('Python：',accept_msg)
        me_msg = input('我：')
        accept_queue.put(me_msg)
        time.sleep(0.5)