データの連続送受信に関して。

class Rcv extends Thread {
	final static int SERVER_PORT = 5555;

	public Rcv() {
		this.start();
	}

	public void run() {
		ServerSocket svSoc;
		try {
			svSoc = new ServerSocket( SERVER_PORT );
		} catch ( Exception e) {
		}

		// 接続要求受付、クライアントスレッド生成
		while( true ) {
			Socket		soc;
			try {
				soc = svSoc.accept();
				new Client(soc);
			} catch ( Exception e) {
			}
		}
	}
}

class Client extends Thread {
	private Socket		soc;
	private InputStream	in;
	private int		len;
	private int		total_len;
	private byte[]		temp_buf	= new byte[1024];
	private byte[]		buf = new byte[5000];

	public Client(Socket soc) {
		this.soc = soc;
		run();
	}

	public void run() {
		try {
			in = soc.getInputStream();

			for ( len = 0, total_len = 0;
				( len = in.read( temp_buf, 0, temp_buf.length ) )!= -1;
				total_len += len )
			{
				System.arraycopy( temp_buf, 0, buf, total_len, len );
			}
			in.close();
		} catch ( Exception e ) {
		}
		
		//bufにメッセージが格納させているので要件に応じて処理。
		・
		・
		・