diff --git a/dialer/pht/dialer.go b/dialer/pht/dialer.go
index de69affc..88502388 100644
--- a/dialer/pht/dialer.go
+++ b/dialer/pht/dialer.go
@@ -109,6 +109,7 @@ func (d *phtDialer) Dial(ctx context.Context, addr string, opts ...dialer.DialOp
 			PushPath:      d.md.pushPath,
 			PullPath:      d.md.pullPath,
 			TLSEnabled:    d.tlsEnabled,
+			Header:        d.md.header,
 			Logger:        d.options.Logger,
 		}
 		d.clients[addr] = client
diff --git a/dialer/pht/metadata.go b/dialer/pht/metadata.go
index 289738ad..12758524 100644
--- a/dialer/pht/metadata.go
+++ b/dialer/pht/metadata.go
@@ -1,6 +1,7 @@
 package pht
 
 import (
+	"net/http"
 	"strings"
 
 	mdata "github.com/go-gost/core/metadata"
@@ -19,6 +20,7 @@ type metadata struct {
 	pushPath      string
 	pullPath      string
 	host          string
+	header        http.Header
 }
 
 func (d *phtDialer) parseMetadata(md mdata.Metadata) (err error) {
@@ -27,6 +29,7 @@ func (d *phtDialer) parseMetadata(md mdata.Metadata) (err error) {
 		pushPath      = "pushPath"
 		pullPath      = "pullPath"
 		host          = "host"
+		header        = "header"
 	)
 
 	d.md.authorizePath = mdutil.GetString(md, authorizePath)
@@ -43,5 +46,15 @@ func (d *phtDialer) parseMetadata(md mdata.Metadata) (err error) {
 	}
 
 	d.md.host = mdutil.GetString(md, host)
+
+	// Parse custom headers
+	if m := mdutil.GetStringMapString(md, header); len(m) > 0 {
+		h := http.Header{}
+		for k, v := range m {
+			h.Add(k, v)
+		}
+		d.md.header = h
+	}
+
 	return
 }
diff --git a/internal/util/pht/client.go b/internal/util/pht/client.go
index c2014753..e4bea03d 100644
--- a/internal/util/pht/client.go
+++ b/internal/util/pht/client.go
@@ -21,6 +21,7 @@ type Client struct {
 	PushPath      string
 	PullPath      string
 	TLSEnabled    bool
+	Header        http.Header
 	Logger        logger.Logger
 }
 
@@ -43,6 +44,7 @@ func (c *Client) Dial(ctx context.Context, addr string) (net.Conn, error) {
 
 	cn := &clientConn{
 		client:     c.Client,
+		header:     c.Header,
 		rxc:        make(chan []byte, 128),
 		closed:     make(chan struct{}),
 		localAddr:  &net.TCPAddr{},
@@ -74,6 +76,15 @@ func (c *Client) authorize(ctx context.Context, addr string) (token string, err
 		return
 	}
 
+	// Inject custom headers
+	if c.Header != nil {
+		for k, values := range c.Header {
+			for _, v := range values {
+				r.Header.Add(k, v)
+			}
+		}
+	}
+
 	if c.Logger.IsLevelEnabled(logger.TraceLevel) {
 		dump, _ := httputil.DumpRequest(r, false)
 		c.Logger.Trace(string(dump))
diff --git a/internal/util/pht/conn.go b/internal/util/pht/conn.go
index 72028503..1e4aea1f 100644
--- a/internal/util/pht/conn.go
+++ b/internal/util/pht/conn.go
@@ -17,6 +17,7 @@ import (
 
 type clientConn struct {
 	client     *http.Client
+	header     http.Header
 	pushURL    string
 	pullURL    string
 	buf        []byte
@@ -69,6 +70,15 @@ func (c *clientConn) write(b []byte) (n int, err error) {
 		return
 	}
 
+	// Add custom headers
+	if c.header != nil {
+		for k, values := range c.header {
+			for _, v := range values {
+				req.Header.Add(k, v)
+			}
+		}
+	}
+
 	if c.logger.IsLevelEnabled(logger.TraceLevel) {
 		dump, _ := httputil.DumpRequest(req, false)
 		c.logger.Trace(string(dump))
@@ -109,6 +119,15 @@ func (c *clientConn) readLoop() {
 				return err
 			}
 
+			// Add custom headers
+			if c.header != nil {
+				for k, values := range c.header {
+					for _, v := range values {
+						r.Header.Add(k, v)
+					}
+				}
+			}
+
 			if c.logger.IsLevelEnabled(logger.TraceLevel) {
 				dump, _ := httputil.DumpRequest(r, false)
 				c.logger.Trace(string(dump))