rpc 添加addr

jsn4ke · jsn4ke · commit 160d1b151ff7 · 2024-01-07T21:52:44.000+08:00
diff --git a/rpc/processor.go b/rpc/processor.go
@@ -110,6 +110,10 @@ func NewClient(addr string, responseChanSize int, consumeNum int32) *Client {
 	return c
 }
 
+func (c *Client) Addr() string {
+	return c.connector.Addr()
+}
+
 func (c *Client) start() {
 
 	if c.tag.IsRunning() {
diff --git a/tcp_connector.go b/tcp_connector.go
@@ -32,6 +32,10 @@ type TcpConnector struct {
 	tag LifeTag
 }
 
+func (c *TcpConnector) Addr() string {
+	return c.addr
+}
+
 func (c *TcpConnector) Session() *TcpSession {
 	c.mtx.Lock()
 	defer c.mtx.Unlock()

Original file line number	Diff line number	Diff line change
`@@ -110,6 +110,10 @@ func NewClient(addr string, responseChanSize int, consumeNum int32) *Client {`
`110`	`110`	`return c`
`111`	`111`	`}`
`112`	`112`
	`113`	`+func (c *Client) Addr() string {`
	`114`	`+ return c.connector.Addr()`
	`115`	`+}`
	`116`	`+`
`113`	`117`	`func (c *Client) start() {`
`114`	`118`
`115`	`119`	`if c.tag.IsRunning() {`