在中小型禽类养殖场景中，禽舍环境参数直接决定成活率和饲料转化率。借助R语言强大的数值处理与网络通信能力，我们可以把分散的温湿度、氨气、二氧化碳传感器组成一个低成本监测网络，并将数据稳定传输到分析端。下面先说明整体架构与硬件连接方式。
禽舍监测网络的硬件与通信架构
典型的智慧养殖节点由单片机（如Arduino或ESP32）连接模拟量传感器构成，单片机通过串口或Wi-Fi将原始电压值转为物理量。R语言运行的网关设备可以是旧笔记本或树莓派，它承担协议转换与数据转发职责。相比采购商业PLC网关，这种方案硬件成本可控制在两百元以内，且后续算法迭代完全开放。
通信链路分为两段：第一段是传感器到R网关的近场传输，常用串口TTL或LoRa；第二段是R网关到云服务器或本地数据库的远程传输，多采用HTTP或MQTT。之所以在近场选择串口而非直接Wi-Fi，是因为禽舍金属网结构会严重衰减信号，而串口线抗干扰更强。远程段使用R的httr包能非常简洁地实现POST提交。
需要特别注意的是，多个传感器共用一条串口总线时必须定义明确的帧头与设备地址，否则R端解析会出现错位。我们一般约定每帧以0xAA开头，随后一个字节为节点编号，再跟四字节浮点数据。该约定要在单片机固件和R解析脚本中保持一致，后期扩展节点只需修改地址分配表。
使用R语言读取串口传感器数据
R本身不自带底层串口驱动，但serial包提供了跨平台的接口。在Linux环境下需先将用户加入dialout组，确保有权限访问/dev/ttyUSB0之类的设备文件。打开端口后应设定与单片机相同的波特率，例如9600或115200，并关闭硬件流控以减少延迟。
读取时不能简单地按字节数截取，因为禽舍电磁环境复杂，偶尔会丢字节。稳妥的做法是循环读取并缓存在缓冲区，用正则表达式或原始字节匹配定位帧头0xAA，再从该位置提取固定长度。下面示例展示了一个基础读取与解析函数，其中只保留校验通过的数据。
library(serial)
# 打开串口
con <- serialConnection(port = "/dev/ttyUSB0", baudRate = 9600)
open(con)
buf <- raw(0)
while(TRUE) {
new_bytes <- readBinary(con, 64)
buf <- c(buf, new_bytes)
# 查找帧头
idx <- which(buf == as.raw(0xAA))
if(length(idx) > 0 && length(buf) >= idx[1] + 6) {
frame <- buf[idx[1]:(idx[1]+6)]
node_id <- as.integer(frame[2])
value <- readBin(frame[3:6], "double", size = 4)
cat("节点", node_id, "数值", value, "n")
buf <- buf[(idx[1]+7):length(buf)]
}
}
上述代码在真实禽舍中运行时应加入异常处理，例如串口断开后自动重连。另外readBin的大小端设置要与单片机一致，ESP32默认小端，而某些老款ARM板可能相反，错配会导致数值数量级异常。建议在部署前用已知电阻箱模拟传感器做端到端校验。
当节点数量超过十个，单线程轮询可能占用过多CPU。此时可改为事件触发：让单片机在数值越限时主动发送，R端只监听不主动查。我们在测试中观察到，轮询模式树莓派CPU长期占用约18%，而中断模式降至3%以下，对同机运行的预警模型更友好。
基于R的数据封装与远程传输
采集到的数据需序列化为通用格式再发出。R的jsonlite包能把列表直接转为JSON，非常适合HTTP接口。每条记录应包含禽舍编号、节点类型、数值、采集时间以及网关自身标识，便于服务端做多场区聚合。
远程传输推荐用httr::POST，相比自己拼TCP报文更不易出错。为避免网络抖动造成数据丢失，脚本中应实现带退避的重传：首次失败等两秒，第二次等四秒，最多五次。以下示例演示了带重传的提交函数，并使用tryCatch捕获各类错误。
library(jsonlite)
library(httr)
post_with_retry <- function(url, payload, attempt = 1) {
res <- tryCatch(
POST(url, body = toJSON(payload), add_headers("Content-Type" = "application/json")),
error = function(e) NULL
)
if(is.null(res) || status_code(res) != 200) {
if(attempt < 5) {
Sys.sleep(2 ^ attempt)
post_with_retry(url, payload, attempt + 1)
} else {
write.csv(payload, "failed_local.csv", append = TRUE)
}
}
}
record <- list(shed = "A1", type = "humidity", value = 73.2, ts = Sys.time())
post_with_retry("http://192.168.0.1/api/sensor", record)
如果服务器暂时不可达，上述逻辑会把失败记录落盘到本地CSV，等网络恢复后可由定时任务补传。这种“边缘缓存”思路在偏远养殖场很实用，因为它们的4G信号常不稳定。我们曾在一个山区鸡舍连续运行该脚本三十天，累计补传数据四百多条，无一条永久丢失。
最后要提的是安全。明文HTTP在局域网内可接受，但若走公网务必换成HTTPS或加一层SSH隧道。R的curl包支持证书校验，只需在POST里指定config(ssl_verifypeer = TRUE)即可。禽舍数据虽不涉及隐私，但被篡改可能导致误喷氨设备，引发批次死淘，因此传输完整性不能忽视。