Chat klient-serwer. Nie tworzy się nowy wątek dla drugiego klienta.

0

Witam
Piszę prosty chat klient-serwer na socketach. Serwer jest wielowątkowy. Chat ma działać tak, że wszyscy podłączeni klienci widzą co każdy pisze i sami mogą pisać. Na początku serwer sam odpisywał podłączonym klientom i wszystko działało. Przerobiłem serwer tak, by rozsyłał otrzymaną wiadomość do wszystkich podłączonych klientów. Gdy podłączę pierwszego klienta, to wszystko działa, ale jak podłączę drugiego, to nie tworzy się dla niego nowy wątek. Dopiero gdy zamknę pierwszego klienta tworzy się wątek dla drugiego.

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;


public class Serwer 
{
	static List<Handler> listaKlientow = new ArrayList<Handler>();
	
	public static void main(String[] args)
	{
		try 
		{
			int i = 1;
			final ServerSocket s = new ServerSocket(8189);
			
			while(true)
			{
				final Socket incoming = s.accept();
				
				//System.out.println("test1");
				Handler handler = new Handler(incoming);
				//System.out.println("test2");
				listaKlientow.add(handler);
				handler.run();
				System.out.println("Serwer: Utworzyłem wątek " + i);
				i++;
			}
		}
		catch(IOException exception) {exception.printStackTrace();}
	}
	
	public synchronized void rozsylanie(String line)
	{
		for(Handler h : listaKlientow)
		{
			System.out.println(line);
			h.wysylanie(line);
		}
	}
}
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;


public class Handler extends Thread
{
	private Socket incoming;
	private PrintWriter out;

	Serwer serwer = new Serwer();
	
	public Handler(Socket socket)
	{
		incoming = socket;
	}
	
	public void run()
	{
		try
		{
			try
			{
				final InputStream inStream = incoming.getInputStream();
				final OutputStream outStream = incoming.getOutputStream();
				
				final Scanner in = new Scanner(inStream);
				out = new PrintWriter(outStream, true);
				
				String line;
				
				out.print("Serwer: Witaj! \n");
				
				while(in.hasNextLine())
				{
					//wczytywanie
					line = in.nextLine();
					System.out.println("Serwer: Wczytałem linię: " + line);
					serwer.rozsylanie(line);
				}
			}
			finally
			{
				Serwer.listaKlientow.remove(this);
				System.out.println("Serwer: Usunalem handler: " + this);
				incoming.close();
			}
		}
		catch(IOException exception) {exception.printStackTrace();}
	}

	public void wysylanie(String line) 
	{
		out.println(line);
	}
}

Czy taki serwer ma w ogóle prawo działać?
Proszę o wyrozumiałość, ponieważ dopiero się uczę :).

0

Bo to jest źle. Widać że nie bardzo rozumiesz co robisz i bezmyślnie klikasz "autofixy" które proponuje ci Eclipse.
Zadania na dziś:

  1. Usuń z kodu wszystkie "static" oprócz tego przy main.
  2. Ustaw wszystkie pola klas jako "private final".
0

Racja, trochę źle ustawiłem modyfikatory dostępu, następnym razem zrobię to lepiej :). Poprawiłem kod, ale nie wszędzie mogę ustawić modyfikator final, ponieważ dalej zmieniam dane pola.

0

A które dokładnie pole? Bo ja widzę tylko pola line, printer i scanner które W OGÓLE nie powinny być polami klasy tylko lokalnymi zmiennymi metody run.

0

Ale PrintWritera używam również w metodzie wysylanie(), więc jeśli się nie mylę, musi być zmienną globalną.
Pole line nie może być final, ponieważ zmienia się za każdym wczytaniem linii. Chyba, że za każdym wczytaniem linii mam tworzyć nową stałą.
Co do reszty, to poprawiłem.

0

Ok, PrintWriter jest ok jako pole obiektu, ale też ma być final i inicjalizowany w konstruktorze.
Line ma W OGÓLE nie być polem obiektu, tylko zwykłą zmienną lokalną.

1 użytkowników online, w tym zalogowanych: 0, gości: 1