urbanstore/goconsumer

镜像概述

urbanstore/goconsumer是基于Go语言开发的RabbitMQ消费者镜像，专为Urbanstore系统设计。它能订阅RabbitMQ中特定路由键的消息，并通过Docker Socket在其他容器执行命令，实现异步任务处理。

核心功能

1. 路由键消息订阅：绑定指定路由键，仅接收对应路由的消息
2. 灵活配置：通过环境变量设置RabbitMQ、ElasticSearch等服务地址
3. Docker交互：挂载Docker Socket后，可在其他容器执行指定命令
4. 异步场景支持：适用于日志存储、邮件发送、通知推送等异步任务

使用场景

• 日志异步处理：将日志消息写入文件或ElasticSearch
• 自动邮件通知：接收消息触发邮件发送任务
• 系统事件推送：通过RabbitMQ消息触发通知服务

配置说明

通过以下环境变量配置镜像：

• GC_AMQP：RabbitMQ地址，格式为amqp://用户名:密码@主机名:端口/
• GC_EXCHANGE：RabbitMQ交换机名称（默认main_exchange）
• GC_EXEC_DOCKERCONTAINER：执行命令的Docker容器名称（留空为独立运行）
• GC_EXEC_COMMAND：待执行命令（如php）
• GC_EXEC_BOOTSTRAPPATH：命令第一个参数（如PHP CLI应用路径）
• GC_EXEC_ACTION：命令第三个参数（如PHP CLI应用动作参数）
• GC_ELASTICSEARCHURL：ElasticSearch地址，格式为http://主机名:端口

Docker部署示例

单容器运行

bash
docker run -d \
  --name goconsumer \
  -v /var/run/docker.sock:/var/run/docker.sock:z \
  -e GC_AMQP="amqp://admin:123456@rabbitmq:5672/" \
  -e GC_EXCHANGE="main_exchange" \
  -e GC_EXEC_COMMAND="php" \
  -e GC_EXEC_BOOTSTRAPPATH="/var/www/app/cli.php" \
  -e GC_EXEC_ACTION="process_message" \
  -e GC_ELASTICSEARCHURL="http://elasticsearch:9200" \
  urbanstore/goconsumer

Docker Compose示例

yaml
version: '3'
services:
  goconsumer:
    image: urbanstore/goconsumer
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock:z
    environment:
      GC_AMQP: "amqp://admin:***@rabbitmq:5672/"
      GC_EXCHANGE: "main_exchange"
      GC_EXEC_COMMAND: "php"
      GC_EXEC_BOOTSTRAPPATH: "/var/www/app/cli.php"
      GC_EXEC_ACTION: "process_message"
      GC_ELASTICSEARCHURL: "[***]"
    depends_on:
      - rabbitmq
      - elasticsearch

  rabbitmq:
    image: rabbitmq:3-management
    ports:
      - "5672:5672"
      - "***:***"

  elasticsearch:
    image: elasticsearch:7.17.0
    ports:
      - "9200:9200"
    environment:
      - discovery.type=single-node