使用计算机名时gRPC DNS解析失败

Question

我是gRPC的新手，正在尝试使用cactuaroid中的聊天服务器/客户端示例来学习它。我修改了代码，以显示WPF应用程序中长时间运行的任务的进度。所有代码都在.NET5上运行，我使用的是最新版本的gRPC软件包。

使用计算机的IP地址时，该过程工作正常，但是当为gRPC客户端使用计算机名称时，我收到“DNS解析失败”异常（计算机名称为“skylake”）：

RpcException： Status（StatusCode=“Unavailable”， Detail=“DNS 解析 failed for service： skylake：6001”， DebugException=“Grpc.Core.Internal.CoreErrorDetailException： {”created“：”@1615312867.300000000“，”description“：”Resolver transient failure“，”file“：”......\src\core\ext\filters\client_channel\client_channel.cc“，”file_line“：2138，”referenced_errors“：[{”created“：”@1615312867.300000000“，”description“：”DNS 解析失败服务： skylake：6001“，”file“：”......\src\core\ext\filters\client_channel\resolver\dns\c_ares\dns_resolver_ares.cc“，”file_line“：362，”grpc_status“：14，”referenced_errors“：[{”created“：”@1615312867.300000000“，”description“：”C-ares status is not ARES_SUCCESS qtype=AAAA name=skylake is_balancer=0： 無法聯繫 DNS 伺服器“，”file“：”......\src\core\ext\filters\client_channel\resolver\dns\c_ares\grpc_ares_wrapper.cc“，“file_line”：716，“referenced_errors”：[{“created”：“@1615312866.142000000”，“description”：“C-ares status is not ARES_SUCCESS qtype=A name=skylake is_balancer=0： Can not contact DNS servers”，“file”：“......\src\core\ext\filters\client_channel\resolver\dns\c_ares\grpc_ares_wrapper.cc”，“file_line”：716}]}]}]}]}“）

我用telnet skylake 6001验证了我可以到达端口。我在本地测试，客户端和服务器都在同一台机器上。奇怪的是，gRPC服务器似乎对计算机名没有问题。只是客户对它有意见。

服务器代码：

[Export(typeof(IService))]
    public class ProgressServiceGrpcServer : Progress.ProgressBase, IService
    {
        [Import]
        private Logger m_logger = null;

        [Import]
        private ProgressService m_progressService = null;
        private readonly Empty m_empty = new Empty();

        private const int Port = 6001;
        private readonly Grpc.Core.Server m_server;

        public ProgressServiceGrpcServer()
        {
            m_server = new Grpc.Core.Server
            {
                Services =
                {
                    Progress.BindService(this)
                        .Intercept(new IpAddressAuthenticator())
                },
                Ports =
                {
                    new ServerPort("skylake", Port, ServerCredentials.Insecure)
                }
            };
        }

        public void Start()
        {
            m_server.Start();
            m_logger.Info("Started.");
        }

        public override async Task Subscribe(ChannelName channelName, IServerStreamWriter<ProgressReport> responseStream, ServerCallContext context)
        {
            context.CancellationToken.Register(() => m_logger.Info($"{context.Host} cancels subscription."));

            try
            {
                await m_progressService.GetProgressReportsAsObservable(channelName)
                    .ToAsyncEnumerable()
      .ForEachAwaitAsync(async (x) => await responseStream.WriteAsync(x), context.CancellationToken)
                    .ConfigureAwait(false);
            }
            catch (TaskCanceledException)
            {
                m_logger.Info($"{context.Host} unsubscribed.");
            }
        }

        public override Task<Empty> Write(ProgressReport request, ServerCallContext context)
        {
            m_logger.Info($"{context.Host} {request}");
            m_progressService.Add(request);
            return Task.FromResult(m_empty);
        }
    }

客户端代码：

public class ProgressServiceClient
    {
        private readonly Progress.ProgressClient m_client =
            new Progress.ProgressClient(
                new Channel("skylake”, 6001, ChannelCredentials.Insecure));

        public async Task Write(ProgressReport progressReport)
        {
            await m_client.WriteAsync(progressReport);
        }

        public IAsyncEnumerable<ProgressReport> ProgressReports(ChannelName channelName)
        {
            var call = m_client.Subscribe(channelName);

            return call.ResponseStream
                .ToAsyncEnumerable()
                .Finally(() => call.Dispose());
        }
    }

写入方法的进展：

while (inProgress)
            {
                progressServiceClient.Write(new GrpcServer.ProgressReport
                {
                    Id = Task.Id.ToString(),
                    PercentDone = percentDone,
                    TimeRemain = timeRemain
                }).Wait();

                Thread.Sleep(500);
            }

进度读取方法：

m_progressService = new ProgressServiceClient();
ChannelName channelName = new ChannelName() { Id = id };

var cts = new CancellationTokenSource();
            _ = m_progressService.ProgressReports(channelName)
                .ForEachAsync((x) =>
                {
                    Log.Debug($"id: {x.Id} progress: {x.PercentDone}");
                }, cts.Token);

            this.Dispatcher.Invoke(() =>
            {
                Application.Current.Exit += (_, __) => cts.Cancel();
                this.Unloaded += (_, __) => cts.Cancel();
            });

Answer 1

感谢@jdweng为我指出了正确的方向，这个问题通过在主机名后面添加DNS后缀(在我的例子中是skylake.lan)得到了解决。我们可以通过ipinterfaceproperties . DNS suffix获得DNS后缀。

或者，（这可能更安全）我们可以通过使用类似的东西来使用正确的IP地址而不是主机名。