DEV Community

Cover image for Turbocharge Your Go App: Mastering Blazing-Fast Static File Serving Over TCP
aymane aallaoui
aymane aallaoui

Posted on

Turbocharge Your Go App: Mastering Blazing-Fast Static File Serving Over TCP

Hey gophers 🐹!

Have you ever thought of the best ways to ensure faster serving of static files using TCP in Go? Although there are built-in functions such as http.ServeFile that get the job done in simple file serving tasks, these functions become a hindrance when it comes to extremely large files or when carried out under a substantial load. In this article, we want to tackle advanced problem areas of this process so that people who want to go beyond the typical level of Go development will be pleased.

The Problem

Special attention has to be paid to the file serving speed as it is particularly important in case of heavy traffic. When serving static content through solutions such as http.ServeFile, there are following problems to address:

  • Buffering in One Layer: Data is loaded into memory first and only then sent over the network, creating unneeded memory footprint and delays.

  • Blocking I/O: Performing blocking operations on files can negatively affect the speed, especially if the files are several megabytes.

  • Poor Load Balance: There is no provision for performing file transfers in a more concurrent manner which means that speed is lost.

New Solution: More Optimizations

This is how you can get around these constraints and improve performance:

Zero-Copy File Transfer

Reduce on memory consumption and increase the speed of transfers by using the sendfile system call from the syscall package to accomplish a zero-copy file transfer. Memory in the user space is not involved and the data is β€˜sent’ directly from the file descriptor to the socket.

import (
    "syscall"
    "net"
    "os"
)

func serveFile(conn net.Conn, filePath string) error {
    file, err := os.Open(filePath)
    if err != nil {
        return err
    }
    defer file.Close()

    fileStat, err := file.Stat()
    if err != nil {
        return err
    }

    // Directly transfer file content to the connection socket
    _, err = syscall.Sendfile(int(conn.(*net.TCPConn).File().Fd()), int(file.Fd()), nil, int(fileStat.Size()))
    return err
}

Enter fullscreen mode Exit fullscreen mode

Gouroutines As An External Async I/O Mechanism

Utilise the concurrency framework in Go by dividing a file transfer into asynchronous pieces. Offload these pieces in parallel employing goroutines to shorten the time wasted in waiting for I/O call to finish.

func asyncServeFile(conn net.Conn, filePath string) error {
    file, err := os.Open(filePath)
    if err != nil {
        return err
    }
    defer file.Close()

    buf := make([]byte, 32*1024) // 32KB buffer
    var wg sync.WaitGroup

    for {
        n, err := file.Read(buf)
        if n > 0 {
            wg.Add(1)
            go func(data []byte) {
                defer wg.Done()
                conn.Write(data)
            }(buf[:n])
        }
        if err != nil {
            if err == io.EOF {
                break
            }
            return err
        }
    }

    wg.Wait()
    return nil
}
Enter fullscreen mode Exit fullscreen mode

Focus On The Critical Sections

All the sections of the file may not be of equal merit. For illustration, video files which can start playing may require video metadata. Focus on such sections in order to enhance the perceived speed within the user interface.

func serveCriticalSections(conn net.Conn, filePath string, criticalSections []fileRange) error {
    file, err := os.Open(filePath)
    if err != nil {
        return err
    }
    defer file.Close()

    for _, section := range criticalSections {
        buf := make([]byte, section.length)
        _, err := file.ReadAt(buf, section.offset)
        if err != nil {
            return err
        }
        conn.Write(buf)
    }

    return nil
}
Enter fullscreen mode Exit fullscreen mode

Conclusion

There is more to optimizing the handling of static file transfers over TCP in Go than just making use of the built-in facilities. Enhanced performance of the application can be achieved through the utilization of zero-copy transfer of files, asynchronous file I/O and management of critical segments of files. These methods enable high traffic and handling of huge files without losing user satisfaction.

That said happy coding and hope that you will not have any problem transferring your files next time. and always remember to just beat it

gopher

Top comments (0)