unit-testing - 远程主机在接收时强行关闭了连接

Question

您好，我想了解为什么会出现此异常:

Message: System.Net.Sockets.SocketException : An existing connection was forcibly closed by the remote host

我正在使用 NUnit 执行单元测试，并且我对所有测试(托管在本地)使用相同的 redis-server 实例。

第一个单元测试集就像一个魅力 - 我可以从 Redis 服务器发送和接收数据。在第二次测试中我可以发送但在接收时我抛出异常。我是否必须在测试之间关闭套接字(假设它在测试范围之外时未被处置)或者在切换时我必须注意什么对另一个进行单元测试？

有效的测试

class RedisTests
    {
        [TestCase("*2\r\n$3\r\nget\r\n$1\r\na\r\n","$1\r\n3\r\n")]
        [TestCase("*3\r\n$3\r\nset\r\n$1\r\na\r\n$1\r\n3\r\n", "+OK\r\n",Description ="Cmd:Set a 3 Result: +OK\r\n")]
        public async Task RedisSetTest(string command, string expectedResult)
        {
            Socket socket = TConstants.MakeSocket();
            IPEndPoint redisPoint = TConstants.MakeEndpoint(TConstants.DEFAULT_ADDRESS,TConstants.REDIS_PORT);
            await socket.ConnectAsync(redisPoint);
            Provider provider = Provider.Create(socket, 30);

            await socket.SendAsync(TConstants.UTF8Encode(command), SocketFlags.None);
            try
            {
                SmartMemory memory = await provider.ReceiveAsync();
                var payload = Extensions.Map(x => (char)x,
                                             memory.Iterator.Slice(0, memory.Message.Length).ToEnumerable()
                    );
                string result = string.Concat(payload);
                Assert.AreEqual(expectedResult, result);
            }
            catch (Exception exception)
            {
                Debug.WriteLine(exception.Message);
                throw;
            }


        }
    }

P.S Provider 的 方法ReceiveAsync 只是一个包装器，它的核心是执行 Socket.ReceiveAsync同理。

抛出异常的测试

    class STMTests
        {

            [TestCase(2)]
            public async Task FillIntegerNode(int value)
            {

                Socket socket = TConstants.MakeSocket();
                IPEndPoint redisPoint=TConstants.MakeEndpoint(TConstants.DEFAULT_ADDRESS, TConstants.REDIS_PORT);
                //port = 6379
                //address="127.0.0.1"
                await socket.ConnectAsync(redisPoint);


                Memory<byte>data=BitConverter.GetBytes(injectableNode.Value);
                int sent=await socket.SendAsync(data, SocketFlags.None);


                Memory<byte> dt = new byte[33];
                var mem = await socket.ReceiveAsync(dt, SocketFlags.None);


                Assert.IsTrue(true);

            }
        }

我添加了一张带有测试层次结构的图片:

Answer 1

一般规则是，如果您创造了一次性的东西，那么您就是负责处理它的人。在这种情况下，您将在每个测试中创建套接字，就在测试方法本身中。因此，您必须在测试方法或 TearDown 中处理它，它在每个测试方法之后立即运行。

通常，处理在测试中创建的内容的最简单方法是通过使用。

OTOH，如果您希望测试夹具类中的所有方法都使用相同的套接字，您应该在 OneTimeSetUp 方法中打开它并在 OneTimeTearDown 中处理它.