Socket entre Java e Delphi

Thread.start() Membro desde: 26/12/2006 19:36:35 Mensagens: 42 Offline

Olá a todos!
Estou implementando uma comunicação socket entre um site desenvolvido em java (Servidor) e uma aplicação Delphi (Cliente).
O servidor java está ok... recebe mensagens do cliente delphi sem problemas, porém, não estou conseguindo fazer com que o retorno do servidor chegue ao cliente. Segue abaixo trechos simplificados do código.

Estou utilizando Delphi 7 com o componente TClienteSocket, original do próprio delphi.

Qualquer sugestão será bem-vinda.

[]s

Juarez

public serverSocket() {
serverSocket = new ServerSocket(1000);
while (true) {
System.out.println("Socket Server inicializado.");
socket = serverSocket.accept();
System.out.println("client conectado");

in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
out = new PrintWriter(socket.getOutputStream(), true);

System.out.println(in.readLine()); // recebe mensagem do cliente. funciona corretamente

out.write("msg de retorno ao cliente"); // nao funcionou. Não chega nada no socket do delphi 7
out.println("msg de retorno ao cliente"); // nao funcionou. Não chega nada no socket do delphi 7

System.out.println("Socket Server finalizado.");
}
}

procedure TfrmCliente.ClientSocket1Read(Sender: TObject;
Socket: TCustomWinSocket);
Var x: String;
begin

showmessage('Chegou mensagem do socket servidor');

...
...
Código para manipulação dos dados recebidos
...
...
end;

JavaTeenager Membro desde: 27/03/2006 10:59:38 Mensagens: 181 Offline

tenta um

depois das linhas

considere seriamente a utilização de webservices.
xfire para servir o com java e uma simples maneira de consumir pelo delphi http://www.linhadecodigo.com.br/Artigo.aspx?id=774

GUJ Master Membro desde: 16/12/2004 17:09:19 Mensagens: 1787 Offline

Adiciona um componente TServerSocket na mesma porta

Thread.start() Membro desde: 26/12/2006 19:36:35 Mensagens: 42 Offline

ricardosoares wrote:considere seriamente a utilização de webservices.
xfire para servir o com java e uma simples maneira de consumir pelo delphi http://www.linhadecodigo.com.br/Artigo.aspx?id=774

Olá Ricardo!
Ainda estou em tempo de partir para outra solução... Pensei em webservice, mas, achei que seria mais rápido e fácil fazer com socket.

Vc acha que não é confiável utilizar socket nesse caso? Não funcionaria bem?

Valeu!!

Juarez

This message was edited 1 time. Last update was at 03/03/2009 08:15:37

Para pacotes pequenos, use também o comando:

Isso desabilita o algoritmo de Nagle, do próprio TCP, que une pacotes pequenos num pacote maior. Esse algoritmo foi criado para evitar sobrecarga da rede caso aplicações que trabalhem com tinigrams (pacotes minúsculos), estejam operando. O Telnet, por exemplo, antes do algoritmo, enviava um pacote TCP por letra pressionada. E imagine uma rede inteira nos anos 70/80 com pessoas usando o telnet para comunicar com seu mainframe sem esse algoritmo...

Thread.start() Membro desde: 26/12/2006 19:36:35 Mensagens: 42 Offline

adriano.ferranti wrote:tenta um

out.flush();

depois das linhas

out.write("msg de retorno ao cliente"); // nao funcionou. Não chega nada no socket do delphi 7 out.println("msg de retorno ao cliente"); // nao funcionou. Não chega nada no socket do delphi 7

Testei o out.flush(); mas, ainda está faltando alguma coisa... Continua não chegando o retorno do servidor(Java) para o cliente(Delphi) .
Valeu!!

juarezna wrote:

ricardosoares wrote:considere seriamente a utilização de webservices.
xfire para servir o com java e uma simples maneira de consumir pelo delphi http://www.linhadecodigo.com.br/Artigo.aspx?id=774

Olá Ricardo!
Ainda estou em tempo de partir para outra solução... Pensei em webservice, mas, achei que seria mais rápido e fácil fazer com socket.

Vc acha que não é confiável utilizar socket nesse caso? Não funcionaria bem?

Valeu!!

Juarez

Não digo que socket não é confiável. Digo apenas que webservices já conta com frameworks dotados de uma certa segurança embutida e controle de acesso. Outro ponto a ser considerado é que algumas redes tem restrições a sockets puros, limitando o trafego em http/https apenas.

Quanto a rapidez do desenvolvimento, volto a recomendar um estudo do XFire e uma olhada no link demonstrando a facilidade de se consumir um webservice pelo Delphi 7.

juarezna wrote:Testei o out.flush(); mas, ainda está faltando alguma coisa... Continua não chegando o retorno do servidor(Java) para o cliente(Delphi) .
Valeu!!

E o comando que eu coloquei, testou também?

Smalltalk Membro desde: 01/03/2009 20:06:37 Mensagens: 1 Offline

Juarezna, tenta usar o código que estou enviando, essa classe que ainda estou montando funciona tanto como cliente como servidor dependendo do construtor usado. Como ainda não terminei (e ainda não sei como resolver o problema) essa classe só responde a primeira conexão, se por acaso o cliente cair, é necessário reiniciar a aplicação para que volte a responder. Já deixei preparado pra responder a mensagem do mesmo jeito que receber. Alías, se conseguir resolver o problema das desconexões, me avisa!!!

import java.io.*;
   import java.net.*;

