ignite
A websocket server module. Require redis to scale to multi nodes.
Client/server message follow format
type Message struct {
Event string `json:"event"`
Payload json.RawMessage `json:"payload"`
}
use module like the code below.
package main
import (
"encoding/json"
"fmt"
"os"
"github.com/dongnguyenltqb/ignite"
)
func main() {
forever := make(chan bool)
hub := ignite.NewServer(os.Getenv("addr"), "/ws", "localhost:6379", "", 10)
fmt.Println("Websocket is listen on", os.Getenv("addr"))
hub.OnNewClient = func(client *ignite.Client) {
// Send indentity message
client.SendIdentityMsg()
// Join a room
client.Join("room-number-1")
// Send to a room except some client
client.SendMsgToRoomWithExcludeClient("room-number-1", []string{client.Id}, ignite.Message{
Event: "new_client_enter_room",
})
// Register handle for an event
client.On("buy", "1", func(payload json.RawMessage) {
client.SendMsg(ignite.Message{
Event: "test",
Payload: payload,
})
helloMsgPayload, _ := json.Marshal("Hello world")
// Send to all member in a room
client.SendMsgToRoom("room-number-1", ignite.Message{
Event: "test_room_1",
Payload: helloMsgPayload,
})
})
client.OnClose(func(reason string) {
fmt.Println("Client ", client.Id, " closed: ", reason)
})
}
<-forever
}
send/received message
{"event":"buy","payload":"PTB"} < {"event":"bought","payload":"PTB"} >">
➜ ignite git:(master) ✗ wscat -c "ws://localhost:8787/ws" Connected (press CTRL+C to quit) < {"event":"identity","payload":{"clientId":"48d44877-f04b-4e63-ad4b-ebf17899a4de"}} > {"event":"buy","payload":"PTB"} < {"event":"bought","payload":"PTB"} >
17 Nov 12, 2021
44 Dec 7, 2022
50 Dec 14, 2022
4.9k Dec 28, 2022
24 Dec 22, 2022
2.5k Dec 31, 2022
2.7k Dec 23, 2022
490 Dec 29, 2022
163 Dec 27, 2022
13 Sep 15, 2022
1 Jan 25, 2022
16.6k Dec 31, 2022
0 Nov 1, 2021
2 Dec 24, 2022
93 Jan 8, 2023
0 Dec 25, 2021
1 Apr 6, 2022
1 Jan 31, 2022
18.6k Jan 2, 2023