JMS的一些代码.docVIP

JMS的一些代码 文章分类:Java编程 通过这里的例子，可以把消息进行分组，然后进行分组的方式进行发送出去，即相当于不同级别的用户可以收取到不同的消息 现在对于消息的基于推的方式还没有想明白，即服务器向客户端推送消息还不是太明白 监听的方式是可以实现，但这是必须先运行接收端 在发送端代码可以使用 producer.send(message); producer.send(message, Message.DEFAULT_DELIVERY_MODE, Message.DEFAULT_PRIORITY, Message.DEFAULT_TIME_TO_LIVE); 在接收端则可以使用consumer.setMessageListener(this);consumer.receive();consumer.receive(Long Timeout); 第一个例子是发布订阅者的例子，使用了选择器(选择器的选择是通过发布者里设置的属性来进行的) 这里使用了Tomcat里的JNDI,使用了ActiveMQ,但在程序里是使用标准来进行编写的，和具体使用的何种MQ没有关系，更换MQ，只需更改JNDI，当然这里没有涉及到分布式的问题，貌似分布式还需要使用JTA的xa吧 发送消息代码：  Java代码 ? package?com.test; ?? ?? import?javax.jms.*; ?? import?javax.naming.*; ?? ?? public?class?TestSendSelectorMain{ ?? ?? ?? ????/** ? ?????*?如果客户端需要接收主题上所有发布的消息，包括那些订阅者不活动期间发布的消 ? ????息，那么就要使用持久化的TopicSubscriber.持久化的TopicSubscriber可以被Session或者被 ? ????TopicSession创建。JMS保持这个持久化订阅的记录并且确保所有来自于主题发布者的消息 ? ????都会被保持到被持久化订阅者确认，或者过期。? ? ?????*/?? ????public?void?sendMessage()????{ ?? ????????try?{ ?? ????????????InitialContext?initCtx?=?new?InitialContext(); ?? ????????????Context?envContext?=?(Context)initCtx.lookup(java:comp/env); ?? ????????????ConnectionFactory?connectionFactory?=?(ConnectionFactory)envContext.lookup(jms/ConnectionFactory); ?? ????????????Connection?connection?=?connectionFactory.createConnection(); ?? ????????????Session?session?=?connection.createSession(false,?1); ?? ????????????MessageProducer?producer?=?session.createProducer((Destination)envContext.lookup(jms/topic/MyTopic)); ?? ????????????Message?testMessage?=?session.createMessage(); ?? ????????????//设置所需传输的属性，可以使用选择器进行选择 ?? ????????????testMessage.setStringProperty(testKey,?testValue); ?? ????????????testMessage.setStringProperty(JMSXGroupID,?QS_10/3/11); ?? ????????????testMessage.setJMSType(car); ?? ????????????producer.send(testMessage); ?? ????????????System.out.println(Send?End); ?? ????????}?catch(NamingException?e)??{ ?? ????????????System.out.println(NamingException); ?? ????????????e.printStackTrace(); ?? ????????}?catch(JMSExcepti