Thread: Multithreaded client/server

I have been trying to create a multithreaded client server though not working.

import java.net.*;
import java.io.*;
 
import org.omg.CORBA.PUBLIC_MEMBER;
 
  public class Server implements Runnable{
	 public static void main(String[] args)throws IOException{
		 (new Thread(new Server())).start();
	 }
	 public void run(){
		 try{
		 ServerSocket serverSocket = new ServerSocket(8765);
		 Socket clientAccept = serverSocket.accept();
		 while(true){
		 BufferedReader input = new BufferedReader(new InputStreamReader(clientAccept.getInputStream()));
		 String s = input.readLine();
		 System.out.println(s);
 
		 BufferedReader out = new BufferedReader(new InputStreamReader(System.in));
		 String p = out.readLine();
		 PrintStream print = new PrintStream(clientAccept.getOutputStream());
		 print.println(p);
		 }
		 }catch(IOException e){
			 e.printStackTrace();
		 }
 
 }
  }

import java.io.*;
import java.net.*;
 
public class Client1 implements Runnable{
 
 
	public static void main(String[] args)throws IOException{
	(new Thread(new Client1())).start();
	}
 
 
 
		@Override
			public void run(){
				try{
				while(true){
			    Socket socket = new Socket("127.0.0.1",8765);
				//Attempted output
				BufferedReader out = new BufferedReader(new InputStreamReader(System.in));
				String s = out.readLine();
				PrintStream print = new PrintStream(socket.getOutputStream());
				print.println(s);
				//Attempted Input
				BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
				String p = in.readLine();
				System.out.println(p);
				}
				}catch(IOException e){
					e.printStackTrace();
				}
				}
 
		}

import java.io.*;
import java.net.*;
 
public class Client implements Runnable{
	public static void main(String[] args)throws IOException{
	(new Thread(new Client())).start();
	}
 
 
 
		@Override
			public void run(){
				try{
				while(true){
			    Socket socket = new Socket("127.0.0.1",8765);
				//Attempted output
				BufferedReader out = new BufferedReader(new InputStreamReader(System.in));
				String s = out.readLine();
				PrintStream print = new PrintStream(socket.getOutputStream());
				print.println(s);
				//Attempted Input
				BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
				String p = in.readLine();
				System.out.println(p);
				}
				}catch(IOException e){
					e.printStackTrace();
				}
				}
 
		}

How is it not working? Is there an error?

Thank you for replying, the server does not output to the right client, sometimes the client does not output to the server and sometimes server returns null. I think the data is getting mixed up, I tried to use the synchronized on the run methods though still get mixed wrong results.

I've done the program and it works great though not sure if it would be considered multithreaded which was my aim, what do you guys think?

import java.io.*;
import java.net.*;
public class Server{
	public static void main(String[] args)throws IOException{
		ServerSocket serverSocket = new ServerSocket(8976);
		while(true){
			final Socket clientAccept = serverSocket.accept();
			Runnable Task = new Runnable(){
 
				@Override
				public void run() {
					try {
						input(clientAccept);
						output(clientAccept);
					} catch (IOException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
 
				}
 
 
		};
		new Thread(Task).start();
		}
 
	}
	public static synchronized void input(Socket connection)throws IOException{
		BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
		String read = reader.readLine();
		System.out.println(read);
	}
	public static synchronized void output(Socket connection)throws IOException{
		BufferedReader out = new BufferedReader(new InputStreamReader(System.in));
		String output = out.readLine();
		PrintStream print = new PrintStream(connection.getOutputStream());
		print.println(output);
	}
}

import java.net.*;
import java.io.*;
public class Client{
	public static void main(String[] args)throws IOException{
		Socket socket = new Socket("127.0.0.1",8976);
		while(true){
		BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
		String read = reader.readLine();
		PrintStream print = new PrintStream(socket.getOutputStream());
		print.println(read);
 
		BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
		String out = in.readLine();
		System.out.println(out);
		}
 
	}
}

java concurrency in practice has been a great help.
Thanks for the advice so far guys.

I'm trying to do the same task with thread pools and it works for around two cycles then the server stops inputting and outputting, I'm not sure what the problems is, please could someone advise me.

import java.net.*;
import java.io.*;
public class Client{
	public static void main(String[] args)throws IOException{
		Socket socket = new Socket("127.0.0.1",8976);
		while(true){
		BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
		String read = reader.readLine();
		PrintStream print = new PrintStream(socket.getOutputStream());
		print.println(read);
 
		BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
		String out = in.readLine();
		System.out.println(out);
		}
 
	}
}

import java.io.*;
import java.net.*;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
public class Server implements Executor{
	private static  final Executor exec = Executors.newFixedThreadPool(2);
	public static void main(String[] args)throws IOException{
		ServerSocket serverSocket = new ServerSocket(8976);
	   while(true){
		   final Socket clientAccept = serverSocket.accept();
		   Runnable Task = new Runnable(){
 
			@Override
			public void run(){
				try{
					input(clientAccept);
				    output(clientAccept);
				}catch(IOException e){
					e.printStackTrace();
				}
			}
		   };
		   exec.execute(Task);
	   }
 
	}
 
 
	public static synchronized void input(Socket connection)throws IOException{
		BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
		String read = reader.readLine();
		System.out.println(read);
	}
	public static synchronized void output(Socket connection)throws IOException{
		BufferedReader out = new BufferedReader(new InputStreamReader(System.in));
		String output = out.readLine();
		PrintStream print = new PrintStream(connection.getOutputStream());
		print.println(output);
	}
	@Override
	public void execute(Runnable command) {
		new Thread(command).start();
 
	}
 
}