在ServiceMix Karaf中通过Camel-JMS连接EMS与IBM MQ的技术问询

一、IBM MQ 配置实现 #

在ServiceMix环境中，使用Camel-JMS对接IBM MQ需依赖IBM官方的MQ连接工厂，具体配置步骤如下：

1. 配置IBM MQ Connection Factory Bean #

定义IBM MQ专属连接工厂，核心参数包含队列管理器、主机地址、端口、通道名及认证信息：

<bean id="ibmMqConnectionFactory" class="com.ibm.mq.jms.MQConnectionFactory">
    <!-- Docker环境下用host.docker.internal替代localhost -->
    <property name="hostName" value="host.docker.internal"/>
    <property name="port" value="1414"/>
    <property name="queueManager" value="QM1"/>
    <property name="channel" value="DEV.ADMIN.SVRCONN"/>
    <property name="transportType" value="1"/> <!-- 1代表TCP/IP传输 -->
    <property name="userID" value="admin"/>
    <property name="password" value="passw0rd"/>
</bean>

2. 配置Camel JmsComponent #

将上述连接工厂注入JmsComponent，也可通过JmsConfiguration统一配置JMS层面的扩展参数：

<bean id="ibmMqTryout" class="org.apache.camel.component.jms.JmsComponent">
    <!-- 直接关联IBM MQ连接工厂 -->
    <property name="connectionFactory" ref="ibmMqConnectionFactory"/>
    <!-- 可选：通过JmsConfiguration统一配置并发数、超时等参数 -->
    <!-- <property name="configuration" ref="ibmMqJmsConfig"/> -->
</bean>

<!-- 可选：JMS配置Bean，用于统一管理JMS参数 -->
<bean id="ibmMqJmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
    <property name="connectionFactory" ref="ibmMqConnectionFactory"/>
    <property name="concurrentConsumers" value="5"/>
    <property name="receiveTimeout" value="30000"/>
</bean>

3. Camel路由示例 #

<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route id="ibm-mq-input">
        <from uri="ibmMqTryout:queue:INPUT.MQ.QUEUE"/>
        <!-- 消息处理逻辑 -->
        <to uri="ibmMqTryout:queue:OUTPUT.MQ.QUEUE"/>
    </route>
</camelContext>

二、EMS（TIBCO Enterprise Message Service）配置实现 #

EMS配置逻辑与ActiveMQ类似，使用TIBCO官方连接工厂，同时支持通过环境变量注入敏感配置（适配ServiceMix环境）。

1. 配置EMS Connection Factory（支持环境变量） #

利用Spring占位符${}读取环境变量或ServiceMix系统属性，实现配置解耦：

<bean id="emsConnectionFactory" class="com.tibco.tibjms.TibjmsConnectionFactory">
    <!-- Docker环境下的EMS地址，默认值为tcp://host.docker.internal:7222 -->
    <constructor-arg value="${EMS_BROKER_URL:tcp://host.docker.internal:7222}"/>
    <property name="userName" value="${EMS_USER:admin}"/>
    <property name="password" value="${EMS_PASSWORD:admin}"/>
</bean>

2. 配置Camel JmsComponent #

<bean id="emsComponent" class="org.apache.camel.component.jms.JmsComponent">
    <property name="connectionFactory" ref="emsConnectionFactory"/>
</bean>

3. ServiceMix中设置环境变量 #

有两种方式注入环境变量：

• 启动前导出变量：

  export EMS_BROKER_URL=tcp://host.docker.internal:7222
  export EMS_USER=admin
  export EMS_PASSWORD=admin
  ./bin/servicemix
  

• ServiceMix控制台设置系统属性：

  config:edit org.apache.felix.configadmin
  config:property-set EMS_BROKER_URL tcp://host.docker.internal:7222
  config:property-set EMS_USER admin
  config:property-set EMS_PASSWORD admin
  config:update
  

4. Camel路由示例 #

<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route id="ems-input">
        <from uri="emsComponent:queue:INPUT.EMS.QUEUE"/>
        <!-- 消息处理逻辑 -->
        <to uri="emsComponent:queue:OUTPUT.EMS.QUEUE"/>
    </route>
</camelContext>

三、ServiceMix环境依赖说明 #

需确保ServiceMix中已安装对应MQ的OSGi兼容bundle：

• IBM MQ：通过feature:install或bundle:install命令添加IBM MQ JMS客户端bundle
• EMS：安装TIBCO EMS提供的OSGi适配客户端bundle

内容的提问来源于stack exchange，提问作者Maciej Kajetan Chrzanowski