package multiclients; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintStream; import java.io.PrintWriter; import java.net.Socket; import java.net.UnknownHostException; import java.util.Scanner; public class Client { public static String name=""; public static void main(String[] args) throws UnknownHostException, IOException { // TODO Auto-generated method stub Scanner p=new Scanner(System.in); Socket xx=new Socket("127.0.0.1",2016); PrintStream oo=new PrintStream(xx.getOutputStream(),true); BufferedReader i=new BufferedReader(new InputStreamReader(System.in)); while(true) { System.out.println("Enter input for server"); String a=i.readLine(); oo.println(a); } } }
package multiclients; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; public class Server { public static void main(String[] args) throws IOException { new Server().Runserver(); } public void Runserver() throws IOException { ServerSocket x=new ServerSocket(2016); System.out.println("Server up ready for connections"); while(true) { Socket ll=x.accept(); new ServerThread(ll).start(); } } }
package multiclients; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.Socket; public class ServerThread extends Thread { Socket xx; String message=null; Client x=new Client(); ServerThread(Socket sock) { this.xx=sock; } public void run() { try { BufferedReader clientmessage=new BufferedReader(new InputStreamReader(xx.getInputStream())); while((message=clientmessage.readLine())!=null) { System.out.println("client message"+" "+message); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
var
This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)