Criando uma conex�o real-time em Java e Node.js

Cada vez mais � maior a interaç�o entre o usu�rio e a web, atrav�s dos mais diversos meios, como jogos online, blogs, chats, interaç�es em redes sociais, etc. Toda essa demanda, requer que a comunicaç�o entre os aplicativos, client e server, ser tornem cada vez mais velozes, atendendo um grande n�mero de usu�rio simult�neos de forma eficiente.

As atuais tecnologias que permitem �real-time� incluem: Node.js, banco de dados noSQL (mongodb), Socket.IO, entre outras.

Neste artigo vamos construir uma simples aplicaç�o de comunicaç�o real-time, usando java no client e nodejs no lado servidor. Com a ajuda deste artigo voc� poder� construir aplicativos Java (desktop, mobile, etc.) se comunicando com tecnologias real-time.

Nota: Conheça os Treinamentos Completos de Java da DevMedia.

Vamos construir um sistema bem simples, baseado em troca de mensagens no estilo �ping-pong".

Para isso, as seguintes ferramentas s�o necess�rias:

Servidor Linux com Node.js instalado (apt-get install nodejs)
Ambiente de desenvolvimento com Java (Eclipse IDE)

Este artigo fornece os c�digos para que voc� possa montar um pequeno mecanismo de comunicaç�o real-time com Java e node.js. A partir destes exemplos funcionais, voc� poder� avançar, incrementando de acordo com sua necessidade.

Na Listagem 1 temos o c�digo do servidor com Nodejs.


  var net = require('net');
   
  var HOST = '127.0.0.1'; // parametrizar o IP do Listen
  var PORT = 6969; // porta TCP LISTEN
   
  // Cria a inst�ncia do Server e aguarda uma conex�o
  net.createServer(function(sock) {
   
      // Opa, recebemos uma conex�o - um objeto socket � associado � conex�o automaticamente
      console.log('CONNECTED: ' + sock.remoteAddress +':'+ sock.remotePort);
   
      // Adiciona um 'data' - "event handler" nesta inst�ncia do socket
      sock.on('data', function(data) {
          // dados foram recebidos no socket 
          // Escreve a mensagem recebida de volta para o socket (echo)
          sock.write(data);
      });
   
      // Adiciona um 'close' - "event handler" nesta inst�ncia do socket
      sock.on('close', function(data) {
          // conex�o fechada
          console.log('CLOSED: ' + sock.remoteAddress +' '+ sock.remotePort);
      });
   
  }).listen(PORT, HOST);
   
  console.log('Server listening on ' + HOST +':'+ PORT);

Listagem 1. C�digo fonte do servidor usando nodejs

Temos alguns pontos importantes a observar no c�digo acima: logo no in�cio do script, parametrize o IP e Porta onde o servidor nodejs ir� fazer o Listen. Altere o 127.0.0.1 para o ip real (v�lido) do seu servidor, conforme abaixo:


  var HOST = '127.0.0.1'; // parametrizar o IP do Listen
  var PORT = 6969; // porta TCP LISTEN

Veja abaixo a funç�o que � disparada quando chega uma nova conex�o, simplesmente faz um echo de volta para o programa client:


  // Adiciona um 'data' - "event handler" nesta inst�ncia do socket
  sock.on('data', function(data) {
  // Escreve a mensagem recebida de volta para o socket (echo)
              sock.write(data);
  });

Na Listagem 2 temos o c�digo client em Java, que abre uma conex�o socket com o servidor, envia uma mensagem qualquer e a recebe de volta, imprimindo-a na tela.


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
 
/**
 * Classe Java (client) para Comunicaç�o com servidor NodeJS
 * Escreve e recebe um simples "echo" -> "mensagem123"
 * by Douglas.Pasqua
 * http://douglaspasqua.com
 */
public class NodeJsEcho {
  // objeto socket
  private Socket socket = null;

  public static void main(String[] args) throws UnknownHostException, 
  IOException, ClassNotFoundException {
    // instancia classe
    NodeJsEcho client = new NodeJsEcho();

    // conex�o socket tcp
    String ip = "1.1.1.1";
    int port = 6969;
    client.socketConnect(ip, port);

    // escreve e recebe mensagem 
    String message = "mensagem123";

    System.out.println("Enviando: " + message);
    String retorno = client.echo(message);
    System.out.println("Recebendo: " + retorno);
  }

  // realiza a conex�o com o socket
  private void socketConnect(String ip, int port) throws UnknownHostException, IOException {
    System.out.println("[Conectando socket...]");
    this.socket = new Socket(ip, port);
  }           
              
  // escreve e recebe mensagem full no socket (String)
  public String echo(String message) {
    try {
      // out & in 
      PrintWriter out = new PrintWriter(getSocket().getOutputStream(), true);
      BufferedReader in = new BufferedReader
      (new InputStreamReader(getSocket().getInputStream()));

      // escreve str no socket e l�r
      out.println(message);
      String retorno = in.readLine();
      return retorno;
               
      } catch (IOException e) {
      e.printStackTrace();
    }
              
    return null;    
  }

  // obtem inst�ncia do socket
  private Socket getSocket() {
              return socket;
  }
}

Listagem 2. C�digo fonte do client java

Lembre-se da parametrizaç�o do IP e Porta onde o client em java ir� se conectar com o servidor nodejs. Altere o ip 1.1.1.1 para o IP v�lido onde esta hospedado o aplicativo nodejs, conforme o c�digo abaixo:


  // instancia classe
  NodeJsEcho client = new NodeJsEcho();
                          
  // conex�o socket tcp
  String ip = "1.1.1.1";
  int port = 6969;
  client.socketConnect(ip, port);

Na Listagem 3 damos destaque ao m�todo que escreve e recebe a mensagem no socket (nodejs).


// escreve e recebe mensagem full no socket (String)
public String echo(String message) {
  try {
    // out & in 
    PrintWriter out = new PrintWriter(getSocket().getOutputStream(), true);
    BufferedReader in = new BufferedReader(new InputStreamReader(getSocket().getInputStream()));

    // escreve str no socket e l�r
    out.println(message);
    String retorno = in.readLine();
    return retorno;
             
  } catch (IOException e) {
    e.printStackTrace();
  }
  
  return null;
}

Listagem 3. Envio e recebimento de mensagens

Agora, na Figura 1 temos o printscreen do console do Eclipse. Ao rodar o client java nesse IDE, voc� dever� obter uma tela semelhante.

Figura 1. Resultado da compilaç�o

Agora basta evoluir este simples aplicativo para sua necessidade. Espero que tenha aproveitado. Boa sorte!

Saiu na DevMedia!

Programe com o Node.js:
Nesta s�rie conversamos sobre qual � o prop�sito do Node.js e o que o torna diferente de outras tecnologias.

Saiba mais sobre Node.js ;)

Principais conceitos da plataforma Node.js:
Nesta publicaç�o ser�o descritos os principais conceitos da plataforma Node.js, sua aplicabilidade e um breve tutorial para elaboraç�o de um aplicativo de micro blog.

Node.js: Criando uma conex�o real-time em Java

Veja nesse artigo como construir uma pequena aplicação real-time usando Java e Node.js criando uma comunicação entre os dois lados através de socket.

Saiu na DevMedia!

Saiba mais sobre Node.js ;)

Artigos relacionados