Как стало совершенно ясно на выставке Oracle OpenWorld 2007, концепции и тенденции интеграции Web 2.0 с приложениями уровня предприятия являются сегодня главным направлением в разработке приложений. Приложения Oracle Fusion Applications предлагают хороший пример того, как объединение очень привлекательных, визуально богатых пользовательских интерфейсов с популярными возможностями Интернета, например, социальные закладки ( social bookmarking ) и мгновенный обмен сообщениями ( IM - instant messaging), приводит к эффективным и продуктивным приложениям. Объединенное в пользовательском интерфейсе приложения взаимодействие является важным фактором при совместной работе, которую продвигает этот новый стиль приложений. Электронная почта ( e - mail ), голосовая связь по IP ( VoIP ) и служба коротких сообщений ( SMS ) - все это входит в число потенциально рассматриваемых каналов коммуникации, но IM (чат) вполне может быть самым мощным среди них.

Рассмотриваемая в статье обучающая программа предначена для демонстрации разработки полнофункционального Web -приложения, которое полностью интегрировано с Google Talk (http://www.google.com/talk/) , одним из главных сервисов IM . Проект с открытым исходным текстом Smack предлагает библиотеку API Java , чтобы подключиться к протоколу Extensible Messaging and Presence Protocol ( XMPP ) - коммуникационным протоколам IM . Используя Smack , можно очень быстро создать Java -приложение, которое разговаривает с Google Talk (и слушает его), или с любым другим сервисом IM , который соответствует техническим требованиям XMPP . Затем можно использовать Oracle ADF Faces Rich Client (который на момент написания этой статьи являлся частью Oracle JDeveloper 11 g Technical Preview ), чтобы создать пользовательский интерфейс и, в частности, Active Data Service (Обслуживание активных данных), который делает возможным мгновенные обновления Web -клиента ("проталкивание" с сервера на браузер) при получении сообщения. И, наконец, возможность перетаскивания "толстого" клиента Oracle ADF Faces используется для быстрого сбрасывания записей данных в сообщения чата.

Полностью файлы проекта и программы-примеры для каждой части обучающей программы доступны по адресу http://www.oracle.com/technology/pub/files/jellema-googtalk-project.zip .

Подготовка

• Загрузите из OTN и установите Oracle JDeveloper 11 g TP . Перейдите к www. oracle.com/technology/products/jdev/11/index.html , загрузите архивный ( ZIP ) файл объемом 500 Мбайт, разархивируйте его на вашей машине, и вы готовы к работе.
• Получите учетную запись Google Talk . Перейдите к https ://www.google.com/accounts/NewAccount?service=talk и создайте свою бесплатную учетную запись (account - аккаунт) Google Talk . Примечание: вы можете также добавить Google Talk как дополнительный компонент к существующему аккаунту Google .
• Загрузите клиента Google Talk . Хотя, строго говоря, это и не является необходимым для рассматриваемой обучающей программы - ведь, в конце концов, мы будем разрабатывать наш собственный клиент Google Talk , - все-таки полезно загрузить с http://www.google.com/talk/ клиента Google Talk . Таким путем вы получите возможность организовать "разговор" этих двух клиентов друг с другом.
• Загрузите библиотеку Java проекта Smack для протокола XMPP . Перейдите к http ://www.igniterealtime.org/downloads/index.jsp и найдите библиотеку Smack . Выберите файл ZIP (размер 2.4 Мбайт) или файл tar . gz (размер 1.6 Мбайт) и загрузите его на вашу машину. Разархивируйте его. Пока нас интересуют только файлы smack . jar и smackx . jar .

Часть 1: Создание Java -приложения, которое разговаривает с Google Talk

Настройка Smack и подключение к Google Talk для программируемых чатов (чтение и отправление сообщений)

Запустите Oracle JDeveloper 11 g . Создайте новое приложение - и назовите его, например, GoogleTalk . Также создайте новый проект; например, GoogleTalkJavaClient .

Выберите из меню Application Template No Template [ All Technologies ] . Из меню, вызываемого нажатием правой кнопки мыши, или из меню Tools откройте окно диалога Project Properties для узла Project . Перейдите к узлу Libraries and Classpath .

Добавьте к проекту архивные файлы smack . jar и smackx . jar : кликните по кнопке Add JAR / Directory . Просмотрите библиотеки и файлы Smack , выберите оба файла (и smack . jar , и smackx . jar ) и кликните по кнопке Select .

Файл JAR будет добавлен к проекту.

Кликните по кнопке OK .

Теперь мы создадим класс, который будет в состоянии через Google Talk посылать сообщения IM . Создайте в пакете otn . adf . googletalk класс MessageSender . Дайте Oracle JDeveloper указание добавить основной ( main ) метод.

package otn.adf.googletalk;

import org.jivesoftware.smack.ConnectionConfiguration;

import org.jivesoftware.smack.XMPPConnection;

import org.jivesoftware.smack.XMPPException;

import  org.jivesoftware.smack.packet.Message;

public class  MessageSender {

    private static String username =  "YOUR_GOOGLE_TALK_USERNAME";

    private static String password =  "YOUR_GOOGLE_TALK_PASSWORD";

    ConnectionConfiguration connConfig;

    XMPPConnection connection;

                      

    public MessageSender() throws  XMPPException {

        connConfig = new  ConnectionConfiguration("talk.google.com", 5222,  "gmail.com");

        connection = new XMPPConnection(connConfig);

        connection.connect();

        connection.login(username, password);

    }

   

    public void sendMessage(String to, String  message ) {

        Message msg = new Message(to,  Message.Type.chat);

        msg.setBody(message);

       connection.sendPacket(msg);

    }

   

    public void disconnect() {

        connection.disconnect();

    }

   

    public static void main(String[] args)  throws XMPPException {

       MessageSender messageSender = new  MessageSender();

       messageSender.sendMessage("youraccount@gmail.com", 

             "Hello You. This is my first message sent programmatically using Smack API  and Google Talk.");

       messageSender.disconnect();

   }

}

Удостоверьтесь, что в строках 10 и 11 вы вставили имя и пароль для своего собственного аккаунта Google Talk . Также вставьте свой аккаунт (или аккаунт вашего друга) в строку 36, как пункт назначения (адресат) этого сообщения: " Hello , world of instant messaging ".

Конструктор класса MessageSender создает подключение к серверу Google Talk и регистрируется на нем (строки 17-21). После создания экземпляра MessageSender вызывается метод sendMessage с адресатом (кому посылается сообщение) и с самим текстом сообщения. И, наконец, подключение закрывается с помощью метода разъединения.

Когда вы выполните приложение, то быстро получите свое первое сообщение Google Talk , посланное вашим собственным приложением через сервер Google Talk :

Присутствие

Одной из хороших возможностей мгновенного обмена сообщениями является присутствие ( presence ), то есть индикация того, кто из друзей и контактов доступны в данный момент. И Google , и API Smack поддерживают присутствие.

Сначала мы можем сказать всему миру о нашем собственном присутствии, выполняя приведенные ниже строки программы:

// сказать миру (или хотя бы нашим друзьям), что мы доступны

Presence presence = new  Presence(Presence.Type.available);

presence.setMode(Presence.Mode.chat);

connection.sendPacket(presence);

Примечание : мы можем выбирать из нескольких режимов присутствия: available (доступен), chat (в чате), away (отошел), xa ( extended away - расширенное отсутствие) и dnd ( do not disturb - просьба не беспокоить).

Еще более интересен для нас тот факт, что наша программа может узнать о присутствии всех наших контактов - в терминах IM , поименный список ( roster ) - или о присутствии определенного контакта. Вот так определяется список всех наших контактов:

Roster roster =  connection.getRoster();

Collection iter =  roster.getEntries();

for (RosterEntry entry : iter) {

     System.out.println(entry.getName()  + " (" + entry.getUser() + ")");

}

Получение сообщений

Если бы мы могли бы только посылать сообщения, то наш разговор (то есть, сеанс связи) был бы весьма унылым. Следующий шаг, который мы собираемся предпринять, добавляет нашему "приложению" возможности прослушивания. Мы создадим класс MessageListener , который будет выглядеть в высшей степени похожим на класс MessageSender. Фактически, для его создания достаточно сначала сохранить файл MessageSender . Java как MessageListener . Java , а затем использовать поиск и замену, чтобы заменить все вхождения слова MessageSender на MessageListener .

Затем сделаем так, чтобы класс реализовывал интерфейс PacketListener , добавляя к спецификации класса implements PacketListener . Единственное требование, предъявляемое нам этим интерфейсом, это реализация метода processPacket , как показано в этом примере:

public void processPacket(Packet packet) {

    Message message = (Message)packet;

    System.out.println("Message  (from: "+message.getFrom()+"): "+message.getBody());

}

После того, как мы зарегистрировали наш класс как прослушиватель для сообщений с подключением, этот метод будут вызывать всякий раз, когда сервер Google Talk посылает сообщение нашему подключению. Регистрация нашего класса как "прослушивателя" для сообщений из чата на наш акаунт делается путем добавления этих строк программы в конце конструктора для MessageListener ():

// прослушивать поступающие сообщения для этого подключения

PacketFilter filter = new  MessageTypeFilter(Message.Type.chat);

connection.addPacketListener((PacketListener)this,  filter);

Примечание: Мы должны добавить к нашему классу следующие операторы импорта; однако, если мы добавим код, описанный выше, то Oracle JDeveloper , вообще говоря, сделает это за нас.

import org.jivesoftware.smack.filter.PacketFilter;

import org.jivesoftware.smack.filter.MessageTypeFilter;

import org.jivesoftware.smack.PacketListener;

import org.jivesoftware.smack.packet.Packet;

Теперь мы готовы получать сообщения. Если мы изменим основной метод нашего класса MessageReceiver следующим образом, то получим наше собственное (посланное нами же) сообщение:

public static void main(String[] args) throws XMPPException,

                                                     InterruptedException {

    MessageListener messageListener = new  MessageListener();

    messageListener.sendMessage("youraccount@gmail.com",

                    "Hello You. This is my second message sent programmatically using Smack API and Google Talk.");

    // listen for 3 seconds

    Thread.sleep(3000);

    messageListener.disconnect();

}

Конечно, вместо того, чтобы говорить с самим собой, было бы намного лучше слушать сообщения из чата, посланные нашими друзьями. Если ни один из них в настоящее время не доступен, Google Talk предлагает вам ряд "друзей", с которыми можно разговаривать. Эти так называемые боты являются программируемыми аккаунтами Google Talk , которые предлагают перевод с одного языка на другой. Боты имеют аккаунты типа en2zh@bot.talk.google.com и nl2en@bot.talk.google.com, составленные из двухбуквенных сокращений языка-источника и выходного языка. (Уведомление о ботах перевода Google Talk можно найти, например, на http://googletalk.blogspot.com/2007/12/merry-christmas-god-jul-and.html )

Мы можем просто послать сообщение из чата боту Google , и он пошлет нам возвращаемое сообщение, что попросту говоря, просто великолепно для быстрого нахождения перевода простых слов или фраз. Мы можем изменить основной метод еще раз и сделать так, чтобы он считал на французском языке от 1 до 10 (хотя, конечно, для того чтобы сделать это, вы не нуждаетесь в боте перевода):

MessageListener messageListener = new  MessageListener();

    String[] englishCounting = new String  [] {"one", "two", "three", "four",  "five", "six",  "seven", "eight", "nine", "ten"};

    for (int  i=0;i< messageListener.disconnect(); } Thread.sleep(500); order right the in replies receiving of chances increase to pause slight add englishCounting[i]); messageListener.sendMessage(?en2fr@bot.talk.google.com?, { i++)>

Результат выполнения приложения на этот раз - счет на французском языке:

Примечание: на своем сервере боты Google Talk выполняются многопоточно (то есть, несколькими потоками). Это означает, что если задержка между посланными боту сообщениями достаточно мала, ответы могут быть возвращены в другом порядке, поскольку, например, поток, обрабатывающий слово "пять", может фактически ответить быстрее, чем поток, имеющий дело со словом "два". Если же перед посылкой следующего сообщения мы будем ожидать 500 мс (или около того), то у нас будут неплохие шансы получить все ответы в надлежащем порядке.

Часть 2: построение Oracle ADF Faces Rich Client

Теперь, когда у нас имеется наше базовое приложение Java , которое может и посылать сообщения в чат, и принимать их, пришло время узнавать, как можно создать Web -приложение, которое сможет делать те же самые вещи. Мы будем использовать Oracle ADF Faces Rich для создания пользовательского интерфейса поверх уровня связывания данных Oracle ADF , чтобы подключить Web -уровень к сервисам данных, которые обеспечивают доступ к контенту и операциям.

Мы добавим к MessageSender небольшую дополнительную функциональную возможность: свойство под названием roster (именной список) - список наших "приятелей по чату" - друзей, которых мы добавили в Google Talk .

Сначала создадим новый класс по имени TalkMate , bean -компонент с двумя свойствами: toName и displayName .

package  otn.adf.googletalk;

public class  TalkMate {

     String toName;

     String displayName;

     public TalkMate() {

     }

     public void setToName(String toName) {

         this.toName = toName;

     }

     public String getToName() {

         return toName;

     }

     public void setDisplayName(String  displayName) {

         this.displayName = displayName;

     }

     public String getDisplayName() {

         return displayName;

     }

}

Добавим к классу MessageSender следующее приватное свойство:

private Collection<TalkMate> roster = new ArrayList();

и создадиме для этого свойства методы средств доступа (получатель ( getter ) и посылающий ( setter )).

Затем добавим к методу конструктора MessageSender () следующие строки программы:

Roster friendsRoster = connection.getRoster();

Collection  rosterIter = friendsRoster.getEntries();

for (RosterEntry entry : rosterIter) {

   TalkMate friend = new TalkMate();

   friend.setDisplayName(entry.getName()!=null?entry.getName():entry.getUser());

   friend.setToName(  entry.getUser());

   this.roster.add(friend);

} rosterIter //

// также, в проверочных целях, добавьте к чату с самим собой

// ваш собственный аккаунт

TalkMate veryBestFriend = new TalkMate();

veryBestFriend.setDisplayName("Your  Own Display Name");

veryBestFriend.setToName(  "YOUR_OWN_GOOGLE_TALK_ACCOUNTNAME");

this.roster.add(veryBestFriend);

 

Теперь мы создадим bean -компонент MessageReceiver , который показывает возможности прослушивания чата способом, дружественным к потенциальным потребителям. Сначала создадим следующий bean -компонент:

package  otn.adf.googletalk;

import  Java.util.Date;

public class  ChatMessage {

     private Date timestamp;

     private String from;

     private String body;

    

     public ChatMessage() {

     }

     public ChatMessage(String from, String  body) {

          this.timestamp = new Date();

          this.from = from;

          this.body = body;

     }

     public void setTimestamp(Date timestamp) {

         this.timestamp = timestamp;

     }

     public Date getTimestamp() {

         return timestamp;

     }

     public void setFrom(String from) {

         this.from = from;

     }

     public String getFrom() {

         return from;

     }

     public void setBody(String body) {

         this.body = body;

     }

     public String getBody() {

         return body;

     }

}

Затем - класс MessageReceiver, что-то вроде этого :

package otn.adf.googletalk;

import Java.util.ArrayList;

import Java.util.List;

public class  MessageReceiver {

    private List messages =  new ArrayList();

    public MessageReceiver() {

        try {

            MessageListener messageListener =  new MessageListener();

            messageListener.setReceiver(this);

        } catch (Exception e) {

        }

    }

    public void processMessage(String from,  String body) {

        ChatMessage message = new  ChatMessage(from, body);

        messages.add(0, message);

        for (ChatMessageListener  listener:messageListeners) {

            listener.processChatMessage(message);

        }

    }

    public void  setMessages(List messages) {

        this.messages = messages;

    }

    public List  getMessages() {

        return messages;

    }

}

Чтобы заставить все это работать вместе, мы должны внести в класс MessageListener небольшое изменение. Добавим получателя приватного ( private ) свойства к классу MessageListener , и создадим для него получателя и посылающего:

MessageReceiver receiver;

Затем добавьте в метод processPacket() следующую строку:

if (this.receiver != null) {

      receiver.processMessage(message.getFrom(), message.getBody());

}

Это заставит MessageListener вызывать processMessage из MessageReceiver, что , в свою очередь , добавит новый ChatMessage к коллекции сообщений в bean- компоненте MessageReceiver.

Чтобы показать MessageSender и bean- компоненты MessageReceiver в палитре управляющих элементов данных Oracle ADF (Oracle ADF Data Control Palette), мы должны опубликовать оба bean- компонента как элементы управления данными . Давайте сначала сосредоточимся на MessageSender : Создайте и опубликуем управление данными из меню, вызываемого щелчком по правой кнопке мыши, из узла bean -компонента:

Кликните по OK , и страница будет создана.

На этой странице мы хотели бы иметь два раздела: один для того, чтобы писать и посылать сообщения в чат, и второй, в котором перечисляются поступающие сообщения. В этой статье мы не будем уделять слишком много внимания проведению сеансов связи (разговоров) в чате с многочисленными реципиентами (получателями) - мы оставим это, как упражнение для читателя (Вас, скорее всего, просто бесит, когда автор пытается выйти сухим из воды, отделываясь выражениями типа этого).

С созданием двух разделов на странице очень удачно справляется компонент Oracle ADF 11 g Faces Rich Panel Splitter . Перетащите этот компонент из палитры компонентов и опустите его на страницу. Это даст нам панель с двумя разделами для посылки и получения сообщений. Установите ширину разделителя панелей на 100%.

Перетащите sendMessage () в первый фасет. Опустите его как ADF Parameter Form .

Задайте в следующем диалоговом окне осмысленные подсказки:

• Обратиться в "Интерфейс" за дополнительной информацией/по вопросу приобретения продуктов
• Подробнее о продуктах Oracle
• Приобрести продукты Oracle в ITShop.ru
• Курсы обучения по продуктам компании Oracle