Flex на Grails

услуги-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<services-config>
  <services>
    <service id="grails-remoting-service"
      class="flex.messaging.services.RemotingService">
      <adapters>
        <adapter-definition id="java-object"
          class="flex.messaging.services.remoting.adapters.JavaAdapter"
          default="true"/>
      </adapters>
    </service>                                                                    <service id="grails-service"                                        
      class="org.codehaus.groovy.grails.plugins.flex.GrailsBootstrapService"/>
    <service id="message-service"                                        #1
      class="flex.messaging.services.MessageService"                     #1
      messageTypes="flex.messaging.messages.AsyncMessage">               #1
      <adapters>                                                         #2
        <adapter-definition id="jms"                                     #2
          class="flex.messaging.services.messaging.adapters.JMSAdapter"  #2
          default="true"/>                                               #2
      </adapters>                                                        #2
      <destination id="contactsTopic">                                   #3
        <properties>                                                     #3
          <jms>                                                          #3
            <destination-jndi-name>contacts</destination-jndi-name>      #3
            <message-type>javax.jms.ObjectMessage</message-type>         #3
            <connection-factory>ConnectionFactory</connection-factory>   #3
            <delivery-mode>NON_PERSISTENT</delivery-mode>                #3
            <message-priority>DEFAULT_PRIORITY</message-priority>        #3
            <acknowledge-mode>AUTO_ACKNOWLEDGE</acknowledge-mode>        #3
            <transacted-sessions>false</transacted-sessions>             #3
            <initial-context-environment>                                #3
              <property>                                                 #3
                <name>Context.PROVIDER_URL</name>                        #3
                <value>vm://localhost</value>                            #3
              </property>                                                #3
              <property>                                                 #3
                <name>Context.INITIAL_CONTEXT_FACTORY</name>             #3
                <value>org.apache.activemq.jndi.ActiveMQInitialContextFactory</value>    #3
              </property>                                                #3
              <property>                                                 #3
                <name>topic.contacts</name>                              #3
                <value>contacts</value>                                  #3
              </property>                                                #3
            </initial-context-environment>                               #3
          </jms>                                                         #3
        </properties>                                                    #3
      </destination>                                                     #3
    </service>
<default-channels>
      <channel ref="grails-amf"/>
    </default-channels>
  </services>
  <channels>
    <channel-definition id="grails-amf" class="mx.messaging.channels.AMFChannel">
      <endpoint url="http://{server.name}:{server.port}/{context.root}/messagebroker/amf"
        class="flex.messaging.endpoints.AMFEndpoint"/>
    </channel-definition>
  </channels>
</services-config> 

# 1 JMS-сервис
# 2 JMS-адаптер
# 3 JMS-конфигурация

