标签过滤器

panlei

2019-08-05 dfcc46bc906e3e5040c74c2d0281f5b0c5d9987b

 labelFilter/req.go

@@ -15,7 +15,6 @@
)

func Die(format string, v ...interface{}) {
   fmt.Fprintln(os.Stderr, fmt.Sprintf(format, v...))
   logger.Info("+++++++",format)
   os.Exit(1)
}
@@ -23,11 +22,12 @@
func date() string {
   return time.Now().Format(time.ANSIC)
}

func Node0(url string) {
var msgChan chan []byte
func Receive(url string) {
   var sock mangos.Socket
   var err error
   var msg []byte
   msgChan = make(chan []byte,200)
   if sock, err = rep.NewSocket(); err != nil {
      Die("can't get new rep socket: %s", err)
   }
@@ -39,11 +39,13 @@
   for {
      // Could also use sock.RecvMsg to get header
      msg, err = sock.Recv()
      if string(msg) == "DATE" { // no need to terminate
         fmt.Println("NODE0: RECEIVED DATE REQUEST")
      if msg != nil { // no need to terminate
         fmt.Println("Received Data request")
         // 把收到的msg塞进通道
         msgChan <- msg
         // 给发送程序反馈信息
         d := date()
         fmt.Printf("NODE0: SENDING DATE %s\n", d)
         err = sock.Send([]byte(d))
         err = sock.Send([]byte("Received Data, --"+d))
         if err != nil {
            Die("can't send reply: %s", err.Error())
         }