MQTT通讯 pipe

pahomqtt 编译时提示缺少pipe是什么情况？

发布于 2022-05-09 13:41:26 浏览：452 订阅该版

crystal266 2022-05-09

这家伙很懒，什么也没写！

crystal266 2022-05-09

这家伙很懒，什么也没写！

或者 根据软件包源码，使用最新版本latest 在文件 packages/pahomqtt-latest/MQTTClient-RT/paho_mqtt.h 的最开始定义宏 `#define RT_USING_POSIX_FS`，这样编译的时候就能包含 struct rt_pipe_device ，就不会报错了。

```c
struct MQTTClient
{
    const char *uri;
    int sock;

MQTTPacket_connectData condata;

unsigned int next_packetid, command_timeout_ms;
    size_t buf_size, readbuf_size;
    unsigned char *buf, *readbuf;
    unsigned int keepAliveInterval;
    int connect_timeout;
    int reconnect_interval;
    int isblocking;
    int isconnected;
    uint32_t tick_ping;

void (*connect_callback)(MQTTClient *);
    void (*online_callback)(MQTTClient *);
    void (*offline_callback)(MQTTClient *);

struct MessageHandlers
    {
        char *topicFilter;
        void (*callback)(MQTTClient *, MessageData *);
        enum QoS qos;
    } messageHandlers[MAX_MESSAGE_HANDLERS]; /* Message handlers are indexed by subscription topic */

void (*defaultMessageHandler)(MQTTClient *, MessageData *);

/* publish interface */
    rt_mutex_t pub_mutex;             /* publish data mutex for blocking */
#if defined(RT_USING_POSIX_FS) && (defined(RT_USING_DFS_NET) || defined(SAL_USING_POSIX))
    struct rt_pipe_device* pipe_device;
    int pub_pipe[2];
#else
    int pub_sock;
    int pub_port;
#endif /* RT_USING_POSIX && (RT_USING_DFS_NET || SAL_USING_POSIX) */

#ifdef MQTT_USING_TLS
    MbedTLSSession *tls_session;      /* mbedtls session struct */
#endif

void *user_data;                  /* user-specific data */
};
```