JMS一個小例子

JMS是一個由AS提供的Message服務。它能接受消息産生者(Message Provider)所發出的消息，并把消息轉發給消息消費者(Message Consumer)。

2、JMS提供2種類型的消息服務：(1)Queue，即點對點，每個消息隻轉發給一個消息消費者使用。(2)Topic，即釋出和訂閱，每個消息可以轉發給所有的訂閱者(消費者)。

3、WEBLOGIC 8下的JMS配置：

(1)配置JMS Connection Factory

(2)配置JMS File Store(目前所找到的文檔都是配置File Store,其實在具體的應用中，可能JMS JDBC Store更廣泛，但暫時沒有找到資料)

(3)配置JMS Server

(4)在JMS Server的destinations中配置JMS Queue或者JMS Topic

其中提供給消息産生者和消息消費者使用的是JMS Connection Factory的JNDI和JMS Queue或者JMS Topic的JNDI。

4、消息産生者向JMS發送消息的步驟：

(1)使用JNDI查詢對象JMS ConnectionFactory和Destination(JMS Queue/Topic)

(2)使用管理對象JMS ConnectionFactory建立連接配接Connection

(3)使用連接配接Connection 建立會話Session

(4)使用會話Session和管理對象Destination建立消息生産者MessageSender

(5)使用消息生産者MessageSender發送消息

一個消息發送者的例子：

Java代碼

package myjms;

import java.util.*;

import javax.naming.*;

import javax.jms.*;

public class MessageProducter {

public static void main(String[] args) {

String queueConnectionFactoryName = "myjmsconnectionfactory"; //JMS Connection Factory的JNDI

String queueName = "myjmsqueue"; //JMS Queue或者JMS Topic的JNDI

boolean transacted = false;//transaction模式

int acknowledgementMode = Session.AUTO_ACKNOWLEDGE;//acknowledgement模式

String message="Message need to send";//模拟需要發送的消息

Properties properties = new Properties();

properties.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");

properties.put(Context.PROVIDER_URL, "t3://localhost:7001");

try {

Context context = new InitialContext(properties);

Object obj = context.lookup(queueConnectionFactoryName);

QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory) obj;//JMS Connection Factory的獲得

obj = context.lookup(queueName);

Queue queue = (Queue) obj;//JMS Queue或者JMS Topic的獲得

QueueConnection queueConnection=queueConnectionFactory.createQueueConnection();//産生連接配接

queueConnection.start();

QueueSession queueSession = queueConnection.createQueueSession(transacted, acknowledgementMode);

TextMessage textMessage = queueSession.createTextMessage();

textMessage.clearBody();

textMessage.setText(message);

QueueSender queueSender = queueSession.createSender(queue);

queueSender.send(textMessage);

if (transacted) {

queueSession.commit();

}

if (queueSender != null) {

queueSender.close();

}

if (queueSession != null) {

queueSession.close();

}

if (queueConnection != null) {

queueConnection.close();

}

}

catch(Exception ex){

ex.printStackTrace();

}

}

}

package myjms;

import java.util.*;

import javax.naming.*;

import javax.jms.*;

public class MessageProducter {

public static void main(String[] args) {

String queueConnectionFactoryName = "myjmsconnectionfactory"; //JMS Connection Factory的JNDI

String queueName = "myjmsqueue"; //JMS Queue或者JMS Topic的JNDI

boolean transacted = false;//transaction模式

int acknowledgementMode = Session.AUTO_ACKNOWLEDGE;//acknowledgement模式

String message="Message need to send";//模拟需要發送的消息

Properties properties = new Properties();

properties.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");

properties.put(Context.PROVIDER_URL, "t3://localhost:7001");

try {

Context context = new InitialContext(properties);

Object obj = context.lookup(queueConnectionFactoryName);

QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory) obj;//JMS Connection Factory的獲得

obj = context.lookup(queueName);

Queue queue = (Queue) obj;//JMS Queue或者JMS Topic的獲得

QueueConnection queueConnection=queueConnectionFactory.createQueueConnection();//産生連接配接

queueConnection.start();

QueueSession queueSession = queueConnection.createQueueSession(transacted, acknowledgementMode);

TextMessage textMessage = queueSession.createTextMessage();

textMessage.clearBody();

textMessage.setText(message);

QueueSender queueSender = queueSession.createSender(queue);

queueSender.send(textMessage);

if (transacted) {

queueSession.commit();

}

if (queueSender != null) {

queueSender.close();

}

if (queueSession != null) {

queueSession.close();

}

if (queueConnection != null) {

queueConnection.close();

}

}

catch(Exception ex){

ex.printStackTrace();

}

}

}

