Amqp.node

amqp.node is a Node.js client and asynchronous messaging middleware designed for communicating with message brokers using the AMQP 0-9-1 protocol. It enables the creation of decoupled, event-driven architectures where independent components exchange data via queues and exchanges.

The library features a multiplexed channel manager that operates multiple logical communication streams over a single persistent connection. It includes stateful connection recovery tools that automatically restore broken network links and re-establish message consumers after service interruptions.

The implementation covers binary protocol framing, non-blocking asynchronous input and output operations, and a centralized error routing system that captures synchronous exceptions from event listeners.

Features

AMQP Protocol Clients - Provides a full AMQP protocol client for Node.js to manage connections and data exchange.
AMQP - Implements the AMQP 0-9-1 wire protocol for encoding and decoding messages.
Messaging Middleware - Acts as asynchronous messaging middleware for routing and processing streams in decoupled architectures.
Connection State Recovery - Tracks previous network state to automatically restore connections and re-establish message consumers.
Automatic Connection Recovery - Automatically detects broken communication channels and re-establishes them to maintain availability.
Event-Driven Architectures - Facilitates the creation of decoupled systems where components communicate via queues and exchanges.
Multiplexed Message Streams - Handles high-volume data streams using multiplexed channels and non-blocking I/O.
Binary Protocols - Implements binary framing for efficient data transmission and stream multiplexing.
Connection Multiplexing - Operates multiple logical communication channels over a single physical TCP connection.
Network Reliability - Ensures stable network links through automatic connection recovery and consumer restoration.
Non-Blocking Socket I/O - Uses non-blocking socket I/O to handle network communication without freezing the event loop.
Virtual Channel Multiplexing - Manages multiple logical streams over a single persistent AMQP connection via virtual channel multiplexing.
Task Queues - AMQP 0-9-1 client for RabbitMQ.

سجل النجوم

squaremoamqp.node

Name: squaremo/amqp.node
Author: squaremo

View on GitHub

3,845 نجوم470 تفرعاتJavaScript1 مشاهدةamqp-node.github.io/amqplib

Amqp.node

Features

AMQP Protocol Clients - Provides a full AMQP protocol client for Node.js to manage connections and data exchange.
AMQP - Implements the AMQP 0-9-1 wire protocol for encoding and decoding messages.
Messaging Middleware - Acts as asynchronous messaging middleware for routing and processing streams in decoupled architectures.
Connection State Recovery - Tracks previous network state to automatically restore connections and re-establish message consumers.
Automatic Connection Recovery - Automatically detects broken communication channels and re-establishes them to maintain availability.
Event-Driven Architectures - Facilitates the creation of decoupled systems where components communicate via queues and exchanges.
Multiplexed Message Streams - Handles high-volume data streams using multiplexed channels and non-blocking I/O.
Binary Protocols - Implements binary framing for efficient data transmission and stream multiplexing.
Connection Multiplexing - Operates multiple logical communication channels over a single physical TCP connection.
Network Reliability - Ensures stable network links through automatic connection recovery and consumer restoration.
Non-Blocking Socket I/O - Uses non-blocking socket I/O to handle network communication without freezing the event loop.
Virtual Channel Multiplexing - Manages multiple logical streams over a single persistent AMQP connection via virtual channel multiplexing.
Task Queues - AMQP 0-9-1 client for RabbitMQ.

بدائل مفتوحة المصدر لـ Amqp.node

مشاريع مفتوحة المصدر مشابهة، مرتبة حسب عدد الميزات المشتركة مع Amqp.node.

pika/pika
pika/pika
3,867عرض على GitHub
Pika is a Python client library for implementing communication between applications and message brokers using the AMQP 0-9-1 protocol. It serves as a toolkit for sending and receiving messages, specifically enabling the creation of producers and consumers that interact with RabbitMQ and other AMQP-compliant brokers. The library provides both an asynchronous messaging framework that integrates with external event loops for non-blocking data exchange and a procedural synchronous wrapper for performing messaging tasks without an asynchronous architecture. Its connection management toolkit inclu
Pythonamqp0-9-1clientpython
عرض على GitHub3,867
streadway/amqp
streadway/amqp
4,932عرض على GitHub
This is a Go client library and protocol implementation for interacting with message brokers using the AMQP 0.9.1 standard. It serves as an asynchronous messaging toolkit and message queue client for implementing producer and consumer patterns. The library provides a programmatic interface for managing the full message lifecycle, including publishing, consumption, and delivery acknowledgments. It supports reliable delivery mechanisms such as publishing confirmations and atomic transactions. The project covers the administration of routing topologies through the declaration and binding of que
Goamqpgoprotocol
عرض على GitHub4,932
php-amqplib/php-amqplib
php-amqplib/php-amqplib
4,597عرض على GitHub
php-amqplib is a PHP library that implements the AMQP protocol to enable communication between applications and message brokers. It provides the necessary tools to integrate PHP applications with RabbitMQ for sending and receiving messages across decoupled services. The library supports a wide range of messaging patterns, including asynchronous task processing, event-driven architectures, and remote procedure calls using correlation identifiers. It manages the full message lifecycle through publishing, queue declaration, and flexible consumption models using either push-based subscriptions or
PHPamqphacktoberfestmessaging
عرض على GitHub4,597
tokio-rs/mio
tokio-rs/mio
7,024عرض على GitHub
Mio is a low-level I/O library for Rust that provides an event-driven framework for monitoring multiple network sockets and file descriptors. It acts as a portable wrapper for operating system native polling systems, including epoll, kqueue, and IOCP, allowing applications to trigger events when resources are ready for reading or writing without blocking the execution thread. The library provides a non-blocking socket interface for managing TCP, UDP, and Unix sockets. It distinguishes itself through a vectored I/O implementation, enabling scatter-gather reads and writes across multiple buffer
Rustasynchronousnetworkingnon-blocking
عرض على GitHub7,024

عرض جميع البدائل الـ 30 لـ Amqp.node

الأسئلة الشائعة

ما هي وظيفة squaremo/amqp.node؟

ما هي الميزات الرئيسية لـ squaremo/amqp.node؟

الميزات الرئيسية لـ squaremo/amqp.node هي: AMQP Protocol Clients, AMQP, Messaging Middleware, Connection State Recovery, Automatic Connection Recovery, Event-Driven Architectures, Multiplexed Message Streams, Binary Protocols.

ما هي البدائل مفتوحة المصدر لـ squaremo/amqp.node؟

تشمل البدائل مفتوحة المصدر لـ squaremo/amqp.node: pika/pika — Pika is a Python client library for implementing communication between applications and message brokers using the AMQP… streadway/amqp — This is a Go client library and protocol implementation for interacting with message brokers using the AMQP 0.9.1… php-amqplib/php-amqplib — php-amqplib is a PHP library that implements the AMQP protocol to enable communication between applications and… tokio-rs/mio — Mio is a low-level I/O library for Rust that provides an event-driven framework for monitoring multiple network… y123456yz/reading-code-of-nginx-1.9.2 — This project is a detailed analysis and study of the Nginx source code, focusing on high-performance server… yuesong-feng/30daymakecppserver — This project is a C++ TCP server framework and educational socket programming guide. It provides a high-performance…