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

Chat klient-serwer. Nie tworzy się nowy wątek dla drugiego klienta.
PP
  • Rejestracja:około 11 lat
  • Ostatnio:około 9 lat
  • Postów:40
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.

Kopiuj
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);
		}
	}
}
Kopiuj
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ę :).


Jeśli coś jest głupie, ale działa, to nie jest głupie.
edytowany 3x, ostatnio: PrzepychaczPL
Shalom
  • Rejestracja:około 21 lat
  • Ostatnio:prawie 3 lata
  • Lokalizacja:Space: the final frontier
  • Postów:26433
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".

"Nie brookliński most, ale przemienić w jasny, nowy dzień najsmutniejszą noc - to jest dopiero coś!"
PP
  • Rejestracja:około 11 lat
  • Ostatnio:około 9 lat
  • Postów:40
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.


Jeśli coś jest głupie, ale działa, to nie jest głupie.
Shalom
  • Rejestracja:około 21 lat
  • Ostatnio:prawie 3 lata
  • Lokalizacja:Space: the final frontier
  • Postów:26433
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.


"Nie brookliński most, ale przemienić w jasny, nowy dzień najsmutniejszą noc - to jest dopiero coś!"
edytowany 1x, ostatnio: Shalom
PP
  • Rejestracja:około 11 lat
  • Ostatnio:około 9 lat
  • Postów:40
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.


Jeśli coś jest głupie, ale działa, to nie jest głupie.
Shalom
  • Rejestracja:około 21 lat
  • Ostatnio:prawie 3 lata
  • Lokalizacja:Space: the final frontier
  • Postów:26433
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ą.


"Nie brookliński most, ale przemienić w jasny, nowy dzień najsmutniejszą noc - to jest dopiero coś!"
Zobacz pozostałe 6 komentarzy
PP
Dlatego mówię, że potocznie :). Z tego kursu uczyłem się kiedyś i takie określenie zapamiętałem. Wiesz, czemu to nie tryka? :)
Shalom
A co właściwie ci nie działa? Umiesz podać kod i komunikat błędu? Bo inicjalizowanie finalnych pól klasy w konstrukturze to jest zupełnie normalna rzecz i nie rozumiem gdzie jest problem.
PP
Błędu nie ma. Co nie działa napisane jest w pierwszym poście.
Shalom
Twój błąd jest banalny -> wątek startuje się przez "start" a nie przez "run" ;) Wywołanie run to wywołanie zwykłej metody w aktualnym wątku.

Zarejestruj się i dołącz do największej społeczności programistów w Polsce.

Otrzymaj wsparcie, dziel się wiedzą i rozwijaj swoje umiejętności z najlepszymi.