电脑上socket的速度是120MB/s，正常吗？

Question

我在一台计算机上测试了通过socket从一个程序向另一个程序传输数据的性能，速度为120MBytes/s，正常吗？

我的服务器和客户端程序都非常简单。

我的电脑是AMD Athlon X2 4000+，4G DDR2 667 RAM，Windows XP SP3。

我朋友说速度慢，应该更快。但我不知道如何改进它们，或者是否有其他库可以尝试获得更好的速度？

更新

服务器和客户端程序都在我自己的计算机上，一台计算机。 网卡会不会限速？

---

服务器.java

import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class SimpleServer {
    public static void main(String[] args) throws Exception {
        ServerSocket server = new ServerSocket(6666);
        Socket socket = server.accept();
        OutputStream output = socket.getOutputStream();

        byte[] bytes = new byte[10 * 1024]; // 10K
        for (int i = 0; i < bytes.length; i++) { bytes[i] = 12; } // fill the bytes

        // send them again and again
        while (true) {
            output.write(bytes);
        }
    }
}

---

客户端.java

public class SimpleClient {

    public static void main(String[] args) throws Exception {
        Socket socket = new Socket("127.0.0.1", 6666);
        InputStream input = socket.getInputStream();
        long total = 0;
        long start = System.currentTimeMillis();

        byte[] bytes = new byte[10240]; // 10K

        // read the data again and again
        while (true) {
            int read = input.read(bytes);
            total += read;
            long cost = System.currentTimeMillis() - start;
            if (cost > 0 && System.currentTimeMillis() % 1000 == 0) {
                 System.out.println("Read " + total + " bytes, speed: " + (total / (1024.0*1024)) / (cost / 1000.0) + " MB/s");
            }
        }
    }

}

Answer 1

你能给我这个程序的输出吗？

public class SimpleServer {
    public static void main(String[] args) throws Exception {
        ServerSocket server = new ServerSocket(6666);
        Socket socket = server.accept();
        OutputStream output = socket.getOutputStream();

        byte[] bytes = new byte[32*1024]; // 32K
        while (true) {
            output.write(bytes);
        }
    }
}
public class SimpleClient {
    public static void main(String[] args) throws Exception {
        Socket socket = new Socket("127.0.0.1", 6666);
        InputStream input = socket.getInputStream();
        long total = 0;
        long start = System.currentTimeMillis();

        byte[] bytes = new byte[32*1024]; // 32K
        for(int i=1;;i++) {
            int read = input.read(bytes);
            if (read < 0) break;
            total += read;
            if (i % 500000 == 0) {
                long cost = System.currentTimeMillis() - start;
                System.out.printf("Read %,d bytes, speed: %,d MB/s%n", total, total/cost/1000);
            }
        }
    }
}

在我的机器上打印

Read 25,586,204,672 bytes, speed: 5,245 MB/s
Read 53,219,426,304 bytes, speed: 5,317 MB/s
Read 85,018,968,064 bytes, speed: 5,416 MB/s
Read 117,786,968,064 bytes, speed: 5,476 MB/s

---

尝试多次发送 32K 块（至少 2 秒），您应该获得 400 MB/s 或更多。例如至少10,000次。

在速度非常快的机器上，您可以在单个客户端上获得 1 GB/s 的速度。对于多个客户端，您可能会获得 8 GB/s。

这是一个示例

使文件传输更高效的Java

---

如果您如果有一块 100 Mb 的卡，您的预期速度约为 11 MB/s（字节每秒）。

同样，对于 1 Gb 以太网，您预计约为 110 MB/s。

对于 10 Gig-E 以太网，您可能会达到 1 GB/s，但除非您的系统经过高度调整，否则您可能只能达到该速度的一半。

Answer 2

您只需传输 10k 字节即可执行测试。您正在做的很多事情都会产生开销，而如此小的数据集可能会因这种开销而产生偏差。 （例如创建套接字、分配内存等）您应该创建并传输更大的数据集（数十MB+），以便更现实地了解正在发生的情况。这样做将使开销成为数据传输过程中较小、不太重要的部分。

您还应该多次执行此测试（> 10）并取平均值，因为您的计算机将在不同的随机时间点承受来自服务、网络传输等的负载，并且这些负载将影响您的传输速率。通过 10 次以上的迭代，您还可以删除任何异常缓慢的运行时间，例如 > 2 个标准差。

Answer 3

网卡会不会限速？

您正在使用 127.0.0.1 - 本地/环回地址。来自/到该地址的流量不通过网卡。

这意味着这不是衡量真实网络吞吐量的有效方法。然而，它是 Java 在您的计算机上通过本地网络堆栈移动数据的能力的合理衡量标准。

---

有趣的是，将您获得的结果与用 C 或 C++ 编写的等效客户端/服务器对进行比较。

Answer 4

测试同一主机中两个对等点之间的带宽根本不会使用 NIC 或网络，而是全部环回。因此你的数据基本上没有意义。在两台计算机之间尝试一下。

Answer 5

WinXP 不支持自动窗口缩放，并且套接字的发送/接收缓冲区大小可能对于吞吐量测试来说太低。

此外，FileInputStream（套接字实际上使用 FileInputStream）在 Windows 上的 char[] 缓冲区比本机代码中的 Linux 更小。读/写是通过堆栈上的辅助缓冲区完成的，并且您放置的大块将被集中通过。

使用大型直接缓冲区（与套接字缓冲区一样大）是提高吞吐量的最佳选择。

Answer 6

嗯，这很有趣，但是这个 nio 实现与上面提供的 SimpleServer/SimpleClient 相当（有时实际上击败了它）（尽管这只是在单线程模式下运行，无论如何都是一对一的！！！

） SimpleServer/SimpleClient 以及该目录中提供的 nio IntegTestLocalhostThroughput.java...

https: //github.com/deanhiller/webpieces/tree/master/core/core-asyncserver/src/test/java/org/webpieces/nio/api/throughput

我只是觉得这相当有趣的是，nio 基本上与旧的 io 一样快，但扩展性更好。