如何使用Java连接到MQ

-6

嘿，我想连接&发送字符串到MQ使用JAVA 我是新来的，所以你可以帮我解决这个问题。我只是想让连接&发送一个字符串多数民众赞成它。如何使用Java连接到MQ

我与我有关于MQ的以下信息。 JNDI名称： ABCDEFH 队列管理器： ABCDEFH 主机名或IP地址： ABCDEFH 端口： ABCDEFH 频道： ABCDEFH 传输类型： ABCDEFH

来源

2014-09-04 Amrinder Singh

你到目前为止尝试过什么？请阅读[我如何问一个好问题？]（http://stackoverflow.com/help/how-to-ask）。 – DavidPostill 2014-09-04 15:59:55

您使用的是什么样的MQ？你有API罐吗？ – llogiq 2014-09-04 16:00:27

欢迎来到StackOverflow。我建议你检查一下如何发布好问题的链接：http://stackoverflow.com/help/how-to-ask。不幸的是，你的帖子（目前的状态）不是问题，你只是要求提供代码。您可能会因此收到降价提议，而且没有人愿意为您编写代码。然而，如果你在尝试某些事情后遇到了特定的问题，那么很多人都乐意帮助你。 – user2221125 2014-09-04 16:01:35

有两种您可以使用不同的API来使用Java语言发送MQ消息。您可以使用MQ Classes for Java，您可以使用JMS API。

既然你提到了JNDI，我怀疑你是指JMS API。但是，我会为两者回答。你听起来像你想要一些示例代码。 IBM MQ产品为您提供了示例代码。

对于Java的MQ类，我建议你看看<wmq-installation-directory>\Tools\wmqjava\samples\MQSample.java--这是Java类的“Hello World”应用程序。

对于JMS接口，我建议你看看<wmq-installation-directory>\Tools\jms\samples\JmsProducer.java

来源

2014-09-19 15:29:21

您可以使用下面的代码有了一些变化：

1.更改主机，端口，通道，QNAME和qManager名称相应。

2.对于OpenOption，请使用MQC.MQOO_OUTPUT。

希望这会有所帮助。

//method to connect and send message to Mq 
public void mqSend(){ 
    try{ 

    //Create a Hashtable with required properties 
    Hashtable properties = new Hashtable<String, Object>(); 
    properties.put("hostname", host); 
    properties.put("port", port); 
    properties.put("channel", channel); 

    //Create a instance of qManager 
    MQQueueManager qMgr = new MQQueueManager(qManagerName, properties); 

    //Connect to the Queue 
    MQQueue queue = qMgr.accessQueue(qname, openOptions); 

    //Creating the mqmessage 
    MQMessage mqMsg = new MQMessage(); 
    mqMsg.writeString(//My Message); 

    MQPutMessageOptions pmo = new MQPutMessageOptions(); 

    queue.put(mqMsg,pmo); 

    queue.close(); 
    qMgr.disconnect(); 
    }catch(MqException mqEx){ 
    mqEx.printStackTrace(); 
    } 
}

注::请忽略错别字和格式化，因为我键入了使用手机。

来源

2018-01-17 18:40:41

如何使用Java连接到MQ

回答

相关问题