feat:(conn): add RemoteAddr and LocalAddr method

accept.go

@@ -156,6 +156,7 @@ func accept(w http.ResponseWriter, r *http.Request, opts *AcceptOptions) (_ *Con
 		client:         false,
 		copts:          copts,
 		flateThreshold: opts.CompressionThreshold,
+		remoteAddr:     r.RemoteAddr,
 
 		br: brw.Reader,
 		bw: brw.Writer,

conn.go

@@ -49,6 +49,7 @@ type Conn struct {
 	client         bool
 	copts          *compressionOptions
 	flateThreshold int
+	remoteAddr     string
 	br             *bufio.Reader
 	bw             *bufio.Writer
 
@@ -88,6 +89,7 @@ type connConfig struct {
 	client         bool
 	copts          *compressionOptions
 	flateThreshold int
+	remoteAddr     string
 
 	br *bufio.Reader
 	bw *bufio.Writer
@@ -100,6 +102,7 @@ func newConn(cfg connConfig) *Conn {
 		client:         cfg.client,
 		copts:          cfg.copts,
 		flateThreshold: cfg.flateThreshold,
+		remoteAddr:     cfg.remoteAddr,
 
 		br: cfg.br,
 		bw: cfg.bw,
@@ -192,6 +195,11 @@ func (c *Conn) flate() bool {
 	return c.copts != nil
 }
 
+// RemoteAddr returns the remote address of websocket connection.
+func (c *Conn) RemoteAddr() string {
+	return c.remoteAddr
+}
+
 // Ping sends a ping to the peer and waits for a pong.
 // Use this to measure latency or ensure the peer is responsive.
 // Ping must be called concurrently with Reader as it does

internal/examples/echo/server.go

@@ -30,6 +30,8 @@ func (s echoServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	}
 	defer c.CloseNow()
 
+	s.logf("new incoming connection: %s", c.RemoteAddr())
+
 	if c.Subprotocol() != "echo" {
 		c.Close(websocket.StatusPolicyViolation, "client must speak the echo subprotocol")
 		return