Версия для печати темы Нажмите сюда для просмотра этой темы в оригинальном формате

Форум программистов > Java EE (J2EE) и Spring > MDB - это просто

Автор: Domestic Cat 23.3.2005, 20:43

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 ЗЫ. Если не работает - сообщайте, мог ошибиться т.к. писал по памяти.

Автор: Sardar 23.3.2005, 23:03

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

Автор: Domestic Cat 23.3.2005, 23:10

Цитата Немного не ясно как клиент общается с сервером. По особым протоколам, на особых портах, которые скоре всего закрыты файрволом или как? Вот тут и протокол, и порт Цитата jnp://localhost:1099 Цитата И воторе, можно ли отсылать бинарники, т.е. что то типа BinaryDataMessage? Звыняюсь в ман не полез. JMS определяет такие мессаги: TextMessage, BytesMessage, StreamMessage, ObjectMessage, MapMessage

Автор: jer1 30.3.2005, 14:21

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

Автор: Domestic Cat 30.3.2005, 18:52

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

Автор: YuG 6.3.2006, 17:49

Сделал всё по инструкции... Вот тут, у клиента: Код TopicConnectionFactory factory = (TopicConnectionFactory) ctx.lookup("java:/XAConnectionFactory"); вот так ругается: Код javax.naming.NameNotFoundException: XAConnectionFactory not bound     at org.jnp.server.NamingServer.getBinding(NamingServer.java:491)     at org.jnp.server.NamingServer.getBinding(NamingServer.java:499)     at org.jnp.server.NamingServer.getObject(NamingServer.java:505)     at org.jnp.server.NamingServer.lookup(NamingServer.java:278)     at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:610)     at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:572)     at javax.naming.InitialContext.lookup(InitialContext.java:347)     at test.jms.MDBClient.main(MDBClient.java:38) Exception in thread "main"  Что не так?

Автор: Tony 7.3.2006, 19:35

Цитата(Domestic Cat @ 30.3.2005, 18:52) Там, где применяется MOM - Message Oriented Middleware, короче говоря, везде. Фактичecки, это то жe самое, что и RMI / TCP/IT/ датаграммы, только kоммуникация асинхронна, плюс необязательно чтобы работал получатель - в этом случае сервер сохраняет мессаги и передает получателю впоследствии. А не прощели написать сервлет.Скачать jakarta HttpClient i посилать всё 4то угодно(взависимости от сервлета)

Автор: chief39 7.3.2006, 20:58

Цитата(Tony @ 7.3.2006, 19:35 ) А не прощели написать сервлет.Скачать jakarta HttpClient i посилать всё 4то угодно(взависимости от сервлета) Да можно и сервлет не писать. Можно хоть УДП датаграмму. Суть в том, что это: во-первых - асинхронно(ты отправил месседж и всё. Его получат. Не надо ждать обработки сего месседжа чтоб продолжить выполнение кода далее) во-вторых - надёжно, как для асинхронного... То есть... это как бы УДП... только на более высоком уровне абстракции и с большими гарантиями доставки

Автор: KostenkoSergey 4.9.2006, 18:49

а как на счёт передачи не TextMessage ? Как раз вот HashMap в пропертиесы запихнуть пытаюсь - так в бине property_name есть, а значение null  (HashMap - serializable ж - должно, а не хочет) Исходина ниже . клиент: Код       QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup(_QCF);       Queue queue = (Queue) ctx.lookup(_queue);       QueueConnection connect = factory.createQueueConnection();       QueueSession session = connect.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);       QueueSender sender = session.createSender(queue);       sender.setDeliveryMode(DeliveryMode.NON_PERSISTENT);       MapMessage message = session.createMapMessage();       connect.start();       message.setObjectProperty("PARAMS", prop_.getProperty(propName)); // тут HashMap       sender.send(message);       connect.close(); бин: Код       MapMessage message_ = (MapMessage) message;       Object p = message_.getObjectProperty("PARAMS"); // а тут нулл (хотя в пропертинеймсах "PARAMS" есть)

