JMS分为两个部分,一部分是应用程序接口,用于编写发送和接收消息的代码;另一部分是服务供应商接口(SPI),在服务供应商接口中可以插入Java消息服务驱动程序。JMS支持点对点和发布/订阅两种消息模式JMS消息服务编程模型:1.定位Java消息驱动程序。首先需要访问您所使用的特定的Java消息服务产品的驱动程序。可以通过查询使用JNDI的驱动程序来完成此任务,就如同使用JDBC一样。此驱动程序称为连接工厂。2.创建Java消息连接服务。Java消息连接与Java消息服务提供者的活动连接是相同的,管理低级的网络通信。可以使用连接工厂来获取连接。如果是在大规模的部署中,这样连接可能会在一组机器之间被负载平衡。3.创建Java消息服务会话。Java消息服务会话是当发送和接收消息的时候可以使用的辅助对象,它作为消息使用者和消息发送者的连接工厂,同时允许在事务中封装自己的消息,可以使用连接来获取会话。4.定位消息服务的目的地。Java消息服务目的地是发送消息或者接收消息所经过的通道。5.创建Java消息发送者或者使用者。如果希望发送消息,那么需要调用Java消息服务对象来传递消息,此对象被称为发送者。若要接收消息,需要调用Java消息服务对象来请求消息,此对象被称为使用者。可以使用会话和目的地来生成发生者和使用者。7.发送或者接收消息。如果需要生成消息,那么首先需要将消息集中起来。在实例化消息后,可以使用发生者来发送消息。JMS(发布/订购方式)//初始JNDIContext ctx=new InitialContext(System.getProperties());//通过JNDI连接工厂TopicConnectionFactory factory=(TopicConnectionFactory)ctx.lookup("javax.jms.TopicConnectionFactory");//使用连接工厂创建JMS连接TopicConnection connection=factory.createTopicConnection();//使用连接创建会话TopicSession session=connection.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);//通过JNDI查询目的地(主题)Topic topic=(Topic)ctx.lookup("testtopic");//创建消息发送者TopicPublisher publisher=session.createPublisher(topic);//创建文本消息,然后发布此文本消息TextMessage msg=session.createTextMessage();msg.setText("This is a test message.");publisher.publish(msg);
相关资源:敏捷开发V1.0.pptx