fatedier 0f1005ff61 using glide 7 년 전
..
.gitignore 93d86ca635 vendor: add github.com/xtaci/smux 7 년 전
.travis.yml 93d86ca635 vendor: add github.com/xtaci/smux 7 년 전
LICENSE 93d86ca635 vendor: add github.com/xtaci/smux 7 년 전
README.md 93d86ca635 vendor: add github.com/xtaci/smux 7 년 전
curve.jpg 93d86ca635 vendor: add github.com/xtaci/smux 7 년 전
frame.go 93d86ca635 vendor: add github.com/xtaci/smux 7 년 전
mux.go 93d86ca635 vendor: add github.com/xtaci/smux 7 년 전
mux.jpg 93d86ca635 vendor: add github.com/xtaci/smux 7 년 전
mux_test.go 0f1005ff61 using glide 7 년 전
session.go 93d86ca635 vendor: add github.com/xtaci/smux 7 년 전
session_test.go 0f1005ff61 using glide 7 년 전
smux.png 93d86ca635 vendor: add github.com/xtaci/smux 7 년 전
stream.go 93d86ca635 vendor: add github.com/xtaci/smux 7 년 전

README.md

smux

GoDoc MIT licensed Build Status Go Report Card Coverage Statusd

smux

Introduction

Smux ( Simple MUltipleXing) is a multiplexing library for Golang. It relies on an underlying connection to provide reliability and ordering, such as TCP or KCP, and provides stream-oriented multiplexing. The original intention of this library is to power the connection management for kcp-go.

Features

  1. Tiny, less than 600 LOC.
  2. Token bucket controlled receiving, which provides smoother bandwidth graph(see picture below).
  3. Session-wide receive buffer, shared among streams, tightly controlled overall memory usage.
  4. Minimized header(8Bytes), maximized payload.
  5. Well-tested on millions of devices in kcptun.

smooth bandwidth curve

Documentation

For complete documentation, see the associated Godoc.

Specification

VERSION(1B) | CMD(1B) | LENGTH(2B) | STREAMID(4B) | DATA(LENGTH)  

Usage

The API of smux are mostly taken from yamux


func client() {
    // Get a TCP connection
    conn, err := net.Dial(...)
    if err != nil {
        panic(err)
    }

    // Setup client side of smux
    session, err := smux.Client(conn, nil)
    if err != nil {
        panic(err)
    }

    // Open a new stream
    stream, err := session.OpenStream()
    if err != nil {
        panic(err)
    }

    // Stream implements io.ReadWriteCloser
    stream.Write([]byte("ping"))
}

func server() {
    // Accept a TCP connection
    conn, err := listener.Accept()
    if err != nil {
        panic(err)
    }

    // Setup server side of smux
    session, err := smux.Server(conn, nil)
    if err != nil {
        panic(err)
    }

    // Accept a stream
    stream, err := session.AcceptStream()
    if err != nil {
        panic(err)
    }

    // Listen for a message
    buf := make([]byte, 4)
    stream.Read(buf)
}

Status

Stable