diff --git a/elk/elasticagent/elasticagent.go b/elk/elasticagent/elasticagent.go
new file mode 100644
index 0000000000000000000000000000000000000000..a7278b2409c288fda7860ea99a93b91a019ea896
--- /dev/null
+++ b/elk/elasticagent/elasticagent.go
@@ -0,0 +1,2 @@
+package elasticagent
+
diff --git a/elk/elasticsearch/elasticsearch.go b/elk/elasticsearch/elasticsearch.go
new file mode 100644
index 0000000000000000000000000000000000000000..53be44f6ecee6ebfb35e99726218c341d89e4842
--- /dev/null
+++ b/elk/elasticsearch/elasticsearch.go
@@ -0,0 +1 @@
+package elasticsearch
\ No newline at end of file
diff --git a/elk/global/IsIPandPORTValid.go b/elk/global/IsIPandPORTValid.go
new file mode 100644
index 0000000000000000000000000000000000000000..4b44da742c4bcc5685c3a9bed6012fd248ee02f3
--- /dev/null
+++ b/elk/global/IsIPandPORTValid.go
@@ -0,0 +1,28 @@
+package global
+
+import (
+	"fmt"
+	"net"
+	"time"
+)
+
+const (
+	req_timeout = 1000 * time.Millisecond
+)
+
+// 检测IP是否可达
+func IsIPandPORTValid(ip, port string) (bool, error) {
+	addr, err := net.ResolveIPAddr("ip", ip)
+	if err != nil {
+		return false, err
+	}
+
+	// 设置连接超时时间
+	conn, err := net.DialTimeout("tcp", fmt.Sprintf("%s:%s", addr.String(), port), req_timeout)
+	if err != nil {
+		return false, err
+	}
+
+	conn.Close()
+	return true, nil
+}
diff --git a/elk/global/file.go b/elk/global/file.go
new file mode 100755
index 0000000000000000000000000000000000000000..d9123703d5f3ca629d80ca2433c8876e23947ac2
--- /dev/null
+++ b/elk/global/file.go
@@ -0,0 +1,43 @@
+package global
+
+import (
+	"io"
+	"os"
+
+	"github.com/pkg/errors"
+)
+
+func FileReadString(filePath string) (string, error) {
+	content, err := os.ReadFile(filePath)
+	if err != nil {
+		return "", errors.Errorf("%s **errstack**0", err.Error())
+	}
+
+	return string(content), nil
+}
+
+func FileReadBytes(filePath string) ([]byte, error) {
+	f, err := os.Open(filePath)
+	if err != nil {
+		return nil, errors.Errorf("%s **errstack**0", err.Error())
+	}
+	defer f.Close()
+
+	var content []byte
+	readbuff := make([]byte, 1024*4)
+	for {
+		n, err := f.Read(readbuff)
+		if err != nil {
+			if err == io.EOF {
+				if n != 0 {
+					content = append(content, readbuff[:n]...)
+				}
+				break
+			}
+			return nil, errors.Errorf("%s **errstack**0", err.Error())
+		}
+		content = append(content, readbuff[:n]...)
+	}
+
+	return content, nil
+}
diff --git a/elk/global/globalConst.go b/elk/global/globalConst.go
new file mode 100755
index 0000000000000000000000000000000000000000..5de34e5c86266fed034c54369b67c80853b4e7e3
--- /dev/null
+++ b/elk/global/globalConst.go
@@ -0,0 +1,5 @@
+package global
+
+func init() {
+
+}