【问题标题】:connecting to a remote JMS provider from a Message Driven Bean (MDB)从消息驱动 Bean (MDB) 连接到远程 JMS 提供程序
【发布时间】:2023-04-08 01:45:01
【问题描述】:

从部署在 Glassfish 上的 EJB 或 POJO,我可以使用以下代码连接到 HornetMQ,在我将必要的 hornet 特定 jar 添加到类路径之后:

Properties properties = new Properties();
  properties.put("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
  // server name
  properties.put("java.naming.provider.url", "jnp://hostname:1099");
  properties.put("java.naming.factory.url.pkgs", "org.jboss.naming:org.jnp.interfaces");

  InitialContext initialContext = new InitialContext(properties);
  // queue name
  Queue queue = (Queue)initialContext.lookup("/queue/exampleQueue");
  // connection factory
  ConnectionFactory connectionFactory = (ConnectionFactory) initialContext.lookup("ConnectionFactory");
  Connection conn = connectionFactory.createConnection();

  Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);

  conn.start();
    // ...

但我想通过消息驱动 Bean 做同样的事情。

如果我使用嵌入式 Glassfish 提供程序,则使用 MDB 非常容易;但是如何配置 GF 以使用远程提供程序?

有什么想法吗?谢谢!

编辑:让事情更清楚一点;典型的 MDB 如下所示:

@MessageDriven(mappedName = "/queue/exampleQueue", activationConfig =  {
        @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
    })
public class MessageProcessor implements MessageListener {

    public MessageProcessor() {
    }


    public void onMessage(Message message) {

    }
}

但在这种情况下,MDB 将在本地服务器而不是远程服务器上查找“/queue/exampleQueue”。

基本上我的问题是如何配置 GF 在使用 MDB 时查找远程服务器(如在第一个 sn-p 中)?

【问题讨论】:

  • @Preston,看看我的更新。

标签: java jakarta-ee jms glassfish-3


【解决方案1】:

经过一番挖掘,我在these forums找到了解决方案

要使 MDB 能够与远程 HornetQ 提供者“对话”,请执行以下步骤:

  • 使用管理控制台将hornetq-ra.rar 部署到 glassfish(您可以在 hornetq 文件夹的“libs”文件夹中找到它)
  • 找到<gf_install_dir>/domains/<your_dmain>/applications/hornetq-ra/META-INF/ra.xml并注释掉以下部分:

 <config-property>
     <description>The transport configuration. These values must be in the form of key=val;key=val;</description>
     <config-property-name>ConnectionParameters</config-property-name>
     <config-property-type>java.lang.String</config-property-type>
     <config-property-value>server-id=0</config-property-value>
  </config-property>

显然离开server-id 会导致部署时间异常。

  • 将以下jar复制到GF域lib文件夹:hornetq-core-client.jarhornetq-jms-client.jarhornetq-logging.jarnetty.jar
  • 为要与 HornetQ 一起使用的 MDB 创建一个 xml 描述符 (sun-ejb-jar.xml):

  <ejb-name>MessageProcessor</ejb-name> <!-- MDB class name -->
  <jndi-name>ExampleMDB</jndi-name>
  <mdb-resource-adapter>
    <!-- The resource adapter mid element ties the generic ra for JMS
        with this particular MDB -->
    <resource-adapter-mid>hornetq-ra</resource-adapter-mid>
    <activation-config>
      <activation-config-property>
        <activation-config-property-name>destinationType</activation-config-property-name>
        <activation-config-property-value>javax.jms.Queue</activation-config-property-value>
      </activation-config-property>
      <activation-config-property>
        <activation-config-property-name>destination</activation-config-property-name>
        <activation-config-property-value>/queue/exampleQueue</activation-config-property-value>
      </activation-config-property>
      <activation-config-property>
        <activation-config-property-name>ConnectorClassName</activation-config-property-name>
        <activation-config-property-value>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</activation-config-property-value>
      </activation-config-property>
      <activation-config-property>
        <activation-config-property-name>ConnectionParameters</activation-config-property-name>
        <activation-config-property-value>host=hostname;port=5445</activation-config-property-value>
      </activation-config-property>
<!--
      <activation-config-property>
        <activation-config-property-name>UserName</activation-config-property-name>
        <activation-config-property-value>user</activation-config-property-value>
      </activation-config-property>
      <activation-config-property>
        <activation-config-property-name>Password</activation-config-property-name>
        <activation-config-property-value>pass</activation-config-property-value>
      </activation-config-property>
-->
    </activation-config>
  </mdb-resource-adapter>
</ejb>
  • 假设您的 MDB 看起来像这样,您应该会收到消息:

@MessageDriven(mappedName = "ExampleMDB")
public class MessageProcessor implements MessageListener {

  public MessageProcessor() {
  }

  public void onMessage(Message message) {

    System.out.println("message received");

  }
}

【讨论】:

    【解决方案2】:

    您正在尝试配置远程 JMS 提供程序。这里有一篇好文章

    http://www.packtpub.com/article/configuring-jms-resources-in-glassfish-1

    但是,我不确定它是否适用于 HornetMQ,您可能必须使用 OpenMQ 的远程实例

    【讨论】:

    • 链接+1;恐怕这篇文章是针对GF2.1的; GF 3.0.1 中似乎没有任何通用资源适配器
    • 在连接工厂版本3的底部没有附加属性部分?那是您配置地址列表的地方。 “如果我们使用远程 JMS 代理,那么我们应该添加一个新属性——AddressList——并将值设置为以逗号分隔的主机:端口组合列表。”
    猜你喜欢
    • 1970-01-01
    • 2015-01-25
    • 1970-01-01
    • 2017-06-13
    • 1970-01-01
    • 2011-08-05
    • 2012-02-27
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多