add mq

client.go

@@ -32,14 +32,13 @@ func NewClient(url string) *Client {
 func (c *Client) ReConnection(url string) {
 	for {
 		if c.GetConnect().IsClosed() || c.GetChannel().IsClosed() {
-			select {
-			case <-c.ReConnectionChan():
-				log.Print("reconnecting ...")
-				c.Connect = connections.NewConnect().Open(url)
-				c.Channel = channels.NewChannel(c.Connection)
-				c.ReChannels()
-				log.Println("Connect is closed ", c.GetConnect().IsClosed(), ",Channel is closed ", c.GetChannel().IsClosed())
-			}
+			<-c.ReConnectionChan()
+			log.Print("reconnecting ...")
+			c.Connect = connections.NewConnect().Open(url)
+			c.Channel = channels.NewChannel(c.Connection)
+			c.ReChannels()
+			log.Println("Connect is closed ", c.GetConnect().IsClosed(), ",Channel is closed ", c.GetChannel().IsClosed())
+
 		}
 	}
 }

connections/connections.go

@@ -14,7 +14,6 @@ type Connect struct {
 	ConnNotifyClose chan *amqp.Error
 	//通道异常接收
 	ChNotifyClose chan *amqp.Error
-	isConnected   bool
 }
 
 // NewConnect new connect

producers/producer.go

@@ -86,27 +86,25 @@ LOOKUP:
 			break LOOKUP
 		}
 		p.publish(m)
-		select {
-		case cf := <-ch.GetConfirmChan():
-			if !cf.Ack {
-				log.Println("exchange error  ", body)
-				exchangeNum++
-				if exchangeNum == p.opt.ResendNum+1 {
-					log.Println("exchange fail data", body)
+		cf := <-ch.GetConfirmChan()
+		if !cf.Ack {
+			log.Println("exchange error  ", body)
+			exchangeNum++
+			if exchangeNum == p.opt.ResendNum+1 {
+				log.Println("exchange fail data", body)
+				Success = false
+			}
+		} else {
+			select {
+			case data := <-ch.GetReturnChan():
+				log.Println("queue error  data", body, ",ReplyCode ", data.ReplyCode, ",retry num", queueNum, ",return data ", string(data.Body))
+				queueNum++
+				if queueNum == p.opt.ResendNum+1 {
+					log.Println("queue fail data", body)
 					Success = false
 				}
-			} else {
-				select {
-				case data := <-ch.GetReturnChan():
-					log.Println("queue error  data", body, ",ReplyCode ", data.ReplyCode, ",retry num", queueNum, ",return data ", string(data.Body))
-					queueNum++
-					if queueNum == p.opt.ResendNum+1 {
-						log.Println("queue fail data", body)
-						Success = false
-					}
-				default:
-					break LOOKUP
-				}
+			default:
+				break LOOKUP
 			}
 		}