JMS

今天因为要写一个开发手册,把整个项目的构建看了一遍,大部分地方还能理解,只是没用过jms，所以去网上查了些资料。现在也只是了解了皮毛

只是知道JMS用于消息通讯,有一套自己的格式 主要有两种模型 一种点对点 一种发布者/订阅者 前者只有一个消费者后者可以有多个消费者

JMS主要有以下几个对象元素 1连接工厂 2JMS连接 3JMS会话 4JMS目的即消息源 5JMS生产者和消费者

建立MQ连接

ConnectionFactory cf = new ConnectionFactory();
cf.setProperty(ConnectionConfiguration.imqBrokerHostName, mqProp.getServerIp());
cf.setProperty(ConnectionConfiguration.imqBrokerHostPort, mqProp.getServerPort());
cf.setProperty(ConnectionConfiguration.imqDefaultUsername, mqProp.getUserName());
cf.setProperty(ConnectionConfiguration.imqDefaultPassword, mqProp.getPasswd());
cf.setProperty(ConnectionConfiguration.imqReconnectEnabled, mqProp.getReconnectEnabled());
cf.setProperty(ConnectionConfiguration.imqReconnectInterval, mqProp.getReconnectInterval());
connection = cf.createConnection();
connection.setClientID("ID-" + connection.hashCode());
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
queue = new com.sun.messaging.Queue(mqProp.getQueueName());
msgConsumer = session.createConsumer(queue);
connection.start();
isMqConn = true;
isStop = false;

获取数据

Message recvmsg = msgConsumer.receive(500);
TextMessage txtMsg = (TextMessage) recvmsg;

今天头有点炸 先记一下 以后再弄JMS JNDI