sctp-go

October 22, 2025 · View on GitHub

A Go library for implementing the Stream Control Transmission Protocol (SCTP) in Go applications. SCTP is a transport-layer protocol that provides reliable, message-oriented data transfer with features like multi-streaming, multi-homing, and congestion control.

Features

Full SCTP protocol implementation
Support for both IPv4 and IPv6
Multi-streaming and multi-homing capabilities
Connection-oriented and message-oriented communication
Integration with Go's net package interfaces
Comprehensive test suite

Installation

go get github.com/thebagchi/sctp-go

Usage

Basic Client

package main

import (
    "fmt"
    "os"

    sctp "github.com/thebagchi/sctp-go"
)

func main() {
    local, err := sctp.MakeSCTPAddr("sctp4", "127.0.0.1:54321")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(1)
    }

    remote, err := sctp.MakeSCTPAddr("sctp4", "127.0.0.1:12345")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(1)
    }

    conn, err := sctp.DialSCTP(
        "sctp4",
        local,
        remote,
        &sctp.SCTPInitMsg{
            NumOutStreams:  0xFFFF,
            MaxInStreams:   0,
            MaxAttempts:    0,
            MaxInitTimeout: 0,
        },
    )
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(1)
    }
    defer conn.Close()

    // Use the connection...
}

Basic Server

package main

import (
    "fmt"
    "os"
    "syscall"

    sctp "github.com/thebagchi/sctp-go"
)

func main() {
    addr, err := sctp.MakeSCTPAddr("sctp4", "127.0.0.1:12345")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(1)
    }

    server, err := sctp.ListenSCTP("sctp4", syscall.SOCK_STREAM, addr)
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(1)
    }
    defer server.Close()

    for {
        conn, err := server.Accept()
        if err != nil {
            fmt.Println("Error:", err)
            continue
        }

        go handleConnection(conn.(*sctp.SCTPConn))
    }
}

func handleConnection(conn *sctp.SCTPConn) {
    defer conn.Close()
    // Handle the connection...
}