chr*_*xko 4 c# java sockets android tcp
我有一个Android客户端和一个C#服务器.它们通过套接字进行通信,C#服务器处理异步接收.
通信本身没有任何问题.我可以在服务器上验证客户端并相互发送消息.但是,如果我尝试通过客户端关闭套接字
socket.close();
Run Code Online (Sandbox Code Playgroud)
服务器被空包发送"垃圾邮件".一旦OutputStream关闭,就会发生这种情况.
这是我的Android客户端代码:
public void run()
{
try
{
InetAddress serverAddr = InetAddress.getByName(pServerIp);
Socket socket = new Socket(serverAddr, pServerPort);
try
{
OutputStream socketoutstr = socket.getOutputStream();
OutputStreamWriter osr = new OutputStreamWriter( socketoutstr );
bw = new BufferedWriter( osr );
InputStream socketinstr = socket.getInputStream();
InputStreamReader isr = new InputStreamReader( socketinstr );
br = new BufferedReader( isr );
User tmp = Login("SESAM", "PASSWORD");
if(tmp != null)
{
Log.e("TCP", "Login succeeded!");
user = tmp;
}
else
{
Log.e("TCP", "Login failed!");
socket.close();
}
}
catch(Exception e)
{
Log.e("TCP", "S: Error", e);
socket.close();
}
finally
{
}
}
}
Run Code Online (Sandbox Code Playgroud)
这是我处理传入数据的服务器代码的一部分:
private void WaitForData()
{
try
{
WorkerCallback = new AsyncCallback(OnDataReceived);
UndefinedPacket packet = new UndefinedPacket();
socket.BeginReceive(packet.DataBuffer, 0, packet.DataBuffer.Length, SocketFlags.None, WorkerCallback, packet);
}
catch (SocketException se)
{
Console.WriteLine(se.Message);
}
}
private void OnDataReceived(IAsyncResult asyn)
{
UndefinedPacket socketData = (UndefinedPacket)asyn.AsyncState;
try
{
int CharCount = socket.EndReceive(asyn);
char[] chars = new char[CharCount];
System.Text.Decoder d = System.Text.Encoding.UTF8.GetDecoder();
String text = System.Text.Encoding.UTF8.GetString(socketData.DataBuffer);
int charLen = d.GetChars(socketData.DataBuffer, 0, CharCount, chars, 0);
String data = new String(chars);
if (data.Length > 0)
{
IClientPacket packet = PacketFactory.GetInstance(data);
server.PacketManager.AddIncomingPacket(packet, this);
}
Console.WriteLine("Received Data!");
WaitForData();
}
catch (ObjectDisposedException)
{
Console.WriteLine("OnDataReceived: Socket has been closed");
server.RemoveWorkerSocket(this);
}
catch (SocketException se)
{
if (se.ErrorCode == 10054) // Connection reset by peer
{
string msg = "Client Disconnected";
Console.WriteLine(msg);
server.RemoveWorkerSocket(this);
}
else
{
Console.WriteLine(se.Message);
server.RemoveWorkerSocket(this);
}
}
catch (Exception e)
{
Console.WriteLine(e.Message);
server.RemoveWorkerSocket(this);
}
}
Run Code Online (Sandbox Code Playgroud)
当我关闭Android模拟器时,我收到正确的服务器消息:"Client Disconnected".
但是当我关闭Outputstream或者客户端OnDataReceived()上的整个套接字被反复调用时,data.length为'0'.
谢谢您的帮助!
| 归档时间: |
|
| 查看次数: |
4302 次 |
| 最近记录: |