English | 简体中文

rmqtt-p2p-messaging

Peer-to-peer messaging plugin for RMQTT. Enables direct client-to-client message delivery over MQTT topics.

Overview

Provides a peer-to-peer messaging mechanism where one client can send messages directly to another specific client using a topic pattern that includes the target client ID. Messages are delivered only to the intended recipient client, not broadcast to all subscribers.

Topic Format

The plugin supports three modes for P2P topic format:

When a client publishes to a P2P topic (e.g., p2p/target-client-id/sensors/temp), the message is routed only to the client identified by target-client-id.

Usage

Add the dependency to Cargo.toml:

rmqtt-p2p-messaging = "0.22"

Register the plugin in your broker startup code:

rmqtt_p2p_messaging::register(&scx, true, false).await?;

Configuration

File: rmqtt-p2p-messaging.toml

Default Configuration

mode = "prefix"

Example: Publishing with prefix mode

Client A wants to send a message to Client B:

• Publish topic: p2p/Client-B/sensors/temp
• Content: { "temperature": 23.5 }
• Result: Only Client B receives the message on sensors/temp

Example: Publishing with suffix mode

mode = "suffix"

• Publish topic: sensors/temp/p2p/Client-B
• Content: { "temperature": 23.5 }
• Result: Only Client B receives the message

Example: Publishing with both modes

mode = "both"

Both prefix and suffix topic formats are recognized:

• p2p/Client-B/sensors/temp
• sensors/temp/p2p/Client-B

Dependencies

• rmqtt (feature plugin)

License

MIT OR Apache-2.0