import java.net.*;
import java.io.*;

public class Srvstream {
	private ServerSocket sock;
	private int port;

	public Srvstream(int p) { port=p;}
	public void start() {
		Socket s;
		try {
			sock=new ServerSocket(port);			
			while(true) {
				s=sock.accept();
				MyThread mth=new MyThread(s);
				mth.run();
			}
		} catch (Exception ex) { System.out.println(ex.getMessage()); }
	}	
	
	public static void main(String args[]) {
		Srvstream server=new Srvstream(3000);		
		server.start();
	}
}

class MyThread implements Runnable {
	private Socket s;
	private BufferedReader in;
	private PrintStream out;
	
	public MyThread(Socket s1) { s=s1;}
	public void run() {
		try {
			in=new BufferedReader(new InputStreamReader(s.getInputStream()));
			out=new PrintStream(s.getOutputStream());

			String str=in.readLine();
			System.out.println("Am primit "+str);
			out.println("test");					

		} catch (Exception ex) {System.out.println(ex.getMessage());}
	}
}