\n| \u9002\u7528\u73af\u5883<\/td>\n | \u65e7\u7248\u6d4b\u8bd5\u73af\u5883\u6216\u975e\u5b89\u5168\u73af\u5883<\/td>\n | \u65b0\u7248\u751f\u4ea7\u73af\u5883（\u9700\u4e25\u683c\u9075\u5faa\u89c4\u8303）<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n \u5efa\u8bae：\u4f18\u5148\u4f7f\u7528\u52a0\u5bc6\u8fde\u63a5（MQTTS\/8883），\u5e76\u6309\u7167\u534e\u4e3a\u4e91\u5b98\u65b9\u6587\u6863\u914d\u7f6e\u7b7e\u540d\u548c\u8bc1\u4e66\u3002\u82e5\u9700\u4e34\u65f6\u8c03\u8bd5，\u53ef\u5148\u5728\u6d4b\u8bd5\u73af\u5883\u4e2d\u4f7f\u7528\u975e\u52a0\u5bc6\u8fde\u63a5，\u4f46\u751f\u4ea7\u73af\u5883\u5fc5\u987b\u542f\u7528\u5b89\u5168\u673a\u5236\u3002\u00a0<\/p>\n<\/p>\n #include <stdio.h>
\n#include <stdlib.h>
\n#include <string.h>
\n#include <unistd.h>
\n#include <fcntl.h>
\n#include <termios.h>
\n#include <sys\/select.h>
\n#include <time.h>
\n#include <pthread.h>
\n#include <stdint.h>
\n#include <queue>
\n#include "MQTTClient.h"
\n#include <cjson\/cJSON.h><\/p>\n \/\/ MQTT\u914d\u7f6e
\n#define MQTT_ADDRESS "tcp:\/\/192.168.1.212:1883"
\n#define MQTT_USERNAME " "
\n#define MQTT_PASSWORD " "
\n#define MQTT_CLIENTID "smart_farm_rs485"
\n#define MQTT_QOS 2
\n#define MQTT_SENSOR_TOPIC "\/Yuei\/sensor\/"
\n#define MQTT_COMMAND_TOPIC "\/Yuei\/command\/"
\n#define MQTT_TIMEOUT 10000L<\/p>\n \/\/ \u534e\u4e3a\u4e91IoT\u914d\u7f6e（\u4e0e\u6587\u6863\u5b8c\u5168\u4e00\u81f4）
\n#define HUAWEI_CLOUD_ADDR "mqtts:\/\/21369d9ff7.st1.iotda-device.cn-north-4.myhuaweicloud.com:8883"
\n#define HUAWEI_CLIENT_ID "6823048384adf27cda58465e_Yiji1_0_0_2025051413"
\n#define HUAWEI_USERNAME "6823048384adf27cda58465e_Yiji1"
\n#define HUAWEI_PASSWORD "e554e71de483b60085373595c34051d0b37f9dbc680257234bb6233e9187704b"
\n#define HUAWEI_PUB_TOPIC "$oc\/devices\/6823048384adf27cda58465e_Yiji1\/sys\/properties\/report"<\/p>\n \/\/ RS485\u914d\u7f6e
\n#define RS485_DEV "\/dev\/ttyS1"
\n#define BAUDRATE B4800
\n#define RECV_TIMEOUT_MS 2000<\/p>\n \/\/ \u7ee7\u7535\u5668\u914d\u7f6e
\n#define RELAY_ADDRESS 4
\n#define RELAY1_ADDR 0x0010
\n#define RELAY2_ADDR 0x0011<\/p>\n \/\/ \u5168\u5c40\u53d8\u91cf
\nint fd;
\nMQTTClient mqtt_client;
\nMQTTClient huawei_client;
\npthread_mutex_t serial_mutex = PTHREAD_MUTEX_INITIALIZER;
\npthread_mutex_t mqtt_mutex = PTHREAD_MUTEX_INITIALIZER;
\nint running = 1;<\/p>\n \/\/ \u547d\u4ee4\u961f\u5217\u7ed3\u6784
\nstruct RelayCommand {
\n uint16_t address;
\n uint8_t value;
\n time_t timestamp;
\n};<\/p>\n typedef struct {
\n float temperature;
\n float humidity;
\n int co;
\n int lux;
\n time_t timestamp;
\n} SensorData;<\/p>\n std::queue<RelayCommand> commandQueue;
\npthread_mutex_t queue_mutex = PTHREAD_MUTEX_INITIALIZER;
\npthread_cond_t queue_cond = PTHREAD_COND_INITIALIZER;<\/p>\n \/\/ \u8ba1\u7b97Modbus CRC16\u6821\u9a8c
\nunsigned short crc16(unsigned char *data, int len) {
\n unsigned short crc = 0xFFFF;
\n for (int i = 0; i < len; i++) {
\n crc ^= data[i];
\n for (int j = 0; j < 8; j++) {
\n if (crc & 0x0001) {
\n crc = (crc >> 1) ^ 0xA001;
\n } else {
\n crc >>= 1;
\n }
\n }
\n }
\n return crc;
\n}<\/p>\n \/\/ \u53d1\u9001Modbus RTU\u6307\u4ee4\u5e76\u63a5\u6536\u54cd\u5e94
\nint send_modbus_command(int fd, unsigned char *command, int cmd_len, unsigned char *response, int resp_len) {
\n fd_set readfds;
\n struct timeval timeout;<\/p>\n printf("\u53d1\u9001\u6307\u4ee4: ");
\n for (int i = 0; i < cmd_len; i++) {
\n printf("%02X ", command[i]);
\n }
\n printf("\\\\n");<\/p>\n tcflush(fd, TCIFLUSH);
\n usleep(50000); <\/p>\n int written = write(fd, command, cmd_len);
\n if (written != cmd_len) {
\n printf("\u53d1\u9001\u5931\u8d25: \u53ea\u53d1\u9001\u4e86 %d \u5b57\u8282，\u5e94\u8be5\u53d1\u9001 %d \u5b57\u8282\\\\n", written, cmd_len);
\n return -1;
\n }<\/p>\n timeout.tv_sec = 1;
\n timeout.tv_usec = 0;<\/p>\n while (1) {
\n FD_ZERO(&readfds);
\n FD_SET(fd, &readfds);<\/p>\n int sel_result = select(fd + 1, &readfds, NULL, NULL, &timeout);
\n if (sel_result < 0) {
\n perror("select error");
\n return -1;
\n } else if (sel_result == 0) {
\n printf("\u54cd\u5e94\u8d85\u65f6\\\\n");
\n return 0;
\n }<\/p>\n if (FD_ISSET(fd, &readfds)) {
\n int bytes = read(fd, response, resp_len);
\n if (bytes > 0) {
\n printf("\u63a5\u6536\u54cd\u5e94: ");
\n for (int i = 0; i < bytes; i++) {
\n printf("%02X ", response[i]);
\n }
\n printf("\\\\n");
\n return bytes;
\n }
\n }
\n }<\/p>\n return 0;
\n}<\/p>\n \/\/ \u91cd\u8bd5\u8bfb\u53d6\u4f20\u611f\u5668\u6570\u636e
\nint read_sensor_data(int fd, unsigned char *command, int cmd_len, unsigned char *response, int resp_len, int max_retries) {
\n int response_len = 0;<\/p>\n for (int i = 0; i < max_retries; i++) {
\n struct timespec ts;
\n clock_gettime(CLOCK_REALTIME, &ts);
\n ts.tv_sec += 1; <\/p>\n if (pthread_mutex_timedlock(&serial_mutex, &ts) != 0) {
\n printf("\u83b7\u53d6\u4e32\u53e3\u9501\u8d85\u65f6（\u5c1d\u8bd5 %d\/%d）\\\\n", i + 1, max_retries);
\n continue;
\n }<\/p>\n response_len = send_modbus_command(fd, command, cmd_len, response, resp_len);
\n pthread_mutex_unlock(&serial_mutex);<\/p>\n if (response_len >= 5) {
\n unsigned short resp_crc = (response[response_len – 2] | (response[response_len – 1] << 8));
\n unsigned short calc_crc = crc16(response, response_len – 2);
\n if (resp_crc == calc_crc) return response_len;
\n else printf("CRC\u6821\u9a8c\u5931\u8d25（\u5c1d\u8bd5 %d\/%d）\\\\n", i + 1, max_retries);
\n } else {
\n if (response_len == 0) printf("\u54cd\u5e94\u8d85\u65f6（\u5c1d\u8bd5 %d\/%d）\\\\n", i + 1, max_retries);
\n else printf("\u54cd\u5e94\u957f\u5ea6\u4e0d\u8db3（\u5c1d\u8bd5 %d\/%d）\\\\n", i + 1, max_retries);
\n }<\/p>\n usleep(100000);
\n }<\/p>\n return -1;
\n}<\/p>\n \/\/ \u8bb0\u5f55\u65e5\u5fd7
\nvoid log_message(const char* message) {
\n FILE* log_file = fopen("sensor_log.txt", "a");
\n if (!log_file) {
\n perror("\u65e0\u6cd5\u6253\u5f00\u65e5\u5fd7\u6587\u4ef6");
\n return;
\n }
\n time_t rawtime;
\n struct tm* timeinfo;
\n time(&rawtime);
\n timeinfo = localtime(&rawtime);
\n char time_str[26];
\n strftime(time_str, sizeof(time_str), "%Y-%m-%d %H:%M:%S", timeinfo);
\n fprintf(log_file, "%s – %s\\\\n", time_str, message);
\n fclose(log_file);
\n}<\/p>\n \/\/ MQTT\u6d88\u606f\u53d1\u5e03\u51fd\u6570 – \u672c\u5730MQTT
\nvoid mqtt_publish(const char *topic, const char *payload) {
\n MQTTClient_message message = MQTTClient_message_initializer;
\n message.payload = (void*)payload;
\n message.payloadlen = strlen(payload);
\n message.qos = MQTT_QOS;
\n message.retained = 0;<\/p>\n MQTTClient_deliveryToken token;
\n int rc;<\/p>\n pthread_mutex_lock(&mqtt_mutex);
\n if ((rc = MQTTClient_publishMessage(mqtt_client, topic, &message, &token)) != MQTTCLIENT_SUCCESS) {
\n printf("MQTT\u53d1\u5e03\u5931\u8d25，\u9519\u8bef\u7801：%d\\\\n", rc);
\n } else {
\n MQTTClient_waitForCompletion(mqtt_client, token, MQTT_TIMEOUT);
\n printf("\u5df2\u53d1\u5e03\u5230\u4e3b\u9898[%s]: %s\\\\n", topic, payload);
\n }
\n pthread_mutex_unlock(&mqtt_mutex);
\n}<\/p>\n \/\/ \u534e\u4e3a\u4e91MQTT\u6570\u636e\u53d1\u5e03\u51fd\u6570（\u4fee\u6b63JSON\u7ed3\u6784）
\nvoid huawei_publish_data(float temperature, float humidity, int co, int lux) {
\n char json_str[256];
\n snprintf(json_str, sizeof(json_str),
\n "{"
\n "\\\\"services\\\\":[{"
\n "\\\\"service_id\\\\":\\\\"default_service\\\\","
\n "\\\\"properties\\\\":{"
\n "\\\\"CO\\\\":%d,"
\n "\\\\"HID\\\\":%d,"
\n "\\\\"humi\\\\":%.1f,"
\n "\\\\"temp\\\\":%.1f"
\n "}"
\n "}]"
\n "}", co, lux, humidity, temperature);<\/p>\n pthread_mutex_lock(&mqtt_mutex);<\/p>\n MQTTClient_message pubmsg = MQTTClient_message_initializer;
\n pubmsg.payload = json_str;
\n pubmsg.payloadlen = strlen(json_str);
\n pubmsg.qos = MQTT_QOS;
\n pubmsg.retained = 0;<\/p>\n MQTTClient_deliveryToken token;
\n int rc = MQTTClient_publishMessage(huawei_client, HUAWEI_PUB_TOPIC, &pubmsg, &token);
\n if (rc != MQTTCLIENT_SUCCESS) {
\n fprintf(stderr, "[\u534e\u4e3a\u4e91] \u53d1\u5e03\u5931\u8d25: %d\\\\n", rc);
\n } else {
\n if (MQTTClient_waitForCompletion(huawei_client, token, MQTT_TIMEOUT) != MQTTCLIENT_SUCCESS) {
\n fprintf(stderr, "[\u534e\u4e3a\u4e91] \u7b49\u5f85\u53d1\u5e03\u5b8c\u6210\u5931\u8d25\\\\n");
\n }
\n printf("[\u534e\u4e3a\u4e91] \u6570\u636e\u5df2\u53d1\u5e03: %s\\\\n", json_str);
\n }<\/p>\n pthread_mutex_unlock(&mqtt_mutex);
\n}<\/p>\n \/\/ \u63a7\u5236\u7ee7\u7535\u5668
\nint control_relay(int fd, uint16_t address, uint8_t value) {
\n uint8_t command[8];
\n command[0] = (uint8_t)RELAY_ADDRESS; \/\/ \u663e\u5f0f\u7c7b\u578b\u8f6c\u6362
\n command[1] = 0x05;
\n command[2] = (uint8_t)((address >> 8) & 0xFF); \/\/ \u663e\u5f0f\u7c7b\u578b\u8f6c\u6362
\n command[3] = (uint8_t)(address & 0xFF); \/\/ \u663e\u5f0f\u7c7b\u578b\u8f6c\u6362
\n command[4] = value ? 0xFF : 0x00;
\n command[5] = 0x00;<\/p>\n uint16_t crc = crc16(command, 6);
\n command[6] = (uint8_t)(crc & 0xFF); \/\/ \u663e\u5f0f\u7c7b\u578b\u8f6c\u6362
\n command[7] = (uint8_t)(crc >> 8); \/\/ \u663e\u5f0f\u7c7b\u578b\u8f6c\u6362<\/p>\n struct timespec ts;
\n clock_gettime(CLOCK_REALTIME, &ts);
\n ts.tv_sec += 2;<\/p>\n int lock_result = pthread_mutex_timedlock(&serial_mutex, &ts);
\n if (lock_result != 0) {
\n printf("\u83b7\u53d6\u4e32\u53e3\u9501\u8d85\u65f6，\u7ee7\u7535\u5668\u63a7\u5236\u88ab\u5ef6\u8fdf\\\\n");
\n return -1;
\n }<\/p>\n tcflush(fd, TCIFLUSH);
\n int bytes_written = write(fd, command, 8);
\n if (bytes_written != 8) {
\n perror("\u53d1\u9001\u547d\u4ee4\u5931\u8d25");
\n pthread_mutex_unlock(&serial_mutex);
\n return -1;
\n }<\/p>\n usleep(100000);
\n uint8_t response[8];
\n int bytes_read = read(fd, response, sizeof(response));
\n pthread_mutex_unlock(&serial_mutex);<\/p>\n if (bytes_read < 5) {
\n printf("\u54cd\u5e94\u6570\u636e\u8fc7\u77ed: %d\u5b57\u8282\\\\n", bytes_read);
\n return -1;
\n }<\/p>\n uint16_t received_crc = (response[bytes_read – 2] | (response[bytes_read – 1] << 8));
\n uint16_t calculated_crc = crc16(response, bytes_read – 2);
\n if (received_crc != calculated_crc || response[1] != 0x05) {
\n printf("CRC\u6821\u9a8c\u6216\u529f\u80fd\u7801\u9519\u8bef\\\\n");
\n return -1;
\n }<\/p>\n return 0;
\n}<\/p>\n \/\/ MQTT\u6d88\u606f\u5230\u8fbe\u56de\u8c03\u51fd\u6570
\nint msgarrvd(void *context, char *topicName, int topicLen, MQTTClient_message *message) {
\n char* payload = (char*)message->payload;
\n printf("\u6536\u5230\u6d88\u606f: \u4e3b\u9898[%s], \u5185\u5bb9: %s\\\\n", topicName, payload);<\/p>\n if (strncmp(topicName, MQTT_COMMAND_TOPIC, strlen(MQTT_COMMAND_TOPIC)) == 0) {
\n int relay_num, action;
\n if (sscanf(payload, "relay%d=%d", &relay_num, &action) == 2) {
\n RelayCommand cmd;
\n cmd.address = (relay_num == 1) ? RELAY1_ADDR : RELAY2_ADDR;
\n cmd.value = (uint8_t)action; \/\/ \u663e\u5f0f\u7c7b\u578b\u8f6c\u6362
\n cmd.timestamp = time(NULL);<\/p>\n pthread_mutex_lock(&queue_mutex);
\n commandQueue.push(cmd);
\n pthread_cond_signal(&queue_cond);
\n pthread_mutex_unlock(&queue_mutex);<\/p>\n printf("\u5df2\u5c06\u7ee7\u7535\u5668\u547d\u4ee4\u52a0\u5165\u961f\u5217: \u7ee7\u7535\u5668%d=%d\\\\n", relay_num, action);
\n } else {
\n printf("\u65e0\u6cd5\u89e3\u6790\u7684\u547d\u4ee4\u683c\u5f0f: %s\\\\n", payload);
\n }
\n }<\/p>\n MQTTClient_freeMessage(&message);
\n MQTTClient_free(topicName);
\n return 1;
\n}<\/p>\n \/\/ \u547d\u4ee4\u5904\u7406\u7ebf\u7a0b
\nvoid* command_thread(void* arg) {
\n while (running) {
\n pthread_mutex_lock(&queue_mutex);
\n while (commandQueue.empty() && running) {
\n pthread_cond_wait(&queue_cond, &queue_mutex);
\n }
\n if (!running) {
\n pthread_mutex_unlock(&queue_mutex);
\n break;
\n }
\n RelayCommand cmd = commandQueue.front();
\n commandQueue.pop();
\n pthread_mutex_unlock(&queue_mutex);<\/p>\n printf("\u5904\u7406\u7ee7\u7535\u5668\u547d\u4ee4: \u5730\u5740 0x%04X, \u503c %d\\\\n", cmd.address, cmd.value);
\n int result = control_relay(fd, cmd.address, cmd.value);<\/p>\n char status_msg[50];
\n snprintf(status_msg, sizeof(status_msg), "relay%d_status=%d", (cmd.address==RELAY1_ADDR?1:2), cmd.value);
\n mqtt_publish(MQTT_SENSOR_TOPIC, status_msg);<\/p>\n printf(result==0?"\u7ee7\u7535\u5668\u63a7\u5236\u6210\u529f\\\\n":"\u7ee7\u7535\u5668\u63a7\u5236\u5931\u8d25\\\\n");
\n }
\n return NULL;
\n}<\/p>\n \/\/ MQTT\u8fde\u63a5\u521d\u59cb\u5316
\nint init_mqtt() {
\n int rc;
\n MQTTClient_create(&mqtt_client, MQTT_ADDRESS, MQTT_CLIENTID, MQTTCLIENT_PERSISTENCE_NONE, NULL);
\n MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
\n conn_opts.username = MQTT_USERNAME;
\n conn_opts.password = MQTT_PASSWORD;
\n conn_opts.keepAliveInterval = 20;
\n conn_opts.cleansession = 1;
\n MQTTClient_setCallbacks(mqtt_client, NULL, NULL, msgarrvd, NULL);<\/p>\n if ((rc = MQTTClient_connect(mqtt_client, &conn_opts)) != MQTTCLIENT_SUCCESS) {
\n printf("MQTT\u8fde\u63a5\u5931\u8d25，\u9519\u8bef\u7801：%d\\\\n", rc);
\n return -1;
\n }
\n printf("MQTT\u8fde\u63a5\u6210\u529f: %s\\\\n", MQTT_ADDRESS);<\/p>\n if ((rc = MQTTClient_subscribe(mqtt_client, MQTT_COMMAND_TOPIC, MQTT_QOS)) != MQTTCLIENT_SUCCESS) {
\n printf("\u8ba2\u9605\u4e3b\u9898\u5931\u8d25，\u9519\u8bef\u7801：%d\\\\n", rc);
\n return -1;
\n }
\n printf("\u5df2\u8ba2\u9605\u4e3b\u9898: %s\\\\n", MQTT_COMMAND_TOPIC);<\/p>\n return 0;
\n}<\/p>\n \/\/ \u534e\u4e3a\u4e91MQTT\u8fde\u63a5\u521d\u59cb\u5316（\u589e\u5f3a\u5b89\u5168\u6027）
\nint init_huawei_mqtt() {
\n \/\/ \u68c0\u67e5\u534e\u4e3a\u4e91\u53c2\u6570\u6709\u6548\u6027
\n if (HUAWEI_CLIENT_ID == NULL || HUAWEI_USERNAME == NULL || HUAWEI_PASSWORD == NULL) {
\n printf("\u9519\u8bef: \u534e\u4e3a\u4e91\u53c2\u6570\u4e3a\u7a7a\\\\n");
\n return -1;
\n }<\/p>\n int rc;
\n MQTTClient_create(&huawei_client, HUAWEI_CLOUD_ADDR, HUAWEI_CLIENT_ID, MQTTCLIENT_PERSISTENCE_NONE, NULL);
\n MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
\n conn_opts.username = HUAWEI_USERNAME;
\n conn_opts.password = HUAWEI_PASSWORD;
\n conn_opts.keepAliveInterval = 20;
\n conn_opts.cleansession = 1;
\n conn_opts.connectTimeout = 10;<\/p>\n \/\/ \u914d\u7f6eSSL\/TLS
\n MQTTClient_SSLOptions ssl_opts = MQTTClient_SSLOptions_initializer;
\n ssl_opts.trustStore = "\/etc\/ssl\/certs\/ca-certificates.crt";
\n ssl_opts.verify = 1;
\n ssl_opts.sslVersion = MQTT_SSL_VERSION_TLS_1_2; \/\/ \u6307\u5b9aTLS\u7248\u672c
\n conn_opts.ssl = &ssl_opts;<\/p>\n \/\/ \u9a8c\u8bc1\u8bc1\u4e66\u6587\u4ef6\u662f\u5426\u5b58\u5728\u4e14\u53ef\u8bfb
\n if (access(ssl_opts.trustStore, R_OK) != 0) {
\n printf("\u9519\u8bef: \u8bc1\u4e66\u6587\u4ef6\u4e0d\u53ef\u8bfb: %s\\\\n", ssl_opts.trustStore);
\n return -1;
\n }<\/p>\n if ((rc = MQTTClient_connect(huawei_client, &conn_opts)) != MQTTCLIENT_SUCCESS) {
\n printf("\u534e\u4e3a\u4e91MQTT\u8fde\u63a5\u5931\u8d25，\u9519\u8bef\u7801：%d，\u9519\u8bef\u4fe1\u606f：%s\\\\n", rc, MQTTClient_strerror(rc));
\n return -1;
\n }
\n printf("\u534e\u4e3a\u4e91MQTT\u8fde\u63a5\u6210\u529f: %s\\\\n", HUAWEI_CLOUD_ADDR);<\/p>\n return 0;
\n}<\/p>\n \/\/ \u4e32\u53e3\u521d\u59cb\u5316
\nint init_serial() {
\n fd = open(RS485_DEV, O_RDWR | O_NOCTTY | O_NDELAY);
\n if (fd < 0) {
\n perror("\u65e0\u6cd5\u6253\u5f00\u4e32\u53e3");
\n log_message("\u65e0\u6cd5\u6253\u5f00\u4e32\u53e3");
\n return -1;
\n }<\/p>\n struct termios oldtio, newtio;
\n tcgetattr(fd, &oldtio);
\n bzero(&newtio, sizeof(newtio));
\n newtio.c_cflag = BAUDRATE | CS8 | CLOCAL | CREAD;
\n newtio.c_cflag &= ~CSTOPB;
\n newtio.c_iflag = IGNPAR;
\n newtio.c_oflag = 0;
\n tcflush(fd, TCIFLUSH);
\n tcsetattr(fd, TCSANOW, &newtio);<\/p>\n return 0;
\n}<\/p>\n \/\/ \u4fee\u6539\u540e\u7684\u4f20\u611f\u5668\u7ebf\u7a0b\u51fd\u6570
\nvoid* sensor_thread(void* arg) {
\n int max_retries = 3;
\n unsigned char response[256];
\n SensorData sensor_data = {0};<\/p>\n while (running) {
\n memset(&sensor_data, 0, sizeof(sensor_data));
\n int data_valid = 1;<\/p>\n \/\/ \u8bfb\u53d6\u6e29\u6e7f\u5ea6
\n printf("\\\\n\u8bfb\u53d6\u6e29\u6e7f\u5ea6\u4f20\u611f\u5668\u6570\u636e…\\\\n");
\n unsigned char temp_cmd[] = {0x01, 0x03, 0x00, 0x00, 0x00, 0x02};
\n temp_cmd[6] = crc16(temp_cmd, 6) & 0xFF;
\n temp_cmd[7] = crc16(temp_cmd, 6) >> 8;
\n int resp_len = read_sensor_data(fd, temp_cmd, 8, response, sizeof(response), max_retries);
\n if (resp_len >= 7 && response[0] == 0x01 && response[1] == 0x03 && response[2] == 0x04) {
\n sensor_data.humidity = ((response[3]<<8)|response[4])\/10.0f;
\n sensor_data.temperature = ((response[5]<<8)|response[6])\/10.0f;
\n } else {
\n data_valid = 0;
\n }<\/p>\n \/\/ \u8bfb\u53d6CO\u6d53\u5ea6
\n printf("\\\\n\u8bfb\u53d6CO\u6d53\u5ea6\u68c0\u6d4b\u6570\u636e…\\\\n");
\n unsigned char co_cmd[] = {0x02, 0x03, 0x00, 0x00, 0x00, 0x01};
\n co_cmd[6] = crc16(co_cmd, 6) & 0xFF;
\n co_cmd[7] = crc16(co_cmd, 6) >> 8;
\n resp_len = read_sensor_data(fd, co_cmd, 8, response, sizeof(response), max_retries);
\n if (resp_len >= 5 && response[0] == 0x02 && response[1] == 0x03 && response[2] == 0x02) {
\n sensor_data.co = (response[3]<<8)|response[4];
\n } else {
\n data_valid = 0;
\n }<\/p>\n \/\/ \u8bfb\u53d6\u5149\u7167\u503c
\n printf("\\\\n\u8bfb\u53d6\u5149\u7167\u503c\u68c0\u6d4b\u6570\u636e…\\\\n");
\n unsigned char light_cmd[] = {0x03, 0x03, 0x00, 0x00, 0x00, 0x01};
\n light_cmd[6] = crc16(light_cmd, 6) & 0xFF;
\n light_cmd[7] = crc16(light_cmd, 6) >> 8;
\n resp_len = read_sensor_data(fd, light_cmd, 8, response, sizeof(response), max_retries);
\n if (resp_len >= 5 && response[0] == 0x03 && response[1] == 0x03 && response[2] == 0x02) {
\n sensor_data.lux = (response[3]<<8)|response[4];
\n } else {
\n data_valid = 0;
\n }<\/p>\n if (data_valid) {
\n char payload[256];
\n snprintf(payload, sizeof(payload),
\n "{\\\\"TEMP\\\\":%.1f,\\\\"HUMI\\\\":%.1f,\\\\"CO\\\\":%d,\\\\"LUX\\\\":%d}",
\n sensor_data.temperature, sensor_data.humidity, sensor_data.co, sensor_data.lux);
\n mqtt_publish(MQTT_SENSOR_TOPIC, payload);
\n huawei_publish_data(sensor_data.temperature, sensor_data.humidity, sensor_data.co, sensor_data.lux);<\/p>\n char log_msg[256];
\n sprintf(log_msg, "\u4f20\u611f\u5668\u6570\u636e – \u6e29\u5ea6:%.1f \u6e7f\u5ea6:%.1f CO:%d LUX:%d",
\n sensor_data.temperature, sensor_data.humidity, sensor_data.co, sensor_data.lux);
\n log_message(log_msg);
\n } else {
\n log_message("\u4f20\u611f\u5668\u6570\u636e\u4e0d\u5b8c\u6574，\u672c\u6b21\u672a\u53d1\u9001");
\n }<\/p>\n sleep(2);
\n }<\/p>\n return NULL;
\n}<\/p>\n \/\/ \u534e\u4e3a\u4e91MQTT\u7f51\u7edc\u7ebf\u7a0b\u51fd\u6570
\nvoid *huawei_mqtt_thread(void *arg) {
\n while(running) {
\n MQTTClient_yield(); \/\/ \u4fee\u6b63\u51fd\u6570\u8c03\u7528
\n usleep(100000);
\n }
\n return NULL;
\n}<\/p>\n int main() {
\n int huawei_initialized = 0; \/\/ \u6807\u8bb0\u534e\u4e3a\u4e91\u662f\u5426\u521d\u59cb\u5316\u6210\u529f<\/p>\n if (init_serial() < 0) return -1;
\n if (init_mqtt() < 0) { close(fd); return -1; }<\/p>\n pthread_t command_tid, sensor_tid, huawei_tid;<\/p>\n if (pthread_create(&command_tid, NULL, command_thread, NULL) != 0 ||
\n pthread_create(&sensor_tid, NULL, sensor_thread, NULL) != 0) {
\n perror("\u7ebf\u7a0b\u521b\u5efa\u5931\u8d25");
\n running = 0;
\n close(fd);
\n MQTTClient_disconnect(mqtt_client, MQTT_TIMEOUT);
\n MQTTClient_destroy(&mqtt_client);
\n return -1;
\n }<\/p>\n \/\/ \u521d\u59cb\u5316\u534e\u4e3a\u4e91MQTT
\n if (init_huawei_mqtt() == 0) {
\n huawei_initialized = 1;
\n if (pthread_create(&huawei_tid, NULL, huawei_mqtt_thread, NULL) != 0) {
\n fprintf(stderr, "\u521b\u5efa\u534e\u4e3a\u4e91MQTT\u7ebf\u7a0b\u5931\u8d25\\\\n");
\n huawei_initialized = 0;
\n }
\n } else {
\n fprintf(stderr, "\u534e\u4e3a\u4e91MQTT\u521d\u59cb\u5316\u5931\u8d25，\u7ee7\u7eed\u8fd0\u884c\u4f46\u4e0d\u4f1a\u53d1\u9001\u6570\u636e\u5230\u4e91\u7aef\\\\n");
\n }<\/p>\n printf("\u7a0b\u5e8f\u8fd0\u884c\u4e2d，\u6309\u56de\u8f66\u952e\u9000\u51fa…\\\\n");
\n getchar(); <\/p>\n running = 0;
\n pthread_cond_signal(&queue_cond);
\n pthread_join(command_tid, NULL);
\n pthread_join(sensor_tid, NULL);<\/p>\n \/\/ \u6b63\u786e\u91ca\u653e\u534e\u4e3a\u4e91MQTT\u8d44\u6e90
\n if (huawei_initialized) {
\n pthread_join(huawei_tid, NULL);
\n MQTTClient_disconnect(huawei_client, MQTT_TIMEOUT);
\n MQTTClient_destroy(&huawei_client);
\n }<\/p>\n MQTTClient_unsubscribe(mqtt_client, MQTT_COMMAND_TOPIC);
\n MQTTClient_disconnect(mqtt_client, MQTT_TIMEOUT);
\n MQTTClient_destroy(&mqtt_client);
\n close(fd);
\n pthread_mutex_destroy(&serial_mutex);
\n pthread_mutex_destroy(&mqtt_mutex);
\n pthread_mutex_destroy(&queue_mutex);
\n pthread_cond_destroy(&queue_cond);<\/p>\n return 0;
\n}
\n#include <stdio.h>
\n#include <stdlib.h>
\n#include <string.h>
\n#include <unistd.h>
\n#include <fcntl.h>
\n#include <termios.h>
\n#include <sys\/select.h>
\n#include <time.h>
\n#include <pthread.h>
\n#include <stdint.h>
\n#include <queue>
\n#include "MQTTClient.h"
\n#include <cjson\/cJSON.h><\/p>\n \/\/ MQTT\u914d\u7f6e
\n#define MQTT_ADDRESS "tcp:\/\/192.168.1.212:1883"
\n#define MQTT_USERNAME " "
\n#define MQTT_PASSWORD " "
\n#define MQTT_CLIENTID "smart_farm_rs485"
\n#define MQTT_QOS 2
\n#define MQTT_SENSOR_TOPIC "\/Yuei\/sensor\/"
\n#define MQTT_COMMAND_TOPIC "\/Yuei\/command\/"
\n#define MQTT_TIMEOUT 10000L<\/p>\n \/\/ \u534e\u4e3a\u4e91IoT\u914d\u7f6e（\u4e0e\u6587\u6863\u5b8c\u5168\u4e00\u81f4）
\n#define HUAWEI_CLOUD_ADDR "tcp:\/\/21369d9ff7.st1.iotda-device.cn-north-4.myhuaweicloud.com:1883"
\n#define HUAWEI_CLIENT_ID "6823048384adf27cda58465e_Yiji1_0_0_2025051413"
\n#define HUAWEI_USERNAME "6823048384adf27cda58465e_Yiji1"
\n#define HUAWEI_PASSWORD "e554e71de483b60085373595c34051d0b37f9dbc680257234bb6233e9187704b"
\n#define HUAWEI_PUB_TOPIC "$oc\/devices\/6823048384adf27cda58465e_Yiji1\/sys\/properties\/report"<\/p>\n \/\/ RS485\u914d\u7f6e
\n#define RS485_DEV "\/dev\/ttyS1"
\n#define BAUDRATE B4800
\n#define RECV_TIMEOUT_MS 2000<\/p>\n \/\/ \u7ee7\u7535\u5668\u914d\u7f6e
\n#define RELAY_ADDRESS 4
\n#define RELAY1_ADDR 0x0010
\n#define RELAY2_ADDR 0x0011<\/p>\n \/\/ \u5168\u5c40\u53d8\u91cf
\nint fd;
\nMQTTClient mqtt_client;
\nMQTTClient huawei_client;
\npthread_mutex_t serial_mutex = PTHREAD_MUTEX_INITIALIZER;
\npthread_mutex_t mqtt_mutex = PTHREAD_MUTEX_INITIALIZER;
\nint running = 1;<\/p>\n \/\/ \u547d\u4ee4\u961f\u5217\u7ed3\u6784
\nstruct RelayCommand {
\n uint16_t address;
\n uint8_t value;
\n time_t timestamp;
\n};<\/p>\n typedef struct {
\n float temperature;
\n float humidity;
\n int co;
\n int lux;
\n time_t timestamp;
\n} SensorData;<\/p>\n std::queue<RelayCommand> commandQueue;
\npthread_mutex_t queue_mutex = PTHREAD_MUTEX_INITIALIZER;
\npthread_cond_t queue_cond = PTHREAD_COND_INITIALIZER;<\/p>\n \/\/ \u8ba1\u7b97Modbus CRC16\u6821\u9a8c
\nunsigned short crc16(unsigned char* data, int len) {
\n unsigned short crc = 0xFFFF;
\n for (int i = 0; i < len; i++) {
\n crc ^= data[i];
\n for (int j = 0; j < 8; j++) {
\n if (crc & 0x0001) {
\n crc = (crc >> 1) ^ 0xA001;
\n }
\n else {
\n crc >>= 1;
\n }
\n }
\n }
\n return crc;
\n}<\/p>\n \/\/ \u53d1\u9001Modbus RTU\u6307\u4ee4\u5e76\u63a5\u6536\u54cd\u5e94
\nint send_modbus_command(int fd, unsigned char* command, int cmd_len, unsigned char* response, int resp_len) {
\n fd_set readfds;
\n struct timeval timeout;<\/p>\n printf("\u53d1\u9001\u6307\u4ee4: ");
\n for (int i = 0; i < cmd_len; i++) {
\n printf("%02X ", command[i]);
\n }
\n printf("\\\\n");<\/p>\n tcflush(fd, TCIFLUSH);
\n usleep(50000);<\/p>\n int written = write(fd, command, cmd_len);
\n if (written != cmd_len) {
\n printf("\u53d1\u9001\u5931\u8d25: \u53ea\u53d1\u9001\u4e86 %d \u5b57\u8282，\u5e94\u8be5\u53d1\u9001 %d \u5b57\u8282\\\\n", written, cmd_len);
\n return -1;
\n }<\/p>\n timeout.tv_sec = 1;
\n timeout.tv_usec = 0;<\/p>\n while (1) {
\n FD_ZERO(&readfds);
\n FD_SET(fd, &readfds);<\/p>\n int sel_result = select(fd + 1, &readfds, NULL, NULL, &timeout);
\n if (sel_result < 0) {
\n perror("select error");
\n return -1;
\n }
\n else if (sel_result == 0) {
\n printf("\u54cd\u5e94\u8d85\u65f6\\\\n");
\n return 0;
\n }<\/p>\n if (FD_ISSET(fd, &readfds)) {
\n int bytes = read(fd, response, resp_len);
\n if (bytes > 0) {
\n printf("\u63a5\u6536\u54cd\u5e94: ");
\n for (int i = 0; i < bytes; i++) {
\n printf("%02X ", response[i]);
\n }
\n printf("\\\\n");
\n return bytes;
\n }
\n }
\n }<\/p>\n return 0;
\n}<\/p>\n \/\/ \u91cd\u8bd5\u8bfb\u53d6\u4f20\u611f\u5668\u6570\u636e
\nint read_sensor_data(int fd, unsigned char* command, int cmd_len, unsigned char* response, int resp_len, int max_retries) {
\n int response_len = 0;<\/p>\n for (int i = 0; i < max_retries; i++) {
\n struct timespec ts;
\n clock_gettime(CLOCK_REALTIME, &ts);
\n ts.tv_sec += 1;<\/p>\n if (pthread_mutex_timedlock(&serial_mutex, &ts) != 0) {
\n printf("\u83b7\u53d6\u4e32\u53e3\u9501\u8d85\u65f6（\u5c1d\u8bd5 %d\/%d）\\\\n", i + 1, max_retries);
\n continue;
\n }<\/p>\n response_len = send_modbus_command(fd, command, cmd_len, response, resp_len);
\n pthread_mutex_unlock(&serial_mutex);<\/p>\n if (response_len >= 5) {
\n unsigned short resp_crc = (response[response_len – 2] | (response[response_len – 1] << 8));
\n unsigned short calc_crc = crc16(response, response_len – 2);
\n if (resp_crc == calc_crc) return response_len;
\n else printf("CRC\u6821\u9a8c\u5931\u8d25（\u5c1d\u8bd5 %d\/%d）\\\\n", i + 1, max_retries);
\n }
\n else {
\n if (response_len == 0) printf("\u54cd\u5e94\u8d85\u65f6（\u5c1d\u8bd5 %d\/%d）\\\\n", i + 1, max_retries);
\n else printf("\u54cd\u5e94\u957f\u5ea6\u4e0d\u8db3（\u5c1d\u8bd5 %d\/%d）\\\\n", i + 1, max_retries);
\n }<\/p>\n usleep(100000);
\n }<\/p>\n return -1;
\n}<\/p>\n \/\/ \u8bb0\u5f55\u65e5\u5fd7
\nvoid log_message(const char* message) {
\n FILE* log_file = fopen("sensor_log.txt", "a");
\n if (!log_file) {
\n perror("\u65e0\u6cd5\u6253\u5f00\u65e5\u5fd7\u6587\u4ef6");
\n return;
\n }
\n time_t rawtime;
\n struct tm* timeinfo;
\n time(&rawtime);
\n timeinfo = localtime(&rawtime);
\n char time_str[26];
\n strftime(time_str, sizeof(time_str), "%Y-%m-%d %H:%M:%S", timeinfo);
\n fprintf(log_file, "%s – %s\\\\n", time_str, message);
\n fclose(log_file);
\n}<\/p>\n \/\/ MQTT\u6d88\u606f\u53d1\u5e03\u51fd\u6570 – \u672c\u5730MQTT
\nvoid mqtt_publish(const char* topic, const char* payload) {
\n MQTTClient_message message = MQTTClient_message_initializer;
\n message.payload = (void*)payload;
\n message.payloadlen = strlen(payload);
\n message.qos = MQTT_QOS;
\n message.retained = 0;<\/p>\n MQTTClient_deliveryToken token;
\n int rc;<\/p>\n pthread_mutex_lock(&mqtt_mutex);
\n if ((rc = MQTTClient_publishMessage(mqtt_client, topic, &message, &token)) != MQTTCLIENT_SUCCESS) {
\n printf("MQTT\u53d1\u5e03\u5931\u8d25，\u9519\u8bef\u7801：%d\\\\n", rc);
\n }
\n else {
\n MQTTClient_waitForCompletion(mqtt_client, token, MQTT_TIMEOUT);
\n printf("\u5df2\u53d1\u5e03\u5230\u4e3b\u9898[%s]: %s\\\\n", topic, payload);
\n }
\n pthread_mutex_unlock(&mqtt_mutex);
\n}<\/p>\n \/\/ \u534e\u4e3a\u4e91MQTT\u6570\u636e\u53d1\u5e03\u51fd\u6570（\u4fee\u6b63JSON\u7ed3\u6784）
\nvoid huawei_publish_data(float temperature, float humidity, int co, int lux) {
\n char json_str[256];
\n snprintf(json_str, sizeof(json_str),
\n "{"
\n "\\\\"services\\\\":[{"
\n "\\\\"service_id\\\\":\\\\"Sensor\\\\","
\n "\\\\"properties\\\\":{"
\n "\\\\"CO\u6d53\u5ea6\\\\":%d,"
\n "\\\\"\u5149\u7167\u5f3a\u5ea6\\\\":%d,"
\n "\\\\"\u6e7f\u5ea6\\\\":%.1f,"
\n "\\\\"\u6e29\u5ea6\\\\":%.1f"
\n "}"
\n "}]"
\n "}", co, lux, humidity, temperature);<\/p>\n pthread_mutex_lock(&mqtt_mutex);<\/p>\n MQTTClient_message pubmsg = MQTTClient_message_initializer;
\n pubmsg.payload = json_str;
\n pubmsg.payloadlen = strlen(json_str);
\n pubmsg.qos = MQTT_QOS;
\n pubmsg.retained = 0;<\/p>\n MQTTClient_deliveryToken token;
\n int rc = MQTTClient_publishMessage(huawei_client, HUAWEI_PUB_TOPIC, &pubmsg, &token);
\n if (rc != MQTTCLIENT_SUCCESS) {
\n fprintf(stderr, "[\u534e\u4e3a\u4e91] \u53d1\u5e03\u5931\u8d25: %d\\\\n", rc);
\n }
\n else {
\n if (MQTTClient_waitForCompletion(huawei_client, token, MQTT_TIMEOUT) != MQTTCLIENT_SUCCESS) {
\n fprintf(stderr, "[\u534e\u4e3a\u4e91] \u7b49\u5f85\u53d1\u5e03\u5b8c\u6210\u5931\u8d25\\\\n");
\n }
\n printf("[\u534e\u4e3a\u4e91] \u6570\u636e\u5df2\u53d1\u5e03: %s\\\\n", json_str);
\n }<\/p>\n pthread_mutex_unlock(&mqtt_mutex);
\n}<\/p>\n \/\/ \u63a7\u5236\u7ee7\u7535\u5668
\nint control_relay(int fd, uint16_t address, uint8_t value) {
\n uint8_t command[8];
\n command[0] = (uint8_t)RELAY_ADDRESS; \/\/ \u663e\u5f0f\u7c7b\u578b\u8f6c\u6362
\n command[1] = 0x05;
\n command[2] = (uint8_t)((address >> 8) & 0xFF); \/\/ \u663e\u5f0f\u7c7b\u578b\u8f6c\u6362
\n command[3] = (uint8_t)(address & 0xFF); \/\/ \u663e\u5f0f\u7c7b\u578b\u8f6c\u6362
\n command[4] = value ? 0xFF : 0x00;
\n command[5] = 0x00;<\/p>\n uint16_t crc = crc16(command, 6);
\n command[6] = (uint8_t)(crc & 0xFF); \/\/ \u663e\u5f0f\u7c7b\u578b\u8f6c\u6362
\n command[7] = (uint8_t)(crc >> 8); \/\/ \u663e\u5f0f\u7c7b\u578b\u8f6c\u6362<\/p>\n struct timespec ts;
\n clock_gettime(CLOCK_REALTIME, &ts);
\n ts.tv_sec += 2;<\/p>\n int lock_result = pthread_mutex_timedlock(&serial_mutex, &ts);
\n if (lock_result != 0) {
\n printf("\u83b7\u53d6\u4e32\u53e3\u9501\u8d85\u65f6，\u7ee7\u7535\u5668\u63a7\u5236\u88ab\u5ef6\u8fdf\\\\n");
\n return -1;
\n }<\/p>\n tcflush(fd, TCIFLUSH);
\n int bytes_written = write(fd, command, 8);
\n if (bytes_written != 8) {
\n perror("\u53d1\u9001\u547d\u4ee4\u5931\u8d25");
\n pthread_mutex_unlock(&serial_mutex);
\n return -1;
\n }<\/p>\n usleep(100000);
\n uint8_t response[8];
\n int bytes_read = read(fd, response, sizeof(response));
\n pthread_mutex_unlock(&serial_mutex);<\/p>\n if (bytes_read < 5) {
\n printf("\u54cd\u5e94\u6570\u636e\u8fc7\u77ed: %d\u5b57\u8282\\\\n", bytes_read);
\n return -1;
\n }<\/p>\n uint16_t received_crc = (response[bytes_read – 2] | (response[bytes_read – 1] << 8));
\n uint16_t calculated_crc = crc16(response, bytes_read – 2);
\n if (received_crc != calculated_crc || response[1] != 0x05) {
\n printf("CRC\u6821\u9a8c\u6216\u529f\u80fd\u7801\u9519\u8bef\\\\n");
\n return -1;
\n }<\/p>\n return 0;
\n}<\/p>\n \/\/ MQTT\u6d88\u606f\u5230\u8fbe\u56de\u8c03\u51fd\u6570
\nint msgarrvd(void* context, char* topicName, int topicLen, MQTTClient_message* message) {
\n char* payload = (char*)message->payload;
\n printf("\u6536\u5230\u6d88\u606f: \u4e3b\u9898[%s], \u5185\u5bb9: %s\\\\n", topicName, payload);<\/p>\n if (strncmp(topicName, MQTT_COMMAND_TOPIC, strlen(MQTT_COMMAND_TOPIC)) == 0) {
\n int relay_num, action;
\n if (sscanf(payload, "relay%d=%d", &relay_num, &action) == 2) {
\n RelayCommand cmd;
\n cmd.address = (relay_num == 1) ? RELAY1_ADDR : RELAY2_ADDR;
\n cmd.value = (uint8_t)action; \/\/ \u663e\u5f0f\u7c7b\u578b\u8f6c\u6362
\n cmd.timestamp = time(NULL);<\/p>\n pthread_mutex_lock(&queue_mutex);
\n commandQueue.push(cmd);
\n pthread_cond_signal(&queue_cond);
\n pthread_mutex_unlock(&queue_mutex);<\/p>\n printf("\u5df2\u5c06\u7ee7\u7535\u5668\u547d\u4ee4\u52a0\u5165\u961f\u5217: \u7ee7\u7535\u5668%d=%d\\\\n", relay_num, action);
\n }
\n else {
\n printf("\u65e0\u6cd5\u89e3\u6790\u7684\u547d\u4ee4\u683c\u5f0f: %s\\\\n", payload);
\n }
\n }<\/p>\n MQTTClient_freeMessage(&message);
\n MQTTClient_free(topicName);
\n return 1;
\n}<\/p>\n \/\/ \u547d\u4ee4\u5904\u7406\u7ebf\u7a0b
\nvoid* command_thread(void* arg) {
\n while (running) {
\n pthread_mutex_lock(&queue_mutex);
\n while (commandQueue.empty() && running) {
\n pthread_cond_wait(&queue_cond, &queue_mutex);
\n }
\n if (!running) {
\n pthread_mutex_unlock(&queue_mutex);
\n break;
\n }
\n RelayCommand cmd = commandQueue.front();
\n commandQueue.pop();
\n pthread_mutex_unlock(&queue_mutex);<\/p>\n printf("\u5904\u7406\u7ee7\u7535\u5668\u547d\u4ee4: \u5730\u5740 0x%04X, \u503c %d\\\\n", cmd.address, cmd.value);
\n int result = control_relay(fd, cmd.address, cmd.value);<\/p>\n char status_msg[50];
\n snprintf(status_msg, sizeof(status_msg), "relay%d_status=%d", (cmd.address == RELAY1_ADDR ? 1 : 2), cmd.value);
\n mqtt_publish(MQTT_SENSOR_TOPIC, status_msg);<\/p>\n printf(result == 0 ? "\u7ee7\u7535\u5668\u63a7\u5236\u6210\u529f\\\\n" : "\u7ee7\u7535\u5668\u63a7\u5236\u5931\u8d25\\\\n");
\n }
\n return NULL;
\n}<\/p>\n \/\/ MQTT\u8fde\u63a5\u521d\u59cb\u5316
\nint init_mqtt() {
\n int rc;
\n MQTTClient_create(&mqtt_client, MQTT_ADDRESS, MQTT_CLIENTID, MQTTCLIENT_PERSISTENCE_NONE, NULL);
\n MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
\n conn_opts.username = MQTT_USERNAME;
\n conn_opts.password = MQTT_PASSWORD;
\n conn_opts.keepAliveInterval = 20;
\n conn_opts.cleansession = 1;
\n MQTTClient_setCallbacks(mqtt_client, NULL, NULL, msgarrvd, NULL);<\/p>\n if ((rc = MQTTClient_connect(mqtt_client, &conn_opts)) != MQTTCLIENT_SUCCESS) {
\n printf("MQTT\u8fde\u63a5\u5931\u8d25，\u9519\u8bef\u7801：%d\\\\n", rc);
\n return -1;
\n }
\n printf("MQTT\u8fde\u63a5\u6210\u529f: %s\\\\n", MQTT_ADDRESS);<\/p>\n if ((rc = MQTTClient_subscribe(mqtt_client, MQTT_COMMAND_TOPIC, MQTT_QOS)) != MQTTCLIENT_SUCCESS) {
\n printf("\u8ba2\u9605\u4e3b\u9898\u5931\u8d25，\u9519\u8bef\u7801：%d\\\\n", rc);
\n return -1;
\n }
\n printf("\u5df2\u8ba2\u9605\u4e3b\u9898: %s\\\\n", MQTT_COMMAND_TOPIC);<\/p>\n return 0;
\n}<\/p>\n \/\/ \u534e\u4e3a\u4e91MQTT\u8fde\u63a5\u521d\u59cb\u5316（\u589e\u5f3a\u5b89\u5168\u6027）
\nint init_huawei_mqtt() {
\n \/\/ \u68c0\u67e5\u534e\u4e3a\u4e91\u53c2\u6570\u6709\u6548\u6027
\n if (HUAWEI_CLIENT_ID == NULL || HUAWEI_USERNAME == NULL || HUAWEI_PASSWORD == NULL) {
\n printf("\u9519\u8bef: \u534e\u4e3a\u4e91\u53c2\u6570\u4e3a\u7a7a\\\\n");
\n return -1;
\n }<\/p>\n int rc;
\n MQTTClient_create(&huawei_client, HUAWEI_CLOUD_ADDR, HUAWEI_CLIENT_ID, MQTTCLIENT_PERSISTENCE_NONE, NULL);
\n MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
\n conn_opts.username = HUAWEI_USERNAME;
\n conn_opts.password = HUAWEI_PASSWORD;
\n \/\/ conn_opts.keepAliveInterval = 20;
\n \/\/ conn_opts.cleansession = 1;
\n \/\/ conn_opts.connectTimeout = 10;<\/p>\n \/\/ \u914d\u7f6eSSL\/TLS
\n \/\/ MQTTClient_SSLOptions ssl_opts = MQTTClient_SSLOptions_initializer;
\n \/\/ ssl_opts.trustStore = "\/etc\/ssl\/certs\/ca-certificates.crt";
\n \/\/ ssl_opts.verify = 1;
\n \/\/ ssl_opts.sslVersion = MQTT_SSL_VERSION_TLS_1_2; \/\/ \u6307\u5b9aTLS\u7248\u672c
\n \/\/ conn_opts.ssl = &ssl_opts;<\/p>\n \/\/ \u9a8c\u8bc1\u8bc1\u4e66\u6587\u4ef6\u662f\u5426\u5b58\u5728\u4e14\u53ef\u8bfb
\n \/\/ if (access(ssl_opts.trustStore, R_OK) != 0) {
\n \/\/ printf("\u9519\u8bef: \u8bc1\u4e66\u6587\u4ef6\u4e0d\u53ef\u8bfb: %s\\\\n", ssl_opts.trustStore);
\n \/\/ return -1;
\n \/\/ }<\/p>\n if ((rc = MQTTClient_connect(huawei_client, &conn_opts)) != MQTTCLIENT_SUCCESS) {
\n printf("\u534e\u4e3a\u4e91MQTT\u8fde\u63a5\u5931\u8d25，\u9519\u8bef\u7801：%d，\u9519\u8bef\u4fe1\u606f：%s\\\\n", rc, MQTTClient_strerror(rc));
\n return -1;
\n }
\n printf("\u534e\u4e3a\u4e91MQTT\u8fde\u63a5\u6210\u529f: %s\\\\n", HUAWEI_CLOUD_ADDR);<\/p>\n return 0;
\n}<\/p>\n \/\/ \u4e32\u53e3\u521d\u59cb\u5316
\nint init_serial() {
\n fd = open(RS485_DEV, O_RDWR | O_NOCTTY | O_NDELAY);
\n if (fd < 0) {
\n perror("\u65e0\u6cd5\u6253\u5f00\u4e32\u53e3");
\n log_message("\u65e0\u6cd5\u6253\u5f00\u4e32\u53e3");
\n return -1;
\n }<\/p>\n struct termios oldtio, newtio;
\n tcgetattr(fd, &oldtio);
\n bzero(&newtio, sizeof(newtio));
\n newtio.c_cflag = BAUDRATE | CS8 | CLOCAL | CREAD;
\n newtio.c_cflag &= ~CSTOPB;
\n newtio.c_iflag = IGNPAR;
\n newtio.c_oflag = 0;
\n tcflush(fd, TCIFLUSH);
\n tcsetattr(fd, TCSANOW, &newtio);<\/p>\n return 0;
\n}<\/p>\n \/\/ \u4fee\u6539\u540e\u7684\u4f20\u611f\u5668\u7ebf\u7a0b\u51fd\u6570
\nvoid* sensor_thread(void* arg) {
\n int max_retries = 3;
\n unsigned char response[256];
\n SensorData sensor_data = { 0 };<\/p>\n while (running) {
\n memset(&sensor_data, 0, sizeof(sensor_data));
\n int data_valid = 1;<\/p>\n \/\/ \u8bfb\u53d6\u6e29\u6e7f\u5ea6
\n printf("\\\\n\u8bfb\u53d6\u6e29\u6e7f\u5ea6\u4f20\u611f\u5668\u6570\u636e…\\\\n");
\n unsigned char temp_cmd[] = { 0x01, 0x03, 0x00, 0x00, 0x00, 0x02 };
\n temp_cmd[6] = crc16(temp_cmd, 6) & 0xFF;
\n temp_cmd[7] = crc16(temp_cmd, 6) >> 8;
\n int resp_len = read_sensor_data(fd, temp_cmd, 8, response, sizeof(response), max_retries);
\n if (resp_len >= 7 && response[0] == 0x01 && response[1] == 0x03 && response[2] == 0x04) {
\n sensor_data.humidity = ((response[3] << 8) | response[4]) \/ 10.0f;
\n sensor_data.temperature = ((response[5] << 8) | response[6]) \/ 10.0f;
\n }
\n else {
\n data_valid = 0;
\n }<\/p>\n \/\/ \u8bfb\u53d6CO\u6d53\u5ea6
\n printf("\\\\n\u8bfb\u53d6CO\u6d53\u5ea6\u68c0\u6d4b\u6570\u636e…\\\\n");
\n unsigned char co_cmd[] = { 0x02, 0x03, 0x00, 0x00, 0x00, 0x01 };
\n co_cmd[6] = crc16(co_cmd, 6) & 0xFF;
\n co_cmd[7] = crc16(co_cmd, 6) >> 8;
\n resp_len = read_sensor_data(fd, co_cmd, 8, response, sizeof(response), max_retries);
\n if (resp_len >= 5 && response[0] == 0x02 && response[1] == 0x03 && response[2] == 0x02) {
\n sensor_data.co = (response[3] << 8) | response[4];
\n }
\n else {
\n data_valid = 0;
\n }<\/p>\n \/\/ \u8bfb\u53d6\u5149\u7167\u503c
\n printf("\\\\n\u8bfb\u53d6\u5149\u7167\u503c\u68c0\u6d4b\u6570\u636e…\\\\n");
\n unsigned char light_cmd[] = { 0x03, 0x03, 0x00, 0x00, 0x00, 0x01 };
\n light_cmd[6] = crc16(light_cmd, 6) & 0xFF;
\n light_cmd[7] = crc16(light_cmd, 6) >> 8;
\n resp_len = read_sensor_data(fd, light_cmd, 8, response, sizeof(response), max_retries);
\n if (resp_len >= 5 && response[0] == 0x03 && response[1] == 0x03 && response[2] == 0x02) {
\n sensor_data.lux = (response[3] << 8) | response[4];
\n }
\n else {
\n data_valid = 0;
\n }<\/p>\n if (data_valid) {
\n char payload[256];
\n snprintf(payload, sizeof(payload),
\n "{\\\\"TEMP\\\\":%.1f,\\\\"HUMI\\\\":%.1f,\\\\"CO\\\\":%d,\\\\"LUX\\\\":%d}",
\n sensor_data.temperature, sensor_data.humidity, sensor_data.co, sensor_data.lux);
\n mqtt_publish(MQTT_SENSOR_TOPIC, payload);
\n huawei_publish_data(sensor_data.temperature, sensor_data.humidity, sensor_data.co, sensor_data.lux);<\/p>\n char log_msg[256];
\n sprintf(log_msg, "\u4f20\u611f\u5668\u6570\u636e – \u6e29\u5ea6:%.1f \u6e7f\u5ea6:%.1f CO:%d LUX:%d",
\n sensor_data.temperature, sensor_data.humidity, sensor_data.co, sensor_data.lux);
\n log_message(log_msg);
\n }
\n else {
\n log_message("\u4f20\u611f\u5668\u6570\u636e\u4e0d\u5b8c\u6574，\u672c\u6b21\u672a\u53d1\u9001");
\n }<\/p>\n sleep(2);
\n }<\/p>\n return NULL;
\n}<\/p>\n \/\/ \u534e\u4e3a\u4e91MQTT\u7f51\u7edc\u7ebf\u7a0b\u51fd\u6570
\nvoid* huawei_mqtt_thread(void* arg) {
\n while (running) {
\n MQTTClient_yield(); \/\/ \u4fee\u6b63\u51fd\u6570\u8c03\u7528
\n usleep(100000);
\n }
\n return NULL;
\n}<\/p>\n int main() {
\n int huawei_initialized = 0; \/\/ \u6807\u8bb0\u534e\u4e3a\u4e91\u662f\u5426\u521d\u59cb\u5316\u6210\u529f<\/p>\n if (init_serial() < 0) return -1;
\n if (init_mqtt() < 0) { close(fd); return -1; }<\/p>\n pthread_t command_tid, sensor_tid, huawei_tid;<\/p>\n if (pthread_create(&command_tid, NULL, command_thread, NULL) != 0 ||
\n pthread_create(&sensor_tid, NULL, sensor_thread, NULL) != 0) {
\n perror("\u7ebf\u7a0b\u521b\u5efa\u5931\u8d25");
\n running = 0;
\n close(fd);
\n MQTTClient_disconnect(mqtt_client, MQTT_TIMEOUT);
\n MQTTClient_destroy(&mqtt_client);
\n return -1;
\n }<\/p>\n \/\/ \u521d\u59cb\u5316\u534e\u4e3a\u4e91MQTT
\n if (init_huawei_mqtt() == 0) {
\n huawei_initialized = 1;
\n if (pthread_create(&huawei_tid, NULL, huawei_mqtt_thread, NULL) != 0) {
\n fprintf(stderr, "\u521b\u5efa\u534e\u4e3a\u4e91MQTT\u7ebf\u7a0b\u5931\u8d25\\\\n");
\n huawei_initialized = 0;
\n }
\n }
\n else {
\n fprintf(stderr, "\u534e\u4e3a\u4e91MQTT\u521d\u59cb\u5316\u5931\u8d25，\u7ee7\u7eed\u8fd0\u884c\u4f46\u4e0d\u4f1a\u53d1\u9001\u6570\u636e\u5230\u4e91\u7aef\\\\n");
\n }<\/p>\n printf("\u7a0b\u5e8f\u8fd0\u884c\u4e2d，\u6309\u56de\u8f66\u952e\u9000\u51fa…\\\\n");
\n getchar();<\/p>\n running = 0;
\n pthread_cond_signal(&queue_cond);
\n pthread_join(command_tid, NULL);
\n pthread_join(sensor_tid, NULL);<\/p>\n \/\/ \u6b63\u786e\u91ca\u653e\u534e\u4e3a\u4e91MQTT\u8d44\u6e90
\n if (huawei_initialized) {
\n pthread_join(huawei_tid, NULL);
\n MQTTClient_disconnect(huawei_client, MQTT_TIMEOUT);
\n MQTTClient_destroy(&huawei_client);
\n }<\/p>\n MQTTClient_unsubscribe(mqtt_client, MQTT_COMMAND_TOPIC);
\n MQTTClient_disconnect(mqtt_client, MQTT_TIMEOUT);
\n MQTTClient_destroy(&mqtt_client);
\n close(fd);
\n pthread_mutex_destroy(&serial_mutex);
\n pthread_mutex_destroy(&mqtt_mutex);
\n pthread_mutex_destroy(&queue_mutex);
\n pthread_cond_destroy(&queue_cond);<\/p>\n return 0;
\n} <\/p>\n","protected":false},"excerpt":{"rendered":" \u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.8k\u6b21\uff0c\u70b9\u8d5e24\u6b21\uff0c\u6536\u85cf30\u6b21\u3002\u672c\u6587\u8be6\u7ec6\u4ecb\u7ecd\u4e86\u57fa\u4e8eRS485\u603b\u7ebf\u548cMQTT\u534f\u8bae\u7684\u4f20\u611f\u5668\u6570\u636e\u91c7\u96c6\u4e0e\u4f20\u8f93\u7cfb\u7edf\u7684\u5b9e\u73b0\u6d41\u7a0b\u3002\u7cfb\u7edf\u91c7\u7528\u603b\u7ebf\u578b\u62d3\u6251\u7ed3\u6784\uff0c\u901a\u8fc7Modbus\u534f\u8bae\u4e0e\u591a\u4e2a\u4f20\u611f\u5668\u901a\u4fe1\uff0c\u914d\u7f6e\u4e86\u4e3b\u4ece\u67b6\u6784\u548c\u901a\u4fe1\u53c2\u6570\uff08\u6ce2\u7279\u7387\u3001\u6570\u636e\u4f4d\u3001\u505c\u6b62\u4f4d\u7b49\uff09\u3002\u4f20\u611f\u5668\u6570\u636e\u901a\u8fc7RS485\u603b\u7ebf\u91c7\u96c6\u540e\uff0c\u4f7f\u7528C++\u7a0b\u5e8f\u89e3\u6790\uff0c\u5e76\u901a\u8fc7MQTT\u534f\u8bae\u53d1\u5e03\u5230\u672c\u5730\u548c\u534e\u4e3a\u4e91IoT\u5e73\u53f0\u3002\u6587\u7ae0\u8fd8\u63d0\u4f9b\u4e86\u786c\u4ef6\u8fde\u63a5\u3001\u901a\u4fe1\u534f\u8bae\u914d\u7f6e\u3001\u8f6f\u4ef6\u5b9e\u73b0\u6d41\u7a0b\u7684\u8be6\u7ec6\u6b65\u9aa4\uff0c\u5e76\u5f3a\u8c03\u4e86\u7535\u6c14\u5b89\u5168\u3001\u901a\u4fe1\u7a33\u5b9a\u6027\u548c\u9519\u8bef\u5904\u7406\u7684\u91cd\u8981\u6027\u3002\u6700\u540e\uff0c\u4ecb\u7ecd\u4e86\u5982\u4f55\u901a\u8fc7Node-RED\u4eea\u8868\u76d8\u5c55\u793a\u6570\u636e\uff0c\u5e76\u63d0\u4f9b\u4e86\u8fde\u63a5\u534e\u4e3a\u4e91IoT\u5e73\u53f0\u7684\u5177\u4f53\u4ee3\u7801\u793a\u4f8b\u548c\u5e38\u89c1_3588\u5b89\u88c5nodered<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[55,3159,1216,1447,219,220],"topic":[],"class_list":["post-43224","post","type-post","status-publish","format-standard","hentry","category-server","tag-c","tag-rk3588","tag-rs485","tag-1447","tag-219","tag-220"],"yoast_head":"\n \u57fa\u4e8eRK3588\u7684\u667a\u6167\u519c\u573a\u7cfb\u7edf\u5f00\u53d1|RS485\u603b\u7ebf|\u534e\u4e3a\u4e91IOT|node-red|MQTT - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/43224.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u57fa\u4e8eRK3588\u7684\u667a\u6167\u519c\u573a\u7cfb\u7edf\u5f00\u53d1|RS485\u603b\u7ebf|\u534e\u4e3a\u4e91IOT|node-red|MQTT - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.8k\u6b21\uff0c\u70b9\u8d5e24\u6b21\uff0c\u6536\u85cf30\u6b21\u3002\u672c\u6587\u8be6\u7ec6\u4ecb\u7ecd\u4e86\u57fa\u4e8eRS485\u603b\u7ebf\u548cMQTT\u534f\u8bae\u7684\u4f20\u611f\u5668\u6570\u636e\u91c7\u96c6\u4e0e\u4f20\u8f93\u7cfb\u7edf\u7684\u5b9e\u73b0\u6d41\u7a0b\u3002\u7cfb\u7edf\u91c7\u7528\u603b\u7ebf\u578b\u62d3\u6251\u7ed3\u6784\uff0c\u901a\u8fc7Modbus\u534f\u8bae\u4e0e\u591a\u4e2a\u4f20\u611f\u5668\u901a\u4fe1\uff0c\u914d\u7f6e\u4e86\u4e3b\u4ece\u67b6\u6784\u548c\u901a\u4fe1\u53c2\u6570\uff08\u6ce2\u7279\u7387\u3001\u6570\u636e\u4f4d\u3001\u505c\u6b62\u4f4d\u7b49\uff09\u3002\u4f20\u611f\u5668\u6570\u636e\u901a\u8fc7RS485\u603b\u7ebf\u91c7\u96c6\u540e\uff0c\u4f7f\u7528C++\u7a0b\u5e8f\u89e3\u6790\uff0c\u5e76\u901a\u8fc7MQTT\u534f\u8bae\u53d1\u5e03\u5230\u672c\u5730\u548c\u534e\u4e3a\u4e91IoT\u5e73\u53f0\u3002\u6587\u7ae0\u8fd8\u63d0\u4f9b\u4e86\u786c\u4ef6\u8fde\u63a5\u3001\u901a\u4fe1\u534f\u8bae\u914d\u7f6e\u3001\u8f6f\u4ef6\u5b9e\u73b0\u6d41\u7a0b\u7684\u8be6\u7ec6\u6b65\u9aa4\uff0c\u5e76\u5f3a\u8c03\u4e86\u7535\u6c14\u5b89\u5168\u3001\u901a\u4fe1\u7a33\u5b9a\u6027\u548c\u9519\u8bef\u5904\u7406\u7684\u91cd\u8981\u6027\u3002\u6700\u540e\uff0c\u4ecb\u7ecd\u4e86\u5982\u4f55\u901a\u8fc7Node-RED\u4eea\u8868\u76d8\u5c55\u793a\u6570\u636e\uff0c\u5e76\u63d0\u4f9b\u4e86\u8fde\u63a5\u534e\u4e3a\u4e91IoT\u5e73\u53f0\u7684\u5177\u4f53\u4ee3\u7801\u793a\u4f8b\u548c\u5e38\u89c1_3588\u5b89\u88c5nodered\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/43224.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2025-06-11T00:56:53+00:00\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"26 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/43224.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/43224.html\",\"name\":\"\u57fa\u4e8eRK3588\u7684\u667a\u6167\u519c\u573a\u7cfb\u7edf\u5f00\u53d1|RS485\u603b\u7ebf|\u534e\u4e3a\u4e91IOT|node-red|MQTT - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2025-06-11T00:56:53+00:00\",\"dateModified\":\"2025-06-11T00:56:53+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/43224.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/43224.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/43224.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u57fa\u4e8eRK3588\u7684\u667a\u6167\u519c\u573a\u7cfb\u7edf\u5f00\u53d1|RS485\u603b\u7ebf|\u534e\u4e3a\u4e91IOT|node-red|MQTT\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"\u57fa\u4e8eRK3588\u7684\u667a\u6167\u519c\u573a\u7cfb\u7edf\u5f00\u53d1|RS485\u603b\u7ebf|\u534e\u4e3a\u4e91IOT|node-red|MQTT - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/43224.html","og_locale":"zh_CN","og_type":"article","og_title":"\u57fa\u4e8eRK3588\u7684\u667a\u6167\u519c\u573a\u7cfb\u7edf\u5f00\u53d1|RS485\u603b\u7ebf|\u534e\u4e3a\u4e91IOT|node-red|MQTT - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.8k\u6b21\uff0c\u70b9\u8d5e24\u6b21\uff0c\u6536\u85cf30\u6b21\u3002\u672c\u6587\u8be6\u7ec6\u4ecb\u7ecd\u4e86\u57fa\u4e8eRS485\u603b\u7ebf\u548cMQTT\u534f\u8bae\u7684\u4f20\u611f\u5668\u6570\u636e\u91c7\u96c6\u4e0e\u4f20\u8f93\u7cfb\u7edf\u7684\u5b9e\u73b0\u6d41\u7a0b\u3002\u7cfb\u7edf\u91c7\u7528\u603b\u7ebf\u578b\u62d3\u6251\u7ed3\u6784\uff0c\u901a\u8fc7Modbus\u534f\u8bae\u4e0e\u591a\u4e2a\u4f20\u611f\u5668\u901a\u4fe1\uff0c\u914d\u7f6e\u4e86\u4e3b\u4ece\u67b6\u6784\u548c\u901a\u4fe1\u53c2\u6570\uff08\u6ce2\u7279\u7387\u3001\u6570\u636e\u4f4d\u3001\u505c\u6b62\u4f4d\u7b49\uff09\u3002\u4f20\u611f\u5668\u6570\u636e\u901a\u8fc7RS485\u603b\u7ebf\u91c7\u96c6\u540e\uff0c\u4f7f\u7528C++\u7a0b\u5e8f\u89e3\u6790\uff0c\u5e76\u901a\u8fc7MQTT\u534f\u8bae\u53d1\u5e03\u5230\u672c\u5730\u548c\u534e\u4e3a\u4e91IoT\u5e73\u53f0\u3002\u6587\u7ae0\u8fd8\u63d0\u4f9b\u4e86\u786c\u4ef6\u8fde\u63a5\u3001\u901a\u4fe1\u534f\u8bae\u914d\u7f6e\u3001\u8f6f\u4ef6\u5b9e\u73b0\u6d41\u7a0b\u7684\u8be6\u7ec6\u6b65\u9aa4\uff0c\u5e76\u5f3a\u8c03\u4e86\u7535\u6c14\u5b89\u5168\u3001\u901a\u4fe1\u7a33\u5b9a\u6027\u548c\u9519\u8bef\u5904\u7406\u7684\u91cd\u8981\u6027\u3002\u6700\u540e\uff0c\u4ecb\u7ecd\u4e86\u5982\u4f55\u901a\u8fc7Node-RED\u4eea\u8868\u76d8\u5c55\u793a\u6570\u636e\uff0c\u5e76\u63d0\u4f9b\u4e86\u8fde\u63a5\u534e\u4e3a\u4e91IoT\u5e73\u53f0\u7684\u5177\u4f53\u4ee3\u7801\u793a\u4f8b\u548c\u5e38\u89c1_3588\u5b89\u88c5nodered","og_url":"https:\/\/www.wsisp.com\/helps\/43224.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2025-06-11T00:56:53+00:00","author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"26 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/43224.html","url":"https:\/\/www.wsisp.com\/helps\/43224.html","name":"\u57fa\u4e8eRK3588\u7684\u667a\u6167\u519c\u573a\u7cfb\u7edf\u5f00\u53d1|RS485\u603b\u7ebf|\u534e\u4e3a\u4e91IOT|node-red|MQTT - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2025-06-11T00:56:53+00:00","dateModified":"2025-06-11T00:56:53+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/43224.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/43224.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/43224.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"\u57fa\u4e8eRK3588\u7684\u667a\u6167\u519c\u573a\u7cfb\u7edf\u5f00\u53d1|RS485\u603b\u7ebf|\u534e\u4e3a\u4e91IOT|node-red|MQTT"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/43224","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=43224"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/43224\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=43224"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=43224"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=43224"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=43224"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}} |