Автор: KostenkoSergey 4.9.2006, 19:46

В предидущем посте я немного тупанул....  message.setObjectProperty("PARAMS", new HashMap());  - вызывает javax.jms.MessageFormatException: Invalid object type Посмотрел исходину жбосовского SpyMapMessage: Код synchronized (content)       {          if (value instanceof Boolean)             content.put(name, value);          else if (value instanceof Byte)             content.put(name, value);          else if (value instanceof Short)             content.put(name, value);          else if (value instanceof Character)             content.put(name, value);          else if (value instanceof Integer)             content.put(name, value);          else if (value instanceof Long)             content.put(name, value);          else if (value instanceof Float)             content.put(name, value);          else if (value instanceof Double)             content.put(name, value);          else if (value instanceof String)             content.put(name, value);          else if (value instanceof byte[])             content.put(name, ((byte[]) value).clone());          else             throw new MessageFormatException("Invalid object type.");       } абыдно ....

Автор: w1nd 4.9.2006, 22:15

Цитата(Tony @ 7.3.2006,  19:35) А не прощели написать сервлет.Скачать jakarta HttpClient i посилать всё 4то угодно(взависимости от сервлета)   Может и проще. Пока не дойдёт до транзакций, кластеризации, распределения нагрузки, необходимости хранения и/или повторной обработки сообщений, удаленного мониторинга и т. д. и т. п.

Автор: KostenkoSergey 14.5.2007, 14:33

... ещё 5 копеек  Цитата(Domestic Cat @  23.3.2005,  20:43 )         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");   Имхо, такие весчи, если подразумевается множественное использование, лучше вынести из метода куда-то или в конструктор класса или  по паттерну "Service Locator", и пользовать  Код _connection.start(); Кстати, есть какие-то паттерны, рекомендуемые к использованию в случае MDB ?

Автор: chief39 14.5.2007, 14:41

Цитата(KostenkoSergey @  14.5.2007,  14:33 ) Кстати, есть какие-то паттерны, рекомендуемые к использованию в случае MDB ? РАДИ JMS? Или на основе его, типа: Service Activator etc?

Автор: KostenkoSergey 14.5.2007, 17:46

Цитата(chief39 @  14.5.2007,  14:41 ) РАДИ JMS? Или на основе его, типа: Service Activator etc?  А хто его знает ... У мя тут, при большом кол-ве JMS-сендов:  Код 2007-05-14 14:50:36,140 ERROR  - javax.jms.JMSException: The broker cannot accept any more connections. 2007-05-14 14:50:36,140 ERROR  -        at progress.message.jimpl.JMSExceptionUtil.createJMSException(Unknown Source) 2007-05-14 14:50:36,140 ERROR  -        at progress.message.jimpl.Connection.<init>(Unknown Source) 2007-05-14 14:50:36,140 ERROR  -        at progress.message.jimpl.QueueConnection.<init>(Unknown Source) 2007-05-14 14:50:36,140 ERROR  -        at progress.message.jimpl.xa.XAQueueConnection.<init>(Unknown Source) 2007-05-14 14:50:36,140 ERROR  -        at progress.message.jclient.xa.XAQueueConnectionFactory.createXAQueueConnection(Unkno Source) 2007-05-14 14:50:36,140 ERROR  -        at progress.message.jclient.xa.XAQueueConnectionFactory.createQueueConnection(Unknown urce) 2007-05-14 14:50:36,140 ERROR  -        at progress.message.jclient.xa.XAQueueConnectionFactory.createQueueConnection(Unknown urce) воть и думаю... мож я што то не так делаю ...

Автор: chief39 14.5.2007, 18:36

