importjsonimportmultiprocessingimportsettingsfromnameko.standalone.rpcimportClusterRpcProxyfromnameko.standalone.eventsimportevent_dispatcherfromnameko.constantsimportNON_PERSISTENT,PERSISTENTconfig={'AMQP_URI':f'amqp://{settings.RABBITMQ_CONFIG.username}:'f'{设置.RABBITMQ_CONFIG.password}@{settings.RABBITMQ_CONFIG.host}:'f'{settings.RABBITMQ_CONFIG.port}/{settings.RABBITMQ_CONFIG.vhost}'}dispatch=event_dispatcher(config,delivery_mode=NON_PERSISTENT,use_confirms=False)defrun():data={'name':'jike','age':18,'score':{'math':100,'science':99.5,'english':59}}for_inrange(10000000):dispatch('worker_service','to_rubbish',json.dumps(data))if__name__=="__main__":pool=multiprocessing.Pool(processes=8)foriinrange(100000):pool.apply_async(run)pool.close()pool.join()很简单，就是先pool.close()，再pool.join()
