Guble - Go分布式消息推送服务插件库

Guble是一个轻量级的分布式消息推送服务库，专为Go语言设计。它提供了发布/订阅模式的消息推送功能，支持WebSocket和HTTP长轮询协议。

主要特性

• 轻量级设计
• 支持主题(topic)和队列(queue)两种消息模式
• 提供WebSocket和HTTP长轮询接口
• 可扩展的存储后端
• 简单的API设计

安装

go get github.com/smancke/guble

基本使用示例

1. 启动Guble服务器

package main

import (
	"log"
	"github.com/smancke/guble/server"
)

func main() {
	// 创建配置
	cfg := server.NewConfig()
	cfg.HttpListen = ":8080"  // HTTP监听端口
	cfg.WSListen = ":8081"   // WebSocket监听端口
    
	// 创建并启动服务器
	srv := server.NewServer(cfg)
	if err := srv.Start(); err != nil {
		log.Fatal("启动服务器失败:", err)
	}
	log.Println("Guble服务器已启动")
	
	// 阻塞主线程
	select {}
}

2. 发布消息

package main

import (
	"log"
	"github.com/smancke/guble/client"
)

func main() {
	// 创建客户端
	c, err := client.NewWebSocketClient("ws://localhost:8081/")
	if err != nil {
		log.Fatal("创建客户端失败:", err)
	}
	
	// 连接到服务器
	if err := c.Start(); err != nil {
		log.Fatal("连接服务器失败:", err)
	}
	
	// 发布消息到主题
	err = c.Send("/topic/example", "这是一条测试消息", nil)
	if err != nil {
		log.Fatal("发送消息失败:", err)
	}
	
	log.Println("消息已发布")
	c.Stop()
}

3. 订阅消息

package main

import (
	"log"
	"time"
	
	"github.com/smancke/guble/client"
)

func main() {
	// 创建客户端
	c, err := client.NewWebSocketClient("ws://localhost:8081/")
	if err != nil {
		log.Fatal("创建客户端失败:", err)
	}
	
	// 连接到服务器
	if err := c.Start(); err != nil {
		log.Fatal("连接服务器失败:", err)
	}
	
	// 订阅主题
	err = c.Subscribe("/topic/example", func(msg *client.Message) {
		log.Printf("收到消息: 主题=%s, 内容=%s, ID=%d", 
			msg.Path, msg.Body, msg.Id)
	})
	if err != nil {
		log.Fatal("订阅失败:", err)
	}
	
	log.Println("已订阅主题 /topic/example")
	
	// 保持连接
	time.Sleep(5 * time.Minute)
	c.Stop()
}

高级功能

消息过滤

Guble支持基于消息ID的过滤：

// 只接收ID大于100的消息
err = c.Subscribe("/topic/example", func(msg *client.Message) {
	log.Printf("收到新消息: %s", msg.Body)
}, client.StartId(100))

使用HTTP长轮询

package main

import (
	"log"
	"net/http"
	"github.com/smancke/guble/client"
)

func main() {
	// 创建HTTP客户端
	c := client.NewHttpClient("http://localhost:8080/")
	
	// 订阅主题
	err := c.Subscribe("/topic/example", func(msg *client.Message) {
		log.Printf("收到消息: %s", msg.Body)
	})
	if err != nil {
		log.Fatal("订阅失败:", err)
	}
	
	// 启动HTTP服务器来接收回调
	http.HandleFunc("/callback", func(w http.ResponseWriter, r *http.Request) {
		c.HandleCallback(w, r)
	})
	
	log.Println("启动回调服务器 :8082")
	http.ListenAndServe(":8082", nil)
}

集群模式

Guble支持简单的集群模式，多个节点可以通过配置共享存储后端：

cfg := server.NewConfig()
cfg.ClusterEnabled = true
cfg.ClusterNodes = []string{"node1:8080", "node2:8080"} // 其他节点地址

存储后端

Guble支持多种存储后端，默认使用内存存储，也可以配置为使用文件或Redis：

// 使用文件存储
cfg.StoragePath = "./data"

// 使用Redis存储
cfg.RedisEnabled = true
cfg.RedisAddr = "localhost:6379"

性能考虑

• 对于高吞吐量场景，建议使用WebSocket协议
• 集群模式可以水平扩展处理能力
• Redis存储后端可以提高持久化性能

Guble是一个简单但功能强大的消息推送解决方案，特别适合需要实时通知功能的Go应用程序。它的轻量级设计使得它可以很容易地集成到现有系统中。