RE: RES: [java-br] Socket

olha, acho que você deve implementar mais coisas ai que são "quase essenciais": 1 - implementar após o accept(), um sistema de login e senha.... 2 - separe um pouco as classes, faça o tratamento dos dados assim que receber a informação, quanto menos Ifs melhor 3 - fazer testes de stress, coloque um while(1<1000) na classe (cliente) para se conectar 1000x e ler/escrever 1000 no socket, depois faça outro teste, 1000 conexões e 100.000 ler/escrever no socket, de acordo com a dica abaixo(4)........... veja o tempo que demorou e quanto consumiu de memoria.....acompanhe o processamento e banda do servidor 4 - quando um cliente realiza conexão é criada uma nova thread para esse cliente, ai ele envia as informações e desconecta...eu acho que nesse caso é legal você manter a conexão ativa, segurando uma thread la na classe do cliente, por exemplo, se conectou...vai enviando informações a vontade, se alguma tentativa falhar, conecta novamente. 5 - trate as exceções com carinho, de inicio tudo bem você vai dando exception e descobrindo onde esta os maiores problemas, mais depois com o tempo, tente tratar as exceções antes delas ocorrerem, para minimizar erros nos clientes. (que seja com ifs) 6 - de acordo com a dica acima(5), se pelo que eu entendi, eu tenho um GPS e falhou vai dar erro e ja era...ai é problema, por que erros vão ter....você vai ter que ter uma tolerancia a esses erros, por exemplo se eu recebi a requisição agora: 20s e não recebi a de 40s, você pode ter um Log e marca-lo, porém sem deixar de funcionar o cliente... qualquer dúvida estamos ai To: java-br@yahoogrupos.com.br
From: lvctecno@yahoo.com.br
Date: Tue, 14 Aug 2012 12:13:49 -0300
Subject: RES: [java-br] Socket


























Ola Marcelo obrigado pelo interesse na ajuda.



Deixa eu te passar o cenário do problema:



Tenho um aplicativo rodando em Android que se comunica através de HTTP

(paginas jsp) com servidor Tomcat, trabalho com sistemas de rastreamento

cada aparelho me envia de 60 em 60 segundos sua id e localização.



Cada aparelho faz em media 5 requisições por minuto, incluso o envio de

localização, ae tu multiplica isso por 100 aparelhos e vamos chegar na casa

das 500 requisições por minuto, o que as paginas estão dando conta sem

problemas.



O meu problema está no consumo, pois cada requisição hoje, me enviando 0 ou

1 ou nada, consome no aparelho 1Kb, quando percebi que via socket consome

somente 1k, ou seja 1023k a menos.



Consegui depois de muito penar na web, construir um servidor socket assim

(sei que devo estar fazendo altos sacrilégios, mas foi como consegui chegar

e até então meu conhecimento em sockets era abaixo de zero) :



Na classe principal:



public static void main(String[] args) throws IOException {



ServerSocket serverSocket = new ServerSocket(PORTA);



System.out.println("INICIADO");



while(true){



Socket socket = serverSocket.accept();



new ServicoThread(socket).start();



}



}



Na classe Serviço:



public class ServicoThread extends Thread {



private final Socket socket;



public ServicoThread(Socket socket) {



this.socket = socket;



}



@Override public void run() {



try {



DataInputStream in = new

DataInputStream(socket.getInputStream());



DataOutputStream out = new

DataOutputStream(socket.getOutputStream());



ExecutaServico es = new ExecutaServico(in);



es.enviar(out);



out.close();



in.close();



socket.close();



} catch (IOException e) {



e.printStackTrace();



}



}



}



Na classe executora assim:



