外部客户端无法访问 Azure Service Fabric 上的 WCF 通信侦听器

下面是一种适用于具有WebHttpBinding的 WCF 服务的方法： https://github.com/loekd/ServiceFabric.WcfCalc

尝试更改代码，使其不使用endpointResourceName而是address包含显式 URL。URL 应该是群集的公共名称，如 mycluster.region.cloudapp.azure.com。

编辑：url应该使用节点名称，这更容易。

string host = context.NodeContext.IPAddressOrFQDN;
  var endpointConfig = context.CodePackageActivationContext.GetEndpoint    
    ("CalculatorEndpoint");
  int port = endpointConfig.Port;
  string scheme = endpointConfig.Protocol.ToString();
  string uri = string.Format(CultureInfo.InvariantCulture, 
    "{0}://{1}:{2}/", scheme, host, port);

这是我基于 LoekD 的答案更新的代码。

服务变更：若要使服务可供 Internet 客户端使用，必须向 WCFCommunicationListener 添加一个"Address"属性，以告知服务要侦听哪个终结点（http://mycluster.region.azure.com 或 http://localhost）

客户端更改：使用普通的 WCF 客户端，而不使用任何 WCFCommunicationListener 引用。仅在服务结构内部使用 WCFCommunicationListener 客户端（我的原始代码在此方案中工作正常）。

WCF 服务器侦听器

return delegate (StatelessServiceContext context)
        {
            string host = HostFromConfig(context);
            if (string.IsNullOrWhiteSpace(host))
            {
                host = context.NodeContext.IPAddressOrFQDN;
            }
            var endpointConfig = context.CodePackageActivationContext.GetEndpoint("ServiceEndpoint");
            int port = endpointConfig.Port;
            string scheme = endpointConfig.Protocol.ToString();
            //http://mycluster.region.cloudapp.azure.com or http://localhost
            string uri = string.Format(CultureInfo.InvariantCulture, "{0}://{1}:{2}", scheme, host, port);
            var listener = new WcfCommunicationListener<IHello>(
                wcfServiceObject: this,
                serviceContext: context,
                listenerBinding: CreateDefaultHttpBinding(),
                address: new EndpointAddress(uri)
            );
            return listener;
        };

WCF 客户端应用程序

static void Main(string[] args)
    {
        System.Console.WriteLine("'nPress any key to start the wcf client.");
        System.Console.ReadKey();
        System.Console.WriteLine("*************Calling Hello Service*************");
        try
        {
            var binding = CreateDefaultHttpBinding();
            var address = new EndpointAddress("http://cluster.region.cloudapp.azure.com/"); //new EndpointAddress("http://localhost");
            var results = WcfWebClient<IHello>.InvokeRestMethod(x => x.Hello(),binding, address ); 
            System.Console.WriteLine($"*************Results from Hello Service: '{results}'*************");
            Console.ReadKey();
        }
        catch (Exception e)
        {
            System.Console.WriteLine($"*************Exception calling Hello Service: '{e}'*************");
        }
    }

WCF 绑定

public static Binding CreateDefaultHttpBinding()
{
    var binding = new WSHttpBinding(SecurityMode.None)
    {
        CloseTimeout = new TimeSpan(00, 05, 00),
        OpenTimeout = new TimeSpan(00, 05, 00),
        ReceiveTimeout = new TimeSpan(00, 05, 00),
        SendTimeout = new TimeSpan(00, 05, 00),
        MaxReceivedMessageSize = int.MaxValue,
    };
    var quota = new XmlDictionaryReaderQuotas
    {
        MaxArrayLength = int.MaxValue,
        MaxDepth = int.MaxValue
    };
    binding.ReaderQuotas = quota;
    return binding;
}

示例外部/互联网 WCF 客户端：

public abstract class WcfWebClient<T> where T : class
{
    public static TResult InvokeRestMethod<TResult>(Func<T, TResult> method, Binding binding, EndpointAddress address)
    {
        var myChannelFactory = new ChannelFactory<T>(binding, address);
        var wcfClient = myChannelFactory.CreateChannel();
        try
        {
            var result = method(wcfClient);
            ((IClientChannel)wcfClient).Close();
            return result;
        }
        catch (TimeoutException e)
        {
            Trace.TraceError("WCF Client Timeout Exception" + e.Message);
            // Handle the timeout exception.
            ((IClientChannel)wcfClient).Abort();
            throw;
        }
        catch (CommunicationException e)
        {
            Trace.TraceError("WCF Client Communication Exception" + e.Message);
            // Handle the communication exception.
            ((IClientChannel)wcfClient).Abort();
            throw;
        }
    }
}

还可以尝试通过将以下属性放在服务实现上来为 WCF 服务启用任何地址绑定模式：

[ServiceBehavior(AddressFilterMode=AddressFilterMode.Any)]