No response when using RPC client in multiprocess.

[QuantumEnergyE]

When I used zerorpc.Client in multiprocessing, the request to a zerorpc.Server was blocked without any response.

Note:

• RPC Client->RPC Server(9898)->Process->RPC Client->RCP Server1(9999)
• When I changed multiprocessing to threading, It Succeed.

CODE:

• server.py

import multiprocessing
import zerorpc


def proxy():
    try:
        c = zerorpc.Client(timeout=3)
        c.debug = True
        c.connect("tcp://0.0.0.0:9999")
        print('connected...')
        print(c.test())
    except Exception as ex:
        print(ex)


class M(object):
    def __init__(self):
        pass

    def test(self):
        print('server test')
        p = multiprocessing.Process(target=proxy)
        p.start()
        return 'server test'


def func():
    s = zerorpc.Server(M())
    s.debug = True
    s.bind("tcp://0.0.0.0:9898")
    s.run()


func()

• server1.py

import zerorpc


class M(object):
    def __init__(self):
        pass

    def test(self):
        print('server1 test')
        return "server1 test"


def func():
    s = zerorpc.Server(M())
    s.bind("tcp://0.0.0.0:9999")
    s.run()


func()

• client.py

import zerorpc


def func():
    c = zerorpc.Client()
    c.debug = True
    c.connect("tcp://0.0.0.0:9898")
    print c.test()


func()

OUTPUT:

• client.py:

server test

• server.py:

server test
connected...

[mvheimburg]

I'm experiencing a similar problem. Did you find a solution?

[johaven]

Default Python multiprocessing is not compatible with gevent (see monkey patch or use another solution: greenlet etc ...)

[LoneWolfDog]

I encounter the same questions, any solution to fix it?

[mvheimburg]

I ended up initiating all other servers before the proxy, then passing their port numbers as arguments to the proxy. Then you can make clients within the proxy to connect to the other servers.