Multithread-call center support

[Hamzah khammash]

Hello ,
I am creating simple multithread call center application server received messages from clients with there IDs and response for each one independently i mean when server is send message to client1 client2 connot see it and same to client 2 ,my problem is when i send or received messages it not sent directly it wait until all clients and server to send then it do send and receive process i will put the code of server , client code didn't contain anything special

import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;

import java.io.IOException;

public class Server {

	private int port = 5878;
	private ServerSocket serverSocket;
	private Socket socket;

	HashMap<Integer, Socket> map = new HashMap<Integer, Socket>();
	PrintWriter writer;
	int clientCode = 0;
	ServerThread severServerThread;

	public Server() throws IOException {
		serverSocket = new ServerSocket(port);
		System.out.println("waiting For connection on this port " + " " + port);

		while (true) {
			socket = serverSocket.accept();
		
			new ServerThread(socket).start();

		}

	}

	public static void main(String[] args) throws IOException,
			ClassNotFoundException, InterruptedException {
		Server server = new Server();
		// server.invokingMethod();

	}
}

server thread code :

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;

class ServerThread extends Thread {

	Socket socket = null;
	HashMap<Integer, Socket> map = new HashMap<Integer, Socket>();
	BufferedReader inputStream;
	BufferedWriter outputStream;
	BufferedWriter bufferedWriter;
	BufferedReader inputSt;
	int clientCode = 0;

	public ServerThread(Socket clientSocket) {
		this.socket = clientSocket;
		Random random = new Random();
		clientCode = Math.abs(random.nextInt());
	}

	public synchronized void run() {

		try {

			inputStream = new BufferedReader(new InputStreamReader(
					socket.getInputStream()));

			outputStream = new BufferedWriter(new OutputStreamWriter(
					socket.getOutputStream()));
			outputStream.flush();

			inputSt = new BufferedReader(new InputStreamReader(System.in));

			processing();

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

	public void add(Integer clientCode) {

		map.put(clientCode, socket);
	}

	public void processing() throws IOException, ClassNotFoundException, InterruptedException {
		System.out.println("Client with ClientCode " + clientCode + " "
				+ "Connected");
		add(clientCode);
		String message = "Connected Succefully";
		send(message);

	}

	public synchronized void send(String message) throws IOException,
			ClassNotFoundException, InterruptedException {
		while (true) {
			message = inputSt.readLine();

			outputStream.write(message);
			outputStream.newLine();
			outputStream.flush();
			outputStream.flush();
			outputStream.flush();
			outputStream.flush();
            Thread.sleep(1000);
			recive();
		}

	}

	public void recive() throws IOException, ClassNotFoundException {
		System.out.println("message from client: " + clientCode + ">>>"
				+ inputStream.readLine());
		outputStream.flush();

	}

	public void invokingMethod() throws IOException, ClassNotFoundException,
			InterruptedException {

		processing();
		close(clientCode);
	}

	public int getclientCode() {
		return clientCode;
	}

	public void close(int clientCode) throws IOException,
			ClassNotFoundException {
		System.out.println("The Client is disconnected");
		inputSt.close();
		inputStream.close();
		outputStream.close();
		socket.close();

	}

}