Então pessoal, estou vendo Socket´s e não estou conseguindo fazer rodar o tal socket ae...
Erro:java.net.SocketException: Connection reset
at java.net.SocketInputStream.read(SocketInputStream.java:168)
at java.net.SocketInputStream.read(SocketInputStream.java:182)
at java.io.DataInputStream.readLine(DataInputStream.java:496)
at br.com.sovis.servidor.ComunicacaoSocket.comunicacao(ComunicacaoSocket.java:51)
at br.com.sovis.servidor.ComunicacaoSocket.run(ComunicacaoSocket.java:36)
at br.com.sovis.servidor.ServidorSocket.start(ServidorSocket.java:38)
at serversocket.Main.main(Main.java:24)
public class ServidorSocket {
private ServerSocket serverSocket = null;
private Socket socket = null;
private ComunicacaoSocket comunicacao = null;
private ConfiguracaoServerSocket configuracao = null;
public ServidorSocket (ConfiguracaoServerSocket configuracao) {
this.configuracao = configuracao;
}
public void start() {
try {
serverSocket = new ServerSocket(configuracao.getPorta());
System.out.println("Aguardando Conexão... [" + configuracao.getPorta() + "]");
while (true) {
socket = serverSocket.accept();
System.out.println("Conectado a: " + socket.getInetAddress().getHostAddress());
comunicacao = new ComunicacaoSocket(socket);
comunicacao.run();
//accept a connection ;
//create a thread to deal with the client ;
}
} catch (IOException ex) {
Logger.getLogger(ServidorSocket.class.getName()).log(Level.SEVERE, null, ex);
}
}
public void stop() {
try {
socket.close();
serverSocket.close();
socket = null;
serverSocket = null;
} catch (IOException ex) {
Logger.getLogger(ServidorSocket.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
public class ComunicacaoSocket extends Thread {
private DataInputStream input = null;
private DataOutputStream output = null;
private Socket socket = null;
private String mensagem = "";
public ComunicacaoSocket(Socket socket) {
this.socket = socket;
}
@Override
public void run() {
try {
input = new DataInputStream(socket.getInputStream());
output = new DataOutputStream(socket.getOutputStream());
comunicacao();
System.out.println("Descontado de: " + socket.getInetAddress().getHostAddress());
output.close();
input.close();
socket.close();
} catch (IOException ex) {
Logger.getLogger(ComunicacaoSocket.class.getName()).log(Level.SEVERE, null, ex);
}
}
public void comunicacao() throws IOException{
while (true) {
mensagem = "";
mensagem = input.readLine();
System.out.println("Recebeu: " + mensagem);
}
//TODO: Verificar Possibilidade de retornar alguma mensagem para o Cliente
}
}
public class ClienteSocket {
public static void main(String[] args) {
Socket socket = null;
PrintWriter out = null;
BufferedReader in = null;
try {
socket = new Socket("localhost", 90);
out = new PrintWriter(socket.getOutputStream());
//in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
out.write("Enviando Dados...");
} catch (UnknownHostException ex) {
Logger.getLogger(ClienteSocket.class.getName()).log(Level.SEVERE, null, ex);
} catch (IOException ex) {
Logger.getLogger(ClienteSocket.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
Alguma coisa simples que não estou percebendo?!?!?!
