mosquitto使用多线程时,最好使用mosquitto_loop_start(),then mosquitto_disconnect() and mosquitto_loop_stop()

当使用mosquitto_loop_forever()时,使用mosquitto_threaded_set(mosq, true)

How to disconnect and close the struct mosquitto object safely? · Issue #1282 · eclipse/mosquitto (github.com)https://github.com/eclipse/mosquitto/issues/1282

Mosquitto library should default to thread-safe · Issue #450 · eclipse/mosquitto (github.com)https://github.com/eclipse/mosquitto/issues/450

mosquitto的API:

mosquitto.hhttp://mosquitto.org/api/files/mosquitto-h.html

2023.7.27更新:

mosquitto断线重连

if (robotunePub->loop(-1, 1))
{
	robotunePub->reconnect();
}

 mosquitto格式转换

void vn_mosquitto::on_message(const struct mosquitto_message* message)
{
    std::string robotTuneMsg((char *)message->payload);
}

 

struct mosquitto_message{
	int mid;
	char *topic;
	void *payload;
	int payloadlen;
	int qos;
	bool retain;
};

Logo

瓜分20万奖金 获得内推名额 丰厚实物奖励 易参与易上手

更多推荐