1
1
package main
2
2
3
3
import (
4
- _ "fmt"
4
+ "fmt"
5
5
"github.com/gorilla/websocket"
6
6
"net/http"
7
+ "time"
7
8
)
8
9
9
10
var upgrader = websocket.Upgrader {}
@@ -15,7 +16,7 @@ func main() {
15
16
})
16
17
17
18
http .HandleFunc ("/v1/ws" , func (w http.ResponseWriter , r * http.Request ) {
18
- conn , _ := upgrader .Upgrade (w , r , nil )
19
+ conn , _ := upgrader .Upgrade (w , r , nil )
19
20
go func (conn * websocket.Conn ) {
20
21
21
22
for {
@@ -27,5 +28,38 @@ func main() {
27
28
28
29
})
29
30
31
+ http .HandleFunc ("/v2/ws" , func (w http.ResponseWriter , r * http.Request ) {
32
+ conn , _ := upgrader .Upgrade (w , r , nil )
33
+ go func (conn * websocket.Conn ) {
34
+
35
+ for {
36
+ _ , msg , _ := conn .ReadMessage ()
37
+ fmt .Println (string (msg ))
38
+ }
39
+
40
+ }(conn )
41
+
42
+ })
43
+
44
+ http .HandleFunc ("/v3/ws" , func (w http.ResponseWriter , r * http.Request ) {
45
+ conn , _ := upgrader .Upgrade (w , r , nil )
46
+ go func (conn * websocket.Conn ) {
47
+ ch := time .Tick (5 * time .Second )
48
+ for range ch {
49
+ conn .WriteJSON (myStruct {
50
+ User : "gunjan5" ,
51
+ Name : "Gunjan Patel" ,
52
+ })
53
+ }
54
+
55
+
56
+ }(conn )
57
+
58
+ })
59
+
30
60
http .ListenAndServe (":8080" , nil )
31
61
}
62
+ type myStruct struct {
63
+ User string `json:"user"`
64
+ Name string `json:"name"`
65
+ }
0 commit comments