J2EE组件开发 消息驱动的EJB

豆豆网   技术应用频道   2007年10月29日  【字号: 收藏本文

内容摘要:Java消息服务(Java Message Service,JMS)是一个Java API,它定义了消息的客户程序如何以一种标准化的形式与底层的消息服务提供者交互。JMS提供了一种接口,底层消息服务提供者通过该接口向客户程序提供JMS消息服务。

  QueueConnection接口是Connection接口的一种子类型,它代表着一个与JMS点对点消息队列服务的连接。JMS客户程序调用createQueueSession()方法创建QueueSession的实例,createQueueSession()方法调用中一个boolean类型的参数指定了QueueSession对象是否要提供事务支持。另外,回执的模式也在createQueueSession()调用中通过参数指定,这个参数的值可以是三个静态的标识符之一:AUTO_ACKNOWLEDGE,CLIENT_ACKNOWLED GE,DUPS_OK_ACKNOWLEDGE。

  QueueSession.createQueue()方法返回一个Queue对象的实例,调用Queue.getQueueName()方法可以返回队列的名字。

  QueueSession.createSender()方法创建一个QueueSender消息生产者,利用QueueSender可以把消息发送到Queue。消息可以通过各种不同的QueueSender.send()方法发送到Queue,这些不同的send()方法能够把消息发送给QueueSender对象关联的Queue对象,或者发送给send()方法调用中指定的Queue对象。消息递送模式、优先级、消息的有效时间都可以在调用QueueSender.send()方法时指定。

  发送给Queue的消息可以用Session接口中定义的各种消息构造方法创建。

  四、发布-订阅消息模式

  在一个支持发布-订阅消息模式的系统中JMS的基本体系结构。发布-订阅消息机制也是核心JMS机制的一种扩展,增加了一些适合发布-订阅消息模式的功能。连接工厂、连接、会话、消息生产者、消息消费者等都用发布-订阅形式的接口进行了扩展。

  JMS客户程序通过JNDI获得一个TopicConnectionFactory对象的引用。TopicConnectionFactory.createTopicConnection()方法用来创建TopicConnection对象的实例。调用createTopicConnection()方法时可以指定一个用户名字和密码,或者,我们也可以使用该方法不带参数的版本,此时假定使用默认用户身份。

责编:豆豆技术应用

正在加载评论...