ibmstocktrader/messaging

镜像概述

该镜像提供一个基于消息驱动Bean(MDB)实现的微服务，核心功能是监听JMS队列中的消息（由loyalty-level微服务放入队列），并调用通知服务发送推文或Slack频道消息。

核心功能与特性

• 消息驱动架构：基于JMS规范的消息驱动Bean(MDB)实现，自动监听指定JMS队列
• 消息响应机制：实时响应loyalty-level微服务发送到JMS队列的消息
• 多渠道通知：集成通知服务，支持发送推文(***)或Slack频道消息
• 松耦合设计：通过JMS队列与上游loyalty-level微服务解耦，提高系统弹性

使用场景与适用范围

适用于需要基于事件消息触发社交媒体通知的业务场景，例如：

• 用户忠诚度等级变更通知
• 系统关键事件实时提醒
• 业务流程状态更新推送
• 跨系统事件联动通知

使用方法与配置说明

环境变量配置

运行容器时需配置以下关键环境变量：

• JMS_QUEUE_NAME：监听的JMS队列名称（必填）
• JMS_BROKER_URL：JMS消息代理连接URL（必填，如tcp://activemq:61616）
• NOTIFICATION_CHANNEL：通知渠道类型，可选值：twitter（推文）或slack（Slack消息）（必填）
• SLACK_WEBHOOK：Slack Webhook URL（当NOTIFICATION_CHANNEL为slack时必填）
• TWITTER_API_KEY：*** API密钥（当NOTIFICATION_CHANNEL为twitter时必填）
• TWITTER_API_SECRET：*** API密钥（当NOTIFICATION_CHANNEL为twitter时必填）

Docker部署示例

基本运行命令

bash
docker run -d \
  -e JMS_QUEUE_NAME=loyalty-notifications \
  -e JMS_BROKER_URL=tcp://activemq:61616 \
  -e NOTIFICATION_CHANNEL=slack \
  -e SLACK_WEBHOOK=https://hooks.slack.com/services/XXXXX/XXXXX/XXXX \
  --name messaging-service \
  ibmstocktrader/messaging:latest

Docker Compose配置示例

yaml
version: '3'
services:
  messaging-service:
    image: ibmstocktrader/messaging:latest
    environment:
      - JMS_QUEUE_NAME=loyalty-notifications
      - JMS_BROKER_URL=tcp://activemq:61616
      - NOTIFICATION_CHANNEL=twitter
      - TWITTER_API_KEY=your_twitter_api_key
      - TWITTER_API_SECRET=your_twitter_api_secret
    depends_on:
      - activemq
  activemq:
    image: webcenter/activemq:latest
    ports:
      - "61616:61616"

源代码获取

完整源代码托管于GitHub：https://github.com/ibmstocktrader/messaging