eclipse-paho/paho.mqtt.java
Paho.mqtt.java
这是一个 Java 消息开发工具包，旨在促进应用与消息代理之间的实时数据交换。它作为一个 MQTT 客户端库，提供了在分布式系统和物联网环境中实现发布/订阅消息模式所需的工具。
该库通过专注于弹性网络连接和可靠的消息传递脱颖而出。它通过内部状态机管理持久连接，处理自动重连和心跳保活，确保在网络不稳定的环境中保持稳定性。应用可以配置特定的服务质量（QoS）级别以保证数据完整性，范围从“至多一次”到“恰好一次”传递，并利用“遗嘱”（Last Will and Testament）配置来管理意外的客户端断开连接。
该框架利用非阻塞异步通信原语支持高吞吐量数据处理。它使开发者能够通过基于主题的订阅（包括通配符模式）路由消息，并通过基于令牌的句柄跟踪单个操作的进度。该库作为标准的 Java 开发工具包分发，可集成到更广泛的消息传递和物联网基础设施中。
Features
- MQTT Clients - Implements the MQTT protocol for publishing and subscribing to messages with configurable delivery quality.
- MQTT Messaging Integrations - Enables bidirectional data exchange and real-time communication between Java applications and MQTT brokers.
- Topic-Based Messaging - Implements a publish-subscribe messaging pattern that routes data to specific topics for real-time exchange between applications and brokers.
- Topic Subscription Management - Manages subscriptions to specific messaging topics, including support for wildcard patterns to receive real-time data streams.
- IoT Frameworks - Provides a toolkit for building connected devices and backend systems requiring reliable data transmission.
- MQTT Broker Connections - Establishes persistent TCP connections to MQTT brokers for bidirectional data exchange.
- Asynchronous Messaging Clients - Supports non-blocking communication tasks to handle high-volume or high-latency data transfers.
- Bidirectional Socket Communication - Maintains persistent bidirectional data streams over TCP sockets for real-time broker communication.
- Device Communication Protocols - Facilitates reliable data pipelines for sensor updates and remote command execution on internet-connected devices.
- Connection Management - Maintains stable network sessions through automatic reconnection and keep-alive signals.
- Message Delivery Guarantees - Ensures data integrity by configuring specific delivery guarantees for messages between publishers and subscribers.
- Exactly-Once Delivery Guarantees - Provides configurable delivery guarantees including fire-and-forget, acknowledged delivery, and exactly-once processing.
- Topic Routing Patterns - Routes incoming data streams to application handlers by matching topics against registered subscription patterns and wildcards.
- Connection Resilience Layers - Maintains stable communication sessions through automatic reconnection logic and keep-alive signals in unstable network environments.
- Publish-Subscribe Systems - Implements flexible publish-and-subscribe patterns for sending data to topics and receiving real-time updates.
- Reliability Levels - Manages message persistence and acknowledgment handshakes to ensure specific delivery guarantees.
- Real-Time Message Push - Ships a development kit for integrating real-time message exchange into Java applications via persistent connections.
- Protocol State Machines - Tracks session states and manages automatic reconnection and keep-alive heartbeats through internal state machines.
- Asynchronous Task Processing - Offloads messaging tasks to background threads to maintain application responsiveness during high-volume data processing.
- Event-Driven Callbacks - Implements non-blocking listener patterns to notify applications of incoming messages and connection status changes.
