{"id":9129,"date":"2023-01-14T09:05:41","date_gmt":"2023-01-14T01:05:41","guid":{"rendered":"http:\/\/123.57.164.21\/?p=9129"},"modified":"2023-03-15T17:26:03","modified_gmt":"2023-03-15T09:26:03","slug":"apache-camel-%e5%92%8cibm-mq%e7%9a%84tips","status":"publish","type":"post","link":"https:\/\/92it.top\/?p=9129","title":{"rendered":"Apache Camel \u548cIBM MQ\u7684Tips"},"content":{"rendered":"\n

Apache Camel \u53ef\u4ee5\u5f88\u65b9\u4fbf\u7684\u548cIBM MQ\u8fdb\u884c\u901a\u4fe1\uff0c\u4e0b\u9762\u662f\u4e00\u4e9bTips\u3002<\/p>\n\n\n\n

1.IBM MQ \u5b89\u88c5<\/strong><\/p>\n\n\n\n

\n\n\n\n

Docker\u5b89\u88c5IBM MQ\uff08\u6ce8\u610f \u955c\u50cf\u4e0d\u652f\u6301M1\u82af\u7247\u7684Mac\uff09<\/p>\n\n\n\n

#\u4e0b\u8f7d \u955c\u50cf\n docker pull ibmcom\/mq:9.2.4.0-r1\n\n#\u8fd0\u884c\u5bb9\u5668\n docker run  --name ibmmq -p 1414:1414  -p 9443:9443 -e LICENSE=accept  -e MQ_QMGR_NAME=QM1  -e MQ_APP_PASSWORD=passw0rd -d ibmcom\/mq:9.2.4.0-r1<\/pre>\n\n\n\n
2.IBM MQ\u306e\u7ba1\u7406\u9875\u9762<\/strong><\/p>\n\n\n\n
\n\n\n\n
https:\/\/ip host\u5730\u5740:9443\/ibmmq\nusername: admin\npassword: passw0rd<\/pre>\n\n\n\n
\"\"<\/figure><\/div>\n\n\n\n
\"\"<\/figure><\/div>\n\n\n\n
3.Camel Maven\u5de5\u7a0b IBM MQ Pom\u5bfc\u5165<\/strong><\/p>\n\n\n\n
\n\n\n\n
<dependency>\n    <groupId>org.apache.camel<\/groupId>\n    <artifactId>camel-jms<\/artifactId>\n    <scope>provided<\/scope>\n<\/dependency>\n<dependency>\n    <groupId>com.ibm.mq<\/groupId>\n    <artifactId>com.ibm.mq.allclient<\/artifactId>\n    <version>9.1.0.5<\/version>\n<\/dependency><\/pre>\n\n\n\n
\"\"<\/figure><\/div>\n\n\n\n
4.Camel \u5de5\u7a0b\u4e2d Spring DSL (XML) Sample<\/strong><\/p>\n\n\n\n
\n\n\n\n
<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n<beans xmlns=\"http:\/\/www.springframework.org\/schema\/beans\"\n    xmlns:xsi=\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\"\n    xsi:schemaLocation=\"\n        http:\/\/www.springframework.org\/schema\/beans http:\/\/www.springframework.org\/schema\/beans\/spring-beans.xsd\n        http:\/\/camel.apache.org\/schema\/spring http:\/\/camel.apache.org\/schema\/spring\/camel-spring.xsd\">\n\n    <!-- \u30b3\u30f3\u30c6\u30ad\u30b9\u30c8\u5b9a\u7fa9 -->\n    <bean id=\"mqConnectionFactory\" class=\"com.ibm.mq.jms.MQConnectionFactory\">\n        <property name=\"hostName\" value=\"123.57.164.21\" \/>\n        <property name=\"port\" value=\"1414\" \/>\n        <property name=\"queueManager\" value=\"QM1\" \/>\n        <property name=\"channel\" value=\"DEV.APP.SVRCONN\" \/>\n        <property name=\"transportType\" value=\"1\" \/>\n        <property name=\"shareConvAllowed\" value=\"0\" \/>\n    <\/bean>\n\n    <bean id=\"mqcredential\" class=\"org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter\">\n        <property name=\"targetConnectionFactory\"\n            ref=\"mqConnectionFactory\" \/>\n        <property name=\"username\" value=\"app\" \/>\n        <property name=\"password\" value=\"\" \/>\n    <\/bean>\n\n    <bean id=\"mq\" class=\"org.apache.camel.component.jms.JmsComponent\">\n        <property name=\"connectionFactory\" ref=\"mqcredential\" \/>\n        <property name=\"maxConcurrentConsumers\" value=\"1\" \/>\n        <property name=\"cacheLevelName\" value=\"CACHE_CONSUMER\" \/>\n    <\/bean>\n\n    <!-- \u30b3\u30f3\u30c6\u30ad\u30b9\u30c8\u5b9a\u7fa9 -->\n    <routeContext id=\"route-1\"\n        xmlns=\"http:\/\/camel.apache.org\/schema\/spring\">\n        <!-- \u30e1\u30a4\u30f3 -->\n        <route id=\"mainroute-1\">\n            <!--  \u30e1\u30c3\u30bb\u30fc\u30b8\u306e\u8aad\u307f\u53d6\u308a  -->\n            <from uri=\"mq:queue:DEV.QUEUE.1\"\/>\n            <log loggingLevel=\"DEBUG\" message=\">>>${body}\" \/>\n            <!--  \u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u4fe1 -->\n            <to uri=\"mq:queue:DEV.QUEUE.2\"\/>\n        <\/route>\n    <\/routeContext>\n<\/beans>\n<\/pre>\n\n\n\n
5.\u4e00\u4e9b\u95ee\u9898<\/strong><\/p>\n\n\n\n
\n\n\n\n
JMSWMQ2013: \u4e3a\u961f\u5217\u7ba1\u7406\u5668\u201cQM1\u201d\u63d0\u4f9b\u7684\u5b89\u5168\u6027\u8ba4\u8bc1\u65e0\u6548\uff0c\u8fde\u63a5\u65b9\u5f0f\u4e3a\u201cClient\u201d\uff0c\u4e3b\u673a\u540d\u4e3a\u201c192.168.1.1(1415)\u201d\u3002 \u8bf7\u68c0\u67e5\u63d0\u4f9b\u7684\u7528\u6237\u540d\u548c\u5bc6\u7801\u5728\u60a8\u8fde\u63a5\u81f3\u7684\u961f\u5217\u7ba1\u7406\u5668\u4e2d<\/pre>\n\n\n\n
\u5982\u679c\u51fa\u73b0\u8fd9\u4e2a\u9519\u8bef\uff0cQM1 \u961f\u5217\u7ba1\u7406\u5668\u3002\u5173\u95edCHLAUTH\u8bb0\u5f55<\/p>\n\n\n\n
\"\"<\/figure><\/div>\n\n\n\n
JMSCMQ0001: WebSphere MQ \u8c03\u7528\u5931\u8d25\uff0c\u5b8c\u6210\u4ee3\u7801\u4e3a\u201c2\u201d\uff08\u201cMQCC_FAILED\u201d\uff09\uff0c\u539f\u56e0\u4e3a\u201c2035\u201d\uff08\u201cMQRC_NOT_AUTHORIZED\u201d\uff09\u3002<\/pre>\n\n\n\n
\u7528\u8fd9\u4e2aapp\u8d26\u6237\u53bb\u8fde\u63a5<\/p>\n\n\n\n
\"\"<\/figure><\/div>\n\n\n\n
    <bean id=\"mqcredential\" class=\"org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter\">\n        <property name=\"targetConnectionFactory\"\n            ref=\"mqConnectionFactory\" \/>\n        <property name=\"username\" value=\"app\" \/>\n        <property name=\"password\" value=\"\" \/>\n    <\/bean><\/pre>\n\n\n\n
6.\u8865\u5145Java DSL (Java\u8a00\u8a9e)sample<\/strong><\/p>\n\n\n\n
\n\n\n\n
IBM MQ<\/strong> provides these messaging and queuing capabilities across multiple modes of operation: point-to-point ; publish\/subscribe. You can easily integrate with this messaging provider by using the camel JMSComponent by setting the MQQueueConnectionFactory<\/strong> properties either in configuration or using Java DSL.<\/p>\n\n\n\n
Let\u2019s check how to write a Java DSL class which defines the JmsComponent<\/strong> named \u201cmq\u201d which takes the MQQueueConnectionFactory<\/strong> from Class variable:<\/p>\n\n\n\n
import org.apache.camel.component.jms.JmsComponent;\nimport org.slf4j.Logger;\nimport org.slf4j.LoggerFactory;\nimport org.springframework.beans.factory.annotation.Value;\nimport org.springframework.context.annotation.Bean;\nimport org.springframework.context.annotation.Configuration;\nimport org.springframework.context.annotation.Primary;\nimport org.springframework.jms.connection.CachingConnectionFactory;\nimport org.springframework.jms.connection.JmsTransactionManager;\nimport org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter;\nimport org.springframework.transaction.PlatformTransactionManager;\nimport org.springframework.transaction.annotation.EnableTransactionManagement;\nimport com.ibm.mq.jms.MQQueueConnectionFactory;\nimport com.ibm.msg.client.wmq.WMQConstants;\n@Configuration\n@EnableTransactionManagement\npublic class JmsConfiguration {\n  private static final Logger LOG = LoggerFactory.getLogger(JmsConfiguration.class);\n  private String host = \"localhost\";\n  private int port = 1414;\n  private String queueManager = \"QM1\";\n  private String channel = \"DEV.APP.SVRCONN\";\n  private String username = \"app\";\n  private String password = \"\";\n  private long receiveTimeout = 2000;\n  @Bean\n  public JmsComponent mq() {\n    JmsComponent jmsComponent = new JmsComponent();\n    jmsComponent.setConnectionFactory(mqQueueConnectionFactory());\n    return jmsComponent;\n  }\n  @Bean\n  public MQQueueConnectionFactory mqQueueConnectionFactory() {\n    MQQueueConnectionFactory mqQueueConnectionFactory = new MQQueueConnectionFactory();\n    mqQueueConnectionFactory.setHostName(host);\n    try {\n      mqQueueConnectionFactory.setTransportType(WMQConstants.WMQ_CM_CLIENT);\n      mqQueueConnectionFactory.setChannel(channel);\n      mqQueueConnectionFactory.setPort(port);\n      mqQueueConnectionFactory.setQueueManager(queueManager);\n    } catch (Exception e) {\n      LOG.error(e.getMessage(), e);\n    }\n    return mqQueueConnectionFactory;\n  }\n  @Bean\n  public UserCredentialsConnectionFactoryAdapter userCredentialsConnectionFactoryAdapter(\n      MQQueueConnectionFactory mqQueueConnectionFactory) {\n    UserCredentialsConnectionFactoryAdapter userCredentialsConnectionFactoryAdapter =\n        new UserCredentialsConnectionFactoryAdapter();\n    userCredentialsConnectionFactoryAdapter.setUsername(username);\n    userCredentialsConnectionFactoryAdapter.setPassword(password);\n    userCredentialsConnectionFactoryAdapter.setTargetConnectionFactory(mqQueueConnectionFactory);\n    return userCredentialsConnectionFactoryAdapter;\n  }\n  @Bean\n  @Primary\n  public CachingConnectionFactory cachingConnectionFactory(\n      UserCredentialsConnectionFactoryAdapter userCredentialsConnectionFactoryAdapter) {\n    CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory();\n    cachingConnectionFactory.setTargetConnectionFactory(userCredentialsConnectionFactoryAdapter);\n    cachingConnectionFactory.setSessionCacheSize(500);\n    cachingConnectionFactory.setReconnectOnException(true);\n    return cachingConnectionFactory;\n  }\n  @Bean\n  public PlatformTransactionManager jmsTransactionManager(\n      CachingConnectionFactory cachingConnectionFactory) {\n    JmsTransactionManager jmsTransactionManager = new JmsTransactionManager();\n    jmsTransactionManager.setConnectionFactory(cachingConnectionFactory);\n    return jmsTransactionManager;\n  }\n}<\/pre>\n\n\n\n
In order to use the JMSComponent<\/strong>, you can implement a simple Route like this:<\/p>\n\n\n\n
import org.apache.camel.builder.RouteBuilder;\nimport org.springframework.stereotype.Component;\n@Component\npublic class CamelRouteBuilder extends RouteBuilder {\n  public void configure() throws Exception {\n    from(\"timer:mytimer?period=5000\")\n        .routeId(\"generate-route\")\n        .transform(constant(\"HELLO from Camel!\"))\n        .to(\"mq:queue:DEV.QUEUE.1\");\n  }\n}<\/pre>\n","protected":false},"excerpt":{"rendered":"
Apache Camel \u53ef\u4ee5\u5f88\u65b9\u4fbf\u7684\u548cIBM MQ\u8fdb\u884c\u901a\u4fe1\uff0c\u4e0b\u9762\u662f\u4e00\u4e9bTips\u3002 1.IBM MQ \u5b89\u88c5 D […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[26,27],"tags":[],"_links":{"self":[{"href":"https:\/\/92it.top\/index.php?rest_route=\/wp\/v2\/posts\/9129"}],"collection":[{"href":"https:\/\/92it.top\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/92it.top\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/92it.top\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/92it.top\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=9129"}],"version-history":[{"count":10,"href":"https:\/\/92it.top\/index.php?rest_route=\/wp\/v2\/posts\/9129\/revisions"}],"predecessor-version":[{"id":9917,"href":"https:\/\/92it.top\/index.php?rest_route=\/wp\/v2\/posts\/9129\/revisions\/9917"}],"wp:attachment":[{"href":"https:\/\/92it.top\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=9129"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/92it.top\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=9129"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/92it.top\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=9129"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}