From ac4fa219d20e717a20cbddac1103206987ca640c Mon Sep 17 00:00:00 2001 From: Shikong <919411476@qq.com> Date: Fri, 25 Nov 2022 11:18:08 +0800 Subject: [PATCH] =?UTF-8?q?=E7=AE=80=E5=8D=95=E7=9A=84=E7=94=9F=E4=BA=A7?= =?UTF-8?q?=E8=80=85/=E6=B6=88=E8=B4=B9=E8=80=85=E5=AE=9E=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- main.go | 36 +++++++++++++++++------------------- 1 file changed, 17 insertions(+), 19 deletions(-) diff --git a/main.go b/main.go index fa61de1..967c20a 100644 --- a/main.go +++ b/main.go @@ -57,25 +57,23 @@ func main() { ch := make(chan bool) go func() { - for i := 0; i < 10; i++ { - for j := 0; j < 1000_0000; j++ { - _ = publish.Send(channel, - exchange.DefaultDirectExchangeName, route1, false, false, &Message{ - Time: time.Now().Unix(), - MilliTime: time.Now().UnixMilli(), - MicroTime: time.Now().UnixMicro(), - NanoTime: time.Now().UnixNano(), - }, - ) - _ = publish.Send(channel, - exchange.DefaultDirectExchangeName, route2, false, false, &Message{ - Time: time.Now().Unix(), - MilliTime: time.Now().UnixMilli(), - MicroTime: time.Now().UnixMicro(), - NanoTime: time.Now().UnixNano(), - }, - ) - } + for j := 0; j < 10_0000; j++ { + _ = publish.Send(channel, + exchange.DefaultDirectExchangeName, route1, false, false, &Message{ + Time: time.Now().Unix(), + MilliTime: time.Now().UnixMilli(), + MicroTime: time.Now().UnixMicro(), + NanoTime: time.Now().UnixNano(), + }, + ) + _ = publish.Send(channel, + exchange.DefaultDirectExchangeName, route2, false, false, &Message{ + Time: time.Now().Unix(), + MilliTime: time.Now().UnixMilli(), + MicroTime: time.Now().UnixMicro(), + NanoTime: time.Now().UnixNano(), + }, + ) } ch <- true