论坛徽章:: 0

电梯直达

1楼 [收藏(0)] [报告]

发表于 2013-02-12 15:30 |只看该作者 |倒序浏览

各位大侠,我在使用C# 运用System.Net.Sockets写客户端,我希望能使用一个异步的Task创造一个无限循环去不断尝试读socket端口是否有输入,但是现在遇到了一个奇怪的问题,百思不得其解,具体问题代码之中有描述.祝各位新春快乐!

namespace SocketServer
{
public partial class Form1 : Form
{
private Socket _socket = null;
private Socket client = null;
private static byte[] ReadBuffer = new byte[1024];
private static byte[] WriteBuffer = new byte[1024];
public static ManualResetEvent allDone = new ManualResetEvent(false);
Task ReadLoopTask;
public Form1()
{
InitializeComponent();
//Control.CheckForIllegalCrossThreadCalls = false;
Console.WriteLine("OK");
}
delegate void ReceBoxSetText(string text);
private void DoReceBoxSetText(string text)
{
if (this.ReceTxt.InvokeRequired)
{
ReceBoxSetText d = new ReceBoxSetText(DoReceBoxSetText);
this.Invoke(d, new object[]{text});
}
else
{
this.ReceTxt.AppendText(text);
this.ReceTxt.Refresh();
}
}
private void setPort_Click(object sender, EventArgs e)
{
// /*
string port = null;
if (String.IsNullOrEmpty(portNum.Text))
{
MessageBox.Show("Error Port Number");
}
else
{
port = portNum.Text;
}
//得到监听的端口号
_socket = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
string HostName = Dns.GetHostName();
IPHostEntry hostIP = Dns.GetHostEntry(HostName);
string localIP = hostIP.AddressList[1].ToString();
localIP = "127.0.0.1";
IPEndPoint ipEndPoint = new IPEndPoint(IPAddress.Parse(localIP),int.Parse(port));
_socket.Bind(ipEndPoint);
_socket.Listen(10);
client.ReceiveBufferSize = 1024;
SocketAsyncEventArgs SocAs= new SocketAsyncEventArgs();
SocAs.AcceptSocket = client;
client.ReceiveTimeout = -1;
SocAs.Completed += SocAs_Completed;//获得连接
SocAs.Completed += SocAs_StartGet;//启动读循环
_socket.AcceptAsync(SocAs);
Console.WriteLine("Main finished");
// */
}
///*
void SocAs_Completed(object sender, SocketAsyncEventArgs e)
{
DoReceBoxSetText("Connection created");
ReadLoopTask = new Task(() =>
{
int t = 0;
while (true)
{
Console.WriteLine("OK"+t.ToString());
t++;
//单独执行上述代码时确实在不断输出
//那么就是下面代码的问题了,为什么加了client.Recieve()之后就会执行一次或者两次然后退出呢？
//这里的情况是这样的,如果server端不发送数据,那么这个循环只执行一次输出OK0
//如果server端发送了一个数据,那么这个循环会再执行一次,于是又输出OK1,
//之后无论server端发送什么数据,调试的时候按步这个循环都是执行到client.Recieve()就会显示程序界面,不再执行后面的语句
int i=0;
try
{
i = client.Receive(ReadBuffer);//i是指读了多少
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
if (i!= 0)
{
//下面就是处理读取到的byte[]的时刻了
int a = 3;
DoReceBoxSetText(t.ToString());
}
ReadBuffer = new byte[1024];
}
});
//为新建连接创建新的socket
}
void SocAs_StartGet(object sender, SocketAsyncEventArgs e)
{
ServerReadLoop();
}
public void ServerReadLoop()
{
ReadLoopTask.Start();
}

复制代码

文库|博客

返回列表

Chinaunix › 论坛 › IT运维 › 网络技术 › .Net Socket 客户端编写遇到奇怪问题

.Net Socket 客户端编写遇到奇怪问题 [复制链接]

浏览过的版块