mqtt5-wasm

MQTT v5.0 and v3.1.1 WebAssembly client and broker for browser environments.

Features

• WebSocket transport - Connect to remote MQTT brokers via ws:// or wss://
• In-tab broker - Run a complete MQTT broker in the browser
• MessagePort/BroadcastChannel - Inter-tab and worker communication
• Broker bridging - Connect multiple in-browser brokers via MessagePort
• Full QoS support - QoS 0, 1, and 2 with proper acknowledgment
• Shared subscriptions - Load balancing across multiple subscribers
• Event callbacks - Connection, disconnect, and error event handlers
• Automatic keepalive - Connection health monitoring with timeout detection
• Will messages - Last Will and Testament (LWT) support

Installation

npm (browser/bundler)

npm install mqtt5-wasm

Cargo (Rust)

[dependencies]
mqtt5-wasm = "0.7"

Build with wasm-pack:

wasm-pack build --target web --features client,broker

Usage

Basic Example

import init, { WasmMqttClient } from "mqtt5-wasm";

await init();
const client = new WasmMqttClient("browser-client");

await client.connect("wss://broker.example.com:8084/mqtt");

await client.subscribe_with_callback("sensors/#", (topic, payload) => {
  console.log(`${topic}: ${new TextDecoder().decode(payload)}`);
});

await client.publish("sensors/temp", new TextEncoder().encode("25.5"));

await client.disconnect();

Event Callbacks

const client = new WasmMqttClient("browser-client");

client.on_connect((reasonCode, sessionPresent) => {
  console.log(`Connected: reason=${reasonCode}, session=${sessionPresent}`);
});

client.on_disconnect(() => {
  console.log("Disconnected from broker");
});

client.on_error((error) => {
  console.error(`Error: ${error}`);
});

await client.connect("wss://broker.example.com:8084/mqtt");

In-Browser Broker

import init, { WasmBroker, WasmMqttClient } from "mqtt5-wasm";

await init();

const broker = new WasmBroker();
const port = broker.create_client_port();

const client = new WasmMqttClient("local-client");
await client.connect_message_port(port);

Documentation

See the main repository for complete documentation and examples.

License

Licensed under either of Apache License, Version 2.0 or MIT license at your option.