【亲测免费】 Mochi MQTT 服务器使用教程

1. 项目的目录结构及介绍

Mochi MQTT 服务器的目录结构如下：

mochi-mqtt/
├── cmd/
│   └── server/
│       └── main.go
├── config/
│   └── config.go
├── docs/
├── internal/
│   ├── auth/
│   ├── broker/
│   ├── config/
│   ├── metrics/
│   ├── persistence/
│   ├── protocol/
│   ├── session/
│   ├── system/
│   └── transport/
├── pkg/
│   ├── auth/
│   ├── broker/
│   ├── config/
│   ├── metrics/
│   ├── persistence/
│   ├── protocol/
│   ├── session/
│   ├── system/
│   └── transport/
├── scripts/
├── test/
├── .gitignore
├── Dockerfile
├── go.mod
├── go.sum
└── README.md

目录介绍

• cmd/: 包含主要的可执行文件。
  • server/: 包含服务器的启动文件 main.go。
• config/: 包含配置文件相关的代码。
• docs/: 包含项目的文档。
• internal/: 包含内部包，这些包不对外公开。
  • auth/: 认证相关代码。
  • broker/: MQTT 代理相关代码。
  • config/: 配置相关代码。
  • metrics/: 指标相关代码。
  • persistence/: 持久化相关代码。
  • protocol/: 协议相关代码。
  • session/: 会话相关代码。
  • system/: 系统相关代码。
  • transport/: 传输相关代码。
• pkg/: 包含对外公开的包。
  • 结构与 internal/ 类似，但这些包可以被其他项目引用。
• scripts/: 包含一些脚本文件。
• test/: 包含测试文件。
• .gitignore: Git 忽略文件。
• Dockerfile: Docker 配置文件。
• go.mod: Go 模块文件。
• go.sum: Go 模块校验文件。
• README.md: 项目说明文件。

2. 项目的启动文件介绍

项目的启动文件位于 cmd/server/main.go。这个文件负责启动 MQTT 服务器。

启动文件内容概述

package main

import (
    "log"
    "mochi-mqtt/config"
    "mochi-mqtt/internal/broker"
)

func main() {
    cfg, err := config.LoadConfig()
    if err != nil {
        log.Fatalf("Failed to load config: %v", err)
    }

    b, err := broker.NewBroker(cfg)
    if err != nil {
        log.Fatalf("Failed to create broker: %v", err)
    }

    if err := b.Start(); err != nil {
        log.Fatalf("Failed to start broker: %v", err)
    }
}

启动流程

1. 加载配置文件。
2. 创建 MQTT 代理实例。
3. 启动 MQTT 代理。

3. 项目的配置文件介绍

项目的配置文件相关的代码位于 config/config.go。这个文件定义了如何加载和解析配置文件。

配置文件内容概述

package config

import (
    "encoding/json"
    "os"
)

type Config struct {
    ListenAddress string `json:"listen_address"`
    LogLevel      string `json:"log_level"`
    // 其他配置项
}

func LoadConfig() (*Config, error) {
    file, err := os.Open("config.json")
    if err != nil {
        return nil, err
    }
    defer file.Close()

    var cfg Config
    decoder := json.NewDecoder(file)
    if err := decoder.Decode(&cfg); err != nil {
        return nil, err
    }

    return &cfg, nil
}

配置文件示例

{
    "listen_address": "0.0.0.0