public class Conexao extends Thread {
   
      private ServerSocket serverSock;
      private Socket clientSock;
      private boolean tipoConex; //false=Servidor e true=Cliente
      private String mensagem;
      private InputStreamReader isr;
      private OutputStreamWriter osw;
    
    //Construtor para ser Servidor
       public Conexao(int porta) {
         super("Server");
         try {
            serverSock = new ServerSocket(porta);
            tipoConex = false;
         } 
             catch (IOException e) {
               System.err.println("Erro: nao foi possivel criar o socket");
               System.exit(1);
            }
      }
    
    //Construtor para ser Cliente
       public Conexao(String serverIP, int serverPort) {
      
         try {
            clientSock = new Socket(serverIP, serverPort);
            isr = new InputStreamReader(clientSock.getInputStream());
            osw = new OutputStreamWriter(clientSock.getOutputStream());
            tipoConex = true;
         } 
             catch (UnknownHostException e) {
               System.err.println("Nao foi possivel conectar em " + serverIP);
               System.exit(1);
            } 
             catch (IOException e) {
               System.err.println("Falha geral ao tentar conectar em " + serverIP);
               System.exit(1);
            }
      }
   
       public void run() {
      
         if (tipoConex == false) {
            // Procura por clientes
            while (true) {
                // Espera por cliente
               if (serverSock == null) {
                  return;
               }
               try {
                  clientSock = serverSock.accept();
               } 
                   catch (IOException e) {
                     System.err.println("Erro: nao foi possivel conectar ao cliente");
                     System.exit(1);
                  }
            
                // Processa requisicoes de cliente
               try {
                  isr = new InputStreamReader(clientSock.getInputStream());
                  osw = new OutputStreamWriter(clientSock.getOutputStream());
               
                  while (true) {
                     String msgRecebida = "";
                     int tamanho = clientSock.getInputStream().available();
                     for (int counter = 0; counter < tamanho; counter++) {
                        msgRecebida += (char) isr.read();
                     }
                     if (tamanho != 0) {
                        mensagem = msgRecebida;
                     }
                  }
               } 
                   catch (Exception e) {
                     System.err.println("Error: " + e);
                     e.printStackTrace();
                  }
            }
         } 
         else {
            while (true) {
               try {
                  String msgRecebida = "";
                  int tamanho = clientSock.getInputStream().available();
                  for (int counter = 0; counter < tamanho; counter++) {
                     msgRecebida += (char) isr.read();
                  }
                  if (tamanho != 0) {
                     mensagem = msgRecebida;
                  }
               } 
                   catch (Exception e) {
                     System.err.println("Error: " + e);
                     e.printStackTrace();
                  }
            }
         }
      }
   
       public String getMensagem() {
         if (mensagem != null) {
            String msgRetorno = mensagem;
            mensagem = null;
            return msgRetorno;
         }
         return null;
      }
   
       public boolean enviaMensagem(String mensagem) {
         try {
            osw.write(mensagem);
            osw.flush();
            return true;
         } 
             catch (Exception e) {
               return false;
            }
      
      
      }
   
       public static void main (String args[]){
         Conexao c = new Conexao(5555);
         c.start();
         while (true){
            try{
               if (c.enviaMensagem(c.getMensagem())){
                  System.out.println("mensagem enviada com sucesso!");
               }
            }
                catch(Exception e){
                  System.out.println("ooops deu erro");
               }
         }	
      }
   }

Thread.start() Membro desde: 26/12/2006 19:36:35 Mensagens: 42 Offline

ViniGodoy wrote:Para pacotes pequenos, use também o comando:
socket.setTcpNoDelay(true);

Isso desabilita o algoritmo de Nagle, do próprio TCP, que une pacotes pequenos num pacote maior. Esse algoritmo foi criado para evitar sobrecarga da rede caso aplicações que trabalhem com tinigrams (pacotes minúsculos), estejam operando. O Telnet, por exemplo, antes do algoritmo, enviava um pacote TCP por letra pressionada. E imagine uma rede inteira nos anos 70/80 com pessoas usando o telnet para comunicar com seu mainframe sem esse algoritmo...

Olá!! Testei também o comando, mas a mensagem continua não chegando ao Delphi:

procedure TfrmCliente.ClientSocket1Read(Sender: TObject;
Socket: TCustomWinSocket);
begin
showmessage('Chegou mensagem do socket servidor');
end;

[]s

Use o whireshark para dar uma olhada na conexão e ver se o problema é do lado do Java ou do Delphi. Está tudo certo demais para ser problema do Java.

Amigo,

Tenta utilizar o PrintStream do java no lugar do OutputStreamWriter para ver no quê da.

Olha, no seu cliente você precisa colocar um estrutura parecida como abaixo para ele ficar verificando "eternamente" quando chega um mensagem. Se você simplesmente der um system.out no in.readLine() pode ser que nesse momento realmente não tenha nada a exibir. Dai é bom você olhar o código bergão.

Outro detalhe, e que para seu server java suportar mais de um cliente é necessário usar Threads.

Aproveitando o topico, gostaria de tirar um dúvida. É possível ter um servidor socket em um aplicativo .war rodando em um servidor de aplicação?

Abraço

Você só deve usar o PrintStream se for enviar mensagens de texto.

Smalltalk Membro desde: 11/03/2009 16:42:02 Mensagens: 2 Offline

Acredito estar com o mesmo problema.
Este caso já foi resolvido?

Notícias, artigos e o maior fórum brasileiro sobre Java