【RA-Eco-RA6M4开发板评测】——7.使用RA6M4开发板通过MQTT实现远程IOT温度上传到手机，不限距离全世界级别

本主题由 System 于 2025-8-26 05:00 解除限时精华

RA6M5远程上传温度到手机

上一节我已经讲解了如何获取RA-Eco-RA6M4的片内温度值，这节我就讲解如何通过手机远程获取RA-Eco-RA6M4的板子温度，它的工作原理就是运用到了互联网IOT的MQTT协议，使用MQTT协议，只要设备和手机都在联网的情况下，实现无距离全世界控制读取数据。

创建工程我就不讲了，直接去看我之前写的帖子，里面写的非常清楚，不重复早轮子了。
这里这接将核心代码
#include "hal_data.h"
#include "usart9.h"
#include "usart6.h"
#include "modbusSlave.h"
#include "esp8266.h"
#include "onenet.h"
#include "MqttKit.h"

FSP_CPP_HEADER
void R_BSP_WarmStart(bsp_warm_start_event_t event);
FSP_CPP_FOOTER

void delay_ms(uint32_t ms)
{
R_BSP_SoftwareDelay(ms, BSP_DELAY_UNITS_MILLISECONDS);
}

uint16_t timeCount = 0;
char PUB_BUF[256];//上传数据的buf（温度，湿度，光照强度,LED和蜂鸣器）
const char *devSubTopic[] = {"LED"}; // 设备订阅命令地址，MQTTX发送命令到服务器，stm32接收命令
const char devPubTopic[] = "RA6M4-Temperature"; // 设备上行数据地址，stm32传感器向服务器传输数据并使用MQTTX接收

uint8_t alarmFlag;//是否报警的标志
uint8_t alarm_is_free;

/*******************************************************************************************************************//**

main() is generated by the RA Configuration editor and is used to generate threads if an RTOS is used. This function

is called by main() when no RTOS is used.
*********************************************************************************************************************/
void hal_entry(void)
{
/ TODO: add your own code here */
UART9_Init();UART6_Init();UART0_Init();
uint8_t *dataPtr = NULL;
ESP8266_Init();

while(OneNet_DevLink() == 1) // 循环连接服务器
{delay_ms(500);}

OneNet_Subscribe(devSubTopic, 1); // 参数1：

//printf("modbus_slave test\r\n");

while(1)
{
if(++timeCount >= 40) // 五秒发送间隔
{
printf("OneNet_Publish \r\n");

sprintf(PUB_BUF, "{\"Temp\":%d.%d, \"Hum\":%d.%d, \"Light\":%.1f, \"LED\":%d, \"BEEP\":%d}",
 	22,3,33,4,1,1?0:1,alarmFlag);// 使用alarmFlag描述蜂鸣器状态
 	 //LED_Status?0:1 如果LED_Status返回值是0，则输出1，如果是1，则输出0

 	OneNet_Publish(devPubTopic, "35.78c");
 	timeCount = 0;
 	ESP8266_Clear();
 }
  // 检查有没有下发指令
 dataPtr = ESP8266_GetIPD(3); // 15ms执行一次
 // 用来检查ESP8266有没有收到信息，如果有返回值就说明收到信息，没有就是没收到
 if(dataPtr != NULL)

 	OneNet_RevPro(dataPtr);

 delay_ms(10);

// if(user_uart6_wait_receive( ) == REV_OK)
// {
// modbus_slave();
// user_uart6_clear();
// }
//

// //printf("ruisa dizn zi ---------------\n");
// R_BSP_SoftwareDelay(100, BSP_DELAY_UNITS_MILLISECONDS);
}

#if BSP_TZ_SECURE_BUILD
/* Enter non-secure code */
R_BSP_NonSecureEnter();
#endif
}

