add comment

outdate
兔子 5 years ago
parent 2cf31950e2
commit 0ca8a71e8d

@ -9,11 +9,14 @@ import (
var connc net.Conn var connc net.Conn
var clientSign map[string]chan string var clientSign map[string]chan string
var clientStopSign chan int
func init() { func init() {
clientStopSign = make(chan int)
clientSign = make(map[string]chan string) clientSign = make(map[string]chan string)
} }
// Notify 用于获取一个通知
func Notify(key string) chan string { func Notify(key string) chan string {
if _, ok := clientSign[key]; !ok { if _, ok := clientSign[key]; !ok {
ch := make(chan string, 5) ch := make(chan string, 5)
@ -32,6 +35,7 @@ func store(key, value string) {
clientSign[key] <- value clientSign[key] <- value
} }
// NewNotifyC 用于新建一个Client端进程
func NewNotifyC(netype, value string) error { func NewNotifyC(netype, value string) error {
var err error var err error
connc, err = net.Dial(netype, value) connc, err = net.Dial(netype, value)
@ -41,6 +45,12 @@ func NewNotifyC(netype, value string) error {
go cnotify() go cnotify()
go func() { go func() {
for { for {
select {
case <-clientStopSign:
connc.Close()
break
default:
}
buf := make([]byte, 8192) buf := make([]byte, 8192)
n, err := connc.Read(buf) n, err := connc.Read(buf)
Queue.ParseMessage(buf[0:n], connc) Queue.ParseMessage(buf[0:n], connc)
@ -55,6 +65,7 @@ func NewNotifyC(netype, value string) error {
return nil return nil
} }
// Send 用于向Server端发送数据
func Send(name string) error { func Send(name string) error {
_, err := connc.Write(Queue.BuildMessage(name)) _, err := connc.Write(Queue.BuildMessage(name))
return err return err
@ -63,6 +74,8 @@ func Send(name string) error {
func cnotify() { func cnotify() {
for { for {
select { select {
case <-clientStopSign:
break
case <-notifychan: case <-notifychan:
break break
default: default:
@ -79,3 +92,8 @@ func cnotify() {
go store(strs[0], strs[1]) go store(strs[0], strs[1])
} }
} }
// ClientStop 终止client端运行
func ClientStop() {
clientStopSign <- 0
}

@ -1,3 +1,4 @@
// Package notify is a package which provide common tcp/udp/unix socket service
package notify package notify
import ( import (
@ -7,18 +8,23 @@ import (
"b612.me/starainrt" "b612.me/starainrt"
) )
// Queue 是用来处理收发信息的简单消息队列
var Queue *starainrt.StarQueue var Queue *starainrt.StarQueue
// FuncLists 记录了被通知项所记录的函数
var FuncLists map[string]func(NetMsg) string var FuncLists map[string]func(NetMsg) string
var serverStopSign chan int var serverStopSign chan int
var notifychan chan int var notifychan chan int
// NetMsg 指明当前被通知的关键字
type NetMsg struct { type NetMsg struct {
Conn net.Conn Conn net.Conn
key string key string
} }
func (this *NetMsg) Send(msg string) error { // Send 用于向client端发送数据
_, err := this.Conn.Write(Queue.BuildMessage(this.key + "||" + msg)) func (nmsg *NetMsg) Send(msg string) error {
_, err := nmsg.Conn.Write(Queue.BuildMessage(nmsg.key + "||" + msg))
return err return err
} }
@ -27,6 +33,8 @@ func init() {
Queue = starainrt.NewQueue() Queue = starainrt.NewQueue()
FuncLists = make(map[string]func(NetMsg) string) FuncLists = make(map[string]func(NetMsg) string)
} }
// NewNotifyS 开启一个新的Server端通知
func NewNotifyS(netype, value string) error { func NewNotifyS(netype, value string) error {
listener, err := net.Listen(netype, value) listener, err := net.Listen(netype, value)
if err == nil { if err == nil {
@ -67,6 +75,7 @@ func NewNotifyS(netype, value string) error {
return err return err
} }
// SetNotify 用于设置通知关键词和调用函数
func SetNotify(name string, data func(NetMsg) string) { func SetNotify(name string, data func(NetMsg) string) {
FuncLists[name] = data FuncLists[name] = data
} }
@ -96,6 +105,7 @@ func notify() {
} }
} }
// ServerStop 用于终止Server端运行
func ServerStop() { func ServerStop() {
serverStopSign <- 0 serverStopSign <- 0
} }

Loading…
Cancel
Save