GoLang implementation of socket.io library, client and server.
Examples directory contains simple client and server.
go get -u github.com/arielitovsky/ariesocketioDEBUG=1 go run server.gopackage main
import (
"github.com/arielitovsky/ariesocketio"
"github.com/arielitovsky/ariesocketio/websocket"
"log"
"net/http"
"time"
)
type Message struct {
Id int `json:"id"`
Channel string `json:"channel"`
}
type Desc struct {
Text string `json:"text"`
}
func main() {
server := ariesocketio.NewServer(*websocket.GetDefaultWebsocketTransport())
server.On(ariesocketio.OnConnection, func(c *ariesocketio.Channel) {
log.Println("[server] connected! id:", c.Id())
log.Println("[server]", c.RemoteAddr().Network()+" "+c.RemoteAddr().String()+
" --> "+c.LocalAddr().Network()+" "+c.LocalAddr().String())
c.Join("room")
server.BroadcastTo("room", "/admin", Message{1, "new members!"})
time.Sleep(100 * time.Millisecond)
c.BroadcastTo("room", "/admin", Message{2, "hello everyone!"})
_ = c.Emit("message", Message{10, "{\"chinese\":\"中文才是最屌的\"}"})
// return [][]byte
result, err := c.Ack("/ackFromServer", time.Second*5, "go", 3)
if err != nil {
log.Println("[server] ack cb err:", err)
return
}
log.Println("[server] ack cb:", result)
})
server.On(ariesocketio.OnDisconnection, func(c *ariesocketio.Channel, reason websocket.CloseError) {
log.Println("[server] received disconnect", c.Id(), "code:", reason.Code, "text:", reason.Text)
})
server.On("message", func(c *ariesocketio.Channel, arg1 string, arg2 Message, arg3 int, arg4 bool) {
log.Println("[server] received message:", "arg1:", arg1, "arg2:", arg2, "arg3:", arg3, "arg4:", arg4)
})
// listen ack event
server.On("/ackFromClient", func(c *ariesocketio.Channel, msg Message, num int) (int, Desc, string) {
log.Println("[server] received ack:", msg, num)
return 1, Desc{Text: "resp"}, "server"
})
serveMux := http.NewServeMux()
serveMux.Handle("/socket.io/", server)
log.Println("[server] starting server...")
log.Panic(http.ListenAndServe(":2233", serveMux))
}package main
import (
"encoding/json"
"github.com/arielitovsky/ariesocketio"
"github.com/arielitovsky/ariesocketio/websocket"
"log"
"time"
)
type Message struct {
Id int `json:"id"`
Channel string `json:"channel"`
}
type Desc struct {
Text string `json:"text"`
}
func sendAck(c *ariesocketio.Client) {
// return [][]byte
result, err := c.Ack("/ackFromClient", time.Second*5, Message{Id: 3, Channel: "client channel"}, 4)
if err != nil {
log.Println("[client] ack cb err:", err)
} else {
res := result.([]interface{})
if c.BinaryMessage() {
log.Println("[client] ack cb:", res)
return
}
if len(result.([]interface{})) == 0 {
return
}
var outArg1 int
var outArg2 Desc
var outArg3 string
err := json.Unmarshal(res[0].([]byte), &outArg1)
if err != nil {
log.Println("[client] ack cb err:", err)
return
}
log.Println("[client] ack cb outArg1:", outArg1)
err = json.Unmarshal(res[1].([]byte), &outArg2)
if err != nil {
log.Println("[client] ack cb err:", err)
return
}
log.Println("[client] ack cb outArg2:", outArg2.Text)
err = json.Unmarshal(res[2].([]byte), &outArg3)
if err != nil {
log.Println("[client] ack cb err:", err)
return
}
log.Println("[client] ack cb outArg3:", outArg3)
}
}
func sendMessage(c *ariesocketio.Client, args ...interface{}) {
err := c.Emit("message", args...)
if err != nil {
panic(err)
}
}
func createClient() *ariesocketio.Client {
c, err := ariesocketio.Dial(
ariesocketio.GetUrl("localhost", 2233, false),
*websocket.GetDefaultWebsocketTransport())
if err != nil {
panic(err)
}
_ = c.On(ariesocketio.OnConnection, func(h *ariesocketio.Channel) {
log.Println("[client] connected! id:", h.Id())
log.Println("[client]", h.LocalAddr().Network()+" "+h.LocalAddr().String()+
" --> "+h.RemoteAddr().Network()+" "+h.RemoteAddr().String())
})
_ = c.On(ariesocketio.OnDisconnection, func(h *ariesocketio.Channel, reason websocket.CloseError) {
log.Println("[client] disconnected, code:", reason.Code, "text:", reason.Text)
})
_ = c.On("message", func(h *ariesocketio.Channel, args Message) {
log.Println("[client] got chat message:", args)
})
_ = c.On("/admin", func(h *ariesocketio.Channel, args Message) {
log.Println("[client] got admin message:", args)
})
// sending ack response
_ = c.On("/ackFromServer", func(h *ariesocketio.Channel, arg1 string, arg2 int) (Message, int) {
log.Println("[client] got ack from server:", arg1, arg2)
time.Sleep(3 * time.Second)
return Message{
Id: 5,
Channel: "client",
}, 6
})
return c
}
func main() {
c := createClient()
time.Sleep(1 * time.Second)
sendMessage(c, "client", &Message{
Id: 1,
Channel: "client channel",
}, 2)
time.Sleep(1 * time.Second)
sendAck(c)
select {}
}const io = require("socket.io-client");
const socket = io("ws://127.0.0.1:2233", {transports: ["websocket"]});
// listen for messages
socket.on("message", function (msg) {
console.log("[client] received msg:", msg);
});
// sending ack response
socket.on("/ackFromServer", function (a, b, f) {
console.log("[client] received ack:", a, b);
f({id: 5, channel: "js channel"}, 6);
});
socket.on("/admin", function (msg) {
console.log("[client] received admin msg:", msg);
});
socket.on("connect", function () {
console.log("[client] socket connected");
socket.emit("message", "js", {id: 1, channel: "js"}, 2);
// ack
socket.emit("/ackFromClient", {id: 3, channel: "js ack"}, 4, (a, b, c) => {
console.log("[client] ack cb:", a, b, c);
});
});
socket.on("disconnect", function (e) {
console.log("[client] socket disconnect", e);
});
socket.on("connect_error", function (e) {
console.log("[client] connect_error", e);
});const {Server} = require("socket.io");
const customParser = require("socket.io-msgpack-parser");
const io = new Server(2233, {
// parser: customParser // enable binary msg
});
io.on("connection", (socket) => {
// ...
socket.on("message", function (arg1, arg2, arg3) {
console.log("[server] received message:", arg1, arg2, arg3);
});
// listen ack event
socket.on("/ackFromClient", function (arg1, arg2, func) {
console.log("[server] received ack:", arg1, arg2);
func(1, {text: "resp"}, "server");
});
socket.emit("message", {id: 2, channel: "server channel"});
// emit ack event
socket.emit("/ackFromServer", "go", 3, function (arg1, arg2) {
console.log("[server] ack cb:", arg1, arg2);
});
});
console.log("[server] starting server...");MIT