我已经用了3年的beego,虽然beego的版本在不断更新,但当别人谈论到它时,我越来越“冷静“,它对新手很友好,同时也发现了各种限制,尝试不同的框架还是好的。 Go语言的伟大之处在于:如果你也不是写网站出身,没有时间去学tomcat的配置,看到Java厚重的SSH框架书籍就脑袋疼,看到python群里各种2、3版本争论不休,Go可以在最短的时间内把自己的服务器搭起来,在最短的时间内把自己的工资提起来。
参考链接
http://www.oschina.net/translate/build-a-realtime-chat-server-with-go-and-websockets?lang=chs&page=1# oschina立功,这篇神一般的翻译非常值得一看,下面的代码几乎都是从此篇中学(chao)习(xi)而来 http://blog.csdn.net/freewebsys/article/details/46882777 这篇文章使用的是官方x/net中的websocket,短小精悍,js值得借(chao)鉴(xi),很遗憾的是,官方的这个websocket不太容易集成到beego中 https://github.com/beego/samples/tree/master/WebIM beego的web在线聊天室,代码又臭又长,看起来云遮雾罩,但是,其中通过路由来拆解websocket注册的思路很巧妙,虽然说穿了不值一提
如果你把上面3个链接都看完 下面就不用看了
我们开始试着把上面提到的文章内的代码拆开再自己组合起来
目的,使用Gorilla WebSocket而不是官方的x/net下的websocket,毕竟要往beego项目里集成只要把数据通过websocket的方式显示到页面上就算成功先实现个简单版,不往项目里扔
效果
项目结构:
main.go
package main
import (
"log"
"net/http"
"github.com/gorilla/websocket"
"time"
)
var clients =
make(
map[*websocket.Conn]
bool)
var broadcast =
make(
chan Message)
var upgrader = websocket.Upgrader{}
type Message
struct {
Message
string `json:"message"`
}
func main() {
fs := http.FileServer(http.Dir(
"public"))
http.Handle(
"/", fs)
http.HandleFunc(
"/ws", handleConnections)
go handleMessages()
log.Println(
"http server started on :8000")
err := http.ListenAndServe(
":8000",
nil)
if err !=
nil {
log.Fatal(
"ListenAndServe: ", err)
}
}
func handleConnections(w http.ResponseWriter, r *http.Request) {
ws, err := upgrader.Upgrade(w, r,
nil)
if err !=
nil {
log.Fatal(err)
}
defer ws.Close()
clients[ws] =
true
for {
time.Sleep(time.Second *
3)
msg := Message{Message:
"这是向页面发送的数据 " + time.Now().Format(
"2006-01-02 15:04:05")}
broadcast <- msg
}
}
func handleMessages() {
for {
msg := <-broadcast
for client :=
range clients {
err := client.WriteJSON(msg)
if err !=
nil {
log.Printf(
"client.WriteJSON error: %v", err)
client.Close()
delete(clients, client)
}
}
}
}
index.html
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8"/>
<title>Sample of websocket with golang
</title>
<script src="http://apps.bdimg.com/libs/jquery/2.1.4/jquery.min.js"></script>
<script>
$(function() {
var ws = new WebSocket('ws://' + window.location.host + '/ws');
ws.onmessage = function(e) {
$('<li>').text(event.data).appendTo($ul);
};
var $ul = $('#msg-list');
});
</script>
</head>
<body>
<ul id="msg-list"></ul>
</body>
</html>
是不是代码简单到爆炸?从上面你可以看到,在go文件中核心代码就2句
ws, err := upgrader
.Upgrade(w, r, nil)
err := client
.WriteJSON(msg)
一句注册,一句发送,搞定,收工