测试通过-日志保存到ES

config/subconfigs/log_config.go

@@ -8,16 +8,24 @@ import (
 // LogConfig 日志配置
 type LogConfig struct {
 	BaseConfig
-	Level      string `yaml:"level"`
-	Output     string `yaml:"output"`
-	FilePath   string `yaml:"file_path"`
-	MaxSize    int    `yaml:"max_size"`
-	MaxBackups int    `yaml:"max_backups"`
-	MaxAge     int    `yaml:"max_age"`
-	Compress   bool   `yaml:"compress"`
-	//ESEnabled  bool   `yaml:"es_enabled"`
-	ESPath     string `yaml:"es_path"`
-	JSONFormat bool   `yaml:"json_format"`
+	Level      string `yaml:"level" json:"level"`             // 日志级别
+	Output     string `yaml:"output" json:"output"`           // 输出目标：console,file,es
+	JSONFormat bool   `yaml:"json_format" json:"json_format"` // 是否JSON格式
+
+	// 文件输出配置
+	FilePath   string `yaml:"file_path" json:"file_path"`
+	MaxSize    int    `yaml:"max_size" json:"max_size"`
+	MaxBackups int    `yaml:"max_backups" json:"max_backups"`
+	MaxAge     int    `yaml:"max_age" json:"max_age"`
+	Compress   bool   `yaml:"compress" json:"compress"`
+
+	// ES输出配置（当Output包含"es"时生效）
+	ESPath     string `yaml:"es_path" json:"es_path"`           // ES地址
+	ESUsername string `yaml:"es_username" json:"es_username"`   // 用户名（可选）
+	ESPassword string `yaml:"es_password" json:"es_password"`   // 密码（可选）
+	ESAPIKey   string `yaml:"es_api_key" json:"es_api_key"`     // API Key（可选）
+	ESBuffer   int    `yaml:"es_buffer" json:"es_buffer"`       // 缓冲大小，默认10000
+	ESMaxRetry int    `yaml:"es_max_retry" json:"es_max_retry"` // 最大重试，默认3
 }
 
 // NewLogConfig 创建日志配置实例

go.mod

@@ -13,7 +13,10 @@ require (
 	github.com/armon/go-metrics v0.0.0-20180917152333-f0300d1749da // indirect
 	github.com/cloudflare/circl v1.6.1 // indirect
 	github.com/cyphar/filepath-securejoin v0.6.1 // indirect
+	github.com/elastic/elastic-transport-go/v8 v8.7.0 // indirect
 	github.com/fatih/color v1.9.0 // indirect
+	github.com/go-logr/logr v1.4.2 // indirect
+	github.com/go-logr/stdr v1.2.2 // indirect
 	github.com/golang/groupcache v0.0.0-20241129210726-2c02b8208cf8 // indirect
 	github.com/hashicorp/consul/api v1.9.0 // indirect
 	github.com/hashicorp/errwrap v1.1.0 // indirect
@@ -33,6 +36,9 @@ require (
 	github.com/pjbgf/sha1cd v0.5.0 // indirect
 	github.com/skeema/knownhosts v1.3.2 // indirect
 	github.com/stretchr/objx v0.5.2 // indirect
+	go.opentelemetry.io/otel v1.28.0 // indirect
+	go.opentelemetry.io/otel/metric v1.28.0 // indirect
+	go.opentelemetry.io/otel/trace v1.28.0 // indirect
 	go.uber.org/multierr v1.10.0 // indirect
 )
 
@@ -41,6 +47,7 @@ require (
 	github.com/ProtonMail/go-crypto v1.3.0 // indirect
 	github.com/bitly/go-simplejson v0.5.1 // indirect
 	github.com/cpuguy83/go-md2man/v2 v2.0.7 // indirect
+	github.com/elastic/go-elasticsearch/v8 v8.19.0
 	github.com/emirpasic/gods v1.18.1 // indirect
 	github.com/fsnotify/fsnotify v1.9.0 // indirect
 	github.com/go-git/gcfg v1.5.1-0.20230307220236-3a3c6141e376 // indirect

go.sum

@@ -26,6 +26,10 @@ github.com/cyphar/filepath-securejoin v0.6.1/go.mod h1:A8hd4EnAeyujCJRrICiOWqjS1
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/elastic/elastic-transport-go/v8 v8.7.0 h1:OgTneVuXP2uip4BA658Xi6Hfw+PeIOod2rY3GVMGoVE=
+github.com/elastic/elastic-transport-go/v8 v8.7.0/go.mod h1:YLHer5cj0csTzNFXoNQ8qhtGY1GTvSqPnKWKaqQE3Hk=
+github.com/elastic/go-elasticsearch/v8 v8.19.0 h1:VmfBLNRORY7RZL+9hTxBD97ehl9H8Nxf2QigDh6HuMU=
+github.com/elastic/go-elasticsearch/v8 v8.19.0/go.mod h1:F3j9e+BubmKvzvLjNui/1++nJuJxbkhHefbaT0kFKGY=
 github.com/elazarl/goproxy v1.7.2 h1:Y2o6urb7Eule09PjlhQRGNsqRfPmYI3KKQLFpCAV3+o=
 github.com/elazarl/goproxy v1.7.2/go.mod h1:82vkLNir0ALaW14Rc399OTTjyNREgmdL2cVoIbS6XaE=
 github.com/emirpasic/gods v1.18.1 h1:FXtiHYKDGKCW2KzwZKx0iC0PQmdlorYgdFG9jPXJ1Bc=
@@ -46,6 +50,11 @@ github.com/go-git/go-git-fixtures/v4 v4.3.2-0.20231010084843-55a94097c399 h1:eMj
 github.com/go-git/go-git-fixtures/v4 v4.3.2-0.20231010084843-55a94097c399/go.mod h1:1OCfN199q1Jm3HZlxleg+Dw/mwps2Wbk9frAWm+4FII=
 github.com/go-git/go-git/v5 v5.16.4 h1:7ajIEZHZJULcyJebDLo99bGgS0jRrOxzZG4uCk2Yb2Y=
 github.com/go-git/go-git/v5 v5.16.4/go.mod h1:4Ge4alE/5gPs30F2H1esi2gPd69R0C39lolkucHBOp8=
+github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
+github.com/go-logr/logr v1.4.2 h1:6pFjapn8bFcIbiKo3XT4j/BhANplGihG6tvd+8rYgrY=
+github.com/go-logr/logr v1.4.2/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
+github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
+github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
 github.com/go-micro/plugins/v4/registry/consul v1.2.1 h1:3wctYMtstwQLCjoJ1HA6mKGGFF1hcdKDv5MzHakB1jE=
 github.com/go-micro/plugins/v4/registry/consul v1.2.1/go.mod h1:wTat7/K9XQ+i64VbbcMYFcEwipYfSgJM51HcA/sgsM4=
 github.com/golang/groupcache v0.0.0-20241129210726-2c02b8208cf8 h1:f+oWsMOmNPc8JmEHVZIycC7hBoQxHH9pNKQORJNozsQ=
@@ -186,6 +195,14 @@ github.com/xrash/smetrics v0.0.0-20250705151800-55b8f293f342 h1:FnBeRrxr7OU4VvAz
 github.com/xrash/smetrics v0.0.0-20250705151800-55b8f293f342/go.mod h1:Ohn+xnUBiLI6FVj/9LpzZWtj1/D6lUovWYBkxHVV3aM=
 go-micro.dev/v4 v4.11.0 h1:DZ2xcr0pnZJDlp6MJiCLhw4tXRxLw9xrJlPT91kubr0=
 go-micro.dev/v4 v4.11.0/go.mod h1:eE/tD53n3KbVrzrWxKLxdkGw45Fg1qaNLWjpJMvIUF4=
+go.opentelemetry.io/otel v1.28.0 h1:/SqNcYk+idO0CxKEUOtKQClMK/MimZihKYMruSMViUo=
+go.opentelemetry.io/otel v1.28.0/go.mod h1:q68ijF8Fc8CnMHKyzqL6akLO46ePnjkgfIMIjUIX9z4=
+go.opentelemetry.io/otel/metric v1.28.0 h1:f0HGvSl1KRAU1DLgLGFjrwVyismPlnuU6JD6bOeuA5Q=
+go.opentelemetry.io/otel/metric v1.28.0/go.mod h1:Fb1eVBFZmLVTMb6PPohq3TO9IIhUisDsbJoL/+uQW4s=
+go.opentelemetry.io/otel/trace v1.28.0 h1:GhQ9cUuQGmNDd5BTCP2dAvv75RdMxEfTmYejp+lkx9g=
+go.opentelemetry.io/otel/trace v1.28.0/go.mod h1:jPyXzNPg6da9+38HEwElrQiHlVMTnVfM3/yv2OlIHaI=
+go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
+go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
 go.uber.org/multierr v1.10.0 h1:S0h4aNzvfcFsC3dRF1jLoaov7oRaKqRGC/pUEJ2yvPQ=
 go.uber.org/multierr v1.10.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
 go.uber.org/zap v1.27.1 h1:08RqriUEv8+ArZRYSTXy1LeBScaMpVSTBhCeaZYfMYc=

logger/esv8/es_writer.go

@@ -0,0 +1,216 @@
+// logger/es_logger.go
+package esv8
+
+import (
+	"bytes"
+	"context"
+	"fmt"
+	"log"
+	"sync"
+	"time"
+
+	"git.x2erp.com/qdy/go-base/logger/helpers"
+	"github.com/elastic/go-elasticsearch/v8"
+	"github.com/elastic/go-elasticsearch/v8/esapi"
+)
+
+// ====================== 核心结构 ======================
+
+type esWriter struct {
+	serviceName string
+	esClient    *elasticsearch.Client
+	mu          sync.RWMutex
+	isRunning   bool
+	wg          sync.WaitGroup
+	stopChan    chan struct{}
+}
+
+// ====================== 全局单例 ======================
+
+var (
+	instance *esWriter
+	once     sync.Once
+	initErr  error
+)
+
+// InitESWriter 初始化全局ES写入器
+func InitESWriter(serviceName, esURL, username, password string) error {
+	once.Do(func() {
+		instance = &esWriter{
+			serviceName: serviceName,
+			stopChan:    make(chan struct{}),
+			isRunning:   false,
+		}
+		// 初始化ES客户端
+		initErr = instance.initialize(esURL, username, password)
+	})
+
+	return initErr
+}
+
+// GetESWriter 获取全局ES写入器
+func GetESWriter() *esWriter {
+	if instance == nil {
+		panic("ESWriter not initialized. Call InitESWriter first")
+	}
+	return instance
+}
+
+// ====================== 核心方法 ======================
+
+// Write 实现io.Writer接口 - 异步写入ES
+func (w *esWriter) Write(p []byte) (int, error) {
+	w.mu.RLock()
+	defer w.mu.RUnlock()
+
+	if !w.isRunning {
+		return len(p), nil // 已停止，静默丢弃
+	}
+
+	// 异步发送：启动一个goroutine来处理写入
+	go w.asyncSendToES(p)
+
+	return len(p), nil
+}
+
+// asyncSendToES 异步发送到ES
+func (w *esWriter) asyncSendToES(data []byte) {
+	// 创建索引名
+	//indexName := w.serviceName + "-" + time.Now().Format("2006-01-02")
+	indexName := helpers.GetIndexName(w.serviceName)
+	// 复制数据以避免竞争
+	dataCopy := make([]byte, len(data))
+	copy(dataCopy, data)
+
+	// 执行写入
+	err := w.sendToES(indexName, dataCopy)
+	if err != nil {
+		// 记录错误但继续执行
+		log.Printf("[ES-ERROR] 异步写入ES失败: %v", err)
+	}
+}
+
+// ====================== 私有方法 ======================
+
+// initialize 初始化ES连接
+func (w *esWriter) initialize(esURL, username, password string) error {
+	cfg := elasticsearch.Config{
+		Addresses:     []string{esURL},
+		RetryOnStatus: []int{502, 503, 504, 429},
+		MaxRetries:    3,
+	}
+
+	if username != "" && password != "" {
+		cfg.Username = username
+		cfg.Password = password
+	}
+
+	client, err := elasticsearch.NewClient(cfg)
+	if err != nil {
+		return fmt.Errorf("创建ES客户端失败: %v", err)
+	}
+
+	// 测试连接
+	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
+	defer cancel()
+
+	resp, err := client.Ping(client.Ping.WithContext(ctx))
+	if err != nil {
+		return fmt.Errorf("ES连接测试失败: %v", err)
+	}
+	defer resp.Body.Close()
+
+	if resp.IsError() {
+		return fmt.Errorf("ES服务响应错误: %s", resp.Status())
+	}
+
+	w.esClient = client
+	w.isRunning = true
+
+	log.Printf("[ES] ES异步写入器已启动: %s", esURL)
+	return nil
+}
+
+// sendToES 发送日志到ES（同步）
+func (w *esWriter) sendToES(indexName string, data []byte) error {
+	// 准备文档
+	body := bytes.NewReader(data)
+
+	// 创建索引请求
+	req := esapi.IndexRequest{
+		Index:   indexName,
+		Body:    body,
+		Refresh: "false",
+	}
+
+	// 设置超时
+	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
+	defer cancel()
+
+	// 执行请求
+	resp, err := req.Do(ctx, w.esClient)
+	if err != nil {
+		return fmt.Errorf("发送请求失败: %v", err)
+	}
+	defer resp.Body.Close()
+
+	// 检查响应
+	if resp.IsError() {
+		return fmt.Errorf("ES响应错误: %s", resp.Status())
+	}
+
+	return nil
+}
+
+// Reconnect 重新连接ES
+func (w *esWriter) Reconnect(esURL, username, password string) error {
+	w.mu.Lock()
+	defer w.mu.Unlock()
+
+	// 停止当前
+	w.isRunning = false
+
+	// 重新初始化
+	return w.initialize(esURL, username, password)
+}
+
+// HealthCheck 健康检查
+func (w *esWriter) HealthCheck() bool {
+	w.mu.RLock()
+	defer w.mu.RUnlock()
+
+	if !w.isRunning {
+		return false
+	}
+
+	ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
+	defer cancel()
+
+	resp, err := w.esClient.Ping(w.esClient.Ping.WithContext(ctx))
+	if err != nil {
+		return false
+	}
+	defer resp.Body.Close()
+
+	return !resp.IsError()
+}
+
+// Stop 停止写入器
+func (w *esWriter) stop() {
+	w.mu.Lock()
+	defer w.mu.Unlock()
+
+	if w.isRunning {
+		w.isRunning = false
+		close(w.stopChan)
+		w.wg.Wait()
+		log.Printf("[ES] ES写入器已停止")
+	}
+}
+
+// 包级别函数
+func StopESWriter() {
+	if instance != nil {
+		instance.stop()
+	}
+}

logger/helpers/es_index_name.go

@@ -0,0 +1,11 @@
+package helpers
+
+import (
+	"strings"
+	"time"
+)
+
+// 创建索引名（按服务名和日期）
+func GetIndexName(serviceName string) string {
+	return strings.ToLower("log-"+serviceName) + "-" + time.Now().Format("2006-01-02")
+}

logger/http/es_http_writer.go

@@ -0,0 +1,227 @@
+// logger/es_logger.go
+package http
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"log"
+	"net/http"
+	"strings"
+	"sync"
+	"time"
+
+	"git.x2erp.com/qdy/go-base/logger/helpers"
+)
+
+// ====================== 核心结构 ======================
+
+type esWriter struct {
+	serviceName string
+	baseURL     string
+	username    string
+	password    string
+	httpClient  *http.Client
+	mu          sync.RWMutex
+	isRunning   bool
+	console     bool //配置文件里是否配置了终端显示，配置了后，每次保存es都在终端显示。方便调试。正式环境不能配置终端显示
+	stopChan    chan struct{}
+}
+
+// ====================== 全局单例 ======================
+
+var (
+	instance *esWriter
+	once     sync.Once
+	initErr  error
+)
+
+// initESWriter 初始化全局ES写入器
+func InitESWriter(serviceName, esURL, username, password string, console bool) error {
+	once.Do(func() {
+		instance = &esWriter{
+			serviceName: serviceName,
+			stopChan:    make(chan struct{}),
+			isRunning:   false,
+			console:     console,
+		}
+		// 初始化ES客户端
+		initErr = instance.initialize(esURL, username, password)
+	})
+
+	return initErr
+}
+
+// getESWriter 获取全局ES写入器 - 确保这个函数存在且导出
+func GetESWriter() *esWriter {
+	if instance == nil {
+		panic("ESWriter not initialized. Call initESWriter first")
+	}
+	return instance
+}
+
+// ====================== 核心方法 ======================
+
+// Write 实现io.Writer接口
+func (w *esWriter) Write(p []byte) (int, error) {
+	w.mu.RLock()
+	defer w.mu.RUnlock()
+
+	if !w.isRunning {
+		return len(p), nil
+	}
+
+	// 异步发送
+	go w.sendToES(p)
+
+	return len(p), nil
+}
+
+// ====================== 私有方法 ======================
+
+// initialize 初始化ES连接 - 使用HTTP实现
+func (w *esWriter) initialize(esURL, username, password string) error {
+	// 创建HTTP客户端
+	w.httpClient = &http.Client{
+		Timeout: 30 * time.Second,
+		Transport: &http.Transport{
+			MaxIdleConns:        100,
+			MaxIdleConnsPerHost: 100,
+			IdleConnTimeout:     90 * time.Second,
+		},
+	}
+
+	w.baseURL = strings.TrimSuffix(esURL, "/")
+	w.username = username
+	w.password = password
+
+	// 测试连接
+	if err := w.testConnection(); err != nil {
+		return fmt.Errorf("ES连接测试失败: %v", err)
+	}
+
+	w.isRunning = true
+
+	log.Printf("[ES] HTTP ES写入器已启动: %s", esURL)
+	return nil
+}
+
+// testConnection 测试连接
+func (w *esWriter) testConnection() error {
+	req, err := http.NewRequest("GET", w.baseURL, nil)
+	if err != nil {
+		return fmt.Errorf("创建请求失败: %v", err)
+	}
+
+	if w.username != "" && w.password != "" {
+		req.SetBasicAuth(w.username, w.password)
+	}
+
+	resp, err := w.httpClient.Do(req)
+	if err != nil {
+		return fmt.Errorf("连接失败: %v", err)
+	}
+	defer resp.Body.Close()
+
+	if resp.StatusCode != http.StatusOK {
+		body, _ := json.Marshal(resp.Header)
+		return fmt.Errorf("ES响应错误 [%d]: %s", resp.StatusCode, string(body))
+	}
+
+	return nil
+}
+
+// sendToES 发送日志到ES
+func (w *esWriter) sendToES(data []byte) {
+	// 解析JSON数据
+	var logEntry map[string]interface{}
+	if err := json.Unmarshal(data, &logEntry); err != nil {
+		log.Printf("[ES-ERROR] 解析日志JSON失败: %v", err)
+		return
+	}
+
+	// 创建索引名（按服务名和日期）
+	//indexName := strings.ToLower("log-"+w.serviceName) + "-" + time.Now().Format("2006-01-02")
+	indexName := helpers.GetIndexName(w.serviceName)
+	url := fmt.Sprintf("%s/%s/_doc", w.baseURL, indexName)
+
+	if w.console {
+		log.Printf("ES索引url: %s", url)
+	}
+
+	// 添加时间戳
+	if _, exists := logEntry["@timestamp"]; !exists {
+		logEntry["@timestamp"] = time.Now().Format(time.RFC3339)
+	}
+
+	// 转换为JSON
+	jsonData, err := json.Marshal(logEntry)
+	if err != nil {
+		log.Printf("[ES-ERROR] 编码JSON失败: %v", err)
+		return
+	}
+
+	// 创建请求
+	req, err := http.NewRequest("POST", url, bytes.NewBuffer(jsonData))
+	if err != nil {
+		log.Printf("[ES-ERROR] 创建请求失败: %v", err)
+		return
+	}
+
+	req.Header.Set("Content-Type", "application/json")
+	if w.username != "" && w.password != "" {
+		req.SetBasicAuth(w.username, w.password)
+	}
+
+	// 发送请求
+	resp, err := w.httpClient.Do(req)
+	if err != nil {
+		log.Printf("[ES-ERROR] 发送请求失败: %v", err)
+		return
+	}
+
+	if w.console {
+		log.Printf("log save to es success: %s", indexName)
+	}
+
+	defer resp.Body.Close()
+
+	if resp.StatusCode >= 400 {
+		log.Printf("[ES-ERROR] 写入失败 [%d]: %s", resp.StatusCode, resp.Status)
+	}
+}
+
+// ====================== 公共方法 ======================
+
+// HealthCheck 健康检查
+func (w *esWriter) HealthCheck() bool {
+	w.mu.RLock()
+	defer w.mu.RUnlock()
+
+	if !w.isRunning {
+		return false
+	}
+
+	return w.testConnection() == nil
+}
+
+// Stop 停止写入器
+func (w *esWriter) stop() {
+	w.mu.Lock()
+	defer w.mu.Unlock()
+
+	if w.isRunning {
+		w.isRunning = false
+		close(w.stopChan)
+		log.Printf("[ES] ES写入器已停止")
+	}
+}
+
+// ====================== 包级别函数 ======================
+
+// StopESWriter 停止ES写入器
+func StopESWriter() {
+	if instance != nil {
+		instance.stop()
+	}
+}

logger/runtime_logger.go

@@ -2,7 +2,6 @@
 package logger
 
 import (
-	"encoding/json"
 	"log"
 	"os"
 	"strings"
@@ -10,6 +9,8 @@ import (
 	"time"
 
 	"git.x2erp.com/qdy/go-base/config/subconfigs"
+	"git.x2erp.com/qdy/go-base/logger/http"
+
 	"go.uber.org/zap"
 	"go.uber.org/zap/zapcore"
 	"gopkg.in/natefinch/lumberjack.v2"
@@ -30,67 +31,6 @@ type LogContext struct {
 	InstanceName string
 }
 
-// ESWriter ES写入器
-type ESWriter struct {
-	serviceName string
-	esURL       string
-}
-
-func NewESWriter(serviceName, esURL string) *ESWriter {
-	return &ESWriter{
-		serviceName: serviceName,
-		esURL:       esURL,
-	}
-}
-
-func (w *ESWriter) Write(p []byte) (n int, err error) {
-	// 解析日志数据
-	var logEntry map[string]interface{}
-	if err := json.Unmarshal(p, &logEntry); err != nil {
-		// 使用标准log输出到启动日志
-		log.Printf("[ES-WRITER] 解析日志JSON失败: %v", err)
-		return len(p), nil // 返回成功，不阻塞主流程
-	}
-
-	// 动态生成索引名：service-日期
-	indexName := strings.ToLower(w.serviceName) + "-" + time.Now().Format("2006-01-02")
-
-	// 使用标准log输出到启动日志
-	log.Printf("[ES-WRITER] 开始写入ES日志")
-	log.Printf("索引名称: %s", indexName)
-	log.Printf("数据长度: %d 字节", len(p))
-	log.Printf("服务名称: %s", w.serviceName)
-	log.Printf("写入时间: %s", time.Now().Format("2006-01-02 15:04:05"))
-
-	// TODO: 这里是实际写入ES的代码
-	// 这里只是示例，实际应该连接ES并写入数据
-	// esClient.Index().Index(indexName).BodyJson(logEntry).Do(ctx)
-
-	// 模拟写入ES（在开发环境可以打印到控制台查看）
-	w.simulateESWrite(indexName, logEntry)
-
-	return len(p), nil
-}
-
-// simulateESWrite 模拟ES写入（仅用于开发调试）
-func (w *ESWriter) simulateESWrite(indexName string, data map[string]interface{}) {
-	// 在开发环境，可以打印到控制台查看
-	if os.Getenv("GO_ENV") == "development" {
-		jsonData, _ := json.MarshalIndent(data, "", "  ")
-		log.Printf("[ES-SIMULATE] === ES写入模拟开始 ===")
-		log.Printf("索引名称: %s", indexName)
-		log.Printf("写入时间: %s", time.Now().Format("2006-01-02 15:04:05"))
-		log.Printf("jsonData: %s", string(jsonData))
-		//log.Printf("[ES-SIMULATE] 索引: %s\n数据:\n%s", indexName, string(jsonData))
-	}
-}
-
-func (w *ESWriter) Sync() error {
-	// ES客户端通常不需要同步
-	log.Printf("[ES-WRITER] 同步ES写入器")
-	return nil
-}
-
 // InitRuntimeLogger 初始化
 func InitRuntimeLogger(svcName string, logConfig *subconfigs.LogConfig) {
 	initOnce.Do(func() {
@@ -202,17 +142,36 @@ func createRuntimeLogger(svcName string, cfg *subconfigs.LogConfig) error {
 			}
 
 		case "es":
-			// ES输出
+			// 1. 检查必要配置
+			if cfg.ESPath == "" {
+				log.Printf("[RUNTIME-LOGGER] ES地址未配置，跳过ES输出")
+				break
+			}
+			// 判断是否包含console输出
+			containsConsole := strings.Contains(strings.ToLower(cfg.Output), "console")
+
+			// 2. 初始化全局ES写入器
+			err := http.InitESWriter(
+				svcName,
+				cfg.ESPath,
+				cfg.ESUsername, // 假设LogConfig已有这些字段
+				cfg.ESPassword,
+				containsConsole,
+			)
+
+			if err != nil {
+				log.Printf("[RUNTIME-LOGGER] ES写入器初始化失败: %v", err)
+				break
+			}
 
-			log.Printf("[RUNTIME-LOGGER] 初始化ES日志输出, 路径: %s", cfg.ESPath)
-			esWriter := NewESWriter(svcName, cfg.ESPath)
+			// 3. 创建zap core
 			esCore := zapcore.NewCore(
 				jsonEncoder,
-				zapcore.AddSync(esWriter),
+				zapcore.AddSync(http.GetESWriter()), // 使用全局实例
 				level,
 			)
 			cores = append(cores, esCore)
-
+			log.Printf("[RUNTIME-LOGGER] ES日志输出已启用: %s", cfg.ESPath)
 		}
 	}
 
@@ -340,3 +299,8 @@ func Sync() error {
 	}
 	return nil
 }
+
+// StopESWriter 停止ES写入器
+func StopESWriter() {
+	http.StopESWriter()
+}