Notas de Aula - MAC 5755 - Sistemas Operacionais Distribuídos

Aula 7 - 29/8/2001

CORBA - Common Object Request Broker Architecture

• História: Sun RPC (produto comercial) -> Sun Spring (SOD experimental baseado em objetos) -> CORBA (padrão da industria)
• Arquitetura de Middleware baseada em Objetos Distribuídos definada pela OMG (Object Management Group)
• A melhor referência para programação CORBA é o livro do Henning e Vinoski que está na bibliografia.

Mais sobre o ORB (vimos um pouco na aula passada):

• Há ORBs para C/C++, Java, Smalltalk, Cobol, Ada, Fortran, etc.
• Mas C++ e Java são mais comuns. A JDK 1.3 da Sun vem com CORBA incluso.

• A linguagem de definição de interfaces da OMG: IDL
• exemplos de especificações usando IDL:

 

 

/*************************/
/* Arquivo impressao.idl */
/*************************/
exception SemPapel {};
exception PapelEnroscou {
    short posicao;
};

typedef sequence<octet> Arquivo;

interface Impressora {
    void print (in Arquivo arq) raises (SemPapel, PapelEnroscou);
    int  estado (out FilaDeImpressao fdi);
}

interface ImpressoraColorida : Impressora {
    enum ModoDeCores { BrancoEPreto, TonsDeCinza, Colorido };
    void modo (inout ModoDeCores mdc);
}
 

• GIOP - General Inter-ORB Protocol
• Interoperable Object Reference (IOR) é a referência (ou apontador) para um objeto CORBA
• pode conter uma lista de modos de se localizar um objeto usando protocolos diferentes
• normalmente, só um protocolo é usado. O mais usado é IIOP.
• IIOP - Internet IOP (baseado em TCP/IP)
• neste caso a IOR contém:
1. ID do tipo do objeto
2. nome do domínio ou endereço IP
3. porta TCP
4. chave do objeto (identifica objeto dentro do ORB do servidor)
• Pluggable Protocols (Schmidt et al)
• Interceptadores (Portable Interceptors)
• nível da requisição (request level): controle de acesso, monitoramento, etc.
• nível da mensagem (message level): criptografia, compressão, etc.

Serviços CORBA

• Serviço de Nomes
• Mapeador de nomes compostos para IOR:
• Me dê a referência para o objeto "Lanchonete".
• Me dê a referência para o objeto "impressoras/blocoA/lapis".
• Quais são todos os objetos no contexto "impressoras/BlocoB"?
• Possibilidade de criar federação de servidores
• Serviço de Negociação de Objetos (Object Trading Service)
• Guarda atributos sobre objetos como um banco de dados:
• Me dê uma IOR para uma impressora colorida postscript localizada neste bloco, que imprima mais do que 10 páginas por minuto. Dentre os candidatos satisfazendo essas exigências, minimize o preço.
• Possibilidade de criar federação de servidores com diferentes políticas de negociação entre eles.
• Serviço de Segurança
• Controle de acesso
• Criptografia
• Serviço de Envio de Mensagens
• Serviço de Eventos
• Cria-se vários canais para transmissão de eventos (event channels)
• Consumidores podem se inscrever para receber anúncios para certos tipos de eventos
• Produtores podem gerar eventos
• Modelos de distribuição de eventos
1. empurre canônico
2. puxe canônico
3. empurre/puxe híbrido
4. puxe/empurre híbrido
• Serviço de Notificação
• É uma extensão do Serviço de Eventos com suporte para filtros e Qualidade de Serviço
• Serviço de Persitência de Estado
• Serviço de Transações

Exemplo de Código de Cliente (versão crua)

    CORBA::Object_var obj =
          orb->resolve_initial_references ("NameService");
    CosNaming::NamingContext_var ns =
          CosNaming::NamingContext::_narrow (obj);

    CosNaming::Name nome;
    nome.length (2);
    nome[1].id = CORBA::string_dup ("blocoA");
    nome[1].id = CORBA::string_dup ("lapis");
    Impressora imp = Impressora::_narrow(ns->lookup (nome));

    // Inserir código para ler arquivo do disco na variável meuArquivo
    imp->print (meuArquivo);
  }
 catch (const CORBA::Exception &e)
  {
    cerr << "Problemas com impressão: " << e << endl;
    exit (-1);
  }
 exit (0);
}

Exemplo de Código de Cliente (versão usando biblioteca de ajuda)

#include "impressao.h"
#include "ORBHelper.h"
#include "NSHelper.h"
int main (int argc, char * argv[])
 {
   try
    {
      MyORB orb = MyORB::init (argc, argv);
      MyNS  ns  = orb->getNS();
      Impressora imp = ns->lookup ("blocoA/lapis", Impressora);
      // Inserir código para ler arquivo do disco na variável meuArquivo
      imp->print (meuArquivo);
    }
   catch (const CORBA::Exception &e)
    {
      cerr << "Problemas com impressão: " << e << endl;
      exit (-1);
    }
   exit (0);
 }

Funcionalidades Adicionais

• Tolerância a Falhas
• Comunicação de Grupo
• Tempo Real
• Componentes (Corba Component Model - CCM)
• Repositório de Interfaces
• Repositório de Implementações
• Especificação de Troca de Mensagens (CORBA Messaging)
• suporte para mensagens assíncronas
• "time-independent invocation" (???)
• protocolos de roteamento padrão

Definição de Interfaces Padrões para Aplicações

• Saúde
• Finanças
• Negócios
• Telecomunicações
• Industrias
• Transporte
• Especificações disponíveis em http://www.omg.org/technology/documents/specifications.htm