6

我有以下问题：

一旦我关闭我的 WM6 应用程序，然后尝试再次启动它，我就会收到此错误： System.Net.Sockets.Socket.Bind(EndPoint localEP) 通常只允许使用每个套接字地址（协议/网络地址/端口）在 System.Net.Sockets.Socket.TcpListener.Start() ...

我认为这是由于连接超时的时间间隔，所以我想关闭所有打开的连接并强制它创建一个新的连接，这是正确的方法还是有不同的方法来处理这个？

这是用于开始收听的代码：

/// <summary>
/// Listens Asynchronously to Clients, creates a recieveMessageHandler to process the read.
/// 
/// Check WIKI, TODOS
/// </summary>
/// <returns></returns>
public void Listen()
{
    myTcpListener.Start();

    while (true)
    {
        //blocks until a client has connected to the server
        try
        {
            TcpClient myTcpClient = myTcpListener.AcceptTcpClient();
            DateTime now = DateTime.Now;
            //Test if it's necessary to create a client
            ClientConnection client = new ClientConnection(myTcpClient, new byte[myTcpClient.ReceiveBufferSize]);

            // Capture the specific client and pass it to the receive handler
            client.NetworkStream.BeginRead(client.Data, 0, myTcpClient.ReceiveBufferSize, r => receiveMessageHandler(r, client), null);
        }
        catch (Exception excp)
        {
            Debug.WriteLine(excp.ToString());
        }
    }
}
4

2 回答 2

5

是的，您的服务器套接字很可能处于 TIME_WAIT 状态。

您可以访问底层的ServerSocket，然后使用SetSocketOption并指定ReuseAddress。

于 2013-03-13T15:46:41.000 回答
1

我猜这里ClientConnection是你的 DLL，因为我看不到它已经包含在 CF 中。

但是，如果您声明MethodInvoker，您实际上并不需要它。

public delegate void MethodInvoker(); // required

为了使您的代码真正流畅，您还应该创建自己的EventArgs类：

public class WmTcpEventArgs : EventArgs {

  private string data;

  public WmTcpEventArgs(string text) {
    data = text;
  }

  public string Data { get { return data; } }

}

非常简单。有了这个新的WmTcpEventArgs类，您应该已经准备好接收可以发布到类似TextBox控件的数据：

private void NetworkResponder(object sender, WmTcpEventArgs e) {
  textBox1.Text = e.Data;
}

while(true)我更喜欢在代码中包含一个小布尔变量，而不是在代码中编码

private bool abortListener;

代码看起来像这样：

public void Listen() {
  listener.Start();
  while (!abortListener) {
    try {
      using (var client = listener.AcceptTcpClient()) {
        int MAX = client.ReceiveBufferSize;
        var now = DateTime.Now;
        using (var stream = client.GetStream()) {
          Byte[] buffer = new Byte[MAX];
          int len = stream.Read(buffer, 0, MAX);
          if (0 < len) {
            string data = Encoding.UTF8.GetString(buffer, 0, len);
            MethodInvoker method = delegate { NetworkResponder(this, new WmTcpEventArgs(data)); };
            abortListener = ((form1 == null) || form1.IsDisposed);
            if (!abortListener) {
              form1.Invoke(method);
            }
          }
        }
      }
    } catch (Exception err) {
      Debug.WriteLine(err.Message);
    } finally {
      listener.Stop();
    }
  }
}

请注意，您仍在捕获异常，但您也停止了TcpListener。

于 2013-03-14T16:39:37.590 回答