Last active
April 1, 2018 19:05
-
-
Save sacOO7/3092241412def3b2358ed46bc90a92b2 to your computer and use it in GitHub Desktop.
Go websocket client example
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| //echo_websocket.go | |
| package main | |
| import ( | |
| "log" | |
| "github.com/sacOO7/gowebsocket" | |
| "os" | |
| "os/signal" | |
| ) | |
| func main() { | |
| interrupt := make(chan os.Signal, 1) | |
| signal.Notify(interrupt, os.Interrupt) | |
| socket := gowebsocket.New("ws://echo.websocket.org/") | |
| socket.OnConnectError = func(err error, socket gowebsocket.Socket) { | |
| log.Fatal("Received connect error - ", err) | |
| } | |
| socket.OnConnected = func(socket gowebsocket.Socket) { | |
| log.Println("Connected to server"); | |
| } | |
| socket.OnTextMessage = func(message string, socket gowebsocket.Socket) { | |
| log.Println("Received message - " + message) | |
| } | |
| socket.OnPingReceived = func(data string, socket gowebsocket.Socket) { | |
| log.Println("Received ping - " + data) | |
| } | |
| socket.OnPongReceived = func(data string, socket gowebsocket.Socket) { | |
| log.Println("Received pong - " + data) | |
| } | |
| socket.OnDisconnected = func(err error, socket gowebsocket.Socket) { | |
| log.Println("Disconnected from server ") | |
| return | |
| } | |
| socket.Connect() | |
| socket.SendText("Thoughtworks guys are awesome !!!!") | |
| for { | |
| select { | |
| case <-interrupt: | |
| log.Println("interrupt") | |
| socket.Close() | |
| return | |
| } | |
| } | |
| } |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment