/
main.go
100 lines (80 loc) · 1.76 KB
/
main.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
package main
import (
"fmt"
"log"
"time"
"github.com/fasthttp/router"
"github.com/valyala/fasthttp"
"github.com/fasthttp/fastws"
)
func main() {
// Configure websocket upgrader.
upgr := fastws.Upgrader{
UpgradeHandler: tokenVerify,
Handler: websocketHandler,
}
// Configure router handler.
r := router.New()
r.GET("/loginHandler", loginHandler)
r.GET("/ws", upgr.Upgrade)
server := fasthttp.Server{
Handler: r.Handler,
}
go server.ListenAndServe(":8080")
startClient("ws://:8080/ws", "http://localhost:8080/loginHandler")
select {}
}
func websocketHandler(c *fastws.Conn) {
c.WriteString("Hello world")
for {
_, msg, err := c.ReadMessage(nil)
if err != nil {
fmt.Printf("ERROR %v\n", err)
break
}
log.Printf("Readed %s\n", msg)
_, err = c.Write(msg)
if err != nil {
fmt.Printf("ERROR %v\n", err)
break
}
}
c.Close()
}
func startClient(urlws, urlset string) {
// c, err := fastws.Dial(urlws)
// if err == nil {
// panic("connected")
// }
req, resp := fasthttp.AcquireRequest(), fasthttp.AcquireResponse()
defer fasthttp.ReleaseRequest(req)
defer fasthttp.ReleaseResponse(resp)
req.SetRequestURI(urlset)
err := fasthttp.Do(req, resp)
checkErr(err)
if resp.StatusCode() == fasthttp.StatusOK {
token := resp.Body()
req.Reset()
req.Header.SetBytesKV(AuthHeader, token)
conn, er1 := fastws.DialWithHeaders(urlws, req)
checkErr(er1)
defer conn.Close()
log.Println("Connected")
conn.WriteString("Hello")
var msg []byte
for i := 0; i < 50; i++ {
_, msg, err := conn.ReadMessage(msg[:0])
if err != nil {
break
}
log.Printf("Client: %s\n", msg)
conn.WriteString(time.Now().String())
time.Sleep(time.Second)
}
}
}
func checkErr(err error) {
if err != nil {
panic(err)
}
}