SpringBoot与Californium整合，实现物联网设备低功耗通信系统

CoAP：专为物联网而生的轻量级通信协议

在物联网的世界里，设备往往“精打细算”——内存有限、电量紧张，网络环境也可能时好时坏。针对这种资源受限的场景，CoAP协议应运而生。它是一种专为物联网设计的轻量级应用层协议，凭借其简单的二进制消息格式、高效的数据传输机制和原生的RESTful架构，让设备在低带宽、高延迟甚至不可靠的网络中也能顺畅通信。

哪些公司使用Californium？

作为一款成熟的CoAP协议Ja va实现，Eclipse Californium在工业界得到了广泛采用。看看这份名单，你就知道它的分量了：

科技巨头与工业领袖： Intel在其物联网平台中集成了Californium来提供CoAP支持；IBM则利用它来为物联网和边缘计算解决方案实现高效的数据传输；老牌工业巨头西门子，也在其物联网方案中使用Californium来连接低功耗设备。

制造业与通信领域： Bosch Rexroth用它来支撑工业物联网应用中的设备通信；芯片制造商Infineon Technologies将其集成到嵌入式系统中；电信设备商爱立信，在其物联网平台里也采用了Californium来确保设备间通信的效率。

解决方案与工具链： Texas Instruments直接为开发者提供了基于Californium的开发套件和示例代码；电力自动化专家ABB Ltd.在智能制造方案中用它实现数据交换；而网络设备领导者Cisco Systems，则在其物联网平台上依赖Californium来达成低延迟、可靠的设备通信。

Californium的特点

为什么这些行业领导者都选择了Californium？看看它这些“看家本领”就明白了：

轻量级： 核心设计极度精简，天生适合运行在资源紧张的设备上。

可靠传输： 完整支持CoAP的四种消息类型——需要确认的(CON)、无需确认的(NON)、复位(RST)和应答(ACK)，确保了不同场景下的通信可靠性。

多播支持： 允许向一组设备同时发送请求，这对设备群组管理来说是关键功能。

观察机制： 客户端可以“订阅”某个资源，服务器会在资源状态变化时主动推送更新，实现了高效的实时数据监测。

安全性： 支持基于DTLS的加密，为数据传输提供了安全保障。

RESTful架构： 直接使用GET、POST、PUT、DELETE这些HTTP语义，使得与现有Web服务的集成变得异常简单。

Californium的核心组件

要上手Californium，先得熟悉它的几个核心“积木”：

CoapClient： 用来构建CoAP客户端，负责发送请求并处理来自服务器的响应。

CoapServer： 用来构建CoAP服务器，负责监听并处理客户端发来的各种请求。

CoapResource： 用于定义服务器上的资源。每个资源对应一个特定的URI路径，并处理到达该路径的请求。

CoapExchange： 它封装了一次请求-响应的完整上下文，让你在处理具体业务逻辑时，能方便地访问请求信息和发送响应。

代码实操

理论说再多，不如动手搭一个。下面我们用一个Spring Boot项目，快速构建一个具备设备管理功能的CoAP服务器。首先，引入必要的依赖：

    org.springframework.boot
    spring-boot-starter-web



    org.eclipse.californium
    californium-spring-boot-starter-server
    2.6.0



    org.springframework.boot
    spring-boot-starter-data-jpa



    mysql
    mysql-connector-ja va
    runtime

application.properties

# MySQL 数据库配置
spring.datasource.url=jdbc:mysql://localhost:3306/iot_db?useSSL=false&serverTimezone=UTC
spring.datasource.username=root
spring.datasource.password=rootpassword
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

# Hibernate 配置
spring.jpa.hibernate.ddl-auto=update
spring.jpa.show-sql=true
spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL8Dialect

Device实体类

我们需要一个实体来映射数据库中的设备表：

package com.example.coapserver.entity;

import ja vax.persistence.Entity;
import ja vax.persistence.GeneratedValue;
import ja vax.persistence.GenerationType;
import ja vax.persistence.Id;

@Entity
public class Device {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id; // 设备ID，自增主键
    private String deviceId; // 设备唯一标识符
    private String type; // 设备类型
    private double temperature; // 温度数据
    private boolean active; // 设备是否激活

    // 此处省略了标准的Getter和Setter方法
    ...
}

仓库接口

通过JPA仓库接口，我们可以方便地操作设备数据：

package com.example.coapserver.repository;

import com.example.coapserver.entity.Device;
import org.springframework.data.jpa.repository.JpaRepository;

public interface DeviceRepository extends JpaRepository {
    Device findByDeviceId(String deviceId); // 根据设备ID查找设备
}

Controller

这里是业务逻辑的核心，一个控制器同时处理HTTP和CoAP请求：

