当前位置：首页 > news >正文

#智能电饭煲技术开发原理与源代码实现

news 2025/10/8 7:47:49

前言

随着物联网技术的快速发展，传统家电正在向智能化方向转型。智能电饭煲作为厨房电器智能化的典型代表，不仅能实现精准的温度控制和多样化的烹饪模式，还能通过手机APP远程控制，极大地提升了用户体验。本文将深入探讨智能电饭煲的技术开发原理，并提供完整的程序源代码实现。

一、系统架构设计

1.1 整体架构

智能电饭煲系统主要由以下几个模块组成：

主控制器模块：采用STM32F103C8T6作为主控MCU
传感器模块：温度传感器、压力传感器、水位传感器
执行器模块：加热器控制、电机控制
通信模块：WiFi模块（ESP8266）、蓝牙模块
人机交互模块：LCD显示屏、触摸按键
电源管理模块：AC-DC转换、稳压电路

1.2 硬件选型

组件	型号	功能说明
主控MCU	STM32F103C8T6	主控制器，处理核心逻辑
温度传感器	PT100	精确测量锅内温度
压力传感器	MPX4115	监测锅内压力
WiFi模块	ESP8266	实现网络连接
加热器	800W电热盘	主加热元件
显示屏	2.4寸TFT LCD	显示状态信息

二、核心技术原理

2.1 模糊PID温度控制算法

智能电饭煲的核心是精准的温度控制。传统PID控制在非线性系统中表现不佳，因此我们采用模糊PID控制算法。

算法原理：

将温度误差e和误差变化率ec进行模糊化
根据模糊规则调整PID参数
输出控制量调节加热功率

2.2 烹饪曲线优化

不同米种和口感需要不同的烹饪曲线：

预热阶段：60°C，5分钟，激活淀粉
加热阶段：快速升温至100°C
沸腾阶段：保持98-102°C，15-20分钟
焖饭阶段：降至85°C，10分钟
保温阶段：维持65-70°C

2.3 智能识别技术

通过多传感器融合技术，实现：

米水比例自动识别
米种类型判断
烹饪完成度检测

三、主控程序源代码

3.1 主程序框架

// main.c - STM32主控程序
#include "stm32f10x.h"
#include "stdio.h"
#include "string.h"
#include "math.h"// 系统状态定义
typedef enum {STATE_IDLE = 0,      // 待机STATE_PREHEAT,       // 预热STATE_COOKING,       // 烹饪STATE_SIMMER,        // 焖饭STATE_KEEP_WARM,     // 保温STATE_ERROR         // 错误
} SystemState;// 烹饪模式定义
typedef enum {MODE_STANDARD = 0,   // 标准煮饭MODE_QUICK,         // 快速煮饭MODE_PORRIDGE,      // 煮粥MODE_STEAM,         // 蒸煮MODE_SOUP           // 煲汤
} CookingMode;// 全局变量
SystemState g_systemState = STATE_IDLE;
CookingMode g_cookingMode = MODE_STANDARD;
float g_currentTemp = 0.0;
float g_targetTemp = 0.0;
float g_pressure = 0.0;
uint32_t g_cookingTime = 0;// PID控制器结构体
typedef struct {float Kp;           // 比例系数float Ki;           // 积分系数float Kd;           // 微分系数float error;        // 当前误差float lastError;    // 上次误差float integral;     // 积分累计float output;       // 输出值
} PIDController;PIDController tempPID = {2.0, 0.5, 0.1, 0, 0, 0, 0};// 主函数
int main(void) {// 系统初始化SystemInit();GPIO_Init_Config();ADC_Init_Config();Timer_Init_Config();UART_Init_Config();WiFi_Init();LCD_Init();// 显示启动画面LCD_ShowString(0, 0, "Smart Rice Cooker");LCD_ShowString(0, 20, "Version 1.0");Delay_ms(2000);while(1) {// 读取传感器数据UpdateSensorData();// 状态机处理ProcessStateMachine();// 更新显示UpdateDisplay();// 处理WiFi通信ProcessWiFiCommand();// 安全检测SafetyCheck();Delay_ms(100);  // 主循环周期100ms}
}

