多线程同步实现 接收数据

private TcpListener _listener;
public static TcpClient _client;
private int _listenterPort = 8401;
private Thread clientservice;
private DateTime Time;
public static string str1 = AppDomain.CurrentDomain.SetupInformation.ApplicationBase;
public static string tempPath = DateTime.Now.Year.ToString() + "-" + DateTime.Now.Month.ToString() + "-" + DateTime.Now.Day.ToString();
private delegate void AddTest(string message);
private Thread theadLisener;
private int n = 1;
private int max = 10;
private object monitor = new object();
public Form1()
{
InitializeComponent();
theadLisener = new Thread(new ThreadStart(Listen));
theadLisener.Start();

}

static public object LockShare = new object();



public void Listen()
{
AddTest add = new AddTest(AddListBox);
_listener = new TcpListener(_listenterPort);
try
{
_listener.Start();
}
catch(Exception ex)
{
SendNotice.SendBoth("监听错误", ex.Message, "启动监听");
}

this.BeginInvoke(add, new object[] { "开始侦听" });
while (true)
{


try
{

_client = _listener.AcceptTcpClient();
this.BeginInvoke(add, new object[] { _client.Client.RemoteEndPoint.ToString() + "已经建立好连接" });
clientservice = new Thread(new ThreadStart(this.ServiceClient));
clientservice.Start();

//ManualResetEvent vent = new ManualResetEvent(false);
//ThreadPool.QueueUserWorkItem(new WaitCallback(ServiceClient));

//vent.WaitOne(Timeout.Infinite, true);

}
catch (Exception ex)
{
this.BeginInvoke(add, new object[] { ex.Message });
}


}
}
private void test(object state)
{ }

private void ServiceClient()
{
AddTest add = new AddTest(AddListBox);
bool keepalive = true;
string md5 = "";


while (keepalive)
{
lock (monitor)
{
for (; n < max; n++)
{
try
{
byte[] bytes = new byte[1024];
NetworkStream stream = _client.GetStream();
int count = stream.Read(bytes, 0, bytes.Length);
Time = DateTime.Now;
if (File.Exists(tempPath))
{
}
else
{
Directory.CreateDirectory(str1 + tempPath);

}

string fileTime = Time.Year.ToString() + Time.Month.ToString() + Time.Day.ToString() + "-" +
Time.Hour.ToString() + Time.Minute.ToString() + Time.Second.ToString();
string fileName = str1 + tempPath + "\\" + fileTime + ".xml";
if (count > 0)
{
FileStream fstream = new FileStream(fileName, FileMode.Create);
fstream.Write(bytes, 0, count);
fstream.Close();
string type = this.Check(fileName).ToLower().Trim();
if (type.Equals("request"))
{
System.Random rad = new Random();
string radCode = rad.Next(10000000, 99999999).ToString();

writeSequence(radCode);
FileStream fs = new FileStream(str1 + "sequence.xml", FileMode.Open);
byte[] buffer = new byte[fs.Length];
fs.Read(buffer, 0, buffer.Length);
stream.Write(buffer, 0, buffer.Length);

_client.Client.Send(buffer, buffer.Length, 0);
fs.Dispose();
md5 = MD5Encrypt(radCode, 32);
}
else if (type.Equals("md5"))
{
string md_5 = GetMD5(fileName);
if ((md_5 == md5) && !md5.Equals(""))
{
writeResult(true);
FileStream fs = new FileStream(str1 + "result.xml", FileMode.Open);
byte[] buffer = new byte[fs.Length];
fs.Read(buffer, 0, buffer.Length);
stream.Write(buffer, 0, buffer.Length);
this.BeginInvoke(add, new object[] { "MD5验证通过。" });
fs.Dispose();
}

else
{
writeResult(false);
FileStream fs = new FileStream(str1 + "result.xml", FileMode.Open);
byte[] buffer = new byte[fs.Length];
fs.Read(buffer, 0, buffer.Length);
stream.Write(buffer, 0, buffer.Length);
fs.Dispose();

// this.BeginInvoke(add, new object[] { "MD5验证失败，连接关闭。" });
_client.Close();
clientservice.Abort();
}
}
else
{

SqlTool st = new SqlTool();
st.createCon();
bool existEnergy = getEnergy(fileName);
if (existEnergy)
{
try
{
insertSql(fileName);
this.BeginInvoke(add, new object[] { DateTime.Now.ToString() + "数据入库。" });
}
catch
{ }

}
else
{
SendNotice.SendBoth("接收文件", "不是能耗文件", "接收服务");
}

}
}



}
catch (Exception ex)
{

clientservice.Abort();
this.BeginInvoke(add, new object[] { ex.Message });
SendNotice.SendBoth("接收文件", ex.Message, "接收服务");

}

}
Monitor.Wait(monitor);
}

}
}
不知道怎么改了 有两个客户端链接 第一次的时候两个都可以发送过数据 之后就只有后面开启的那个客户端能够发过来数据 急急急！！！！！！！