fix #736, [掉线重连可能导致服务丢失](#736) (#737)

ijustyce · yangchun2 · web-flow · commit a0c848a550e7 · 2024-06-13T09:44:30.000+08:00
Co-authored-by: yangchun2 &lt;yangchun2@shopline.com&gt;
diff --git a/common/remote/rpc/rpc_client.go b/common/remote/rpc/rpc_client.go
@@ -413,6 +413,7 @@ func (r *RpcClient) reconnect(serverInfo ServerInfo, onRequestFail bool) {
 	if onRequestFail && r.sendHealthCheck() {
 		logger.Infof("%s server check success, currentServer is %+v", r.name, r.currentConnection.getServerInfo())
 		atomic.StoreInt32((*int32)(&r.rpcClientStatus), (int32)(RUNNING))
+		r.notifyConnectionChange(CONNECTED)
 		return
 	}
 	var (

Original file line number	Diff line number	Diff line change
`@@ -413,6 +413,7 @@ func (r *RpcClient) reconnect(serverInfo ServerInfo, onRequestFail bool) {`
`413`	`413`	`if onRequestFail && r.sendHealthCheck() {`
`414`	`414`	`logger.Infof("%s server check success, currentServer is %+v", r.name, r.currentConnection.getServerInfo())`
`415`	`415`	`atomic.StoreInt32((*int32)(&r.rpcClientStatus), (int32)(RUNNING))`
	`416`	`+ r.notifyConnectionChange(CONNECTED)`
`416`	`417`	`return`
`417`	`418`	`}`
`418`	`419`	`var (`