5、消息消費者從JMS接受消息的步驟：

(1)使用JNDI查詢對象JMS ConnectionFactory和Destination(JMS Queue/Topic)

(2)使用管理對象JMS ConnectionFactory建立連接配接Connection

(3)使用連接配接Connection 建立會話Session

(4)使用會話Session和管理對象Destination建立消息消費者MessageReceiver

(5)使用消息消費者MessageReceiver接受消息，需要用setMessageListener将MessageListener接口綁定到MessageReceiver

消息消費者必須實作了MessageListener接口，需要定義onMessage事件方法。

一個消息消費者的例子：

Java代碼

package myjms;

import java.util.*;

import javax.naming.*;

import javax.jms.*;

public class MessageReciever

implements MessageListener {

public void onMessage(Message message) {

if (message instanceof TextMessage) {

TextMessage textMessage = (TextMessage) message;

try {

System.out.println("Message content is:" + textMessage.getText());

}

catch (JMSException e) {

e.printStackTrace();

}

}

}

public static void main(String[] args) {

MessageReciever msgRcvr=new MessageReciever();

String queueConnectionFactoryName = "myjmsconnectionfactory";

String queueName = "myjmsqueue";

boolean transacted = false;

int acknowledgementMode = Session.AUTO_ACKNOWLEDGE;

Properties properties = new Properties();

properties.put(Context.INITIAL_CONTEXT_FACTORY,

"weblogic.jndi.WLInitialContextFactory");

properties.put(Context.PROVIDER_URL, "t3://localhost:7001");

try {

Context context = new InitialContext(properties);

Object obj = context.lookup(queueConnectionFactoryName);

QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)

obj;

obj = context.lookup(queueName);

Queue queue = (Queue) obj;

QueueConnection queueConnection = queueConnectionFactory.

createQueueConnection();

queueConnection.start();

QueueSession queueSession = queueConnection.createQueueSession(transacted,

acknowledgementMode);

QueueReceiver queueReceiver = queueSession.createReceiver(queue);

queueReceiver.setMessageListener(msgRcvr);

synchronized(msgRcvr){

msgRcvr.wait(100000);

}

if (queueReceiver != null) {

queueReceiver.close();

}

if (queueSession != null) {

queueSession.close();

}

if (queueConnection != null) {

queueConnection.close();

}

}

catch (Exception ex) {

ex.printStackTrace();

}

}

}

package myjms;

import java.util.*;

import javax.naming.*;

import javax.jms.*;

public class MessageReciever

implements MessageListener {

public void onMessage(Message message) {

if (message instanceof TextMessage) {

TextMessage textMessage = (TextMessage) message;

try {

System.out.println("Message content is:" + textMessage.getText());

}

catch (JMSException e) {

e.printStackTrace();

}

}

}

public static void main(String[] args) {

MessageReciever msgRcvr=new MessageReciever();

String queueConnectionFactoryName = "myjmsconnectionfactory";

String queueName = "myjmsqueue";

boolean transacted = false;

int acknowledgementMode = Session.AUTO_ACKNOWLEDGE;

Properties properties = new Properties();

properties.put(Context.INITIAL_CONTEXT_FACTORY,

"weblogic.jndi.WLInitialContextFactory");

properties.put(Context.PROVIDER_URL, "t3://localhost:7001");

try {

Context context = new InitialContext(properties);

Object obj = context.lookup(queueConnectionFactoryName);

QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)

obj;

obj = context.lookup(queueName);

Queue queue = (Queue) obj;

QueueConnection queueConnection = queueConnectionFactory.

createQueueConnection();

queueConnection.start();

QueueSession queueSession = queueConnection.createQueueSession(transacted,

acknowledgementMode);

QueueReceiver queueReceiver = queueSession.createReceiver(queue);

queueReceiver.setMessageListener(msgRcvr);

synchronized(msgRcvr){

msgRcvr.wait(100000);

}

if (queueReceiver != null) {

queueReceiver.close();

}

if (queueSession != null) {

queueSession.close();

}

if (queueConnection != null) {

queueConnection.close();

}

}

catch (Exception ex) {

ex.printStackTrace();

}

}

}

6、Message-driven Bean

MDB實際上就是一個消息消費者的用戶端程式。它由AS EJB Container來管理。在JBUILDER生成一個MDB非常簡單。