Java 客户端监听 WebSphere MQ Server？

Question

我需要编写一个侦听 WebSphere MQ Server 的 Java 客户端。消息被放入服务器的队列中。

我开发了这段代码，但不确定它是否正确。如果正确的话我该如何测试呢？

这是一个独立的 Java 项目，没有应用程序服务器支持。我应该将哪些 jar 放入类路径中？

我有 MQ 设置，我应该将其放入代码中吗？标准JMS可以跳过这些设置吗？令人困惑....

import javax.jms.Destination;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueReceiver;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class Main {
    Context jndiContext = null;
    QueueConnectionFactory queueConnectionFactory = null;
    QueueConnection queueConnection = null;
    QueueSession queueSession = null;
    Queue controlQueue = null;
    QueueReceiver queueReceiver = null;

    private String queueSubject = "";

    private void start() {
        try {
            queueConnection.start();

            queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
            Destination destination = queueSession.createQueue(queueSubject);
            MessageConsumer consumer = queueSession.createConsumer(destination);
            consumer.setMessageListener(new MyListener());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private void close() {
        try {
            queueSession.close();
            queueConnection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private void init() {
        try {
            jndiContext = new InitialContext();
            queueConnectionFactory = (QueueConnectionFactory) this.jndiLookup("QueueConnectionFactory");
            queueConnection = queueConnectionFactory.createQueueConnection();
            queueConnection.start();
        } catch (Exception e) {
            System.err.println("Could not create JNDI API " + "context: " + e.toString());
            System.exit(1);
        }
    }

    private class MyListener implements MessageListener {
        @Override
        public void onMessage(Message message) {
            System.out.println("get message:" + message);
        }
    }

    private Object jndiLookup(String name) throws NamingException {
        Object obj = null;

        if (jndiContext == null) {
            try {
                jndiContext = new InitialContext();
            } catch (NamingException e) {
                System.err.println("Could not create JNDI API " + "context: " + e.toString());
                throw e;
            }
        }
        try {
            obj = jndiContext.lookup(name);
        } catch (NamingException e) {
            System.err.println("JNDI API lookup failed: " + e.toString());
            throw e;
        }
        return obj;
    }

    public Main() {

    }

    public static void main(String[] args) {
        new Main();

    }
}

MQ队列设置

     <queue-manager>
         <name>AAA</name>
         <port>1423</port>
         <hostname>ddd</hostname>
        <clientChannel>EEE.CLIENTS.00</clientChannel>
        <securityClass>PKIJCExit</securityClass>
         <transportType>1</transportType>
        <targetClientMatching>1</targetClientMatching>
 </queue-manager>
 <queues>
     <queue-details id="queue-1">
        <name>GGGG.NY.00</name>
        <transacted>false</transacted>
        <acknowledgeMode>1</acknowledgeMode>
        <targetClient>1</targetClient>
     </queue-details>
</queues>

Answer 1

有一篇文章包含示例代码 在 WebSphere 上运行独立的 Java 应用程序MQ V6.0 可引导您解决大部分问题，包括如何使用免费的 WMQ 试用安装进行测试。与 v7 或 v7.1 的主要区别（如评论中所述）是，如果您想使用主题，则无需启动代理组件。除此之外，本文应该可以在当前的 WMQ 客户端和/或服务器上正常工作。

此外，请参阅WebSphere MQ 使用 Java 手册（v7.0 客户端）或 使用适用于 Java 的 WebSphere MQ 类手册（v7.1客户端）为您的客户端提供适当的CLASSPATH和其他设置。请记住使用适合您的客户端版本而不是服务器版本的信息中心。您可以混合搭配客户端和服务器版本，但您只能获得服务器支持的功能。例如，将 WMQ v7.1 客户端与 WMQ v7.0 服务器一起使用是完全有效的。

最后，免费客户端下载提供了许多示例程序，它们完全符合您所描述的功能。有些使用 JNDI 来查找 WMQ 资源，其他则使用 Java 方法并且可以使用标准 Java 属性文件进行填充。带有 -nojndi 选项的内容展示了如何在运行时在代码中初始化 WMQ 对象。这些位于

[WMQ Install path]\tools\wmqjava\samples

最新 Windows 客户端安装 (SupportPac MQC71) 下。您还可以使用 v7.0 客户端 (SupportPac MQC7)。我建议使用示例来开始，而不是从头开始。为什么要重新发明轮子，对吧？

除了许多示例程序之外，供应商安装还包括所有必需的 jar 文件。请注意，CLASSPATH 中的内容因 WMQ 客户端版本而异，因此请参阅信息中心。更高版本要简单得多，只需要 CLASSPATH 中的几个 jar 文件。

如果您想要下载 WMQ 试用版进行测试并且没有管理员权限在 Windows 工作站上，您可以轻松地将其安装在 RedHat 或 SUSE 虚拟机上。通过一些操作，您还可以轻松地在 Ubuntu 上安装，如 Andy Piper 博客文章。

Answer 2

如果您可以选择，我建议您引入 Spring 框架来处理 JMS 通信。这样，您只需要编写业务逻辑，并将错误处理留给 Spring。

Spring JMS

下载最新的Spring JARS 并查看配置 DefaultMessageListenerContainer 为您应用。然后，您将使用 onMessage() 事件编写自己的 POJO（普通旧 Java 对象），每次新消息到达时都会调用该事件。

我发现本教程，您可以找到有用的开始

Answer 3

我用 JavaFx2 为 Windows 和 Mac osx 开发了一个小型客户端应用程序。它可以在 Source Forge (https://sourceforge.net/projects/mqconsole) 上找到。

您可以看到监听队列中新消息的示例。

该程序列出了队列、每个队列中的消息、查看消息的详细信息以及向队列发送消息并监听响应。

您可以查看代码、使用它并改进它。