webreal

基于websocket的客户端级的订阅和发布服务

语言表达有限，望见谅

背景

因为有些项目都用到这种模式：客户端需要实时得到服务端的一些数据，并且由客户端主动订阅。

比如：用户账户余额变动，服务器监听MySQL的BinLog日志，然后通过Redis订阅模型发布消息，推送服务器就可以监听Redis的订阅，通过此Lib来向客户端发出余额变动的消息。

流程

1. 客户端连接
2. 客户端订阅
3. 服务器向订阅数据的客户端发出消息

验证客户端

有些时候要对客户端的订阅信息进行Token验证，比如User1仅能订阅他自己的账户余额变动，User1订阅时需要携带他的Token信息，推送服务器进行验证，验证成功就订阅。

快速开始

package main

import (
	"github.com/myxtype/go-webreal"
	"log"
	"time"
)

// 逻辑处理
type PushingHandler struct {
}

// 客户端连接
func (p *PushingHandler) OnConnect(c *webreal.Client) {
	// 连接时就主动订阅hello
	c.Subscribe("hello")
	log.Printf("client %v connected", c.ID())
}

// 客户端发送消息
func (p *PushingHandler) OnMessage(c *webreal.Client, msg *webreal.Message) {
	log.Printf("client %v Message: %v", c.ID(), msg.Data)

	switch msg.Type {
	case "close":
		c.Close()
	}
}

// 客户端断开连接
func (p *PushingHandler) OnClose(c *webreal.Client) {
	log.Printf("client %v closed.", c.ID())
}

func main() {
	hub := webreal.NewSubscriptionHub()

	// 向订阅hello的客户端发送hello
	go func() {
		tik := time.NewTicker(time.Second)

		for {
			select {
			case <-tik.C:
				for i := 0; i < 10; i++ {
					hub.Publish("hello", []byte("hello"))
				}
			}
		}
	}()

	// todo::其他数据流的Publish

	server := webreal.NewServer(&PushingHandler{}, hub, webreal.DefaultConfig())
	server.Run("127.0.0.1:8080", "/ws")
}