1

我有一些客户端-服务器套接字代码，我希望能够构造和（重新）定期连接到相同的端点地址：localhost:17999

这是服务器：

// Listen for a connection:
IPEndPoint localEndPoint = new IPEndPoint(IPAddress.Loopback, 17999);             
Socket listener = new Socket(IPAddress.Loopback.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
listener.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
listener.Bind(localEndPoint);
listener.Listen(1);

// Accept the connection and send a message:
Socket handler = listener.Accept();
byte[] bytes = new byte[1024];
bytes = Encoding.ASCII.GetBytes("The Message...");                 
handler.Send(bytes);

// Clean up
handler.Shutdown(SocketShutdown.Both);
handler.Close();
handler.Dispose();

listener.Shutdown(SocketShutdown.Both);
listener.Close();
listener.Dispose();

这是客户：

byte[] bytes = new byte[1024];
Socket receiver = new Socket(IPAddress.Loopback.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
receiver.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
receiver.Connect(new IPEndPoint(IPAddress.Loopback, 17999));

int num_bytes_received = receiver.Receive(bytes);
string result = Encoding.ASCII.GetString(bytes, 0, num_bytes_received);

receiver.Shutdown(SocketShutdown.Both);
receiver.Close();
receiver.Dispose();

当我第一次创建客户端和服务器时，它工作正常。但是，当我再次创建它时，出现错误：

“不允许发送或接收数据的请求，因为套接字未连接，并且（当使用 sendto 调用在数据报套接字上发送时）未提供地址”

我希望能够在需要时使用以下事件顺序任意启动此机制：

  1. 启动服务器并等待接受连接
  2. 启动客户端并连接到服务器
  3. 在服务器上接受客户端连接
  4. 向客户端发送消息
  5. 必要时重复

我怎样才能做到这一点？

提前谢谢！

编辑：每次我构建客户端和服务器对象时，它都来自不同的进程。

4

2 回答 2

3

你有两个问题：

1）您正在关闭侦听器。让它保持打开状态。

2）您设置ReuseAddress了错误的套接字并且为时已晚。在您调用之前将其设置在侦听套接字上bind（因为那是您使用地址的时候）。

设置ReuseAddress在您不会使用的套接字上bind不会做任何事情。您可以从客户端中删除它。

于 2013-03-06T08:22:24.370 回答
0

我尝试了 Gene 的建议，它似乎有效：

// Listen for a connection:     
IPEndPoint localEndPoint = new IPEndPoint(IPAddress.Loopback, 17999);
using (Socket listener = new Socket(IPAddress.Loopback.AddressFamily, SocketType.Stream, ProtocolType.Tcp))
{

    listener.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
    listener.Bind(localEndPoint);
    listener.Listen(1);

    Thread t = new Thread(() =>
    {
        // Accept the connection and send a message:
        using (Socket handler = listener.Accept())
        {
            byte[] bytes = new byte[1024];
            bytes = Encoding.ASCII.GetBytes("The Message...");
            handler.Send(bytes);
        }
    });
    t.Start();
    t.Join();
}

谢谢大家！

于 2013-03-06T09:55:31.127 回答