如何搭建服务器接收Arduino传感器数据并在Java应用中使用

本文介绍从零搭建轻量级服务器,接收arduino通过http或mqtt上传的传感器数据,并将其存入sqlite数据库,供java桌面或web应用实时调用的完整技术路径。

要实现Arduino传感器数据到Java应用的端到端流转,核心在于构建一个可靠、低开销、易维护的数据中转服务层。你已注册域名(如 yourdomain.com),接下来需完成三步闭环:部署后端服务器 → 暴露安全API接收数据 → 在Java应用中查询/消费数据。以下为推荐方案与实操要点:

✅ 推荐架构:轻量HTTP + SQLite + Java JDBC

相比复杂微服务,此组合更适合原型开发与中小规模IoT项目,兼顾性能与可维护性。

1. 选择并配置服务器

  • 推荐平台:DigitalOcean($5/月 Droplet)、AWS EC2 Free Tier(12个月)或 Google Cloud Shell(临时测试)。
  • 系统镜像:Ubuntu 22.04 LTS(稳定、社区支持强)。
  • 基础配置
    # 登录后更新系统
    sudo apt update && sudo apt upgrade -y
    # 安装Java运行环境(用于后续Java服务)及Python3(快速搭建API)
    sudo apt install openjdk-17-jdk python3-pip sqlite3 nginx -y

2. 搭建数据接收API(Python Flask 示例)

在服务器上创建 /var/www/sensor-api/app.py:

from flask import Flask, request, jsonify
import sqlite3
import time

app = Flask(__name__)
DB_PATH = "/var/www/sensor-api/sensors.db"

def init_db():
    conn = sqlite3.connect(DB_PATH)
    conn.execute("""
        CREATE TABLE IF NOT EXISTS readings (
            id INTEGER PRIMARY KEY AUTOINCREMENT,
            timestamp DATETIME DEFAULT CURRENT_TIMESTAMP,
            temperature REAL,
            humidity REAL,
            sensor_id TEXT
        )
    """)
    conn.close()

@app.route('/api/post', methods=['POST'])
def receive_data():
    try:
        data = request.get_json()
        conn = sqlite3.connect(DB_PATH)
        conn.execute(
            "INSERT INTO readings (temperature, humidity, sensor_id) VALUES (?, ?, ?)",
            (data['temp'], data['humi'], data['id'])
        )
        conn.commit()
        conn.clos

e() return jsonify({"status": "success"}), 200 except Exception as e: return jsonify({"error": str(e)}), 400 if __name__ == '__main__': init_db() app.run(host='0.0.0.0:5000') # 生产环境请用 Gunicorn + Nginx 反向代理

启动服务:

pip3 install flask
nohup python3 /var/www/sensor-api/app.py > /var/log/sensor-api.log 2>&1 &
⚠️ 注意:生产环境务必添加Nginx反向代理、HTTPS(Let’s Encrypt)、请求频率限制和数据校验,避免未授权写入。

3. Arduino端发送数据(HTTP POST 示例)

使用ESP32/ESP8266(带WiFi)模块,通过ArduinoJson + HTTPClient发送:

#include 
#include 
#include 

const char* ssid = "YOUR_WIFI";
const char* password = "YOUR_PASS";
const char* serverUrl = "http://yourdomain.com:5000/api/post"; // 或使用Nginx代理后的域名

void setup() {
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) delay(500);
}

void loop() {
  float temp = readTemperature(); // 替换为你实际的传感器读取函数
  float humi = readHumidity();

  HTTPClient http;
  http.begin(serverUrl);
  http.addHeader("Content-Type", "application/json");

  StaticJsonDocument<256> doc;
  doc["temp"] = temp;
  doc["humi"] = humi;
  doc["id"] = "sensor-01";

  String payload;
  serializeJson(doc, payload);
  int httpResponseCode = http.POST(payload);

  http.end();
  delay(5000); // 每5秒上报一次
}

4. Java应用读取SQLite数据

在Java项目中引入SQLite JDBC驱动(Maven):


  org.xerial
  sqlite-jdbc
  3.45.1.0

示例查询代码:

String dbPath = "/var/www/sensor-api/sensors.db"; // 确保Java有读取权限
Connection conn = DriverManager.getConnection("jdbc:sqlite:" + dbPath);
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM readings ORDER BY timestamp DESC LIMIT 10");
while (rs.next()) {
  System.out.printf("Time: %s, Temp: %.2f°C, Humi: %.2f%%\n",
      rs.getString("timestamp"),
      rs.getDouble("temperature"),
      rs.getDouble("humidity"));
}

? 关键注意事项

  • 域名解析:在GoDaddy DNS设置中,将 A记录 指向你的服务器公网IP;若使用Cloudflare,开启代理(橙色云朵)并配置SSL。
  • 防火墙:开放端口 5000(开发)或 80/443(生产,经Nginx代理)。
  • 安全性:切勿在Arduino固件中硬编码敏感信息;生产环境必须启用HTTPS、API密钥鉴权(如Bearer Token)。
  • 扩展建议:数据量增大后,可平滑迁移至MySQL/PostgreSQL;需双向控制时,改用MQTT(推荐Eclipse Mosquitto服务器 + Arduino PubSubClient库)。

该方案以最小成本实现“Arduino → 云端API → SQLite → Java应用”的全链路贯通,兼顾教学性与工程可行性。下一步可集成定时任务(如Java Quartz)自动拉取最新数据,或构建可视化仪表盘。