A C++ MQTT Message Broker for the Enterprise
summary
A C++ MQTT broker is implemented as a single Linux daemon written in C++14 with template metaprogramming, using a custom thread pool of std::packaged_task, asynchronous I/O, move semantics and a socket acceptor policy to parse MQTT 3.1.1 fixed and variable headers byte by byte. It enforces connection state via an exchange state machine, supports connect/subscribe/publish flows, and is a research prototype not yet performance tested or distributed so heavy payloads and high concurrency remain unproven single process design 65 KB string limit.
AI-written summary · about
chapters (23)
- 0:00Intro
- 0:16Questions
- 1:49Agenda
- 5:29About me
- 7:03Messaging overview
- 13:50Enterprise messaging
- 15:30Architecture
- 16:51Protocol
- 17:14Protocol Requirements
- 20:23Message Types
- 21:00Internet of Things
- 23:23Use Case
- 24:11Transport Connect
- 24:44Basic abstractions
- 28:57Component design
- 31:51Process scaling
- 32:33Demon policy
- 33:03Configuration
- 33:31Linux
- 34:49Network Service
- 36:16Response Strategy
- 37:41Exchange
- 41:17Question
related talks
49mOpen Source MQTT Brokers
41mScaling IoT and Web messaging infrastructure for fun and profit: An Introduction to Eclipse Amlen
38mScaling Financial Transaction using 0MQ and JSON
54mMQTT Deep Dive: With Berries, Morse and a Drone [zero PowerPoint]
01h 19mBackporting C++ Safety
24mReplacing legacy message queueing solutions with RabbitMQ
40mThe Knights Who Say NIO: SwiftNIO in Depth
31mEclipse Amlen: Pub/Sub messaging for ALL the Things