Set payload length ( Variable-Length Integer Encoding ) in pseudo-header to collect full message
https://github.com/adrian-lin-1-0-0/go-variable-length-integer-encoding
- 1's Complement
go get github.com/adrian-lin-1-0-0/go-message-tcp@latest
Client
package main
import (
"log"
tcp "github.com/adrian-lin-1-0-0/go-message-tcp"
)
func main() {
address := ":5000"
conn, err := tcp.Dial(address)
if err != nil {
log.Fatalln(err)
}
defer conn.Close()
conn.SetBufLen(2048) //default 1024
conn.SetChecksum(true) //default false
conn.Write([]byte("hello server"))
buf, err := conn.Read()
if err != nil {
log.Fatalln(err)
}
log.Println("receive data : ", string(buf))
}Server
package main
import (
"log"
tcp "github.com/adrian-lin-1-0-0/go-message-tcp"
)
func main() {
address := ":5000"
li, err := tcp.Listen(address)
log.Println("server listen on ", address)
if err != nil {
log.Fatalln(err)
}
defer li.Close()
li.SetBufLen(2048) //default 1024
li.SetChecksum(true) // default false
for {
conn, err := li.Accept()
if err != nil {
log.Println(err)
continue
}
go handle(conn)
}
}
func handle(conn tcp.Conn) {
for {
buf, err := conn.Read()
if err != nil {
log.Println(err)
break
}
log.Println("receive data : ", string(buf))
_, err = conn.Write([]byte("hi client"))
if err != nil {
log.Println(err)
break
}
}
defer conn.Close()
log.Println("Connection close")
}