Message Driven Beans на jBoss

1. Задача: создать Message Driven Bean (MDB) на jBoss и протестировать его.

2. Я пользовался самой последней версией jBoss и SDK 1.4.

3. Запускаем jBoss.
Прежде всего нужно зайти в ${JBOSSHOME}/ Server/default/deploy/jms, и в файле jbossmq-destinations-service.xml в самом первом mbean исправить строку

Код

<role name="publisher" read="true" write="true" create="false"/>

на

Код

<role name="publisher" read="true" write="true" create="true"/>

Далее запускаем run.**.

4. Пишем MDB.
Структура директории такая:

Код

..   META-INF/              jboss.xml              ejb-jar.xml   example/              MDB.java   MDBClient.java

5. MDB.java

Код

package example; import javax.ejb.*; import javax.jms.*; public class MDB implements MessageDrivenBean, MessageListener {     protected MessageDrivenContext ctx;          public void setMessageDrivenContext(MessageDrivenContext c)     {         this.ctx = c;     }          public void ejbCreate()     { }          public void onMessage(Message msg)     {         if (msg instanceof TextMessage)         {             TextMessage tm = (TextMessage) msg;             try             {                 String text = tm.getText();                 System.out.println("[RECEIVED MESSAGE] " + text);             }             catch (Exception e)             {                 e.printStackTrace();             }         }     }          public void ejbRemove()     { } }

Он предельно прост. Методу onMessage передается TextMessage, из которого извлекается текст и печатается в консоль сервера.

6. ejb-jar.xml

Код

<?xml version="1.0" encoding="UTF-8"?> <ejb-jar xmlns="http://java.sun.com/xml/ns/j2ee" version="2.1"  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  xsi:schemaLocation="http://java.sun.com/xml/nsj2ee http://java.sun.com/xml/ns/j2ee/ejb-jar_2_1.xsd"> <display-name>MDB</display-name> <enterprise-beans>     <message-driven>         <ejb-name>MDB</ejb-name>         <ejb-class>examples.MDB</ejb-class>         <messaging-type>javax.jms.MessageListener</messaging-type>         <transaction-type>Container</transaction-type>         <message-destination-type>javax.jms.Topic</message-destination-type>         <activation-config>                 <activation-config-property>                         <activation-config-property-name>                                 destinationType                         </activation-config-property-name>                         <activation-config-property-value>                                 javax.jms.Topic                         </activation-config-property-value>                     </activation-config-property>         </activation-config>     </message-driven>         </enterprise-beans> </ejb-jar>

Как видим, бин подписан на топик.

7. jboss.xml

Код

<jboss>      <enterprise-beans>          <message-driven>              <ejb-name>MDB</ejb-name>              <destination-jndi-name>topic/testTopic</destination-jndi-name>          </message-driven>      </enterprise-beans>  </jboss>

jboss.xml - специфический для провайдера (jBoss) файл, который указывает на топик, на который подписан наш бин. Это тестовый топик, см. jbossmq-destinations-service.xml.

8. Компилим, предварительно установив CLASSPATH (на винде нужен SET):
export CLASSPATH=:.:/jboss/client/jboss-j2ee.jar:/jboss/client/jbossall-client.jar

Пакуем бин:
jar cf MessageBean.jar *

9. Кидаем в директорию server/default/deploy

10. Здесь сервер должен сказать, что бин deployed.

11. Пишем клиента.

Код

