具有多个IP地址的网络接口上的WCF web服务发现

Question

我正在尝试使用WCF的DiscoveryClient进行Web服务发现，使用以下代码：

// Setup the discovery client (WSDiscovery April 2005)
DiscoveryEndpoint discoveryEndpoint = new UdpDiscoveryEndpoint(DiscoveryVersion.WSDiscoveryApril2005);
DiscoveryClient discoveryClient = new DiscoveryClient(discoveryEndpoint);
// Setup the wanted device criteria
FindCriteria criteria = new FindCriteria();
criteria.ScopeMatchBy = new Uri("http://schemas.xmlsoap.org/ws/2005/04/discovery/rfc3986");
criteria.Scopes.Add(new Uri("onvif://www.onvif.org/"));
// Go find!
criteria.Duration = TimeSpan.FromMilliseconds(duration);
discoveryClient.FindAsync(criteria, this);

这在具有分配给单个网络接口的单个IP地址(10.1.4.25)的机器上运行得非常好。广播从10.1.4.25发送到239.255.255.250，我从同一子网上的5个设备得到响应。

然而，当机器在同一接口上有多个IP时，它似乎会选择一个源IP并从中发送请求。在这种情况下，我从一个设备上得到了一个169.254地址的回复。

我尝试将UdpDiscoveryEndpoint.TransportSettings.MulticastInterfaceId设置为一个合适的接口ID，但这并没有帮助，因为它标识的是单个接口，而不是特定的IP。UdpDiscoveryEndpoint.ListenUri属性还返回多播地址，因此不会影响源IP。UdpDiscoveryEndpoint.Address是用于发现协议的URN。

有没有任何方法可以强制它从特定的IP地址发送，或者理想情况下，在每个配置的IP上发送多个请求？

我也试过ONVIF设备管理器，它似乎也有同样的问题。

请注意，这并不是要使服务绑定到特定的或"所有地址"的IP。它与发送发现请求的IP有关。

Answer 1

好吧，我也遇到了同样的问题，经过几天的研究，阅读了ONVIF文档，学习了一些关于多播的技巧，我开发了这个代码，它运行得很好。例如，我的网络适配器上的主IP地址是192.168.80.55，我还在高级设置中设置了另一个IP(192.168.0.10)。使用此代码，我可以发现IP地址为192.168.0.12的相机的设备服务。这个示例中最重要的部分是"DeepDiscovery"方法，它包含了对网络地址进行迭代和多播适当的Probe消息的主要思想。我建议在"GetSocketResponse"方法中反序列化响应。目前，我只是使用Regex提取服务URI。

如本文所述(https://msdn.microsoft.com/en-us/library/dd456791(v=vs.110).aspx)：

为了使WCF发现正常工作，所有NIC(网络接口控制器)应该只有一个IP地址。

我正在执行WS-Discovery所做的操作，并使用标准3702端口，但我自己构建SOAP信封并且使用Socket类来发送已经为网络接口控制器设置的所有IP地址的分组。

class Program
{
static readonly List<string> addressList = new List<string>();
static readonly IPAddress multicastAddress = IPAddress.Parse("239.255.255.250");
const int multicastPort = 3702;
const int unicastPort = 0;
static void Main(string[] args)
{
DeepDiscovery();
Console.ReadKey();
}
public static void DeepDiscovery()
{
string probeMessageTemplate = @"<s:Envelope xmlns:s=""http://www.w3.org/2003/05/soap-envelope"" xmlns:a=""http://schemas.xmlsoap.org/ws/2004/08/addressing""><s:Header><a:Action s:mustUnderstand=""1"">http://schemas.xmlsoap.org/ws/2005/04/discovery/Probe</a:Action><a:MessageID>urn:uuid:{messageId}</a:MessageID><a:ReplyTo><a:Address>http://schemas.xmlsoap.org/ws/2004/08/addressing/role/anonymous</a:Address></a:ReplyTo><a:To s:mustUnderstand=""1"">urn:schemas-xmlsoap-org:ws:2005:04:discovery</a:To></s:Header><s:Body><Probe xmlns=""http://schemas.xmlsoap.org/ws/2005/04/discovery""><d:Types xmlns:d=""http://schemas.xmlsoap.org/ws/2005/04/discovery"" xmlns:dp0=""http://www.onvif.org/ver10/device/wsdl"">dp0:Device</d:Types></Probe></s:Body></s:Envelope>";
foreach (IPAddress localIp in
Dns.GetHostAddresses(Dns.GetHostName()).Where(i => i.AddressFamily == AddressFamily.InterNetwork))
{
var socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
socket.Bind(new IPEndPoint(localIp, unicastPort));
socket.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, new MulticastOption(multicastAddress, localIp));
socket.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.MulticastTimeToLive, 255);
socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
socket.MulticastLoopback = true;
var thread = new Thread(() => GetSocketResponse(socket));
var probeMessage = probeMessageTemplate.Replace("{messageId}", Guid.NewGuid().ToString());
var message = Encoding.UTF8.GetBytes(probeMessage);
socket.SendTo(message, 0, message.Length, SocketFlags.None, new IPEndPoint(multicastAddress, multicastPort));
thread.Start();
}
}

public static void GetSocketResponse(Socket socket)
{
try
{
while (true)
{
var response = new byte[3000];
EndPoint ep = socket.LocalEndPoint;
socket.ReceiveFrom(response, ref ep);
var str = Encoding.UTF8.GetString(response);
var matches = Regex.Matches(str, @"http://bd{1,3}.d{1,3}.d{1,3}.d{1,3}b/onvif/device_service");
foreach (var match in matches)
{
var value = match.ToString();
if (!addressList.Contains(value))
{
Console.WriteLine(value);
addressList.Add(value);
}
}
//...
}
}
catch (Exception ex)
{
Console.WriteLine(ex);
//...
}
}
}