package com.example.coapserver.controller;

// 导入省略...

@RestController
@CoapController
@RequestMapping(“/api”)
public class SensorDataController {
    private static final Logger logger = LoggerFactory.getLogger(SensorDataController.class);

    @Autowired
    private DeviceRepository deviceRepository;

    private ConcurrentHashMap sensorDataMap = new ConcurrentHashMap<>();
    private AtomicInteger observeCounter = new AtomicInteger(0);

    // HTTP接口：注册新设备
    @PostMapping(“/register”)
    public ResponseEntity registerDevice(@RequestBody Device device) {
        if (deviceRepository.findByDeviceId(device.getDeviceId()) != null) {
            return new ResponseEntity<>(“设备已注册”, HttpStatus.BAD_REQUEST);
        }
        device.setActive(true);
        deviceRepository.sa ve(device);
        logger.info(“注册设备: {}”, device.getDeviceId());
        return new ResponseEntity<>(“设备注册成功”, HttpStatus.CREATED);
    }

    // CoAP接口：更新传感器数据 (PUT请求)
    @CoapPutMapping(“/sensors/{sensorId}”)
    public void updateSensorData(@PathVariable String sensorId, byte[] payload) {
        String dataStr = new String(payload);
        try {
            double data = Double.parseDouble(dataStr);
            Optional deviceOpt = Optional.ofNullable(deviceRepository.findByDeviceId(sensorId));
            if (deviceOpt.isPresent()) {
                Device device = deviceOpt.get();
                device.setTemperature(data);
                deviceRepository.sa ve(device);
                sensorDataMap.put(sensorId, data);
                logger.info(“收到传感器 {} 的数据: {}”, sensorId, data);
                checkAndAlert(sensorId, data); // 检查是否触发警报
                observeCounter.incrementAndGet(); // 触发观察者通知
            } else {
                logger.warn(“未知的传感器ID: {}”, sensorId);
            }
        } catch (NumberFormatException e) {
            logger.error(“传感器 {} 的数据格式无效: {}”, sensorId, dataStr);
        }
    }

    // CoAP接口：获取传感器数据 (GET请求)
    @CoapGetMapping(“/sensors/{sensorId}”)
    public String getSensorData(@PathVariable String sensorId) {
        return sensorDataMap.getOrDefault(sensorId, “无数据”).toString();
    }

    // CoAP接口：提供一个可观察的资源，用于订阅变化
    @CoapObserveRelation
    @CoapGetMapping(“/observe”)
    public String observeSensors() {
        int count = observeCounter.get();
        logger.info(“观察传感器，计数器: {}”, count);
        return String.valueOf(count); // 返回计数器值以触发观察者通知
    }

    // HTTP接口：获取所有设备
    @GetMapping(“/devices”)
    public List getAllDevices() {
        return deviceRepository.findAll();
    }

    // 私有方法：高温警报检查
    private void checkAndAlert(String sensorId, double temperature) {
        if (temperature > 30.0) {
            logger.warn(“高温警报：传感器 {} 的温度为 {}°C”, sensorId, temperature);
            // 此处可集成邮件、信息等报警通知
        }
    }
}

Application

最后，标准的Spring Boot应用启动类：

package com.example.coapserver;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class CoapServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(CoapServerApplication.class, args);
    }
}

测试

服务搭好了，怎么验证它是否正常工作呢？最直接的方式就是使用Californium自带的命令行工具（CF-CLI）来模拟设备发送请求。这个工具可以从Californium的GitHub仓库（https://github.com/eclipse/californium）获取并编译，安装过程非常简单。

更新传感器数据

我们尝试用PUT请求向传感器`sensor1`上报温度值25.5：

cf-cli put coap://localhost:5683/api/sensors/sensor1 --payload “25.5”

如果一切正常，你将看到类似以下的响应，其中“2.04 Changed”代表更新成功：

Sending PUT request to coap://localhost:5683/api/sensors/sensor1
Response from coap://localhost:5683/api/sensors/sensor1:
Code: 2.04 Changed
Payload:

获取传感器数据

接着，我们用GET请求查询一下刚才上报的数据：

cf-cli get coap://localhost:5683/api/sensors/sensor1

成功的响应会直接返回数据内容，并标明内容格式为文本：

Sending GET request to coap://localhost:5683/api/sensors/sensor1
Response from coap://localhost:5683/api/sensors/sensor1:
Code: 2.05 Content
Options: [Content-Format:text/plain]
Payload: 25.5

看到这里，一个具备设备注册、数据上报、状态查询甚至简单警报功能的CoAP服务器框架就已经搭建完成了。通过这个例子，你应该能感受到，借助Californium这样成熟的库，在物联网领域实现高效、轻量的设备通信，并没有想象中那么复杂。