in.java

net

package com.net.tcp;

import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;
import java.util.Scanner;

public class In extends Thread {

	Socket s;

	In(Socket s) {
		this.s = s;
	}

	@Override
	public void run() {
		InputStream in = null;
		try {
			in = s.getInputStream();

			Scanner sc = new Scanner(in);

			while (true) {
				String message = sc.nextLine();
				System.out.println("\n" + message + "\n");
			}

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

	}
}