最新在使用LWIP + MQTT的應(yīng)用過程中，出現(xiàn)一個很奇怪的問題，當(dāng)上位機反送的JSON長度過大時，我的stm32收到的數(shù)據(jù)就會有問題：

上圖中成功接收到失敗接收口相關(guān)1個字節(jié)，用wireshark看數(shù)據(jù)包長度分別是591和590：

發(fā)現(xiàn)可能是我的接收BUFF不夠大引起的,程序中有MqttRxBuff大小定義為1024，改成2048還是一樣接收失敗:

看來問題不是在這個BUFF,

接著看MQtt對應(yīng)的TCP接收BUFF,在LWIP的opt.h中看到有如下一些定義，從圖中看到PBUF_POOL_BUFSIZE大小取決到TCP_MESS大小。當(dāng)前TCP_MESS大小于536 對應(yīng)計算出的PBUF_POOL_BUFSIZE為592，剛好與我們之前的591相近，看到就是這個問題我們把

按理把這個參數(shù)改大后應(yīng)該可以解決，但是發(fā)現(xiàn)實際發(fā)現(xiàn)還是不行！

仿真發(fā)現(xiàn)數(shù)據(jù)從路由器發(fā)送到MCU時，就已經(jīng)分成了兩包，最終將TCP的接收函數(shù)改寫成如下問題解決。

?

/**

? * @brief tcp_receiv callback

? * @param arg: argument to be passed to receive callback

? * @param tpcb: tcp connection control block

? * @param err: receive error code

? * @retval err_t: retuned error

? */

err_t MqttTcp_recv(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err)

{

??? struct mqttclinet *es;

??? err_t ret_err;

??? int i = 0;

?

?

??? LWIP_ASSERT("arg != NULL",arg != NULL);

?

??? es = (struct mqttclinet *)arg;

?

??? /* if we receive an empty tcp frame from server => close connection */

??? if (p == NULL)

??? {

??????? /* remote host closed connection */

??????? es->state = ES_CLOSING;

??????? if(es->p_tx == NULL)

??????? {

??????????? /* we're done sending, close connection */

??????????? MqttTcp_connection_close(tpcb, es);

??????? }

??????? else

??????? {

??????????? /* send remaining data*/

??????????? MqttTcp_send(tpcb, es);

??????? }

??????? ret_err = ERR_OK;

??? }

??? /* else : a non empty frame was received from echo server but for some reason err != ERR_OK */

??? else if(err != ERR_OK)

??? {

??????? /* free received pbuf*/

??????? pbuf_free(p);

?

??????? ret_err = err;

??? }

??? else if(es->state == ES_CONNECTED)

??? {

??????? /* Acknowledge data reception */

??????? tcp_recved(tpcb, p->tot_len);

?

#if 0

??????? // 回顯功能

??????? es->p_tx = p;

??????? MqttTcp_send(tpcb, es);

?

#else

??????? // 將要接收的數(shù)據(jù)放到BUFF里

??????? if( p->flags == 0 )? //? 如果出現(xiàn)了分包的，在這里時行判斷

??????? {

? ??????????MqttRxOffset = p->len;

????????????? ?? memcpy((void *)MqttRxTemp,p->payload,p->len);

??????? }

??????? else

??????? {

??????????? if( MqttRxOffset )

??????????? {

??????????????? if( (MqttRxBwp + MqttRxOffset) -? MqttRxBrp < MQTTBUFFSIZE?? )

??????????????? {

??????????????????? for( i=0; i<MqttRxOffset; i++ )

??????????????????? {

??????????????????????? MqttRxBuff[MqttRxBwp] = MqttRxTemp[i];

????????????????????? ??MqttRxBwp = (MqttRxBwp+1)%MQTTBUFFSIZE;

??????????????????? }

??????????????? }

???????????????????? ? MqttRxOffset = 0;

??????????? }

??????????? if( (MqttRxBwp + p->tot_len) -? MqttRxBrp < MQTTBUFFSIZE?? )

??????????? {

??????????????? for( i=0; i<p->tot_len; i++)

? ??????????????{

??????????????????? MqttRxBuff[MqttRxBwp] = *((uint8_t *)(p->payload)+i);

??????????????????? MqttRxBwp = (MqttRxBwp+1)%MQTTBUFFSIZE;

??????????????? }

??????????? }??

??????? }

??????? pbuf_free(p);

#endif

??????? ret_err = ERR_OK;

??? }

?

??? /* data received when connection already closed */

??? else

??? {

??????? /* Acknowledge data reception */

??????? tcp_recved(tpcb, p->tot_len);

?

??????? /* free pbuf and do nothing */

??????? pbuf_free(p);

??????? ret_err = ERR_OK;

??? }

??? return ret_err;

}

總結(jié)

以上是生活随笔為你收集整理的STM32 LWIP TCP 数据包分包后合并，超过591字节后分会分包问题的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。