Основная часть файла services-config.xml была сгенерирована при установке подключаемого модуля Flex; однако вам необходимо добавить новый раздел службы для службы JMS, который вы будете использовать (# 1), и раздел, в котором указано, что вы хотите, чтобы служба использовала адаптер JMS (# 2). Вам также необходимо настроить тему JMS, с которой вы будете общаться (# 3). Чтобы увидеть все параметры, которые вы определили, обратитесь к пользовательской документации BlazeDS . Теперь давайте перейдем к изменению нашего ContactService для использования вашего обмена сообщениями.

Изменение ContactService

Существующий класс ContactService относительно прост. Вот обновленный класс ContactService с дополнениями для публикации обновленного списка контактов.

КонтактСервис обновлен

class ContactService {
 
  static expose = ['flex-remoting']
  boolean transactional = true
 
  def getContacts() {
   return Contact.list()
  }
 
  def get(id) {
    return Contact.get(id)
  }
 
  def update(Contact contact) {
    contact.save()
    publishContacts()                                           #1
  }

  def remove(Contact contact) {
    contact.delete(flush: true)
    publishContacts()                                           #1
  }

  def private void publishContacts() {
    try {
      sendPubSubJMSMessage("contacts", getContacts());          #2
    } catch (Exception e) {
      log.error("Failed to publish contacts.", e);
    }
  }
} 

# 1 publishContacts
# 2 sendPubSubJMSMessage

Вы добавляете метод publishContacts () (# 1) для публикации обновлений в теме, настроенной вами в файле services-config.xml . SendPubSubJMSMessage

 (# 2) принимает два аргумента. Первый аргумент — это имя назначения JNDI, определенное в вашей теме, а второй — список контактов. Затем вы подключаете обновление и удаляете методы для публикации контактов, когда они вызываются. Другие методы могут быть вызваны в зависимости от ваших потребностей. Поскольку тема поддерживает модель публикации / подписки, она используется для обмена сообщениями «один ко многим», что хорошо работает с приложением «Контакты». Для обмена сообщениями «один-к-одному» или «точка-точка» вместо этого следует использовать очередь. Чтобы узнать больше о плагине JMS,посетите веб-сайт Grails .

Обновите Main.mxml

Последнее, что нужно сделать перед повторным запуском приложения контактов, это обновить файл main.mxml клиента Flex. Вы добавите JMS-сервис к миксу и внесете другие незначительные изменения. Начнем с элемента Application .

Main.mxml (e)

<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml"
    xmlns:local="*"
    layout="vertical"
    viewSourceURL="srcview/index.html"                     
                                                                        #1
creationComplete="contactService.getContacts();jmsConsumer.subscribe()">
 
  <mx:Consumer id="jmsConsumer"                  #2
      destination="contactsTopic"
      message="handleGetContacts(event.message.body)"
      fault="showFault(event)"/>
 
...
 
</mx:Application>

# 1 creationComplete
# 2 Consumer

Объект Flex Consumer (# 2) используется для подключения к contactsTopic . Когда приложение инициализируется, вам необходимо подписаться на contactsTopic . Для этого вы настраиваете определение события creationComplete (# 1) для вызова подписки на jmsConsumer

. Потребитель прослушивает изменения от брокера ActiveMQ и использует метод handleGetContacts для получения данных. Этот метод обновляет список контактов при наличии обновлений.

Отсюда приложение будет работать нормально, как есть. Есть некоторые вещи, которые нужно очистить, потому что теперь мы делаем приложение осведомленным о JMS, и они не требуют дополнительных затрат.

Main.mxml (f)

private function deleteContact(selectedContact:Contact):void {
  contactService.remove(selectedContact);
}
 
private function updateContact(contact:Contact):void {
  contactService.update(selectedContact);
}

...
<mx:ControlBar>
  <mx:Button label="Delete Contact"
    enabled="{contactsGrid.selectedItem != null}"
    click="deleteContact(selectedContact)"/>
</mx:ControlBar>

Вы удаляете вызовы метода getContacts () в RemoteObject при вызове deleteContact и updateContact . Эти вызовы были необходимы до включения JMS для обновления DataGrid при каждом обновлении списка контактов. Вы также можете удалить кнопку Обновить. Потребитель Flex будет получать обновления каждые несколько секунд и будет вызывать метод, который будет обновлять DataGrid, чтобы больше не было необходимости в этих дополнительных вызовах на стороне сервера. Сам потребитель может быть дополнительно настроен, если требуются другие временные или другие параметры.

Чтобы проиллюстрировать передачу информации с сервера на клиент, запустите приложение Grails, открыв командную строку и перейдя в папку проекта. Введите команду grails run-app, которая запустит встроенный контейнер для запуска приложения. Теперь откройте два браузера и укажите их оба на приложение Flex по адресу http: // localhost: 8080 / flex-contacts / main.mxml . Затем, когда вы делаете обновления в одном окне, вы должны видеть, что контакты обновляются в другом окне браузера — больше не нужно вручную обновлять приложение, чтобы получить изменения других пользователей.

Резюме

В этой статье мы показали, как быстро создавать прототипы приложений Flex с поддержкой данных, используя Groovy и Grails в сочетании с плагином Flex для Grails. Вы начали с определения домена в Grails и предоставления некоторых сервисов для своего приложения Flex и самого приложения Flex. Затем вы пошли еще дальше и позволили вашему приложению использовать JMS и ActiveMQ для обновления вашего пользовательского интерфейса в режиме реального времени.