|
|
@@ -84,8 +84,8 @@ func (c *ChatClient) connect(password string) error {
|
|
|
|
|
|
// 建立gRPC连接
|
|
|
conn, err := grpc.DialContext(ctx, c.serviceAddress,
|
|
|
- grpc.WithTransportCredentials(insecure.NewCredentials()), // 使用非安全连接
|
|
|
- grpc.WithBlock(), // 阻塞式连接
|
|
|
+ grpc.WithTransportCredentials(insecure.NewCredentials()), // 使用非安全连接
|
|
|
+ grpc.WithBlock(), // 阻塞式连接
|
|
|
grpc.WithPerRPCCredentials(&authCreds{password: password}), // 设置认证凭证
|
|
|
grpc.WithDefaultCallOptions( // 设置默认调用选项
|
|
|
grpc.MaxCallRecvMsgSize(20*1024*1024), // 最大接收消息大小
|
|
|
@@ -195,7 +195,7 @@ func (c *ChatClient) closeStream() {
|
|
|
|
|
|
// reconnect 执行重连逻辑
|
|
|
func (c *ChatClient) reconnect() {
|
|
|
- const maxRetries = 5 // 最大重试次数
|
|
|
+ const maxRetries = 500 // 最大重试次数
|
|
|
|
|
|
// 加锁检查重连状态
|
|
|
c.mu.Lock()
|
WH01243