/*******************************************************************************************************************//**

This function is called at various points during the startup process. This implementation uses the event that is
called right before main() to set up the pins.
@param[in] event Where at in the start up process the code is currently at
**********************************************************************************************************************/
void R_BSP_WarmStart (bsp_warm_start_event_t event)
{
if (BSP_WARM_START_RESET == event)
{
#if BSP_FEATURE_FLASH_LP_VERSION != 0
```
/* Enable reading from data flash. */
 R_FACI_LP->DFLCTL = 1U;

 /* Would normally have to wait tDSTOP(6us) for data flash recovery. Placing the enable here, before clock and
  * C runtime initialization, should negate the need for a delay since the initialization will typically take more than 6us. */
```

#endif
}

if (BSP_WARM_START_POST_C == event)
{
    /* C runtime environment and system clocks are setup. */

    /* Configure pins. */
    R_IOPORT_Open(&IOPORT_CFG_CTRL, &IOPORT_CFG_NAME);

#if BSP_CFG_SDRAM_ENABLED

/* Setup SDRAM and initialize it. Must configure pins first. */
    R_BSP_SdramInit(true);

#endif
}
}

#if BSP_TZ_SECURE_BUILD

FSP_CPP_HEADER
BSP_CMSE_NONSECURE_ENTRY void template_nonsecure_callable ();

/* Trustzone Secure Projects require at least one nonsecure callable function in order to build (Remove this if it is not required to build). */
BSP_CMSE_NONSECURE_ENTRY void template_nonsecure_callable ()
{

}
FSP_CPP_FOOTER

#endif

在手机上输入这个

初始化ESP8266和MQTT网络连接

#include "esp8266.h"

static volatile bool uart_send_complete_flag = false;

uint8_t esp8266_buf[RXBUFFLENGTH];
uint16_t esp8266_cnt = 0;
uint16_t esp8266_cntPre = 0;

char tx_buffer[150];

void UART0_Init(void)
{
fsp_err_t err = FSP_SUCCESS;

err = R_SCI_UART_Open(&g_uart7_ctrl,&g_uart7_cfg);

assert(err == FSP_SUCCESS);

}

void WIFI_Send_Byte(uint8_t ch)
{
/* 发送一个字节数据到UART */
R_SCI_UART_Write(g_uart7.p_ctrl, (uint8_t *)&ch, 1);

/* 等待发送完毕 */
while(uart_send_complete_flag == false);
uart_send_complete_flag = false;

}

void WIFI_Send_Bytes(uint8_t data, uint32_t len)
{
/ 发送一个字节数据到UART */
R_SCI_UART_Write(g_uart7.p_ctrl, data, len);

/* 等待发送完毕 */
while(uart_send_complete_flag == false);
uart_send_complete_flag = false;

}

void WIFI_Send_String_Length(uint8_t str,uint32_t strlen)
{
unsigned int k=0;
do
{
WIFI_Send_Byte ((str + k));
k++;
} while(k < strlen);
}

void WIFI_Send_String(uint8_t str)
{
unsigned int k=0;
do
{
WIFI_Send_Byte ((str + k));
k++;
} while(*(str + k)!='\0');
}

void ESP8266_Clear(void)
{

memset(esp8266_buf, 0, sizeof(esp8266_buf));
esp8266_cnt = 0;

}

uint8_t ESP8266_WaitRecive(void)
{

if(esp8266_cnt == 0) 							//如果接收计数为0 则说明没有处于接收数据中，所以直接跳出，结束函数
	return REV_WAIT;
	
if(esp8266_cnt == esp8266_cntPre)				//如果上一次的值和这次相同，则说明接收完毕
{
	esp8266_cnt = 0;							//清0接收计数
		
	return REV_OK;								//返回接收完成标志
}
	
esp8266_cntPre = esp8266_cnt;					//置为相同

return REV_WAIT;								//返回接收未完成标志

}

