导入连接到 JMS MQ 的 SOAP 项目时如何在 java 项目中手动创建 Hermes 会话答案

【问题标题】：How to create Hermes session manually in a java project when importing a SOAP project that connects to a JMS MQ导入连接到 JMS MQ 的 SOAP 项目时如何在 java 项目中手动创建 Hermes 会话
【发布时间】：2017-01-01 09:22:37
【问题描述】：

我创建了一个与消息队列连接并向其发送 JMS 消息的 SoapUI 项目。为了与 MQ 连接，我使用了 SoapUI 提供的 HERMES 工具。目前我正在使用 Hermes v1.14。

我已经在 Hermes 端创建了所需的会话和适当的队列，并按照此处所示的步骤发送了 JMS 消息：https://www.soapui.org/documentation/jms/config.html, https://www.soapui.org/jms/working-with-jms-messages.html

这一切都很好。

现在我正在尝试将这个 SOAPUI 项目合并到一个 Java 项目中，我将在其中提供项目 XML 并运行所有必需的测试用例。我无法通过 Java 代码创建 HERMES 会话和队列等。下面是该类的一些代码 sn-ps。我在正确的道路上吗？寻找一些帮助来配置它。

TestRunner runner = null;
SoapUI.setSoapUICore(new StandaloneSoapUICore(true));
WsdlProject project = new WsdlProject("C:\\My Directory\\CustomerTest-soapui-project.xml");
List<TestSuite> suiteList = project.getTestSuiteList();

String defaultHermesJMSPath= HermesUtils.defaultHermesJMSPath();
System.out.println("defaultHermesJMSPath- "+defaultHermesJMSPath);

String soapUiHome = System.getProperty("soapui.home");
System.out.println("soapUiHome - "+soapUiHome);

//System.setProperty("soapui.home", "C:\\Program Files\\SmartBear\\SoapUI-5.2.1\\bin");

TestRunner runner = project.getTestSuiteByName("Private Individual").getTestCaseByName(
"TEST CASE CONTAINING GROOVY SCRIPT TEST STEPTHAT CONNECTS TO HERMES").run
(new PropertiesMap(), false);

输出：

defaultHermesJMSPath - null
soapuiHome - null

附：我为此包含了一些 JAR，它们是：

任何帮助将不胜感激。

【问题讨论】：

I am unable to configure the HERMES session manually via Java code - 令人困惑。手动还是自动？
嘿饶。让我编辑描述。通过手动，我的意思是通过 Java 代码创建 Hermes 会话和队列。我想使用 JAVA 运行独立于 SOAPUI 的 SOAP 项目。所以我不会使用 HERMES UI 来创建会话等。
你已经配置hermes-config.xml了吗？如果是这样，那么你真的不需要打扰。它应该能够自动执行测试。
@Rao 我在网上某处读到“hermes-config.xml”。好吧，我无法在我的任何安装文件夹或 m2 或任何地方找到该文件。请分享我能找到的确切地址。此外，一旦我找到它，我需要将它放在哪里以及如何配置它以便我的项目能够读取属性。请注意，我创建的只是一个 Java 项目，而不是一个 maven 项目，我可以在其中配置 pom.xml 并插入新的依赖项等。我只有一个简单的主类，我打算用它来运行我的 SOAP 项目。
这里是路径，SOAPUI_HOME/hermesJMS/cfg。但是你需要使用 SOAPUI 来配置它，通过发送一个 soap 消息来测试它。

标签： java jms soapui message-queue hermes-jms

【解决方案1】：

