From 997dc130679d90caf16045da0ab71bfba4e88900 Mon Sep 17 00:00:00 2001
From: 18209 <qiu.yanan@freesun.cn>
Date: Tue, 19 May 2026 14:43:11 +0800
Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=97=B6=E8=BF=90=E8=A1=8C=E5=A4=9A?=
 =?UTF-8?q?=E4=B8=AA=E9=85=8D=E7=BD=AE=E6=96=87=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 main.go | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/main.go b/main.go
index 1d5d3ca..e98d447 100644
--- a/main.go
+++ b/main.go
@@ -4,11 +4,12 @@ import (
 	"fmt"
 	"goInOut/config"
 	"goInOut/consumers"
-	"gopkg.in/natefinch/lumberjack.v2"
 	"io"
 	"log"
 	"os"
 	"time"
+
+	"gopkg.in/natefinch/lumberjack.v2"
 )
 
 func init() {
@@ -31,6 +32,7 @@ func main() {
 	//初始化读取配置
 	myConfigs := config.LoadConfig() //数据存储
 	for consumerName, consumerConfig := range myConfigs {
+		log.Printf("consumer [%s]", consumerName)
 		consumer := consumers.GetConsumer(consumerName)
 		if consumer == nil {
 			log.Printf("无匹配的consumer [%s] 请检查", consumerName)
@@ -41,7 +43,12 @@ func main() {
 		if err != nil {
 			log.Panic(fmt.Sprintf("[%s]初始化失败:%s", consumerName, err.Error()))
 		}
-		consumer.Work()
+
+		// 在独立的 goroutine 中运行每个消费者，使它们可以并行执行
+		go func(name string, c consumers.IConsumer) {
+			log.Printf("启动消费者: %s", name)
+			c.Work()
+		}(consumerName, consumer)
 	}
 
 	for {