Preciso fazer um trabalho da faculdade, onde é necessário fazer uma comunicação TCP/IP algo como um "chat de bate-papo" é o que tenho em mente para fazer.
Mas surgiram algumas dúvidas, não sei exatamente como perguntá-las então fiz um desenho de duas maneiras que eu acho que deve ser a arquitetura desse tipo de comunicação. Estou utilizando a linguagem Java
para o programa, mas resolvi não especificar a linguagem no Título para que caso alguém de outra linguagem tenha a mesma dúvida possa sanar com o exemplos daqui mesmo. Porém se puderem responder em Java
eu agradeço demais.
Primeira arquitetura que tenho dúvida
Se essa arquitetura estiver correta, então eu precisarei abrir uma Thread para cada conexão Privada que a app1
for fazer?
Por exemplo: A app1
se comunica com a app2
com a porta 99998
e se caso for conversar com a app3
precisará fazer uma Thread
e se comunicar com a app3
através da porta 99997
?
Segunda arquitetura que tenho dúvida
Nessa arquitetura todas as mensagens passarão pelo Servidor Central
e ele será encarregado de enviar a mensagem para determinada aplicação.
Se essa for a arquitetura correta, como posso fazer para o app1
conversar com o app2
? Eu sei que vai passar pelo Servidor Central
mas como ele vai saber que aquela mensagem do app1
vai para o app2
e não para outro?
E como farei pra enviar a mensagem que já está no Servidor Central
para a app
escolhido pelo app1
?
As dúvidas são essas, espero que estejam claras, se não estiverem por favor peço que me alertem para que eu possa corrigir e deixar mais o mais claro possível.
Talvez o código que eu fiz possa ajudar em alguma coisa, não sei como mas vou publicá-lo, está de uma forma bem ruim pois não conheço totalmente os métodos e ainda não formulei uma boa maneira de fazer uma melhor comunicação.
ClienteUm
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.DataInputStream;
//import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
public class ClienteUm {
private static Socket socket;
public static void main(String[] args) {
try {
socket = new Socket("127.0.0.3", 12345);
DataOutputStream fluxoSaidaDados = new DataOutputStream(socket.getOutputStream());
BufferedReader leitorBuffered = new BufferedReader(new InputStreamReader(System.in));
escreverMensagemAoServidor(fluxoSaidaDados, leitorBuffered);
lerMensagemServidor();
} catch (IOException iec) {
System.out.println(iec.getMessage());
}
}
private static void escreverMensagemAoServidor(final DataOutputStream fluxoSaidaDados, final BufferedReader leitorBuffered)
throws IOException {
new Thread() {
public void run() {
String mensagemSaida;
try {
while (true) {
mensagemSaida = leitorBuffered.readLine();
fluxoSaidaDados.writeUTF("Mensagem do Cliente (1): " + mensagemSaida + "=127.0.0.2");
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}.start();
}
private static void lerMensagemServidor() {
new Thread(){
public void run(){
try {
DataInputStream fluxoEntradaDados = new DataInputStream(socket.getInputStream());
while(true){
String mensagemOutroClienteQueVeioPeloServidor = fluxoEntradaDados.readUTF();
System.out.println(mensagemOutroClienteQueVeioPeloServidor);
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}.start();
}
}
Servidor Central
Ele está sendo chamado no código de ServidorUm
pois já era um código que estava testando antes.
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.SynchronousQueue;
public class ServidorUm {
private static ServerSocket servidorSocket;
private static List<Socket> socketsConectados;
public static void main(String[] args) {
try {
servidorSocket = new ServerSocket(12345);
socketsConectados = new ArrayList<Socket>();
do {
Socket socket = servidorSocket.accept();
DataInputStream fluxoEntradaDados = new DataInputStream(socket.getInputStream());
System.out.println("Cliente "+ socket.getLocalAddress().getHostAddress() +" se conectou! ");
socketsConectados.add(socket);
lerMensagemDoCliente(fluxoEntradaDados);
} while (true);
} catch (Exception e) {
System.err.println("Ops! " + e.getMessage());
}
}
private static void lerMensagemDoCliente(final DataInputStream fluxoEntradaDados) {
new Thread() {
public void run() {
String mensagemEntrada = "";
try {
while (true) {
mensagemEntrada = fluxoEntradaDados.readUTF();
String[] teste = mensagemEntrada.split("=");
String mensagem = teste[0];
String paraQuemEnviar = teste[1];
System.out.println("\n" + mensagem);
Socket socketQueReceberaMensagem = socketsConectados.stream()
.filter(x -> x.getLocalAddress().getHostAddress().equals(paraQuemEnviar))
.findFirst().get();
DataOutputStream fluxoSaidaDados = new DataOutputStream(socketQueReceberaMensagem.getOutputStream());
fluxoSaidaDados.writeUTF(mensagem);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}.start();
}
}
ClienteDois ##
import java.io.BufferedReader;
import java.io.DataInputStream;
//import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
public class ClienteDois {
private static Socket socket;
public static void main(String[] args) {
try {
socket = new Socket("127.0.0.2", 12345);
DataOutputStream fluxoSaidaDados = new DataOutputStream(socket.getOutputStream());
BufferedReader leitorBuffered = new BufferedReader(new InputStreamReader(System.in));
escreverMensagemAoServidor(fluxoSaidaDados, leitorBuffered);
lerMensagemServidor();
} catch (IOException iec) {
System.out.println(iec.getMessage());
}
}
private static void lerMensagemServidor() {
new Thread(){
public void run(){
try {
DataInputStream fluxoEntradaDados = new DataInputStream(socket.getInputStream());
while(true){
String mensagemOutroClienteQueVeioPeloServidor = fluxoEntradaDados.readUTF();
System.out.println(mensagemOutroClienteQueVeioPeloServidor);
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}.start();
}
private static void escreverMensagemAoServidor(final DataOutputStream fluxoSaidaDados, final BufferedReader leitorBuffered)
throws IOException {
new Thread() {
public void run() {
String mensagemSaida;
try {
while (true) {
mensagemSaida = leitorBuffered.readLine();
fluxoSaidaDados.writeUTF("Mensagem do Cliente (2): " + mensagemSaida + "=127.0.0.3");
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}.start();
}
}