soarname/nsq

镜像概述

soarname/nsq是NSQ实时分布式消息系统的分支镜像。NSQ旨在支持大规模消息处理，每日可处理数十亿条消息，采用分布式无单点故障拓扑，确保容错性与高可用性，并提供可靠的消息投递保障。

核心功能

• 分布式无单点故障：避免单点失效，提升系统稳定性
• 高可用性与容错：支持节点故障自动恢复
• 可靠消息投递：确保消息不丢失（基于配置）
• 易配置部署：所有参数通过命令行指定，编译后的二进制无运行时依赖
• 数据格式无关：支持JSON、MsgPack、Protocol Buffers等任意数据格式
• 多语言客户端：官方提供Go、Python库，同时支持多种第三方客户端库

使用场景

• 实时数据处理：如日志流、用户行为分析
• 微服务间通信：解耦服务依赖，提升系统可扩展性
• 事件驱动架构：触发异步任务（如邮件发送、通知推送）
• 大规模消息队列：处理高并发消息场景（如秒杀活动、实时订单处理）

配置说明

NSQ的所有配置参数通过命令行指定，无需额外配置文件。关键参数示例：

• --tcp-address: TCP监听地址（默认0.0.0.0:4150）
• --http-address: HTTP监听地址（默认0.0.0.0:4151）
• --lookupd-tcp-address: 连接NSQ Lookup服务的地址

部署示例

Docker Run 单节点

启动NSQd消息节点：

bash
docker run -d --name nsqd -p 4150:4150 -p 4151:4151 soarname/nsq /nsqd --broadcast-address=192.168.1.100 --lookupd-tcp-address=192.168.1.101:4160

Docker Compose 集群

yaml
version: '3'
services:
  nsqlookupd:
    image: soarname/nsq
    command: /nsqlookupd
    ports:
      - "4160:4160"
      - "4161:4161"
  nsqd:
    image: soarname/nsq
    command: /nsqd --lookupd-tcp-address=nsqlookupd:4160 --broadcast-address=nsqd
    depends_on: [nsqlookupd]
    ports:
      - "4150:4150"
      - "4151:4151"
  nsqadmin:
    image: soarname/nsq
    command: /nsqadmin --lookupd-http-address=nsqlookupd:4161
    depends_on: [nsqlookupd]
    ports:
      - "4171:4171"