用golang 建立起一個(gè)http server 非常的簡(jiǎn)單，只要簡(jiǎn)單的幾行代碼：
package main
import (
"net/http"
)
func SayHello(w http.ResponseWriter, req *http.Request) 
{
w.Write([]byte("Hello"))
}
func main() {
http.HandleFunc("/hello", SayHello)
http.ListenAndServe(":8001", nil)
}使用GoSublime ide
編譯 go build httpserver.go
運(yùn)行 httpserver.exe
用chrome 訪問
http://127.0.0.1:8001/hello可以看到
hello
使用 go語(yǔ)言搭建 websocket 也非常的簡(jiǎn)單
先安裝 websocketbao
go get code.google.com/p/go.net/websocket
編寫golang的服務(wù)器
package main
import (
"code.google.com/p/go.net/websocket"
"fmt"
"io"
"log"
"net/http"
)
func ChatWith(ws *websocket.Conn) {
var err error
for {
var reply string
if err = websocket.Message.Receive(ws, &reply); err != nil {
fmt.Println("Can't receive")
break
}
fmt.Println("Received back from client: " + reply)
//msg := "Received from " + ws.Request().Host + " " + reply
msg := "welcome to websocket do by pp"
fmt.Println("Sending to client: " + msg)
if err = websocket.Message.Send(ws, msg); err != nil {
fmt.Println("Can't send")
break
}
}
}
func Client(w http.ResponseWriter, r *http.Request) {
html := `<!doctype html>
<html>
<script type="text/javascript" src="http://img3.douban.com/js/packed_jquery.min6301986802.js" async="true"></script>
<script type="text/javascript">
var sock = null;
var wsuri = "ws://127.0.0.1:8001";
window.onload = function() {
console.log("onload");
try
{
sock = new WebSocket(wsuri);
}catch (e) {
alert(e.Message);
}
sock.onopen = function() {
console.log("connected to " + wsuri);
}
sock.onerror = function(e) {
console.log(" error from connect " + e);
}
sock.onclose = function(e) {
console.log("connection closed (" + e.code + ")");
}
sock.onmessage = function(e) {
console.log("message received: " + e.data);
$('#log').append('<p> server say: '+e.data+'<p>');
$('#log').get(0).scrollTop = $('#log').get(0).scrollHeight;
}
};
function send() {
var msg = document.getElementById('message').value;
$('#log').append('<p style="color:red;">I say: '+msg+'<p>');
$('#log').get(0).scrollTop = $('#log').get(0).scrollHeight;
$('#msg').val('');
sock.send(msg);
};
</script>
<h1>WebSocket chat with server </h1>
<div id="log" style="height: 300px;overflow-y: scroll;border: 1px solid #CCC;">
</div>
<div>
<form>
<p>
Message: <input id="message" type="text" value="Hello, world!"><button onclick="send();">Send Message</button>
</p>
</form>
</div>
</html>`
io.WriteString(w, html)
}
func main() {
//
http.Handle("/", websocket.Handler(ChatWith))
http.HandleFunc("/chat", Client)
fmt.Println("listen on port 8001")
fmt.Println("visit http://127.0.0.1:8001/chat with web browser(recommend: chrome)")
if err := http.ListenAndServe(":8001", nil); err != nil {
log.Fatal("ListenAndServe:", err)
}
}
啟動(dòng)服務(wù)器：
用chrome 瀏覽器就可以和服務(wù)器交互
這個(gè)程序較為簡(jiǎn)單，以后可以加入服務(wù)器智能回答的功能。
參考：
http://www.sharejs.com/codes/go/4374http://www.xinze.me/%E5%9F%BA%E4%BA%8Egolang%E7%9A%84websocket-server/
posted on 2012-12-14 15:07
漂漂 閱讀(16633)
評(píng)論(0) 編輯 收藏 引用