solace/pubsubplus-processor-message-transformer

Solace PubSub+ Micro集成消息处理器

Solace Corporation [***]

版本：1.4.11
版本日期：2025-07-11

目录

• 概述
• 快速开始
  • 前提条件
  • 使用方法
  • 连接主机上的服务
  • 配置健康检查
• 提供配置
• 端口
• 卷
  • 卷：Spring配置文件
  • 卷：库
  • 卷：类路径文件
  • 卷：输出文件
• 配置JVM
  • 支持
• 许可证

概述

Solace PubSub+ Micro集成消息处理器用于在不同的Solace队列或主题端点之间移动和转换数据，是微集成场景下的消息处理组件。

快速开始

发布说明

前提条件

• Docker 或 Podman
• PubSub+ 事件代理
• Solace

使用方法

连接主机上的服务

若服务（如PubSub+事件代理）在本地主机公开，可通过容器平台的特殊DNS名称结合SOLACE_JAVA_HOST引用，该名称解析为主机使用的内部IP地址。

Docker示例：

bash
docker run -d --name my-connector \
  -v `pwd`/libs/:/app/external/libs/:ro \
  -v `pwd`/config/:/app/external/spring/config/:ro \
  --env SOLACE_JAVA_HOST=host.docker.internal:55555 \
  solace/pubsubplus-processor-message-transformer:1.4.11

Podman示例：

bash
podman run -d --name my-connector \
  -v `pwd`/libs/:/app/external/libs/:ro \
  -v `pwd`/config/:/app/external/spring/config/:ro \
  --env SOLACE_JAVA_HOST=host.containers.internal:55555 \
  solace/pubsubplus-processor-message-transformer:1.4.11

配置健康检查

健康检查可执行以下任务：

• 通过SOLACE_CONNECTOR_SECURITY_USERS_0_NAME和SOLACE_CONNECTOR_SECURITY_USERS_0_PASSWORD创建名为healthcheck的只读用户
• 使用该用户轮询容器健康端点，不健康时检查失败

Docker健康检查示例：

bash
docker run -d --name my-connector \
  -v `pwd`/libs/:/app/external/libs/:ro \
  -v `pwd`/application.yml:/app/external/spring/config/application.yml:ro \
  --env SOLACE_CONNECTOR_SECURITY_USERS_0_NAME=healthcheck \
  --env SOLACE_CONNECTOR_SECURITY_USERS_0_PASSWORD=healthcheck \
  --healthcheck-command="curl -X GET -u healthcheck:healthcheck --fail localhost:8090/actuator/health" \
  solace/pubsubplus-processor-message-transformer:1.4.11

Podman健康检查示例：

bash
podman run -d --name my-connector \
  -v `pwd`/libs/:/app/external/libs/:ro \
  -v `pwd`/application.yml:/app/external/spring/config/application.yml:ro \
  --env SOLACE_CONNECTOR_SECURITY_USERS_0_NAME=healthcheck \
  --env SOLACE_CONNECTOR_SECURITY_USERS_0_PASSWORD=healthcheck \
  --healthcheck-command="curl -X GET -u healthcheck:healthcheck --fail localhost:8090/actuator/health" \
  solace/pubsubplus-processor-message-transformer:1.4.11

提供配置

可通过以下方式提供Spring配置属性：

1. 使用环境变量
2. 使用包含Spring配置文件的卷

端口

容器需暴露以下端口：

卷

支持以下目录的卷和绑定挂载：

卷：Spring配置文件

用于添加Spring配置文件（如application.yml），需挂载为只读卷到/app/external/spring/config/。连接器启动时自动从以下位置加载配置：

1. /app/external/spring/config/根目录
2. /app/external/spring/config/直接子目录

提示：多环境配置建议使用Spring Boot配置文件（如application-prod.yml），而非子目录结构。

卷：库

用于添加外部Java库依赖（JAR文件），需挂载为只读卷到/app/external/libs/。仅在使用特定功能（如Prometheus指标导出）时需要。详细信息见ZIP包中libs目录文档。

卷：类路径文件

用于添加非JAR库和非配置文件的任意文件，需挂载为只读卷到/app/external/classpath/。

注意：此目录不得包含JAR文件或Spring配置文件，避免配置冲突。

卷：输出文件

用于支持文件输出功能（如日志文件），需挂载为读写卷到/app/external/output/。

重要：生成文件的功能必须配置为输出到此目录，其他路径不受支持。

配置JVM

通过设置容器的JDK_JAVA_OPTIONS环境变量配置JVM。详细信息见JDK文档。

提示：容器已使用以下配置测试：

• 2个活动处理器（-XX:ActiveProcessorCount=2）
• 最大堆内存2GB（-Xmx2048m）

支持

通过Solace开发者社区提供尽力支持，高级支持选项请联系Solace。

许可证

本项目根据Solace社区许可证1.0版授权，详见容器/licenses目录下的LICENSE文件。