作者AizawaYuuiti ( )
看板C_Sharp
标题[问题] Socket同步处理，物件遗失？
时间Thu Mar 30 15:00:29 2017
如题
写了一个能接收多方连线的Socket处理物件
不过连线时常常会出现，已经被舍弃的物件无法被使用这个错误
写一下大致的架构，舍弃掉初始化的部分
/*
CServer接收到一个Client後会建个CClient去处理
然後再持续接收下一个Client
CClient的Socket如果断掉会离开while将他final
*/
class CServer
private Socket m_socketServer;
public void Start(){
m_socketServer.BeginAccept(
new AsyncCallback(ConnectedCallback), m_socketServer
);
}
private void ConnectedCallback(IAsyncResult AR){
Socket server = AR.AsyncState as Socket;
Socket client = server.EndAccept(AR);
CClient c = new CClient(this,client);
server.BeginAccept(new AsyncCallback(ConnectedCallback), server);
while(c.isConnected){
//Loop
}
c.Final();
}
}
/*
CClient
由CServer统一呼叫OnTimer去接收讯息
一次呼叫会连续接收直到没讯息为止
isReceiving是为了防止CServer在一次循环呼叫时OnTimer重复处理
*/
class CClient{
CServer m_cServer;
Socket m_Socket;
public CClient(CServer cServer, Socket socket){
m_cServer = cServer;
m_Socket = Socket;
}
public void OnTimer() //由CServer统一呼叫，100ms
{
if (!m_bIsReceiving)
{
m_bIsReceiving = true;
m_Socket.BeginReceive(bytesBuffer, 0, bytesBuffer.Length,
SocketFlags.None, new AsyncCallback(ReceiveCallback), null
);
}
}
public void Final()
{
//bytesBuffer = null;
if (m_Socket != null)
{
m_Socket.Disconnect(false);
m_Socket.Close();
m_Socket = null;
}
}
private void ReceiveCallback(IAsyncResult AR)
{
if (m_Socket == null)
{
return;
}
int recieved = m_Socket.EndReceive(AR); //问题点在这
if (recieved <= 0)
{
m_bIsReceiving = false;
return;
}
byte[] bytesReceived = new byte[recieved];
Array.Copy(bytesBuffer, 0, bytesReceived, 0, recieved);
string strReceived = Encoding.Unicode.GetString(bytesReceived);
//此处纪录strReceived;
m_Socket.BeginReceive(bytesBuffer, 0, bytesBuffer.Length,
SocketFlags.None, new AsyncCallback(ReceiveCallback), null
);
}
}
问题来了
问题点是明明CServer感觉就卡在While那边没有Final掉CClient
但在ReceiveCallback时却会在Socket.EndReceive那边错误
明明前面有判定m_Socket是否null
他却说m_Socket这个东西已经被丢弃了却仍拿来用
有在想是不是哪边加using把他lock住会比较好
不过却好像造成了dead lock(遮脸)
--
※ 发信站: 批踢踢实业坊(ptt.cc), 来自: 220.128.131.226
※ 文章网址: https://webptt.com/cn.aspx?n=bbs/C_Sharp/M.1490857231.A.955.html