Open Cmtd opened 9 months ago
def createConsumer(): consumer = PushConsumer(gid) # 指定group-id consumer.set_namesrv_addr(name_srv) # rocketmq队列接口地址(服务器ip:port) consumer.subscribe(topic, callback) # 订阅 consumer.start() # 开启 if name=='main': print('Parent process %s.' % os.getpid()) for i in range(5): p = Process(target=createConsumer) print('Run child process (%s)...' % (os.getpid())) p.start() while True: time.sleep(3600) 为什么我写了多进程的消费程序,但是却并不执行
我也遇到了
def createConsumer(): consumer = PushConsumer(gid) # 指定group-id consumer.set_namesrv_addr(name_srv) # rocketmq队列接口地址(服务器ip:port) consumer.subscribe(topic, callback) # 订阅 consumer.start() # 开启 if name=='main': print('Parent process %s.' % os.getpid()) for i in range(5): p = Process(target=createConsumer) print('Run child process (%s)...' % (os.getpid())) p.start() while True: time.sleep(3600) 为什么我写了多进程的消费程序,但是却并不执行