8 November 2009

Взаимодействие Java-приложений с JGroups

Lumber room
Сегодня я хочу рассказать о JGroups. Это Java-библиотека для организации группового взаимодействия между различными процессами Java. Приложения, использующие JGroups могут:
  • Создавать и уничтожать группы
  • Присоединяться к группам и покидать их
  • Получать оповещения о новых членах групп
  • Отправлять сообщения конкретному процессу или всем процессам группы
Библиотека достаточно широко используется, в частности в сервере приложений JBoss, в кэше OSCache и в Grid-платформе Infinispan.

Здесь я ограничусь начальной информацией и опишу создание простого группового чата на Java.

Начало работы


Итак, для начала надо скачать JGroups. Сделать это можно здесь: http://sourceforge.net/projects/javagroups/files/. При написании этой статьи я использовал версию 2.6.13.GA. Также, для работы требуется Apache Commons Logging, или что-то его заменяющее (например, jcl-over-slf4j). Скачать можно здесь: http://commons.apache.org/downloads/download_logging.cgi.

Если же Вы используете Maven, то можно добавить репозиторий JBoss:

Copy Source | Copy HTML
  1. <repository>
  2. <id>jboss</id>
  3. <name>jboss</name>
  4. <url>http://repository.jboss.com/maven2</url>
  5. <snapshots>
  6. <enabled>false</enabled>
  7. </snapshots>
  8. </repository>
и добавить в зависимости:

Copy Source | Copy HTML
  1. <dependency>
  2. <groupId>jgroups</groupId>
  3. <artifactId>jgroups</artifactId>
  4. <version>2.6.13.GA</version>
  5. </dependency>
  6. <dependency>
  7. <groupId>commons-logging</groupId>
  8. <artifactId>commons-logging</artifactId>
  9. <version>1.1.1</version>
  10. </dependency>

Возможно, необходимо настроить сетевой интерфейс для работы с мультикастом. В Linux, для этого необходимо добавить соответствующий роут:

route add -net 224.0.0.0 netmask 240.0.0.0 dev lo


Иницализация


Для того, чтобы создать канал необходимо создать объект класса JChannel, передав ему в конструктор параметры конфигурации. В примере в конфигурации я указываю адрес, который должен использоваться для канала. Полный список опций можно посмотреть в документации.

JChannel channel = new JChannel( "UDP(bind_addr=127.0.0.1)" );

Теперь можно подключаться к кластеру вызовом JChannel#connect(). В качестве параметра в него передается имя группы, можете выбрать любое, которое Вам нравится.

channel.connect( "MyCluster" );

Отправка сообщений


Сообщения в JGroups представлены классом Message, который содержит адрес отправителя, адрес получателя и данные. Адреса представлены объектами класса Address, а данные — это любые сериализуемые объекты или просто массив байт. Например, чтобы создать сообщение для всей группой, содержащее строку можно написать:

new Message( null, null, "Some content" )

Здесь первый параметр — получатель, затем — отправитель, а затем — содержимое.

Чтобы отправить сообщение необходимо вызвать метод JChannel#send и передать ему сообщение в качестве параметра. Например:

channel.send( new Message( null, null, "Some content" ) )


Обработка сообщений


Теперь необходимо написать код, для обработки сообщений, приходящих приложению. Для этого необходимо вызвать метод JChannel#setReceiver, передав в качестве параметра объект, реализующий интерфейс Receiver. Например, чтобы просто выводить все полученные сообщения на печать достаточно написать следующий код:

Copy Source | Copy HTML
  1. channel.setReceiver( new ReceiverAdapter(){
  2. @Override
  3. public void receive( Message m ) {
  4. System.out.println( m.getObject() );
  5. }
  6. } );
Здесь, чтобы уменьшить объем кода, объект наследуется от класса ReceiverAdapter, который предоставляет пустые реализации различных методов интерфейса Receiver. Как видно из примера, для обработки сообщения используется метод receive, в который сообщение передается в качестве параметра.

Простейший чат


Теперь можно собрать простейший чат. Он будет рассылать группе строки, принятые с консоли и печатать полученные строки на консоль. Пример кода:

Copy Source | Copy HTML
  1. import java.io.BufferedReader;
  2. import java.io.InputStreamReader;
  3. import org.jgroups.JChannel;
  4. import org.jgroups.Message;
  5. import org.jgroups.ReceiverAdapter;
  6. public class SimplestChat {
  7. public static void main( String[] args ) throws Exception {
  8. JChannel channel = new JChannel( "UDP(bind_addr=127.0.0.1)" );
  9. channel.setReceiver( new ReceiverAdapter() {
  10. @Override
  11. public void receive( Message m ) {
  12. System.out.println( m.getObject() );
  13. }
  14. } );
  15. channel.connect( "MyCluster" ); // Подключаемся к группе
  16. /**<br/> * Цикл обработки команд с консоли<br/> */
  17. BufferedReader in = new BufferedReader( new InputStreamReader( System.in ) );
  18. while ( true ) {
  19. String line = in.readLine();
  20. if ( line.equalsIgnoreCase( "quit" ) || line.equalsIgnoreCase( "exit" ) ) {
  21. break;
  22. }
  23. channel.send( new Message( null, null, line ) );
  24. }
  25. channel.close(); // Отключаемся от группы по завершению работы
  26. }
  27. }
При запуске этот код должен выводить что-нибудь вроде:

  Nov 8, 2009 4:18:27 PM org.jgroups.JChannel init
  INFO: JGroups version: 2.6.13.GA

Что дальше?


Здесь я рассмотрел только создание канала и отправку сообщений группе. В стороне остались достаточно много моментов: адресация, сообщения конкретному процессу и, главное, управление группой. Желающие ознакомиться с ними могут заглянуть в документацию JGroups: http://jgroups.org/ug.html.
Tags:javajgroupsclusteringclusternetworking
Hubs: Lumber room
+6
2.2k 8
Comments 2
Top of the last 24 hours