# iotcloud

**Repository Path**: zhongjack/iotcloud

## Basic Information

- **Project Name**: iotcloud
- **Description**: iotcloud 物联网云端管理系统
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2025-08-31
- **Last Updated**: 2025-09-02

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# IoT Cloud - 南向MQTT接口实现

这是一个使用Go语言实现的IoT南向MQTT接口，基于[github.com/eclipse/paho.mqtt.golang](https://github.com/eclipse/paho.mqtt.golang)库开发。

## 项目结构

- `main.go` - 主程序入口，演示如何使用南向服务
- `south/mqtt/mqtt_client.go` - MQTT客户端的封装实现
- `iot_southbound.go` - IoT南向服务的核心实现
- `go.mod` - Go模块定义文件

## 功能特性

1. **MQTT客户端管理**
   - 连接和断开MQTT代理服务器
   - 主题订阅和取消订阅
   - 消息发布
   - 自动重连机制

2. **设备管理**
   - 设备上线/下线管理
   - 设备属性更新
   - 设备状态查询
   - 设备属性查询

3. **消息处理**
   - 设备数据接收和处理
   - 设备命令下发
   - 自定义消息处理器注册

## 快速开始

### 前提条件

- Go 1.21或更高版本
- 运行中的MQTT代理服务器（如Mosquitto、EMQX等）

### 安装依赖

```bash
go mod tidy
```

### 运行程序

```bash
# 确保MQTT代理服务器在localhost:1883端口运行
# 然后运行程序
go run .
```

## 使用示例

### 1. 创建并启动南向服务

```go
// 创建IoT南向服务实例，连接到MQTT代理服务器	southbound := NewSouthboundService("tcp://localhost:1883")

// 启动南向服务
if err := southbound.Start(); err != nil {
    log.Printf("Failed to start southbound service: %v\n", err)
}
// 确保程序退出时关闭服务
defer southbound.Stop()
```

### 2. 注册自定义消息处理函数

```go
// 注册一个处理设备数据的自定义处理函数
southbound.RegisterHandler("devices/+/data", func(topic string, payload []byte) {
    log.Printf("Custom handler received message on topic %s: %s\n", topic, payload)
    // 在这里处理接收到的设备数据
})
```

### 3. 向设备发送命令

```go
// 构建命令参数
cmdParams := map[string]interface{}{
    "interval": 10, // 例如，设置设备上报间隔为10秒
}

// 发送命令到指定设备
err := southbound.SendCommand("device-1", "set_config", cmdParams)
if err != nil {
    log.Printf("Failed to send command: %v\n", err)
}
```

### 4. 查询设备状态和属性

```go
// 获取设备状态
status, exists := southbound.GetDeviceStatus("device-1")
if exists {
    log.Printf("Device-1 status: %s\n", status)
}

// 获取设备属性
properties, exists := southbound.GetDeviceProperties("device-1")
if exists {
    log.Printf("Device-1 properties: %v\n", properties)
}
```

## MQTT主题设计

该实现使用以下主题结构进行设备通信：

- `devices/{deviceID}/connect` - 设备连接主题
- `devices/{deviceID}/disconnect` - 设备断开连接主题
- `devices/{deviceID}/data` - 设备上报数据主题
- `devices/{deviceID}/response` - 设备响应主题
- `devices/{deviceID}/commands` - 下发命令主题

## 注意事项

1. 在实际部署时，请确保MQTT代理服务器的安全性，配置适当的认证和授权机制
2. 对于大规模部署，考虑增加消息队列、数据库存储等组件来提高系统的可扩展性和可靠性
3. 生产环境中应添加更完善的错误处理和日志记录机制

## 扩展建议

1. 添加设备认证和授权功能
2. 实现数据持久化存储
3. 开发Web管理界面
4. 添加设备固件升级功能
5. 实现消息加密和安全传输