求好手点拨一个Java Socket的需求实现不完美的修改方法

求高手点拨一个Java Socket的需求实现不完美的修改方法.
我写了一个Java的Socket程序，其中有一块C端用户向服务器写出数据，服务器经过计算进行回写给用户的功能实现.
        现在小弟遇到了下面的场景：
       C端向服务器写出数据后，服务器得到数据，debug到Socket的写回数据给C端的方法的时候，C端的对应的逻辑无法立即得到服务器发出的报文的故障。
       小弟经过仔细检查：
       1.每一句写出语句都添加了flush语句了.
       2.采用了TCP协议.
       3.在小弟把MyEclipse中的服务器断开后，C端能够立即接收到服务器的通信报文.
       4.如果小弟不断开服务器，那么，C端就会一直傻傻等待.
       这是小弟用的Socket  API：
       

package c_port_packageBJTeacher;

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;

public class SocketClient {

	public Socket getS() {
		return s;
	}

	public void setS(Socket s) {
		this.s = s;
	}

	private Socket s;
	private InputStream in;
	private OutputStream out;
	private BufferedInputStream inByte;
	private OutputStream outByte;
	private BufferedReader inStr;
	private PrintWriter outStr;

	private long size = 0;

	public SocketClient(String ip, int port) {
		try {
			s = new Socket(ip, port);

			in = s.getInputStream();
			out = s.getOutputStream();

			inByte = new BufferedInputStream(in);
			outByte = out;

			inStr = new BufferedReader(new InputStreamReader(in));

			outStr = new PrintWriter(new OutputStreamWriter(out));
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public String readStr() throws IOException {
		synchronized (this.in) {
			return this.inStr.readLine();
		}
	}

	public void writeStr(String content, String MyThreadname) {
		synchronized (this.out) {
			String IP = GetMyUserIP.getMyIP();
			content = content.replaceAll("\n", "<br>");
			outStr.println(content + "丗" + IP + "丗" + MyThreadname + "\r\n");
			// //System.out.println("=============================||||||||||||||||||||||||||||||||||||||||||||"+content+"丗"+IP+"丗"+MyThreadname);
			outStr.flush();
		}
	}

	public File readToFile(File file) throws IOException {
		synchronized (this.in) {
			FileOutputStream fos = new FileOutputStream(file);
			byte[] temp = new byte[1024 * 8];
			int count = 0;
			while (-1 != (count = this.inByte.read(temp))) {
				fos.write(temp, 0, count);
				fos.flush();
			}
			fos.close();
			return file;
		}
	}

	public void writeFile(File file) {
		synchronized (this.out) {
			size = file.length();
			this.noticeFileSize(size);

			FileInputStream fis;
			try {
				fis = new FileInputStream(file);
				byte[] temp = new byte[1024 * 8];
				int count = 0;
				while (-1 != (count = fis.read(temp))) {
					this.outByte.write(temp, 0, count);
					this.outByte.flush();
				}
				fis.close();
			} catch (Exception e) {
				e.printStackTrace();
			}

			// long progress = 0;
			// while (size != (progress = getServerReceiveSize())) {
			// //////"progress : " + (progress / (size / 100)) + "%");
			// }
		}
	}

	private void noticeFileSize(long l) {
		String str = l + "";
		int j = 19 - str.length();
		for (int i = 0; i < j; i++) {
			str = "0" + str;
		}
		this.writeByByte(str);
	}

	protected void writeByByte(String content) {
		synchronized (this.out) {
			try {
				this.out.write(content.getBytes());
				this.out.flush();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}

	private long getServerReceiveSize() {
		synchronized (in) {
			byte[] b = new byte[19];
			try {
				this.in.read(b);
			} catch (IOException e) {
				e.printStackTrace();
			}

			return Long.parseLong(new String(b));
		}
	}

	public String getProgress() {
		long l = this.getServerReceiveSize() / (size / 100);