Hey guys i tried to make a java chat. It actually worked but it got a weird bug.
It's hard to explain but i'll give my best.
First i run the server.
Then 2 clients : chat A chat B.
At chat A i type : "Hello". and the server receives "Hello".
Then at chat B i type : "Hi". and the server receives "Hi".
Then at chat A i type : "Yo"... server receives "Yo"
But when i type "Yay" at chat B the server does not receive that. It only receives data from chat A.
------------------
Output example at server :
Chat A :
Hello
Yo
wtf is happening?
lalala
Chat B :
Hi
Yay
Server log :
Hello
Hi
Yo
(should say Yay but i doesn't)
wtf is happening?
lalala
ServerSide script
Code:
import java.awt.List;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Scanner;
public class Servidor {
ServerSocket server;
Scanner scanner;
PrintWriter[] escritores = new PrintWriter[10];
int indexEscritores = 0;
private void encaminharParaTodos(String texto){
for (int i = 0; i < indexEscritores; i++){
try{
escritores[i].println(texto);
escritores[i].flush();
}catch(Exception yfasfd){}
}
}
public Servidor() {
try {
server = new ServerSocket(5000);
while (true) {
Socket s = server.accept();
new Thread(new EscutaCliente(s)).start();
PrintWriter p = new PrintWriter(s.getOutputStream());
escritores[indexEscritores++] = p;
}
} catch (Exception e) {
}
}
private class EscutaCliente implements Runnable {
public EscutaCliente(Socket socket) {
try {
scanner = new Scanner(socket.getInputStream());
} catch (Exception y) {}
}
@Override
public void run() {
try{
String texto;
while((texto = scanner.nextLine()) != null){
System.out.println(texto);
encaminharParaTodos(texto);
}
}catch(Exception z){}
}
}
public static void main(String[] args) {
new Servidor();
}
}
Client Script
Code:
import java.awt.BorderLayout;
import java.awt.Container;
import java.awt.Font;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
public class Cliente extends JFrame {
JTextField comandoParaEnviar;
Socket socket;
PrintWriter escritor;
JTextArea textoRecebido;
Scanner leitura;
private class EscutaServidor implements Runnable{
@Override
public void run() {
try{
String texto;
while((texto = leitura.nextLine()) != null){
textoRecebido.insert(texto + "\n", 0);
}
}catch(Exception e){}
}
}
public Cliente() {
super("Cliente");
Font fonte = new Font("Serif", Font.PLAIN, 26);
comandoParaEnviar = new JTextField();
comandoParaEnviar.setFont(fonte);
//addKeyListenet
comandoParaEnviar.addKeyListener(new KeyAdapter() {
@Override
public void keyReleased(KeyEvent e) {
if (e.getKeyCode() == KeyEvent.VK_ENTER) {
escritor.println(comandoParaEnviar.getText());
escritor.flush();
comandoParaEnviar.setText("");
comandoParaEnviar.requestFocus();
}
}
});
JButton botao = new JButton("Enviar");
botao.setFont(fonte);
botao.addActionListener(new EnviarListener());
Container envio = new JPanel();
envio.setLayout(new BorderLayout());
envio.add(BorderLayout.CENTER, comandoParaEnviar);
envio.add(BorderLayout.EAST, botao);
//chamar configuracao de rede
configurarRede();
textoRecebido = new JTextArea();
textoRecebido.setFont(fonte);
textoRecebido.setEditable(false);
JScrollPane scroll = new JScrollPane(textoRecebido);
getContentPane().add(BorderLayout.CENTER, scroll);
getContentPane().add(BorderLayout.SOUTH, envio);
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
setSize(500, 300);
setVisible(true);
}
private class EnviarListener implements ActionListener {
@Override
public void actionPerformed(ActionEvent e) {
escritor.println(comandoParaEnviar.getText());
escritor.flush();
comandoParaEnviar.setText("");
comandoParaEnviar.requestFocus();
}
}
private void configurarRede() {
try {
socket = new Socket("127.0.0.1", 5000);
escritor = new PrintWriter(socket.getOutputStream());
leitura = new Scanner(socket.getInputStream());
new Thread(new EscutaServidor()).start();
} catch (Exception e) {
}
}
public static void main(String[] args) {
new Cliente();
}
}
Before you post, read our: 
