以太格

  • 首页

  • 分类

  • 归档

  • 标签

  • 公益 404

  • 关于我

Mqtt 序列:集群通信

发表于 2023-01-14 | 更新于 2023-01-15 | 分类于 MQTT
本文字数: 4.7k | 阅读时长 ≈ 4 分钟

每一个 MQTT 结点只负载了部分客户端,要实现消息在集群中不同客户端间的传递,必须要实现集群间的消息共享。本文便是介绍其中的实现方式。

阅读全文 »

Mqtt 序列:Subscription

发表于 2023-01-14 | 更新于 2023-01-15 | 分类于 MQTT
本文字数: 3.6k | 阅读时长 ≈ 3 分钟

在 Moquette 中使用类似 Trie(单词查找树) 的数据结构来实现 Topic 的匹配,本文主要介绍这种数据结构。

阅读全文 »

Mqtt 序列:Will

发表于 2023-01-01 | 更新于 2023-01-15 | 分类于 MQTT
本文字数: 3.1k | 阅读时长 ≈ 3 分钟

MQTT 提供了遗嘱 Will 功能,可以在终端异常下线时,向特定的 Will Topic 发送指定的 Will Message, 从而让第三方感知终端的异常下线。

阅读全文 »

Mqtt 序列:Retain Message

发表于 2023-01-01 | 更新于 2023-01-02 | 分类于 MQTT
本文字数: 6.5k | 阅读时长 ≈ 6 分钟

MQTT 可以设置 Topic Retain 消息,每当有新的订阅关系匹配时,所属的新终端便会收到该 Retain 消息。如果有需要在新建订阅时,推送一些初始化信息,可以使用该功能。

阅读全文 »

Mqtt 序列:Clean Session

发表于 2023-01-01 | 分类于 MQTT
本文字数: 1.2k | 阅读时长 ≈ 1 分钟

MQTT 可以设置是否持久化 Session 数据,这样可以保证终端断线之后重新上线可以恢复之前的 Session 数据。这个功能可以通过 Clean Session 设置。

阅读全文 »

Mqtt 序列:QoS

发表于 2022-12-31 | 更新于 2023-01-01 | 分类于 MQTT
本文字数: 12k | 阅读时长 ≈ 11 分钟

MQTT 协议提供了 3 种消息服务质量等级(Quality of Service),保证了在不同的网络环境下消息传递的可靠性。本文讲解这 3 种 QoS 的实现。

阅读全文 »

Mqtt 序列:MQTT 整体架构

发表于 2022-12-31 | 更新于 2023-01-01 | 分类于 MQTT
本文字数: 4k | 阅读时长 ≈ 4 分钟

参考现有一些厂商 MQTT Broker 的实现,发现大部分都要依赖于外部系统 MQ 来实现消息的存储或转发,MQTT Broker 仅用于终端的接入及协议的解析。在这种架构下,各结点可方便进行扩展,可应对大规模终端的接入。在小规模(几十万)的场景下,这个架构相对比较复杂。本文的目的主要是实现一个架构相对比较紧凑,且易于学习的 MQTT Broker 服务器,该服务器不用依赖于外部系统 MQ , 自带消息的集群路由功能。

阅读全文 »

Mqtt 序列:开篇

发表于 2022-12-18 | 更新于 2023-01-02 | 分类于 MQTT
本文字数: 1.2k | 阅读时长 ≈ 1 分钟

Mqtt 协议是物联网中用于设备接入的一个重要协议,该序列文章将介绍 Mqtt 协议相关的知识点,并在 Moquette 开源项目基础上实现一个集群版的 Mqtt 服务器。

阅读全文 »

Flink 系列:TopN 计算流程

发表于 2022-09-24 | 分类于 Flink
本文字数: 26k | 阅读时长 ≈ 24 分钟

这篇文章简要介绍 Flink TopN 计算流程。

阅读全文 »

Flink 系列:Connect

发表于 2022-09-17 | 更新于 2022-09-24 | 分类于 Flink
本文字数: 24k | 阅读时长 ≈ 22 分钟

这篇文章简要介绍 Flink 多流 Connect 操作。

阅读全文 »
12…11

Noahsark

不畏将来,不念过往

102 日志
28 分类
316 标签
© 2023 Noahsark | 311k | 4:43
粤ICP备 2021097726号-1 粤公网安备 44030702004132号
由 Hexo 强力驱动 v3.9.0
|
主题 – NexT.Mist v6.5.0