.NET Web服务调用池？

发布于 2024-08-18 09:53:54 字数 408 浏览 8 评论 0原文

我正在编写验收测试来验证系统，它的数据访问都是通过 Web 服务调用完成的。

不幸的是，因为我打了很多电话，所以很快，我遇到了以下错误

System.Net.Sockets.SocketException：每个套接字地址只能使用一次（协议/网络地址/端口）是通常允许

我在本地缓存了尽可能多的调用，但这还不够。我不能伪造或嘲笑这些电话。它们必须是真实的，这个级别的测试才有效。

有没有办法让网络服务重复频繁地调用池？

或者在尝试调用之前检查是否可以与服务建立连接，并等待直到存在可用的套接字？

在生产中，调用永远不会以这种速度进行，因此不会出现问题......但最好有一些代码允许测试工作，并限制或共享连接。

谢谢

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

安静 2024-08-25 09:53:55

一个简单的解决方案是通过让线程休眠一小段时间来减慢测试速度；比生产中的速度快，但比用完所有端口的时间短。

应用程序或系统没有变化。

回复收藏 0 原文

大海や 2024-08-25 09:53:54

事实证明，一位同事已经有一个解决方案已在我们的电子商务网站上使用。您只需继承您的 Web 服务，使用一些不同的设置覆盖 GetWebRequest 函数即可完成。

class SafeMyWebService : MyWS.Service
{
    private static int _lastBindPortUsed;

    protected override WebRequest GetWebRequest(Uri uri)
    {
        var webreq = base.GetWebRequest(uri) as HttpWebRequest;

        webreq.KeepAlive = true;
        webreq.ProtocolVersion = HttpVersion.Version10;
        webreq.ServicePoint.MaxIdleTime = 10 * 1000; // milliseconds 
        webreq.ServicePoint.BindIPEndPointDelegate = new BindIPEndPoint(BindIPEndPointCallback);
        webreq.Timeout = 2000;
        webreq.ConnectionGroupName = "MyConnectionGroupName";

        return webreq;
    }

    public static IPEndPoint BindIPEndPointCallback(ServicePoint servicePoint, IPEndPoint remoteEndPoint, int retryCount)
    {
        int port = Interlocked.Increment(ref _lastBindPortUsed);
        Interlocked.CompareExchange(ref _lastBindPortUsed, 5001, 65534);

        return remoteEndPoint.AddressFamily == AddressFamily.InterNetwork 
            ? new IPEndPoint(IPAddress.Any, port) 
            : new IPEndPoint(IPAddress.IPv6Any, port);
    }

}

我猜它会使用更多资源，但它不会失败。

Turns out, a co-worker had a solution already that was used on our e-com site. You just inherit from your web-service, override the GetWebRequest function with some different settings and you're done.

class SafeMyWebService : MyWS.Service
{
    private static int _lastBindPortUsed;

    protected override WebRequest GetWebRequest(Uri uri)
    {
        var webreq = base.GetWebRequest(uri) as HttpWebRequest;

        webreq.KeepAlive = true;
        webreq.ProtocolVersion = HttpVersion.Version10;
        webreq.ServicePoint.MaxIdleTime = 10 * 1000; // milliseconds 
        webreq.ServicePoint.BindIPEndPointDelegate = new BindIPEndPoint(BindIPEndPointCallback);
        webreq.Timeout = 2000;
        webreq.ConnectionGroupName = "MyConnectionGroupName";

        return webreq;
    }

    public static IPEndPoint BindIPEndPointCallback(ServicePoint servicePoint, IPEndPoint remoteEndPoint, int retryCount)
    {
        int port = Interlocked.Increment(ref _lastBindPortUsed);
        Interlocked.CompareExchange(ref _lastBindPortUsed, 5001, 65534);

        return remoteEndPoint.AddressFamily == AddressFamily.InterNetwork 
            ? new IPEndPoint(IPAddress.Any, port) 
            : new IPEndPoint(IPAddress.IPv6Any, port);
    }

}

I'm guessing it uses more resources, but it doesn't fail.

回复收藏 0 原文