3.2 模糊PID温度控制实现

// fuzzy_pid.c - 模糊PID控制器实现
#include "fuzzy_pid.h"// 模糊集定义
#define NB -3  // 负大
#define NM -2  // 负中
#define NS -1  // 负小
#define ZO  0  // 零
#define PS  1  // 正小
#define PM  2  // 正中
#define PB  3  // 正大// 模糊规则表 - Kp调整
int KpFuzzyRules[7][7] = {{PB, PB, PM, PM, PS, ZO, ZO},{PB, PB, PM, PS, PS, ZO, NS},{PM, PM, PM, PS, ZO, NS, NS},{PM, PM, PS, ZO, NS, NM, NM},{PS, PS, ZO, NS, NS, NM, NM},{PS, ZO, NS, NM, NM, NM, NB},{ZO, ZO, NM, NM, NM, NB, NB}
};// 温度误差模糊化
int FuzzifyError(float error) {if(error < -10) return NB;else if(error < -5) return NM;else if(error < -2) return NS;else if(error < 2) return ZO;else if(error < 5) return PS;else if(error < 10) return PM;else return PB;
}// 模糊PID参数自整定
void FuzzyPIDTuning(PIDController *pid, float error, float errorRate) {int e_fuzzy = FuzzifyError(error);int ec_fuzzy = FuzzifyError(errorRate);// 根据模糊规则调整PID参数float kp_delta = KpFuzzyRules[e_fuzzy+3][ec_fuzzy+3] * 0.1;pid->Kp = 2.0 + kp_delta;  // 基准值+调整量// Ki和Kd的调整类似pid->Ki = 0.5 + kp_delta * 0.2;pid->Kd = 0.1 + kp_delta * 0.05;
}// PID控制计算
float PIDCalculate(PIDController *pid, float setpoint, float measured) {float error = setpoint - measured;float errorRate = error - pid->lastError;// 模糊自整定FuzzyPIDTuning(pid, error, errorRate);// PID计算pid->integral += error;// 积分限幅if(pid->integral > 100) pid->integral = 100;if(pid->integral < -100) pid->integral = -100;// PID输出pid->output = pid->Kp * error + pid->Ki * pid->integral + pid->Kd * errorRate;// 输出限幅 (0-100%)if(pid->output > 100) pid->output = 100;if(pid->output < 0) pid->output = 0;pid->lastError = error;return pid->output;
}

3.3 传感器数据采集

// sensor.c - 传感器数据采集
#include "sensor.h"
#include "stm32f10x_adc.h"// PT100温度查表
const float PT100_Table[][2] = {{80.31, -50}, {84.27, -40}, {88.22, -30},{92.16, -20}, {96.09, -10}, {100.00, 0},{103.90, 10}, {107.79, 20}, {111.67, 30},{115.54, 40}, {119.40, 50}, {123.24, 60},{127.08, 70}, {130.90, 80}, {134.71, 90},{138.51, 100}, {142.29, 110}, {146.07, 120}
};// 读取温度传感器
float ReadTemperature(void) {uint16_t adcValue;float resistance;float temperature;// 启动ADC转换ADC_SoftwareStartConvCmd(ADC1, ENABLE);while(!ADC_GetFlagStatus(ADC1, ADC_FLAG_EOC));adcValue = ADC_GetConversionValue(ADC1);// 计算PT100电阻值resistance = (float)adcValue * 200.0 / 4096.0;// 查表法计算温度temperature = PT100_LookupTemperature(resistance);// 卡尔曼滤波temperature = KalmanFilter(temperature);return temperature;
}// 卡尔曼滤波器
float KalmanFilter(float input) {static float P = 1.0;static float X = 0.0;const float Q = 0.01;  // 过程噪声const float R = 0.5;   // 测量噪声// 预测P = P + Q;// 更新float K = P / (P + R);X = X + K * (input - X);P = (1 - K) * P;return X;
}// 读取压力传感器
float ReadPressure(void) {uint16_t adcValue;float voltage;float pressure;ADC_RegularChannelConfig(ADC1, ADC_Channel_2, 1, ADC_SampleTime_55Cycles5);ADC_SoftwareStartConvCmd(ADC1, ENABLE);while(!ADC_GetFlagStatus(ADC1, ADC_FLAG_EOC));adcValue = ADC_GetConversionValue(ADC1);// MPX4115: Vout = VS * (0.009 * P - 0.095)voltage = (float)adcValue * 3.3 / 4096.0;pressure = (voltage / 5.0 + 0.095) / 0.009;return pressure;
}// 水位检测
uint8_t ReadWaterLevel(void) {uint8_t level = 0;// 读取多个水位开关状态if(GPIO_ReadInputDataBit(GPIOB, GPIO_Pin_0) == 0) level = 1;  // 低水位if(GPIO_ReadInputDataBit(GPIOB, GPIO_Pin_1) == 0) level = 2;  // 中水位if(GPIO_ReadInputDataBit(GPIOB, GPIO_Pin_2) == 0) level = 3;  // 高水位return level;
}

