Eu tenho um chat que troca mensagens (String
) entre si. Tudo está funcionando corretamente. Porém, agora, quero começar a enviar objetos via Socket
, como por exemplo, uma classe que tem alguns atributos setados por mim (ex: nome, IP, host name, hora, mensagem, etc).
A minha dúvida é a seguinte:
Quando uso apenas String
, para receber os dados, eu faço da seguinte maneira:
Scanner s = new Scanner(servidor.getInputStream());
while (s.hasNext()) {
cliente.writeHistorico(s.nextLine());
}
E para enviar:
PrintStream ps = new PrintStream(socket.getOutputStream());
ps.println("mensagem aqui);
PS: Lembrando que sempre estão dentro de threads e em LOOP. Até aí, sem segredo. Porém, quando vou fazer para ler um objeto:
readObject = new ObjectInputStream(input);
User s = (User) readObject.readObject();
Como vou fazer verificar se o cliente enviou ou não dados para o servidor? Já que dessa maneira, eu não tenho por exemplo, um "hasNext()
". Porque se eu deixar um while(true)
, com a instância de ObjectInputStream
fora, ele não funciona, e se deixar dentro do loop vai ficar criando várias instâncias. Tem alguma maneira de isso? Acho que enrolei um pouco, mas é isso. Já procurei material na net e todos os exemplos possíveis mostram sem usar loop com UM cliente conectado, até mesmo na documentação de sockets mostra apenas como trocar mensagens (String
) e apenas um usuário..
EDITADO:
Fiz um exemplo bem básico. Classe de ler objetos do servidor:
public class ThreadRecebedor extends Thread implements Runnable {
InputStream inputCliente;
ObjectInputStream input;
User user;
public ThreadRecebedor(InputStream inputCliente) {
this.inputCliente = inputCliente;
}
@Override
public void run() {
try {
//while (true) {
input = new ObjectInputStream(inputCliente);
Object aux = input.readObject();
if (aux instanceof User) {
user = (User) aux;
System.out.println(user.getNome());
System.out.println(user.getMsg());
System.out.println(user.getHora());
}
// input.close();
// }
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException ex) {
Logger.getLogger(ThreadRecebedor.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
Classe para enviar os dados:
public class cliente {
public static void main(String[] args) {
try {
Socket cliente = new Socket("192.168.1.7", 1412);
User user = new User();
user.setNome("Teste");
user.setMsg("oi cristiano");
user.setHora(new SimpleDateFormat("HH:mm:ss").format(new Date()));
ObjectOutputStream output = new ObjectOutputStream(cliente.getOutputStream());
output.writeObject(user);
output.flush();
output.reset();
output.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
Da maneira como estão as duas classes, está funcionando. O servidor consegue ler o objeto enviado e mostra no console as propriedades. Mas agora vem o ponto chave: E se eu quiser repassar esses dados para o próprio usuário? Dessa maneira, o socket dele vai estar fechado. E se eu quisesse ficar escutando esse cliente para outros objetos? Como eu faria? Eu juro que li seu comentário umas 3x, mas não consegui entender como fazer isso que quero. Me desculpe pela ignorância.