//==========================================================
// 函数名称： ESP8266_SendCmd
//
// 函数功能：发送命令
//
// 入口参数： cmd：命令
// res：需要检查的返回指令
//
// 返回参数： 0-成功 1-失败
//
// 说明：
//==========================================================
_Bool ESP8266_SendCmd(char *cmd, char *res)
{

unsigned char timeOut = 200;

WIFI_Send_Bytes((uint8_t *)cmd, strlen((uint8_t *)cmd));

while(timeOut--)
{
	if(ESP8266_WaitRecive() == REV_OK)							//如果收到数据
	{
		if(strstr((const char *)esp8266_buf, res) != NULL)		//如果检索到关键词
		{
		    printf("%s\r\n",esp8266_buf);
			ESP8266_Clear();									//清空缓存
			return 0;
		}
	}
	
	delay_ms(10);
}

return 1;

}

//==========================================================
// 函数名称： ESP8266_SendData
//
// 函数功能：发送数据
//
// 入口参数： data：数据
// len：长度
//
// 返回参数：无
//
// 说明：
//==========================================================
void ESP8266_SendData(uint8_t*data, uint32_t len)
{

char cmdBuf[32];

ESP8266_Clear();								//清空接收缓存
sprintf(cmdBuf, "AT+CIPSEND=%d\r\n", len);		//发送命令
if(!ESP8266_SendCmd(cmdBuf, ">"))				//收到‘>’时可以发送数据
{
	WIFI_Send_Bytes(data, len);		//发送设备连接请求数据
}

}

//==========================================================
// 函数名称： ESP8266_GetIPD
//
// 函数功能：获取平台返回的数据
//
// 入口参数：等待的时间(乘以10ms)
//
// 返回参数：平台返回的原始数据
//
// 说明：不同网络设备返回的格式不同，需要去调试
// 如ESP8266的返回格式为 "+IPD,x:yyy" x代表数据长度，yyy是数据内容
//==========================================================
uint8_t *ESP8266_GetIPD(uint16_t timeOut)
{

char *ptrIPD = NULL;

do
{
	if(ESP8266_WaitRecive() == REV_OK)								//如果接收完成
	{
		ptrIPD = strstr((char *)esp8266_buf, "IPD,");				//搜索“IPD”头
		if(ptrIPD == NULL)											//如果没找到，可能是IPD头的延迟，还是需要等待一会，但不会超过设定的时间
		{
			//printf("\"IPD\" not found\r\n");
		}
		else
		{
			ptrIPD = strchr(ptrIPD, ':');							//找到':'
			if(ptrIPD != NULL)
			{
				ptrIPD++;
				return (unsigned char *)(ptrIPD);
			}
			else
				return NULL;
			
		}
	}
	
	delay_ms(5);													//延时等待
} while(timeOut--);

return NULL;														//超时还未找到，返回空指针

}

//==========================================================
// 函数名称： ESP8266_Init
//
// 函数功能：初始化ESP8266
//
// 入口参数：无
//
// 返回参数：无
//
// 说明：
//==========================================================
void ESP8266_Init(void)
{
#define WIFI_SSID "CMCC-c2H2" // WIFI的名称必须用2.4G的wifi不能用5G的，且不能用中文、空格
#define WIFI_PSWD "62x9wttb" // WIFI密码

#define SERVER_HOST "broker.emqx.io" // MQTT服务器域名或IP
#define SERVER_PORT "1883" // MQTT服务器端口（一般为1883不用改）

#define ESP8266_WIFI_INFO "AT+CWJAP="" WIFI_SSID "","" WIFI_PSWD ""\r\n"
#define ESP8266_ONENET_INFO "AT+CIPSTART="TCP","" SERVER_HOST ""," SERVER_PORT "\r\n"

//GPIO_WriteBit(GPIOC, GPIO_Pin_14, Bit_RESET);
//DelayXms(250);
//GPIO_WriteBit(GPIOC, GPIO_Pin_14, Bit_SET);
//DelayXms(500);

ESP8266_Clear();

ESP8266_SendCmd("AT+RST\r\n", "");
	delay_ms(1200);

while(ESP8266_SendCmd("AT\r\n", "OK"))
	delay_ms(500);

/*
ESP8266_SendCmd("AT+CIPCLOSE\r\n", "");
delay_ms(500);
*/

while(ESP8266_SendCmd("AT+CWMODE=1\r\n", "OK"))
	delay_ms(500);

while(ESP8266_SendCmd("AT+CWDHCP=1,1\r\n", "OK"))
	delay_ms(500);

while(ESP8266_SendCmd(ESP8266_WIFI_INFO, "GOT IP"))
	delay_ms(500);

while(ESP8266_SendCmd(ESP8266_ONENET_INFO, "CONNECT"))
	delay_ms(500);

printf("ESP8266 Initialization			[OK]\r\n");

}

