一种基于socket的消息推送服务端，服务端保持与客户端tcp长连接，实现消息的推送或提醒。
目前支持消息模式有两种：1.全员广播；2.特定用户推送
现在还处于开发测试阶段，只能支持单台服务器部署，后期将提供分布式部署方案
package main
import(
"msgserver"
"bufio"
"os"
"fmt"
"strings"
"net"
"errors"
"msgserver/persistence"
)
type testFilter struct{
}
func (this testFilter) OnFilter(conn net.Conn) bool{
fmt.Println(conn.RemoteAddr().String())
return true
}
func main(){
sdr,lster,err:=msgserver.NewDefaultServer()
if err!=nil{
fmt.Println(err)
}
//设置连接过滤器
lster.Filter=new(testFilter)
//设置身份验证方法
lster.OnAuthentication=func(data string) (string,error){
user:=strings.Split(data,";")
if len(user)==2 && user[1]=="123456"{
return user[0],nil
}else{
return "",errors.New("password is wrong")
}
}
//开启一个协程 监听主机3366端口
go func(){
lster.Listen("127.0.0.1:3366")
}()
// 设置离线消息容器
sdr.Container=persistence.CreateMsgContainer("default")
// 消息发送处理最大并行数设置
sdr.MaxParallel=10
//最小并行数设置
sdr.MinParallel=1
//队列中消息堆积阈值设置
sdr.QueueBufferLen=1000
// 开始sender
sdr.BeginSender()
for{
// 从标准输入读取字符串，以\n为分割
text, err := bufio.NewReader(os.Stdin).ReadString('\n')
if(err==nil){
text= strings.Replace(text,"\r\n","",1)
if(text=="count"){
fmt.Println(lster.OnlineCount())
}else{
sdr.SendNotice(text)
}
}
}
}