C# socket 终止接收线程以后再开一个接收线程, 会出现一次丢包现象
//开启一个接收信息的线程Threadreceiver=newThread(newThreadStart(receive));receiver.IsBackground=...
//开启一个接收信息的线程
Thread receiver = new Thread(new ThreadStart(receive));
receiver.IsBackground = true;
receiver.Start();
//从客户端接受信息
private void receive(){
while (true){
//如果长度为0, 则说明socket已关闭
trace("正在接收信息");
byte[] bytes = new byte[1024];
int length = socket.Receive(bytes, bytes.Length, 0);
if (length == 0){
trace("访问用户退出 " + socket.RemoteEndPoint);
clean();
break;
}
string str = Encoding.GetEncoding(charset).GetString(bytes, 0, length);
trace("接收信息:" + "\n" + str);
}
}
public void clean(){
trace("访问用户" + socket.RemoteEndPoint + "退出, 清理数据");
socket = null;
receiver.Abort();
}
private void trace(string str){
Console.WriteLine(str);
} 展开
Thread receiver = new Thread(new ThreadStart(receive));
receiver.IsBackground = true;
receiver.Start();
//从客户端接受信息
private void receive(){
while (true){
//如果长度为0, 则说明socket已关闭
trace("正在接收信息");
byte[] bytes = new byte[1024];
int length = socket.Receive(bytes, bytes.Length, 0);
if (length == 0){
trace("访问用户退出 " + socket.RemoteEndPoint);
clean();
break;
}
string str = Encoding.GetEncoding(charset).GetString(bytes, 0, length);
trace("接收信息:" + "\n" + str);
}
}
public void clean(){
trace("访问用户" + socket.RemoteEndPoint + "退出, 清理数据");
socket = null;
receiver.Abort();
}
private void trace(string str){
Console.WriteLine(str);
} 展开
2个回答
展开全部
现在不知道你判断丢包的标准时什么,
同步模式下是有可能出现因为粘包造成的假丢包现象,真丢包我觉得可能性不太大,你现在采用的是同步模式,建议你用异步模式试试。同步模式是在系统自己认为收完了就结束,但异步不是,异步是一旦收到字节就可以取出。
同步模式下是有可能出现因为粘包造成的假丢包现象,真丢包我觉得可能性不太大,你现在采用的是同步模式,建议你用异步模式试试。同步模式是在系统自己认为收完了就结束,但异步不是,异步是一旦收到字节就可以取出。
更多追问追答
追问
我在外部调用clean()终止接收线程,终止while(true)循环.在其他地方又开了一个线程写了一个类似receive()的方法来接收 socket信息
结果调用clean()终止第一个线程以后以后,第二个线程接收不到前台第一次发送的消息, 第二次开始才能接收到,怎么解决这个问题?
追答
什么意思?第二线程肯定无法接受第一次线程中的内容,socket的内容一旦从缓存中取出就不可能再次被读取得。
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询