Технология RMI. Java. (Лекция 15)

Технология RMI
Как правило, приложения RMI состоят из двух различных программ: сервера

Распределённые объектные приложения должны осуществлять следующее:
Нахождение удалённых объектов. Приложения могут

На рисунке показана структура RMI приложения

Сервер вызывает реестр для того, чтобы связать имя с удалённым объектом.

2. Реализация удалённых объектов.
Удалённые объекты должны реализовать один или несколько удалённых

3. Реализация клиентов.
Клиенты, использующие удалённые объекты,
могут быть реализованы

2. Реализация удалённых объектов.
import java.rmi.*;
import java.rmi.server.*;
/* все удалённые

Регистрация RMI объекта в реестре
import java.rmi.*;
import java.net.*;
public class AddServer{
public static

3. Реализация клиентов.
import java.rmi.*;
public class AddClient{
public static void main (String[]

Рассмотрим использование rmi.
Компилируем все файлы
>javac AddServerIntf.java
>javac AddServerImpl.java
>javac AddServer.java
>javac AddClient.java
2.Генерируем заглушки и

Enterprise JavaBeans

Архитектура технологии EJB
Чаще всего системы строятся следующим образом.
Есть

Такой подход имеет свои плюсы и минусы.
В плюс идет относительно

Существует другой подход построения информационных систем.
Система разделяется на три уровня.

Такой подход тоже имеет свои плюсы и минусы.
В плюс идет:
разделение

Продвигается 5 уровневая архитектура на основе EJB:

Основное в EJB это сервер приложений.
Клиентские приложения будут общаться с

Сервер приложений имеет вид:

JNDI (Java Naming Directory Interface) - эта служба позволяет клиентскими приложениям

Security Service - сервис безопасности.
Так как сервер приложений предоставляет

Контейнер
Контейнер предоставляет среду, в которой могут функционировать компоненты EJB.
Функции контейнера:
Разбор XML-описания

Контейнер имеет вид:

Компонентная модель
Компоненты EJB имеют два внешних описания (интерфейса).
Через них, собственно,

Home-интерфейс является точкой входа в компонент.
Другими словами любое начало

Рассмотрим стандартный сценарий взаимодействия клиента с компонентами EJB.

1. Клиент ищет Home-интерфейс нужного ему компонента по его имени через

Home-интерфейс
Таким образом вся работа с компонентами начинается с обращения к Home-интерфейсу.

В этом интерфейсе необходимо определить методы двух типов.
Это фабричные методы

Поисковые методы позволяют найти уже созданные компоненты на стороне сервера.
Поисковые методы

Remote-интерфейс
После того, как компонент был создан или найден через его Home-интерфейс

Стандартом, конечно, являются get/set-методы, считывающие и устанавливающие состояния параметров EJB-компонентов. Можно

ctx - ссылка на объект, которая позволяет компоненту получать служебную информацию

ejbCreate - методы которые реализует create методы из Home-интерфейса.
Например,

Дерево имен JNDI
Каждому компоненту EJB сопоставляется имя, которое публикуется на дереве

Самым первый способ получения объектной ссылки выглядит так: запускается компонент на

Схематически это выглядит следующим образом:

Сессионные бины
Сессионный бин по функциональности очень похож на обычный класс, от

Сессионные бины бывают двух видов: Stateless and Stateful.
Другими словами бины

Сессионный бин помнящий свое состояние
Бывает ситуации, когда необходимо, что бы бин

Жизненный цикл в Stateful сессионного бина имеет вид:

Идея заложенная в сущностные бины следующая.
Необходимо хранить информацию в реляционных

Здесь показан пример бина, который обслуживает таблицу всего с двумя столбцами

Жизненный цикл сущностных бинов
Жизненный цикл (ЖЦ) сущностных бинов похож на сессионный,

Рассмотрим пример.
Разработаем сеансовый компонент без состояния (Stateless Session Bean), который

Домашний интерфейс
Теперь определим домашний интерфейс (Home Interface) в файле greetHome.java.
import

Класс компонента
import javax.ejb.*;
import java.rmi.*;
import javax.naming.*;
public class greetBean implements SessionBean {
public

Клиентское приложение
import java.net.*;
import javax.ejb.*;
import javax.rmi.*;
import java.rmi.*;
import javax.naming.*;
import java.util.*;
import java.io.*;
import org.jnp.interfaces.NamingContextFactory;
public class

props.put(Context.INITIAL_CONTEXT_FACTORY,
"org.jnp.interfaces.NamingContextFactory");
props.put(Context.PROVIDER_URL, "localhost:1099");
props.put(Context.URL_PKG_PREFIXES,
"org.jboss.naming:org.jnp.interfaces");
Context ctx=new InitialContext(props);
greetHome

Компиляция и развертывание
Развернем данное приложение с использованием сервера приложений JBoss 3.2.

Дескриптор ejb-jar.xml описывает само приложение ejb и имеет вид:

В этом дескрипторе развертывания имеются следующие элементы:
- корневой элемент.
В

- полное имя класса удаленного интерфейса.
- полное имя класса

Теперь рассмотрим непосредственно установку и компиляцию:
Скачать архив JBoss 3.2 и развернуть

4. Скомпилировать файлы greetRemote.java и greetHome.java, greetBean.java:
>javac –cp .;c:\jboss-3.2.8.SP1\client\jboss-j2ee.jar *.java
5. Создать

В случае использование JBoss 6 и ejb 3, код бина поменяется.

Локальный интерфейс greetHome.java будет иметь вид:
import javax.ejb.Local;
@Local
public interface greetHome extends Greet

Файл ejb-jar.xml имеет вид:

xmlns="http://java.sun.com/xml/ns/javaee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
http://java.sun.com/xml/ns/javaee/ejb-jar_3_0.xsd”

Файл jboss.xml:

xs:schemaLocation="http://www.jboss.org/j2ee/schema
jboss_5_0.xsd" version="5.0">


Greet

Клиент будет иметь вид:
import javax.ejb.*;
import javax.naming.*;
import java.util.*;
import java.io.*;
public class Main{
public

InitialContext ctx=new InitialContext(props);
Class clazz =
greetRemote.class;
Greet

JMS

JMS является еще одной технологией создания распределенных приложений, основанных на модели

Модель обмена сообщениями (и JMS ) удобно использовать в том случае,

Архитектура JMS выглядит следующим образом

прикладные программы Java, использующие JMS, называются клиентами JMS (JMS client );
система

JMS предоставляет два подхода к передаче сообщений.
Первый называется "издание-подписка" (

Второй подход называется "точка-точка" ( point to point ) и служит

Модель передачи сообщений "точка-точка" предоставляет возможность клиентам JMS посылать и принимать

Модель взаимодействия "издание-подписка"
При использовании модели взаимодействия "издание-подписка" один клиент (поставщик)

Модель передачи сообщений "издание-подписка", по существу, представляет собой модель сервера, инициирующего

Использование JMS технологии.
Любой компонент, использующий JMS, прежде всего должен создать соединение

Рассмотрим модель взаимодействия “точка-точка” на базе JMS провайдера ActiveMQ.
import javax.jms.*;
import

public static void main(String[] args) throws
JMSException {
//создаем JMS соединение

//задаем имя очереди
Destination destination =
session.createQueue(subject);
//Для отправки сообщения используется MessageProducer

//отправляем сообшение
producer.send(message);
//закрываем соединение
connection.close();
}
}
Рассмотрим процедуру получения сообщения
public

session session =
connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
Destination destination =
session.createQueue(subject);
//Создаем объект

if (message instanceof TextMessage) {
TextMessage textMessage = (TextMessage)
message;

JMS API определяет несколько типов сообщений:
BytesMessage предназначен для передачи потока байт,

Рассмотрим другой пример использования интерфейса MessageListener.
public class Myclass implements
MessageListener{

Session session =
connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
Destination destination =
session.createQueue(“Queue1”);
MessageConsumer consumer =

//Данный метод вызывается, когда в очереди Queue1 появляется сообщение
public void onMessage(Message

Рассмотрим модель взаимодействия "издание-подписка“. Прежде всего рассмотрим класс издателя:
public class Publisher

//Создаем соединение с JMS сервером
TopicConnectionFactory factory = (TopicConnectionFactory)ctx.lookup(
"ConnectionFactory");
TopicConnection conn =

//Создаем издателя
TopicPublisher topicPublisher =
session.createPublisher(mytopic);
//константа NON_PERSISTENT означает, что сообщения не должны

//Записываем сообщение в тему
topicPublisher.publish(message);
session.close();
conn.close();
} catch(NamingException e){
e.printStackTrace();
} catch(JMSException e){
e.printStackTrace();
}

Рассмотрим класс подписчика
import javax.jms.*;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import java.util.Properties;
public class Subscriber implements

//свойства можно вынести в файл jndi.properties, путь к файлу следует указать

//Создаем объект - слушатель
Subscriber asyncSubscriber =
new Subscriber();
//Создаем соединение
TopicConnectionFactory factory

//Ищем тему “MyTopic”
Topic mytopic = (Topic)ctx.lookup("MyTopic");
//Создаем сессию
TopicSession session =
conn.createTopicSession(false,
TopicSession.AUTO_ACKNOWLEDGE);
//Создаем подписчика

//Метод вызывается при появлении сообщения в теме.
public void onMessage(Message message){
TextMessage