php-amqplib/php-amqplib

Features

• AMQP Protocol Clients - Implements the AMQP protocol client to allow PHP applications to communicate with message brokers.
• Durable Queue Definitions - Provides the ability to create durable and exclusive queues that survive broker restarts.
• Delivery Acknowledgements - Implements a handshake protocol requiring explicit confirmation signals before messages are removed from the broker.
• Message Routing - Implements routing logic to distribute messages from publishers to one or many consumers using federation rules.
• Server-Pushed Message Streams - Enables the broker to stream messages to the client as they arrive without requiring constant polling.
• Message Rejections - Allows consumers to reject failed messages, triggering either a discard or a return to the queue for reprocessing.
• Queue Declarations - Allows programmatic definition and creation of queues with specific durability and exclusivity settings.
• RabbitMQ Publishers - Provides capabilities for sending authenticated byte arrays to named RabbitMQ queues.
• Queue and Exchange Orchestration - Manages the structural relationship and routing logic between message exchanges and specific queues.
• Broker Disk Persistence - Sets message delivery modes that write data to disk, ensuring messages survive a broker restart.
• RabbitMQ Integrations - Provides a comprehensive PHP implementation for producing and consuming messages through RabbitMQ brokers.
• TCP Socket Clients - Establishes raw TCP socket clients to transmit binary data streams between the application and messaging host.
• Message Acknowledgement Handlers - Provides explicit and automatic message acknowledgement handlers to control message removal from the broker.
• Message Delivery Guarantees - Ensures reliable message transmission using explicit acknowledgments and data replication across clusters.
• Consumption Models - Supports multiple message consumption models, including push-based subscriptions and pull-based polling.
• Exchange-Based Routing - Provides routing via specialized exchange types including direct matching, broadcast fanout, and pattern-based topics.
• Binary Frame Serialization - Translates high-level message objects into binary frames for efficient network transmission via the AMQP protocol.
• Virtual-Host Isolation - Implements isolation of users and queues into separate virtual host environments within a single broker.
• Asynchronous Task Processing - Offloads heavy computational work to background workers via a message broker to maintain application responsiveness.
• Batch Publishing - Optimizes network throughput by grouping multiple messages for a single exchange and routing key.
• Decoupled Communication Services - Connects decoupled services through a standardized messaging protocol to exchange data without direct dependencies.
• Consumer Prefetch Limits - Balances worker workloads by capping the number of unacknowledged messages a consumer can receive.
• Remote Procedure Calls - Implements mechanisms for executing functions on remote servers via request-response patterns over RabbitMQ queues.
• Virtual Channel Multiplexing - Simulates multiple independent communication sessions over a single TCP connection to reduce system resource overhead.
• Asynchronous Service Decoupling - Uses queues to prevent producers from blocking while waiting for consumers to process data.
• Event-Driven Architectures - Enables the construction of reactive systems that route events to multiple independent consumers.
• Integrated Event Storage and Streaming - Supports appending events to persistent streams that can be read and sought independently by multiple consumers.
• Connection Heartbeats - Manages periodic heartbeats using signal triggers to verify server responsiveness and keep connections alive.
• Request Correlation Tokens - Uses unique correlation identifiers to link asynchronous responses back to their original requests for RPC patterns.

Star history