Цитата(KostenkoSergey @  14.5.2007,  17:46 ) А хто его знает ... У мя тут, при большом кол-ве JMS-сендов:  Гм... может при большом количестве коннекшнов?  Кста, сенды у тебя пакетно проходят? Или коммит после каждого сенда? ЗЫ: Заведи отдельную тему - подумкаем

Автор: KostenkoSergey 15.5.2007, 09:40

Цитата(chief39 @  14.5.2007,  18:36 ) Заведи отдельную тему - подумкаем   - имхо новый топ заводить незачем - MDB ж    Исходина: Код   public void sendLogMessage(LogUnit logUnit) throws Exception{     try {       //-- LookUp:       QueueConnectionFactory factory = (QueueConnectionFactory) context.lookup(queueFactoryLogName);       Queue queue = (Queue) context.lookup(queueLogName);       //-- Create session:       connection = factory.createQueueConnection();       session = connection.createQueueSession(false, javax.jms.Session.AUTO_ACKNOWLEDGE);       sender = session.createSender(queue);       //-= Create ObjectMessage       message = session.createObjectMessage();       message.setObject(logUnit);       //-- Send:       sender.send(message);     }catch (Exception e){       e.printStackTrace();     } finally {       try{ sender.close(); } catch(Exception ignogeEx) {}       try{ session.close(); } catch(Exception ignogeEx){}       try{ connection.close(); } catch(Exception ignogeEx){}     }     return;   } JMS Provider - SonicMQ.

Автор: chief39 15.5.2007, 14:37

Цитата(KostenkoSergey @  15.5.2007,  09:40 ) - имхо новый топ заводить незачем - MDB ж  Ща модераторы придут и натсучат по тыковкам А зачем ты для каждого сенда открываешь коннекшн, сессию и потом их закрываешь, если можно создать их заранее и в этом методе делать только сенд? Или сделать меотд, который будет делать сотню сендов из хэшмапы, а потом коммит?

Автор: KostenkoSergey 15.5.2007, 14:57

Цитата(chief39 @  15.5.2007,  14:37 ) А зачем ты для каждого сенда открываешь коннекшн  - згоден. я в принципах выше писал, что нады вынести - вынес. метод преобразился: Код  public void sendLogMessage(LogUnit logUnit) throws Exception{     try {       //-= Create ObjectMessage       message.clearBody();       message.setObject(logUnit);       //-- Send:       sender.send(message);     }catch (Exception e){       e.printStackTrace();     }      return;   } тут тока непонятка, где ж ему "клозе" делать... делаю в ejb.remove() - и думкаю: нормально это али нет ? ХашМар не падходит. Цитата(chief39 @  15.5.2007,  14:37 ) а потом коммит  - а это ж вроде ваще для транзакционности, мну не надо - это просто логи.

Автор: chief39 15.5.2007, 16:29

Цитата(KostenkoSergey @  15.5.2007,  14:57 ) делаю в ejb.remove() - и думкаю: нормально это али нет ? Вай нот? это из стейтлесса?

Автор: KostenkoSergey 15.5.2007, 17:34

Цитата(chief39 @  15.5.2007,  16:29 ) Вай нот? это из стейтлесса?   Ес )

Автор: chief39 15.5.2007, 18:41

Цитата(KostenkoSergey @  14.5.2007,  17:46 ) javax.jms.JMSException: The broker cannot accept any more connections. Слу... погляди спеки насчёт постеров для очереди Могут ли двое одновременно писать в одно ведро? А на стейтлессах у тя запросто и не двое могут к ведру пристроиться.

Автор: KostenkoSergey 16.5.2007, 14:25

Цитата(chief39 @  15.5.2007,  18:41 ) погляди спеки      не нашёл такого.

Автор: chief39 16.5.2007, 17:18

У меня на две читалки, случайно наштопанные так ругалось, что естественно

Powered by Invision Power Board (http://www.invisionboard.com)
© Invision Power Services (http://www.invisionpower.com)