init

order/sendPurchaseEmail/main.go

@@ -81,7 +81,7 @@ func main() {
 	for{
 	for{
 		var wg sync.WaitGroup
 		var wg sync.WaitGroup
 		fmt.Println("开始执行任务....")
 		fmt.Println("开始执行任务....")
-		for i := 0;i<2;i++{
+		for i := 0;i<3;i++{
 			wg.Add(1)
 			wg.Add(1)
 			go func(wg *sync.WaitGroup){
 			go func(wg *sync.WaitGroup){
 				mq := rabbitmq.New(queueExchange)
 				mq := rabbitmq.New(queueExchange)