问题已解决。

冯总，不采用订阅、发布方式，那就是普通的TCP/UDP方式了吧？

@潘正成-FAE 您好，我修改试了，目前看只偶尔出现过一次，应该是解决了，多谢协助！

@冯士曦 @毛豆米 两位专家，我不用tcdrain，使用固定延时，还是出现了最后一个数据丢失的问题，更奇怪的是后面恢复不了了，这个串口就一直都收不到数据了，这是什么原因呢。

@毛豆米 数据接收时丢失的是最后一个数，很奇怪。我测量了tcdrain延时的时间，两个终端，一个终端tcdrain延时约50ms，一个终端tcdrain延时约10~18ms。延时较小的终端比较容易在tcdrain处卡死。

@冯士曦在读写之间增加时延（如间隔1s），仍会出现tcdrain阻塞的情况。

@冯士曦使用tcdrain判断写完后直接改接收模式进行select判断，成功后直接进行读操作。select中的time参数设置如下：time.tv_sec = 2;time.tv_usec = 0;fs_sel = select(fd, &fs_read, NULL, NULL, &time);if (fs_sel) {        执行读操作；}

问题解决，还是485方向没控制好的问题。@毛豆米 @华为IoT云服务

//成功#define MQTTCLIENT_SUCCESS 0 //失败,通用#define MQTTCLIENT_FAILURE -1 //客户端未连接,未连接,先使用引起#define MQTTCLIENT_DISCONNECTED -3 //已达到允许同时处理的最大消息数(#define MAX_MSG_ID 65535)#define MQTTCLIENT_MAX_MESSAGES_INFLIGHT -4 //UTF-8字符串无效#define MQTTCLIENT_BAD_UTF8_STRING -5 //A NULL parameter has been supplied when this is invalid.#define MQTTCLIENT_NULL_PARAMETER -6 //主题名包含中间NULL,被截断#define MQTTCLIENT_TOPICNAME_TRUNCATED -7 //结构参数不正确,关注版本信息, 发送过库版本与头文件不匹配,导致此异常#define MQTTCLIENT_BAD_STRUCTURE -8 //QOS传入异常参数#define MQTTCLIENT_BAD_QOS -9 //库版本不支持SSL功能#define MQTTCLIENT_SSL_NOT_SUPPORTED -10 //无法识别的MQTT版本 #define MQTTCLIENT_BAD_MQTT_VERSION -11 //服务器地址格式错误,协议字首== tcp:// or ssl://#define MQTTCLIENT_BAD_PROTOCOL -14 //选项不适用于请求的MQTT版本 #define MQTTCLIENT_BAD_MQTT_OPTION -15 //使用的调用 不适用于请求的MQTT版本 #define MQTTCLIENT_WRONG_MQTT_VERSION -16

@冯士曦 我们想的是这样子，如果MQTT不支持，是否还有其他方式？