IRIS MVC websocket
- 目录结构
- 代码示例

IRIS MVC websocket

目录结构

主目录websocket

    —— main.go
    —— views
        —— index.html

代码示例

main.go

package main
import (
    "sync/atomic"
    "github.com/kataras/iris"
    "github.com/kataras/iris/mvc"
    "github.com/kataras/iris/websocket"
)
func main() {
    app := iris.New()
    //加载模板
    app.RegisterView(iris.HTML("./views", ".html"))
    // 渲染模板 ./views/index.html.
    app.Get("/", func(ctx iris.Context) {
        ctx.View("index.html")
    })
    mvc.Configure(app.Party("/websocket"), configureMVC)
    // 或者 mvc.New(app.Party(...)).Configure(configureMVC)
    // http://localhost:8080
    app.Run(iris.Addr(":8080"))
}
func configureMVC(m *mvc.Application) {
    ws := websocket.New(websocket.Config{})
    // http://localhost:8080/websocket/iris-ws.js
    m.Router.Any("/iris-ws.js", websocket.ClientHandler())
    //这将由`m.Handle`服务的控制器，
    //绑定ws.Upgrade的结果，这是一个websocket.Connection
    m.Register(ws.Upgrade)
    m.Handle(new(websocketController))
}
var visits uint64
func increment() uint64 {
    return atomic.AddUint64(&visits, 1)
}
func decrement() uint64 {
    return atomic.AddUint64(&visits, ^uint64(0))
}
type websocketController struct {
    //注意你也可以使用匿名字段，无所谓，binder会找到它。
    //这是当前的websocket连接，每个客户端都有自己的*websocketController实例。
    Conn websocket.Connection
}
func (c *websocketController) onLeave(roomName string) {
    //访问 -
    newCount := decrement()
    //这将在所有客户端上调用“visit”事件，当前客户端除外
    //（它不能因为它已经离开但是对于任何情况都使用这种类型的设计）
    c.Conn.To(websocket.Broadcast).Emit("visit", newCount)
}
func (c *websocketController) update() {
    //访问++
    newCount := increment()
    //这将在所有客户端上调用“visit”事件，包括当前事件
    //使用'newCount'变量。
    //你有很多方法可以做到更快，例如你可以发送一个新的visitor
    //并且客户端可以自行增加，但这里我们只是“展示”websocket控制器。
    c.Conn.To(websocket.All).Emit("visit", newCount)
}
func (c *websocketController) Get( /* websocket.Connection也可以通过这里传值，没关系 */) {
    c.Conn.OnLeave(c.onLeave)
    c.Conn.On("visit", c.update)
    //在所有事件回调注册后调用它
    c.Conn.Wait()
}

/views/index.html

<html>
<head>
<title>在线访问者MVC的例子</title>
<style>
    body {
        margin: 0;
        font-family: -apple-system, "San Francisco", "Helvetica Neue", "Noto", "Roboto", "Calibri Light", sans-serif;
        color: #212121;
        font-size: 1.0em;
        line-height: 1.6;
    }
    .container {
        max-width: 750px;
        margin: auto;
        padding: 15px;
    }
    #online_visitors {
        font-weight: bold;
        font-size: 18px;
    }
</style>
</head>
<body>
    <div class="container">
        <span id="online_visitors">1位在线访客</span>
    </div>
<script src="/websocket/iris-ws.js"></script>
<script type="text/javascript">
    (function () {
        var socket = new Ws("ws://localhost:8080/websocket");
        socket.OnConnect(function(){
            //更新其余连接的客户端，包括"我的"连接100％就绪的"我自"
            socket.Emit("visit");
        });
        socket.On("visit", function (newCount) {
            console.log("visit websocket event with newCount of: ", newCount);
            var text = "1 online visitor";
            if (newCount > 1) {
                text = newCount + " online visitors";
            }
            document.getElementById("online_visitors").innerHTML = text;
        });
        socket.OnDisconnect(function () {
            document.getElementById("online_visitors").innerHTML = "you've been disconnected";
        });
    })();
</script>
</body>
</html>