cloudamqp/lavinmq

LavinMQ 镜像概述

LavinMQ 是一款实现 AMQP 0-9-1 协议的消息队列服务器，采用 Crystal 语言编写。其核心设计目标是提供高性能、低内存占用、支持超长队列和大量并发连接，同时仅需最小化配置。适用于各类需要可靠消息传递的应用场景。

核心功能和特性

• 协议兼容：完全实现 AMQP 0-9-1 标准协议，兼容所有标准 AMQP 客户端
• 高性能：优化的消息处理机制，提供高吞吐量
• 低资源消耗：内存占用低，适合资源受限环境
• 强大的扩展性：支持超长队列存储和大量并发客户端连接
• 简化运维：最小化配置需求，易于部署和维护
• 管理界面：内置 Web 管理 UI，方便监控和操作队列

使用场景和适用范围

LavinMQ 适用于需要消息队列的各类场景，尤其适合：

• 对性能和资源效率有高要求的消息传递系统
• 需要处理大量并发连接的分布式应用架构
• 运行超长队列且服务器资源有限的环境
• 追求简化配置和维护成本的中小型项目

使用方法和配置说明

基本运行命令

通过以下命令拉取并运行最新版 LavinMQ 镜像：

sh
docker run --rm -it -P -v /var/lib/lavinmq:/tmp/amqp cloudamqp/lavinmq

参数说明：

• --rm：容器退出后自动清理容器文件
• -it：启用交互式终端模式
• -P：随机映射容器端口到主机
• -v /var/lib/lavinmq:/tmp/amqp：挂载主机目录以持久化存储消息数据

服务访问方式

• 管理界面：运行后通过 http://localhost:15672 访问 Web 管理 UI
• AMQP 连接：使用 amqp://guest:guest@localhost 地址进行消息发布和消费

调试方法

在 Linux 环境下，可使用 perf 工具进行性能跟踪与分析：

跟踪系统调用

查看进程的系统调用情况：

sh
perf trace -p $(pidof lavinmq)

实时函数调用分析

获取进程中调用频率最高的函数实时统计：

sh
perf top -p $(pidof lavinmq)

内存垃圾回收诊断

内存垃圾回收问题可通过 https://github.com/ivmai/bdwgc/blob/master/docs/README.environment 进行诊断。

多平台客户端支持

LavinMQ 兼容所有 AMQP 客户端库，以下是主流平台的使用指南：

1. Ruby
2. Node.js
3. Java
4. Python
5. PHP
6. Crystal

参考信息

问题反馈

• GitHub Issues：https://github.com/cloudamqp/lavinmq/issues

获取帮助

• Slack 社区：[***]
• Stackoverflow：使用 lavinmq 标签提问
• CloudAMQP 用户支持：***

官方文档

• 快速入门指南：[***]