public ExecutaServico(DataInputStream in) {



String nomeServico = "";



try {



this.servico = DataInputStream.readUTF(in).toString().trim();



if(servico.trim().equals("02")){



nomeServico = "LOCALIZACAO";



this.id = DataInputStream.readUTF(in);



this.latitude = DataInputStream.readUTF(in);



this.longitude = DataInputStream.readUTF(in);



this.velocidade = DataInputStream.readUTF(in);



}



public void enviar(DataOutputStream out) throws IOException{



if (this.servico.equals("02")) { //LOCALIZAÇÃO



int i = cadastrarPosicao();



if(i > 0){



out.writeUTF("1");



} else {



out.writeUTF("0");



}



}



public synchronized int cadastrarPosicao(){



int i = 0;



try {



cs = bd.conectar().prepareCall("{call

qry_001(?,?,?,?)}");



cs.setString(1, id);



cs.setString(2, latitude);



cs.setString(3, longitude);



cs.setString(4, velocidade);



i = cs.executeUpdate();



} catch (SQLException ex) {



ex.printStackTrace();



} finally {



try {



if (cs != null){



cs.close();



cs = null;



}



} catch (SQLException c){ }



bd.desconectar();



}



return i;



}



Bom via de regra geral funciona, mas não tenho coragem de colocar em

produção, porque não estou acreditando que este dará conta da quantidade de

requisições, com apenas dois aparelhos em laboratório, a quantidade de

deadlocks é pequena, mas existe, mas com um grande quantidade acredito que

vá explodir.



Se vc puder me ajudar a enquadrar isso que eu fiz até aqui, na maneira como

vc descreveu e conseguirmos montar alguma coisa que responda a uma grande

quantidade de requisições, a gente tenta encarar.



Fique a vontade se quiser me adicionar no MSN.



De antemão muito obrigado pelas informações, cara valeu.



Luciano



De: java-br@yahoogrupos.com.br [mailto:java-br@yahoogrupos.com.br] Em nome

de MarceloMF

Enviada em: terça-feira, 14 de agosto de 2012 11:01

Para: java-br@yahoogrupos.com.br

Assunto: Re: [java-br] Socket



Olá Luciano,



O protocolo http roda em cima do protocolo TCP, você provavelmente devera

escolher entre 2 protocolos:



TCP - Estabelece conexão, realiza o 3way handshake:

PC1 -------------->(SYN) PC2 (Primeiro pacote solicitando conexão)

PC2 ----->(SYN+ACK) PC1 (Segundo pacote confirmando o recebimento do

primeiro)

PC1 -------------->(ACK) PC2 (Terceiro pacote confirmando o recebimento do

segundo e estabelecendo a conexão)



UDP - Não estabelece conexão, não realiza o 3way handshake, por isso é

utilizado para funcionalidades como streeming.



Então é provável que você utilize o TCP, dessa forma você devera criar um

protocolo para trafegar suas informações, normalmente ele se divida em 2

partes:

header -> Informações gerais sobre o pacote/mensagem

payload -> Conteúdo do pacote/mensagem



Exemplo de header:

NOME_TRANSACAO(10POSICOES C/ " " A ESQUERDA)+TAMANHO_PAYLOAD(10POSICOES C/

0 A ESQUERDA)+PAYLOAD(VARIÁVEL)+HASH_PACOTE(64 POSIÇÕES)



Exemplo de payload:

NOME_INFORMACAO1(10POSIÇÕES C/ " " A

ESQUERDA)+TAMANHO_INFORMACAO1(10POSIÇÕES C/ 0 A

ESQUERDA)+INFORMACAO1(VARIÁVEL)

+NOME_INFORMACAO2(10POSIÇÕES C/ " " A

ESQUERDA)+TAMANHO_INFORMACAO2(10POSIÇÕES C/ 0 A

ESQUERDA)+INFORMACAO2(VARIÁVEL)

+NOME_INFORMACAO3(10POSIÇÕES C/ " " A

ESQUERDA)+TAMANHO_INFORMACAO3(10POSIÇÕES C/ 0 A

ESQUERDA)+INFORMACAO3(VARIÁVEL)



O seu pacote:

HEADER+PAYLOAD



Perceba que os campos do header são fixo e que o payload é variável. Como

você define o tamanho do payload e o tamanho de cada informação dentro do

payload, é possível realizar o parser da string tranquilamente.



Não sei qual sua necessidade, mas considere utilizar webservices, seja

rest, wsdl, ou mesmo JMS.



Depois de definido o layout do seu protocolo, virá a parte mais legal, que

é definir como o seu servidor irá processar essas mensagens.



Nesse ponto sugiro uma lida no livro Programação de rede Unix, Capitulo 30

-> Alternativas de projeto cliente/servidor, irei listar os tópicos, pois

sei que pode te ajudar.



30.4 - > Servidor TCP Interativo

30.5 -> Servidor TCP concorrente, um filho por cliente

30.6 -> Servidor TCP pré-bifurcado, sem bloqueio accept

30.7 -> Servidor TCP pré-bifurcado, bloqueio de arquivo em torno de accept

30.8 -> Servidor TCP pré-bifurcado, bloqueio de thread em torno de accept

30.9 -> Servidor TCP pré-bifurcado, passagem de descritor

30.10 -> Servidor TCP concorrente, um thread por cliente

30.11 -> Servidor TCP pré-threaded, um accept por thread

30.12 -> Servidor TCP pré-threaded, thread principal chama accept



Acima temos exemplos da utilização de forks e threads, no seu caso,

provável que utilize threads e definir como funcionara suas threads/pool de

threads será crucial para a escalabilidade da sua aplicação. Sugiro que

você abstraia a linguagem e se concentre nos conceitos... dessa forma você

irá conseguir desenvolver algo bacana.



O Java - Como programar do Deitel possui exemplos simples de como trabalhar

com sockets/threads, legal para fazer e ver funcionando, mas sinceramente

deixa a desejar e por isso recomendei o Programação de rede Unix como

literatura auxiliar.



Na mesma linha, você pode pesquisar sobre JAVA NIO(caso você possua *muitas

transações* concorrentes) e também se preocupar com a criptografia dos

pacotes... seja ela feita na camada de apresentação ssl/tls ou a nível de

aplicação, seja simétrica ou assimétrica.



Boa sorte! Inveja alheia... queria estar com um problema desses nas mãos

\o/.



[]s



--

Att, Marcelo M. Fleury

Blog - http://marcelomf.blogspot.com/

Slides - http://www.slideshare.net/marcelomf/



"O primeiro dever da inteligência é desconfiar dela mesma." By Einstein



[As partes desta mensagem que não continham texto foram removidas]



[As partes desta mensagem que não continham texto foram removidas]


















[As partes desta mensagem que não continham texto foram removidas]



------------------------------------

Para sair da lista, envie email para: java-br-unsubscribe@yahoogroups.com
Para upload/download de arquivos: http://www.yahoogroups.com/files/java-brLinks do Yahoo! Grupos

<*> Para visitar o site do seu grupo na web, acesse:
http://br.groups.yahoo.com/group/java-br/

<*> Para sair deste grupo, envie um e-mail para:
java-br-unsubscribe@yahoogrupos.com.br

<*> O uso que você faz do Yahoo! Grupos está sujeito aos:
http://br.yahoo.com/info/utos.html