package com.godoro.androidclients;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
public class ChatServer extends Thread {
private ServerSocket serverSocket;
private List<ChatHandler> handlerList = new ArrayList<ChatHandler>();
public ChatServer(int port) throws IOException {
serverSocket = new ServerSocket(port);
}
@Override
public void run() {
System.out.println("Sunucu başlatıldı. Kapı : " + serverSocket.getLocalPort());
while (true) {
try {
Socket socket = serverSocket.accept();
System.out.println("Bir istemci bağlandı ");
ChatHandler handler = new ChatHandler(this, socket);
handlerList.add(handler);
handler.start();
} catch (Exception e) {
e.printStackTrace();
}
}
}
public void send(ChatHandler sender, String message) {
System.out.println("Tüm kotarıcılara ileti gönderiliyor "+handlerList.size());
for (ChatHandler handler : handlerList) {
handler.send("Sunucu "+message);
}
}
public List<ChatHandler> getHandlerList() {
return handlerList;
}
public static void main(String[] args) throws IOException {
int port=9999;
ChatServer server=new ChatServer(port);
server.start();
}
}
Dosyayı İndir