我希望使用activemq支持大约100 K的mqtt连接。activemq服务器拒绝30K以上的连接。如何调优activemq以支持更多的连接。我试过以下几种方法
uri="mqtt+nio://0.0.0.0:1883?maximumConnections=100000&wireFormat.maxFrameSize=104857600&transport.defaultKeepAlive=60000&transport.closeAsync=false&useQueueForAccept=false transportConnector name
在我的django项目中,我将永远订阅MQTT主题,并在主题更改时触发操作。在我的__init__.py应用程序文件中,我尝试:
client1 = mqtt.Client(hex(uuid.getnode()))
data_dict = init_client('IOT/Data/#')
for k, v in data_dict.items():
...do some stuff with data
init_client函数连接到我MQTT服务器并启动循环(我使用paho.mqtt.client):
def init_client(t_topic='IO