3.4 烹饪状态机实现

// cooking_process.c - 烹饪流程控制
#include "cooking_process.h"// 烹饪参数配置
typedef struct {float preheatTemp;      // 预热温度uint32_t preheatTime;   // 预热时间(秒)float cookingTemp;      // 烹饪温度uint32_t cookingTime;   // 烹饪时间(秒)float simmerTemp;       // 焖饭温度uint32_t simmerTime;    // 焖饭时间(秒)float keepWarmTemp;     // 保温温度
} CookingParams;// 不同模式的烹饪参数
const CookingParams cookingParams[] = {// 标准煮饭{60.0, 300, 100.0, 1200, 85.0, 600, 70.0},// 快速煮饭{70.0, 180, 105.0, 900, 85.0, 480, 70.0},// 煮粥{50.0, 600, 95.0, 2400, 80.0, 300, 65.0},// 蒸煮{80.0, 240, 100.0, 1800, 90.0, 300, 75.0},// 煲汤{60.0, 480, 90.0, 3600, 85.0, 600, 70.0}
};// 状态机处理函数
void ProcessStateMachine(void) {static uint32_t stateTimer = 0;CookingParams params = cookingParams[g_cookingMode];switch(g_systemState) {case STATE_IDLE:// 待机状态，等待用户启动if(IsStartButtonPressed()) {g_systemState = STATE_PREHEAT;stateTimer = 0;BeepSound(1);  // 蜂鸣器提示}break;case STATE_PREHEAT:// 预热阶段g_targetTemp = params.preheatTemp;ControlHeating(g_targetTemp);if(++stateTimer >= params.preheatTime * 10) {  // 100ms计数g_systemState = STATE_COOKING;stateTimer = 0;LCD_ShowString(0, 40, "Cooking...");}break;case STATE_COOKING:// 主烹饪阶段g_targetTemp = params.cookingTemp;// 自适应控制if(g_pressure > 110) {  // 压力过高g_targetTemp -= 2;  // 降低温度}ControlHeating(g_targetTemp);// 检测米饭熟度if(IsCookingComplete() || stateTimer >= params.cookingTime * 10) {g_systemState = STATE_SIMMER;stateTimer = 0;LCD_ShowString(0, 40, "Simmering...");}stateTimer++;break;case STATE_SIMMER:// 焖饭阶段g_targetTemp = params.simmerTemp;ControlHeating(g_targetTemp);if(++stateTimer >= params.simmerTime * 10) {g_systemState = STATE_KEEP_WARM;stateTimer = 0;LCD_ShowString(0, 40, "Keep Warm");BeepSound(3);  // 完成提示SendNotification("Rice is ready!");  // 发送手机通知}break;case STATE_KEEP_WARM:// 保温阶段g_targetTemp = params.keepWarmTemp;ControlHeating(g_targetTemp);// 保温最长12小时if(++stateTimer >= 12 * 3600 * 10) {g_systemState = STATE_IDLE;TurnOffHeater();}break;case STATE_ERROR:// 错误处理TurnOffHeater();LCD_ShowString(0, 60, "ERROR!");BeepSound(5);break;}
}// 加热控制
void ControlHeating(float targetTemp) {float power;// 使用PID计算加热功率power = PIDCalculate(&tempPID, targetTemp, g_currentTemp);// PWM控制加热器SetHeaterPWM(power);// 记录功率数据用于优化RecordPowerData(power);
}// 检测烹饪完成
uint8_t IsCookingComplete(void) {static uint32_t steamlessCount = 0;// 通过多个指标判断// 1. 温度稳定在100°C附近if(fabs(g_currentTemp - 100.0) < 2.0) {// 2. 压力开始下降if(IsPressureDecreasing()) {// 3. 无蒸汽产生持续时间if(IsSteamDetected() == 0) {steamlessCount++;if(steamlessCount > 300) {  // 30秒无蒸汽return 1;}} else {steamlessCount = 0;}}}return 0;
}

3.5 WiFi通信与APP控制

// wifi_control.c - WiFi模块控制
#include "wifi_control.h"
#include "esp8266.h"
#include "cJSON.h"// WiFi配置
#define WIFI_SSID "SmartHome"
#define WIFI_PASSWORD "12345678"
#define TCP_SERVER_IP "192.168.1.100"
#define TCP_SERVER_PORT 8080// MQTT配置
#define MQTT_BROKER "broker.emqx.io"
#define MQTT_PORT 1883
#define MQTT_CLIENT_ID "RiceCooker_001"
#define MQTT_TOPIC_STATUS "home/kitchen/ricecooker/status"
#define MQTT_TOPIC_CONTROL "home/kitchen/ricecooker/control"// 初始化WiFi模块
void WiFi_Init(void) {// 初始化ESP8266ESP8266_Init();// 设置为STA模式ESP8266_SendCommand("AT+CWMODE=1");Delay_ms(500);// 连接WiFichar cmd[100];sprintf(cmd, "AT+CWJAP=\"%s\",\"%s\"", WIFI_SSID, WIFI_PASSWORD);ESP8266_SendCommand(cmd);Delay_ms(5000);// 连接MQTT服务器MQTT_Connect();// 订阅控制主题MQTT_Subscribe(MQTT_TOPIC_CONTROL);
}// 处理WiFi命令
void ProcessWiFiCommand(void) {char buffer[256];if(ESP8266_ReceiveData(buffer, sizeof(buffer))) {// 解析JSON命令cJSON *root = cJSON_Parse(buffer);if(root != NULL) {cJSON *cmd = cJSON_GetObjectItem(root, "command");if(cmd != NULL) {ProcessCommand(cmd->valuestring);}cJSON_Delete(root);}}// 定期发送状态static uint32_t lastSendTime = 0;if(GetTickCount() - lastSendTime > 5000) {  // 5秒发送一次SendStatusUpdate();lastSendTime = GetTickCount();}
}// 处理控制命令
void ProcessCommand(char *command) {if(strcmp(command, "START") == 0) {// 启动烹饪if(g_systemState == STATE_IDLE) {g_systemState = STATE_PREHEAT;SendResponse("OK", "Cooking started");}}else if(strcmp(command, "STOP") == 0) {// 停止烹饪g_systemState = STATE_IDLE;TurnOffHeater();SendResponse("OK", "Cooking stopped");}else if(strncmp(command, "MODE:", 5) == 0) {// 设置烹饪模式int mode = atoi(command + 5);if(mode >= 0 && mode <= 4) {g_cookingMode = (CookingMode)mode;SendResponse("OK", "Mode changed");}}else if(strncmp(command, "TIMER:", 6) == 0) {// 预约功能uint32_t minutes = atoi(command + 6);SetCookingTimer(minutes);SendResponse("OK", "Timer set");}
}// 发送状态更新
void SendStatusUpdate(void) {cJSON *root = cJSON_CreateObject();// 添加状态信息cJSON_AddStringToObject(root, "deviceId", MQTT_CLIENT_ID);cJSON_AddNumberToObject(root, "state", g_systemState);cJSON_AddNumberToObject(root, "mode", g_cookingMode);cJSON_AddNumberToObject(root, "currentTemp", g_currentTemp);cJSON_AddNumberToObject(root, "targetTemp", g_targetTemp);cJSON_AddNumberToObject(root, "pressure", g_pressure);cJSON_AddNumberToObject(root, "waterLevel", ReadWaterLevel());cJSON_AddNumberToObject(root, "cookingTime", g_cookingTime);// 转换为JSON字符串char *jsonStr = cJSON_Print(root);// 发送MQTT消息MQTT_Publish(MQTT_TOPIC_STATUS, jsonStr);// 清理free(jsonStr);cJSON_Delete(root);
}

3.6 安全保护机制

// safety.c - 安全保护功能
#include "safety.h"#define MAX_TEMPERATURE 130.0   // 最高温度限制
#define MAX_PRESSURE 150.0      // 最高压力限制
#define MIN_WATER_LEVEL 1       // 最低水位// 安全检测
void SafetyCheck(void) {static uint32_t errorCount = 0;uint8_t hasError = 0;// 温度过高保护if(g_currentTemp > MAX_TEMPERATURE) {TurnOffHeater();g_systemState = STATE_ERROR;RecordError(ERROR_OVER_TEMP);hasError = 1;}// 压力过高保护if(g_pressure > MAX_PRESSURE) {TurnOffHeater();OpenPressureValve();g_systemState = STATE_ERROR;RecordError(ERROR_OVER_PRESSURE);hasError = 1;}// 干烧保护if(ReadWaterLevel() < MIN_WATER_LEVEL && g_systemState == STATE_COOKING) {TurnOffHeater();g_systemState = STATE_ERROR;RecordError(ERROR_DRY_BURNING);hasError = 1;}// 传感器故障检测if(IsSensorFault()) {TurnOffHeater();g_systemState = STATE_ERROR;RecordError(ERROR_SENSOR_FAULT);hasError = 1;}// 连续错误计数if(hasError) {errorCount++;if(errorCount > 3) {// 严重故障，完全停机SystemShutdown();}} else {errorCount = 0;}
}// 传感器故障检测
uint8_t IsSensorFault(void) {static float lastTemp = 0;static uint32_t faultCount = 0;// 温度传感器断线检测if(g_currentTemp < -20 || g_currentTemp > 200) {return 1;}// 温度变化异常检测if(g_systemState == STATE_COOKING) {if(fabs(g_currentTemp - lastTemp) > 20) {  // 2秒内变化超过20度faultCount++;if(faultCount > 5) {return 1;}} else {faultCount = 0;}}lastTemp = g_currentTemp;return 0;
}// 记录错误日志
void RecordError(ErrorCode code) {ErrorLog log;log.code = code;log.timestamp = GetRTCTime();log.temperature = g_currentTemp;log.pressure = g_pressure;// 保存到EEPROMEEPROM_SaveErrorLog(&log);// 发送错误通知char msg[100];sprintf(msg, "Error %d occurred at %s", code, FormatTime(log.timestamp));SendNotification(msg);
}

3.7 电源管理与节能

// power_management.c - 电源管理
#include "power_management.h"// 功率统计
typedef struct {float totalEnergy;      // 总能耗(kWh)float currentPower;     // 当前功率(W)uint32_t runningTime;   // 运行时间(秒)
} PowerStats;PowerStats g_powerStats = {0, 0, 0};// 计算实时功率
float CalculatePower(void) {float voltage = ReadVoltage();float current = ReadCurrent();float power = voltage * current;// 功率因数校正power *= 0.95;return power;
}// 智能节能控制
void PowerSavingControl(void) {// 根据不同阶段调整功率switch(g_systemState) {case STATE_PREHEAT:// 预热阶段使用60%功率SetMaxPower(480);break;case STATE_COOKING:// 烹饪阶段根据温差动态调整if(g_targetTemp - g_currentTemp > 10) {SetMaxPower(800);  // 全功率} else if(g_targetTemp - g_currentTemp > 5) {SetMaxPower(600);  // 75%功率} else {SetMaxPower(400);  // 50%功率}break;case STATE_KEEP_WARM:// 保温阶段间歇加热IntermittentHeating(200, 60, 240);  // 200W，加热60秒，停240秒break;default:SetMaxPower(0);break;}// 更新能耗统计UpdatePowerStats();
}// 间歇加热控制
void IntermittentHeating(uint16_t power, uint32_t onTime, uint32_t offTime) {static uint32_t timer = 0;static uint8_t heatingOn = 1;timer++;if(heatingOn) {SetHeaterPower(power);if(timer >= onTime * 10) {heatingOn = 0;timer = 0;}} else {SetHeaterPower(0);if(timer >= offTime * 10) {heatingOn = 1;timer = 0;}}
}// 更新能耗统计
void UpdatePowerStats(void) {static uint32_t lastUpdateTime = 0;uint32_t currentTime = GetTickCount();if(currentTime - lastUpdateTime >= 1000) {  // 每秒更新g_powerStats.currentPower = CalculatePower();g_powerStats.totalEnergy += g_powerStats.currentPower / 3600000.0;  // kWhg_powerStats.runningTime++;lastUpdateTime = currentTime;}
}

四、Android APP开发

4.1 主界面布局 (activity_main.xml)

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"android:layout_width="match_parent"android:layout_height="match_parent"android:orientation="vertical"android:padding="16dp"><!-- 状态显示区域 --><CardViewandroid:layout_width="match_parent"android:layout_height="wrap_content"android:layout_margin="8dp"><LinearLayoutandroid:layout_width="match_parent"android:layout_height="wrap_content"android:orientation="vertical"android:padding="16dp"><TextViewandroid:id="@+id/tvStatus"android:layout_width="wrap_content"android:layout_height="wrap_content"android:text="状态：待机"android:textSize="18sp"android:textStyle="bold"/><TextViewandroid:id="@+id/tvTemperature"android:layout_width="wrap_content"android:layout_height="wrap_content"android:text="温度：25.0°C"android:textSize="16sp"android:layout_marginTop="8dp"/><ProgressBarandroid:id="@+id/progressCooking"style="?android:attr/progressBarStyleHorizontal"android:layout_width="match_parent"android:layout_height="wrap_content"android:layout_marginTop="8dp"android:max="100"android:progress="0"/></LinearLayout></CardView><!-- 模式选择 --><Spinnerandroid:id="@+id/spinnerMode"android:layout_width="match_parent"android:layout_height="wrap_content"android:layout_margin="8dp"android:entries="@array/cooking_modes"/><!-- 控制按钮 --><LinearLayoutandroid:layout_width="match_parent"android:layout_height="wrap_content"android:orientation="horizontal"android:layout_margin="8dp"><Buttonandroid:id="@+id/btnStart"android:layout_width="0dp"android:layout_height="wrap_content"android:layout_weight="1"android:text="开始"android:layout_marginRight="4dp"/><Buttonandroid:id="@+id/btnStop"android:layout_width="0dp"android:layout_height="wrap_content"android:layout_weight="1"android:text="停止"android:layout_marginLeft="4dp"/></LinearLayout><!-- 预约设置 --><LinearLayoutandroid:layout_width="match_parent"android:layout_height="wrap_content"android:orientation="horizontal"android:layout_margin="8dp"><TextViewandroid:layout_width="wrap_content"android:layout_height="wrap_content"android:text="预约时间："android:textSize="16sp"/><TimePickerandroid:id="@+id/timePicker"android:layout_width="wrap_content"android:layout_height="wrap_content"android:timePickerMode="spinner"/></LinearLayout>
</LinearLayout>

4.2 APP主控制类 (MainActivity.java)

// MainActivity.java
package com.smart.ricecooker;import android.os.Bundle;
import android.os.Handler;
import android.widget.*;
import androidx.appcompat.app.AppCompatActivity;
import org.eclipse.paho.android.service.MqttAndroidClient;
import org.eclipse.paho.client.mqttv3.*;
import org.json.JSONObject;public class MainActivity extends AppCompatActivity {private TextView tvStatus, tvTemperature;private ProgressBar progressCooking;private Spinner spinnerMode;private Button btnStart, btnStop;private TimePicker timePicker;private MqttAndroidClient mqttClient;private final String MQTT_BROKER = "tcp://broker.emqx.io:1883";private final String CLIENT_ID = "RiceCookerApp_" + System.currentTimeMillis();private final String TOPIC_STATUS = "home/kitchen/ricecooker/status";private final String TOPIC_CONTROL = "home/kitchen/ricecooker/control";private Handler handler = new Handler();@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);initViews();initMQTT();setListeners();}private void initViews() {tvStatus = findViewById(R.id.tvStatus);tvTemperature = findViewById(R.id.tvTemperature);progressCooking = findViewById(R.id.progressCooking);spinnerMode = findViewById(R.id.spinnerMode);btnStart = findViewById(R.id.btnStart);btnStop = findViewById(R.id.btnStop);timePicker = findViewById(R.id.timePicker);// 设置24小时制timePicker.setIs24HourView(true);}private void initMQTT() {mqttClient = new MqttAndroidClient(this, MQTT_BROKER, CLIENT_ID);MqttConnectOptions options = new MqttConnectOptions();options.setAutomaticReconnect(true);options.setCleanSession(false);try {mqttClient.connect(options, null, new IMqttActionListener() {@Overridepublic void onSuccess(IMqttToken asyncActionToken) {subscribeToTopic();}@Overridepublic void onFailure(IMqttToken asyncActionToken, Throwable exception) {Toast.makeText(MainActivity.this, "连接失败: " + exception.toString(), Toast.LENGTH_SHORT).show();}});// 设置消息回调mqttClient.setCallback(new MqttCallback() {@Overridepublic void connectionLost(Throwable cause) {// 连接丢失}@Overridepublic void messageArrived(String topic, MqttMessage message) {processMessage(new String(message.getPayload()));}@Overridepublic void deliveryComplete(IMqttDeliveryToken token) {// 消息发送完成}});} catch (MqttException e) {e.printStackTrace();}}private void subscribeToTopic() {try {mqttClient.subscribe(TOPIC_STATUS, 0);} catch (MqttException e) {e.printStackTrace();}}private void processMessage(String payload) {try {JSONObject json = new JSONObject(payload);handler.post(() -> {// 更新UIint state = json.optInt("state");updateStatus(state);double temp = json.optDouble("currentTemp");tvTemperature.setText(String.format("温度：%.1f°C", temp));int cookingTime = json.optInt("cookingTime");updateProgress(cookingTime);});} catch (Exception e) {e.printStackTrace();}}private void updateStatus(int state) {String[] states = {"待机", "预热", "烹饪", "焖饭", "保温", "错误"};if(state >= 0 && state < states.length) {tvStatus.setText("状态：" + states[state]);}}private void updateProgress(int cookingTime) {// 假设总时间30分钟int progress = (cookingTime * 100) / (30 * 60);progressCooking.setProgress(progress);}private void setListeners() {btnStart.setOnClickListener(v -> {sendCommand("START");});btnStop.setOnClickListener(v -> {sendCommand("STOP");});spinnerMode.setOnItemSelectedListener(new AdapterView.OnItemSelectedListener() {@Overridepublic void onItemSelected(AdapterView<?> parent, View view, int position, long id) {sendCommand("MODE:" + position);}@Overridepublic void onNothingSelected(AdapterView<?> parent) {}});}private void sendCommand(String command) {try {JSONObject json = new JSONObject();json.put("command", command);MqttMessage message = new MqttMessage();message.setPayload(json.toString().getBytes());mqttClient.publish(TOPIC_CONTROL, message);} catch (Exception e) {e.printStackTrace();}}
}