void Wifi_connect(char *SSID, char *Password)
{
uint8_t err = 0;
ESP8266_SendCmd("AT+CWQAP\r\n", "OK");
delay_ms(1500);

sprintf(tx_buffer, "AT+CWJAP=\"%s\",\"%s\"\r\n", SSID, Password); /*HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"AT+CWJAP=\"%s\",\"%s\"\r\n",SSID,Password),1000);*/
ESP8266_SendCmd(tx_buffer,"OK");

}

void MQTT_Connect(char *ip,char *port)
{
sprintf(tx_buffer,"AT+MQTTUSERCFG=0,1,"1","1","1",0,0,""\r\n");
ESP8266_SendCmd(tx_buffer,"OK");

sprintf(tx_buffer,"AT+MQTTCONN=0,\"%s\",%s,0\r\n",ip,port); /*HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"AT+CWJAP=\"%s\",\"%s\"\r\n",SSID,Password),1000);*/
ESP8266_SendCmd(tx_buffer,"OK");

}

/*******************************************************
函数名:void MQTT_Subscribe(char *tipname)
功能:订阅MQTT主题
参数:
@tipname:主题字
*******************************************************/
void MQTT_Subscribe(char *tipname)
{
sprintf(tx_buffer,"AT+MQTTSUB=0,"%s",0\r\n",tipname);
ESP8266_SendCmd(tx_buffer,"OK");
}

void MQTT_Publish(char *topicName,char *message)
{
sprintf(tx_buffer,"AT+MQTTPUB=0,"%s","%s",0,0\r\n",topicName,message);
ESP8266_SendCmd(tx_buffer,"OK");
}

void Read_Message(char message)
{
char buff = esp8266_buf;
/----------- 处理数据 ---------------/
if(strstr(buff,"+MQTTSUBRECV:0") == NULL) return ;
buff = strstr(buff,"",")+2;
buff = strstr(buff,",")+1;
strcpy(message,buff);
printf("收到的数据是: %s\r\n",message);
}

void esp8266_wifi (uart_callback_args_t * p_args)
{
if(p_args->event == UART_EVENT_TX_COMPLETE)
{
uart_send_complete_flag = true;
}
if(p_args->event == UART_EVENT_RX_CHAR)
{
if(esp8266_cnt >= sizeof(esp8266_buf)) esp8266_cnt = 0; //防止串口被刷爆
esp8266_buf[esp8266_cnt++] = (uint8_t)p_args->data;

}

#if 0
/* 重定向 printf 输出 */
#if defined GNUC && !defined clang
int _write(int fd, char *pBuffer, int size); //防止编译警告
int _write(int fd, char *pBuffer, int size)
{
(void)fd;
R_SCI_UART_Write(&g_uart0_ctrl, (uint8_t *)pBuffer, (uint32_t)size);
while(uart_send_complete_flag == false);
uart_send_complete_flag = false;
return size;
}
#else
int fputc(int ch, FILE *f)
{
(void)f;
R_SCI_UART_Write(&g_uart0_ctrl, (uint8_t *)&ch, 1);
while(uart_send_complete_flag == false);
uart_send_complete_flag = false;
return ch;
}
#endif
#endif