-1

我正在使用 apollo 代理和 mosquitto C 客户端库。成功发布消息后，我使用 mosquitto_disconnect(mosq) 函数断开客户端。但看起来客户端用来连接代理的端口仍然不是空闲的。有什么方法可以手动释放客户端用于连接 ac 程序中代理的端口？

void on_publish(struct mosquitto *mosq, void *userdata, int mid)
{

    mosquitto_disconnect(mosq);

    log_print("mqtt",1,"Inside publish callback");


}

int sendData_mqtt(char *address, char *port, char* url, char *data)
{
    struct mosquitto *mosq;
    int err; 
    char *clean_session = "true";
    char *retain_flag = "true";
    int port1= atoi(port);

    mosq = mosquitto_new("unknown", clean_session, NULL);
    mosquitto_publish_callback_set(mosq, on_publish);

    mosquitto_username_pw_set(mosq,"admin","password"); 
    err=mosquitto_connect(mosq, address,port1,60);
    if(err != 0 ){
        log_print("mqtt",1,"connect error= %s\n",mosquitto_strerror(err));
        return -1;
    }
        else 
            log_print("mqtt",1,"successfully connected");
    err = mosquitto_publish(mosq, NULL, "subject", strlen(data), data, 1, retain_flag);

    sleep(5);
    if(err != 0 ) {
        log_print("mqtt",1,"Publish error = %s\n",mosquitto_strerror(err));
        return -1;
        }   
    mosquitto_loop_forever(mosq,-1,1); 

    return 10;  
}
4

1 回答 1

0

这应该会自动发生，一旦 libmosquitto 认为它已经发送了 DISCONNECT 数据包，它将关闭套接字。

您是否调用了 mosquitto_loop_forever() 或 mosquitto_loop_start() 来处理网络流量？

您使用的是什么版本的 libmosquitto？

可能是经纪人在您没有意识到的情况下拒绝了您的凭据吗？尝试添加日志回调以查看发生了什么。

void on_log(struct mosquitto *mosq, void *userdata, int level, const char *msg)
{
    printf("%s\n", msg);
}

并使用

mosquitto_log_callback_set(mosq, on_log);

我很想说你也需要回归基础。查看 clean_session 并保留 mosquitto_new 和 mosquitto_publish 的参数——它们不应该是char *设置为“true”的字符串。阅读文档，看看有哪些工具可供您进行调试（例如 on_log），然后出去做一些调试。也许查看源代码以了解您期望发生的情况。

于 2015-09-25T09:57:44.427 回答