Archief - JAVA chat programma

        private MulticastSocket socket;
	private ExecutorService threadPool = Executors.newFixedThreadPool(10);

	public Server(MulticastSocket socket) {
		this.socket = socket;
	}

	public void run() {

		MulticastSocket link = null;

		try {

			do {
				[U][B]link = socket.accept();[/B][/U]
                 
                                .........

MulticastSocket s = new MulticastSocket(34989);
s.joinGroup(InetAddress.getByName("225.4.5.6"));

byte buf[] = new byte[1024];
		    
// Create a DatagramPacket (udp)
DatagramPacket pack = new DatagramPacket(buf, buf.length, InetAddress.getByName("225.4.5.6"), 34989);
		    
s.send(pack);

byte buf[] = new byte[1024];
DatagramPacket pack = new DatagramPacket(buf, buf.length);
	    
s.setSoTimeout(0);
s.receive(pack);
	    
//System.out.println("Received data from: " + pack.getAddress().toString() + ":" + pack.getPort() + " with length: " + pack.getLength());
	    
String result = new String(pack.getData());

package MulticastServer;

import java.net.*;
import java.io.*;
import java.util.*;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Server {

	private ExecutorService threadPool = Executors.newFixedThreadPool(10);

	private Map<Socket, PrintWriter> clients = new HashMap<Socket, PrintWriter>();

	public Server(int port) {
		listen(port);
	}

	/*
	 * het gewone luisteren op een poort en als er een client verbinding maakt
	 * deze aan de map met clients toevoegen
	 */
	private void listen(int port) {

		ServerSocket serverSocket = null;
		Socket socket = null;

		try {

			serverSocket = new ServerSocket(port);
			System.out.println("Server started");

			while (true) {
				socket = serverSocket.accept();
				System.out.println("Connected " + socket.toString());

				PrintWriter out = new PrintWriter(socket.getOutputStream(),
						true);

				clients.put(socket, out);

				threadPool.execute(new ChatThread(this, socket));
			}

		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	/*
	 * met behulp van de map met clients naar alle clients het bericht sturen
	 * dmv een iterator
	 */
	public void sendToAll(String message, Socket currentSocket) {
		synchronized (clients) {

			Set<Socket> socketSet = clients.keySet();
			Iterator<Socket> iterator = socketSet.iterator();

			while (iterator.hasNext()) {

				Socket soc = iterator.next();

				if (soc != currentSocket) {
					PrintWriter out = clients.get(soc);
					out.println(message);
				}
			}
		}
	}

	/*
	 * als een clients afsluit moet deze terug uit de map verwijders worden en
	 * de connectie gesloten
	 */
	public void removeConnection(Socket soc) {
		synchronized (clients) {

			clients.remove(soc);
			System.out.println("removed " + soc);

			try {
				soc.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
}