import examples.*; import javax.naming.*; import java.util.*; import javax.jms.*; public class MDBClient {     public static void main(String[] args) throws Exception     {         Hashtable h = new Hashtable();         h.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");         h.put(Context.PROVIDER_URL, "jnp://localhost:1099");         h.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");         Context ctx = new InitialContext(h);         TopicConnectionFactory factory = (TopicConnectionFactory) ctx.lookup("java:/XAConnectionFactory");         TopicConnection conn = factory.createTopicConnection();         TopicSession session = conn.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);         Topic topic = (Topic) ctx.lookup("topic/testTopic");         TopicPublisher publisher = session.createPublisher(topic);         TextMessage msg = session.createTextMessage();         msg.setText("I'll meet you at midnight, Under the moonlight");         publisher.publish(msg);     } }

Здесь ничего особенного нет. Клиент - паблишер для топика, он идет по стандартной JMS схеме : найти TopicConnectionFactory -> создать соединение -> создать сессию -> создать паблишера для нужного топика -> создать мессагу -> опубликовать ее.
параметры jndi - стандартные для jBoss, параметры для нахождения TopicConnectionFactory и topic сидят в файле server/default/deploy/jms/jms-ds.xml.

12. Компилим и запускаем клиента. Сервер выдаст вот что:
10:14:14,957 INFO [STDOUT] [RECEIVED MESSAGE] I'll meet you at midnight, Under the moonlight


ЗЫ. Если не работает - сообщайте, мог ошибиться т.к. писал по памяти.

Немного не ясно как клиент общается с сервером. По особым протоколам, на особых портах, которые скоре всего закрыты файрволом или как?
И воторе, можно ли отсылать бинарники, т.е. что то типа BinaryDataMessage? Звыняюсь в ман не полез...

Цитата

Немного не ясно как клиент общается с сервером. По особым протоколам, на особых портах, которые скоре всего закрыты файрволом или как?

Вот тут и протокол, и порт

Цитата

jnp://localhost:1099

Цитата

И воторе, можно ли отсылать бинарники, т.е. что то типа BinaryDataMessage? Звыняюсь в ман не полез.

JMS определяет такие мессаги:
TextMessage, BytesMessage, StreamMessage, ObjectMessage, MapMessage

а где это можно применить, несколько примеров, где это оправдано

Там, где применяется MOM - Message Oriented Middleware, короче говоря, везде. Фактичecки, это то жe самое, что и RMI / TCP/IT/ датаграммы, только kоммуникация асинхронна, плюс необязательно чтобы работал получатель - в этом случае сервер сохраняет мессаги и передает получателю впоследствии.

Сделал всё по инструкции...

Вот тут, у клиента:


вот так ругается:


Что не так?

Это сообщение отредактировал(а) YuG - 6.3.2006, 17:50

А не прощели написать сервлет.Скачать jakarta HttpClient i посилать всё 4то угодно(взависимости от сервлета)

Да можно и сервлет не писать. Можно хоть УДП датаграмму.
Суть в том, что это:
во-первых - асинхронно(ты отправил месседж и всё. Его получат. Не надо ждать обработки сего месседжа чтоб продолжить выполнение кода далее)
во-вторых - надёжно, как для асинхронного... То есть... это как бы УДП... только на более высоком уровне абстракции и с большими гарантиями доставки

а как на счёт передачи не TextMessage ?
Как раз вот HashMap в пропертиесы запихнуть пытаюсь - так в бине property_name есть, а значение null 
(HashMap - serializable ж - должно, а не хочет)
Исходина ниже .
клиент:


бин:




Это сообщение отредактировал(а) KostenkoSergey - 4.9.2006, 18:49

В предидущем посте я немного тупанул.... 

message.setObjectProperty("PARAMS", new HashMap());  - вызывает javax.jms.MessageFormatException: Invalid object type
Посмотрел исходину жбосовского SpyMapMessage:



абыдно ....   

Может и проще. Пока не дойдёт до транзакций, кластеризации, распределения нагрузки, необходимости хранения и/или повторной обработки сообщений, удаленного мониторинга и т. д. и т. п.

... ещё 5 копеек 

 

Имхо, такие весчи, если подразумевается множественное использование, лучше вынести из метода куда-то или в конструктор класса или  по паттерну "Service Locator", и пользовать 

Кстати, есть какие-то паттерны, рекомендуемые к использованию в случае MDB ?  

РАДИ JMS?

Или на основе его, типа:
Service Activator etc?

А хто его знает ...
У мя тут, при большом кол-ве JMS-сендов: 


воть и думаю... мож я што то не так делаю ...

Гм... может при большом количестве коннекшнов? 
Кста, сенды у тебя пакетно проходят? Или коммит после каждого сенда?

ЗЫ: Заведи отдельную тему - подумкаем