我怎么能在pahomqtt拥有数百个订户?

2024-04-26 04:41:12 发布

您现在位置:Python中文网/ 问答频道 /正文

我想模拟一个有100个订阅者和100个发布者的系统,我使用Mosquito作为代理,客户端是两个python脚本。在发布服务器方面,我已经成功地使用python线程将其配置为100个发布服务器,但我怀疑在订阅服务器部分是否实现同样的功能

我的意思是创建一个包含所有客户机的列表,然后为每个客户机创建一个线程,这是我在发布服务器中实现的,但是在订阅服务器中创建目标是困难的,因为必须执行多个函数

for client_id, client in all_clients:
     t = threading.Thread (target = sending, args = (client, client_id))
     t.start ()
     all_threads.append (t)
 
# at the end wait for end of threads
for t in all_threads:
     t.join ()

有人能建议我如何实施它吗? 提前谢谢