很简单，你应该创建临时队列来获得响应

    import javax.jms.*;
    import java.util.Enumeration;

    public class JMSExample5 {

protected static final String SERVICE_QUEUE = "QUEUE_NAME_THAT_IS_CREDTED_IN_SERVER_FOR_ACCEPTING";
static String serverUrl = "tcp://10.xxx.xxx.xxx:xxxxx";
static String userName = "UR_UserID";
static String password = "UR_Pass";

public static void sendTopicMessage(String topicName, String messageStr) {

    Connection connection = null;
    Session session = null;
    MessageProducer msgProducer = null;
    Destination destination = null;

    try {
        TextMessage msg;
        System.out.println("Publishing to destination '" + topicName
                + "'\n");
        ConnectionFactory factory = new com.tibco.tibjms.TibjmsConnectionFactory(serverUrl);
        connection = factory.createConnection(userName, password);
        connection.start();
        session = connection
                .createSession(false,javax.jms.Session.AUTO_ACKNOWLEDGE);
        TemporaryQueue tempQueue = session.createTemporaryQueue();

        TextMessage message_t = session.createTextMessage(messageStr);
        //This step is compulsory to get the reply from JMS server
        message_t.setJMSReplyTo(tempQueue);
        MessageProducer producer = session.createProducer(session.createQueue(SERVICE_QUEUE));
        producer.send(message_t);

        System.out.println("INFO::  The producer has sent the message"+message_t);
        Destination dest = tempQueue;

        MessageConsumer consumer = session.createConsumer(dest);
        Message replyMsg = consumer.receive();
        TextMessage tm = (TextMessage) replyMsg;
        System.out.println("INFO The response is "+ replyMsg);
        consumer.close();
        producer.close();
        session.close();
        connection.close();

    } catch (JMSException e) {
         System.out.println("Error :: there was exception"+e);
        e.printStackTrace();
    }
}

/*-----------------------------------------------------------------------
 * main
 *----------------------------------------------------------------------*/
public static void main(String[] args) {
    JMSExample5.sendTopicMessage(SERVICE_QUEUE,
            "<?xml version = \"1.0\" encoding = \"UTF-8\"?>\n" +
                    "<MYServices>\n" +
                    " <header>\n" +
                    "  <Version>1.0</Version>\n" +
                    "  <SrvType>OML</SrvType>\n" +
                    "  <SrvName>REQ_BALANCE_ENQUIRY</SrvName>\n" +
                    "  <SrcApp>BNK</SrcApp>\n" +
                    "  <OrgId>BLA</OrgId>\n" +
                    " </header>\n" +
                    " <body>\n" +
                    "  <srv_req>\n" +
                    "   <req_credit_card_balance_enquiry>\n" +
                    "    <card_no>12345678</card_no>\n" +
                    "   </req_credit_card_balance_enquiry>\n" +
                    "  </srv_req>\n" +
                    " </body>\n" +
                    "</MYServices>\n");
}

}

【讨论】：

【解决方案2】：

这个问题的主要关注点是制作一个最终独立于 HERMES GUI 的 SOAP 项目，以便配置会话、队列等。我最终所做的是我创建了我的 GROOVY 测试步骤中的 MQQueueConnectionFactory、QueueConnection、QueueSession、MQQueue、MQQueueSender、JMSTextMessage 对象并将 JMS 消息发送到队列。因此无需打开 Hermes UI 并在那里进行配置。下面是可以遵循的示例代码。

  def stringBuilder=context.expand('${CustomerXmlsAndCdbs#MasterXmlPrivateIndividual}');
  MQQueueConnectionFactory cf = new MQQueueConnectionFactory()
  cf.setHostName(context.expand('${#Project#HostName}'));
  cf.setPort(Integer.parseInt(context.expand('${#Project#Port}')))
  cf.setQueueManager(context.expand('${#Project#QueueManager}'))
  cf.setTransportType(Integer.parseInt(context.expand('${#Project#TransportType}')))
  QueueConnection queueConn = cf.createQueueConnection("retapp","retapp")
  QueueSession queueSession = queueConn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE)

  MQQueue queue = (MQQueue) queueSession.createQueue(context.expand('${#Project#QueueName}').toString())

  MQQueueSender sender = (MQQueueSender) queueSession.createSender(queue)
  JMSTextMessage message = (JMSTextMessage) queueSession.createTextMessage(stringBuilder.toString())
  sender.send(message)
  sender.close()
  queueSession.close()
  queueConn.close()

SoapUI Lib(\SoapUI-5.2.1\lib) 和 Hermes Lib 文件夹（ \SoapUI-5.2.1\hermesJMS\lib）：

com.ibm.dhbcore.jar、com.ibm.mq.jar、com.ibm.mq.pcf.jar、com.ibm.mqjms.jar、connector.jar、javax.transaction.jar

【讨论】：