Сервисная шина ретрансляции Azure с webHttpRelayBinding с REST/JSON и POST
В следующей статье объясняется, как создать простую службу WCF с помощью служебной шины ретрансляции Azure: https://azure.microsoft.com/en-us/documentation/articles/service-bus-dotnet-how-to-use-relay/ Пример показывает использование с TCP Binding. Я воспроизвел это, и это работает безупречно. Теперь я хочу то же самое с webHttpRelayBinding, но он не работает, как ожидалось. Я разделил код службы на общую DLL, проект WCFServiceWebRole и хост командной строки (в качестве альтернативы web.config) и клиенты:
общий dll с определением интерфейса и файлом настроек с пространством ключей шины, пространства имен и протокола (tcp или http) WCFRelayCommon {using System.ServiceModel; using System.ServiceModel.Web;
[ServiceContract(Namespace = "urn:ps")]
public interface IProblemSolver
{
[OperationContract
WebInvoke(UriTemplate = "/solver", Method = "POST",
RequestFormat = WebMessageFormat.Json, ResponseFormat = WebMessageFormat.Json,
BodyStyle = WebMessageBodyStyle.Wrapped)]
int AddNumbers(int a, int b);
}
public interface IProblemSolverChannel : IProblemSolver, IClientChannel { }
public enum BusProtocol { tcp, http };
public class Utils
{
public static BusProtocol Protocol
{
get
{
BusProtocol mode;
if (!Enum.TryParse(AzureSettings.Default.Protocol, out mode))
{
throw new ArgumentException("wrong input, exiting");
}
return mode;
}
}
}
}
WCFServiceWebRole проект. Сначала я определил все параметры службы (поведение, привязка) в файле Web.config и, таким образом, должен быть самодостаточным как есть.
namespace WCFServiceWebRoleRelay
{
public class ProblemSolver : WCFRelayCommon.IProblemSolver
{
public int AddNumbers(int a, int b)
{
return a + b;
}
}
}
Но я также определил альтернативный хост-проект со всеми настройками по коду, который легче отлаживать. Так что просто проект командной строки с использованием файла настроек. 2 реализации: либо с NetTcpRelayBinding, либо с WebHttpRelayBinding. с безопасным транспортом.
namespace WCFRelayHost
{
class Program
{
static void Main(string[] args)
{
var transportClientEndpointBehavior = new TransportClientEndpointBehavior
{
TokenProvider = TokenProvider.CreateSharedAccessSignatureTokenProvider("RootManageSharedAccessKey", AzureSettings.Default.BusKey)
};
ServiceHost sh;
switch (Utils.Protocol)
{
case BusProtocol.http:
sh = CreateWebHost(AzureSettings.Default.BusNamespace, transportClientEndpointBehavior);
break;
case BusProtocol.tcp:
sh = CreateTcpBindingHost(AzureSettings.Default.BusNamespace, transportClientEndpointBehavior);
break;
default:
throw new Exception("wrong mode");
}
sh.Open();
Console.WriteLine("Press ENTER to close");
Console.ReadLine();
sh.Close();
}
static ServiceHost CreateTcpBindingHost(string busNamespace, TransportClientEndpointBehavior transportClientEndpointBehavior)
{
Uri tcpAddress = ServiceBusEnvironment.CreateServiceUri("sb", busNamespace, "solver");
ServiceHost sh = new ServiceHost(typeof(ProblemSolver));
var binding = new NetTcpRelayBinding(EndToEndSecurityMode.Transport, new RelayClientAuthenticationType());
return AddServiceEndpoint(sh, binding, tcpAddress, transportClientEndpointBehavior);
}
static ServiceHost CreateWebHost(string busNamespace, TransportClientEndpointBehavior transportClientEndpointBehavior)
{
// https://<namespace>.servicebus.windows.net/solver
Uri webAddress = ServiceBusEnvironment.CreateServiceUri("https", busNamespace, "solver");
var binding = new WebHttpRelayBinding(EndToEndWebHttpSecurityMode.Transport, new RelayClientAuthenticationType());
WebServiceHost wsh = new WebServiceHost(typeof(ProblemSolver), webAddress);
return AddServiceEndpoint(wsh, binding, webAddress, transportClientEndpointBehavior);
}
static ServiceHost AddServiceEndpoint(ServiceHost sh, Binding binding, Uri uri, TransportClientEndpointBehavior transportClientEndpointBehavior)
{
sh.AddServiceEndpoint(typeof(IProblemSolver), binding, uri).Behaviors.Add(transportClientEndpointBehavior);
return sh;
}
}
}
И приложение командной строки клиента.
namespace WCFRelayClient
{
class Program
{
static void Main(string[] args)
{
Console.WriteLine("Enter 2 numbers to add separated by space");
var line = Console.ReadLine();
var array = line.Split(' ');
int first, second;
if (!int.TryParse(array[0], out first) || !int.TryParse(array[1], out second))
{
Console.WriteLine("wrong input, exiting");
}
else
{
Console.WriteLine("Wait the host to run, press ENTER when ready to send the request");
Console.ReadLine();
var transportClientEndpointBehavior = new TransportClientEndpointBehavior
{
TokenProvider = TokenProvider.CreateSharedAccessSignatureTokenProvider("RootManageSharedAccessKey", AzureSettings.Default.BusKey)
};
IProblemSolverChannel ch;
switch (Utils.Protocol)
{
case BusProtocol.http:
ch = WebBinding(AzureSettings.Default.BusNamespace, transportClientEndpointBehavior);
break;
case BusProtocol.tcp:
ch = TcpBinding(AzureSettings.Default.BusNamespace, transportClientEndpointBehavior);
break;
default:
throw new Exception("wrong mode");
}
Console.WriteLine(ch.AddNumbers(first, second));
ch.Dispose();
}
Console.ReadLine();
}
static IProblemSolverChannel TcpBinding(string busNamespace, TransportClientEndpointBehavior transportClientEndpointBehavior)
{
var binding = new NetTcpRelayBinding(EndToEndSecurityMode.Transport, new RelayClientAuthenticationType());
var uri = ServiceBusEnvironment.CreateServiceUri("sb", busNamespace, "solver");
return CreateChannel(binding, uri, transportClientEndpointBehavior);
}
static IProblemSolverChannel WebBinding(string busNamespace, TransportClientEndpointBehavior transportClientEndpointBehavior)
{
var binding = new WebHttpRelayBinding(EndToEndWebHttpSecurityMode.Transport, new RelayClientAuthenticationType());
var uri = ServiceBusEnvironment.CreateServiceUri("https", busNamespace, "solver");
return CreateChannel(binding, uri, transportClientEndpointBehavior);
}
static IProblemSolverChannel CreateChannel(Binding binding, Uri uri, TransportClientEndpointBehavior transportClientEndpointBehavior)
{
var cf = new ChannelFactory<IProblemSolverChannel>(binding, new EndpointAddress(uri));
cf.Endpoint.Behaviors.Add(transportClientEndpointBehavior);
return cf.CreateChannel();
}
}
}
Мне просто нужно изменить параметр настройки на http или tcp, чтобы использовать либо webHttpRelayBinding, либо netTcpRelayBiding.
Как уже говорилось, с помощью netTcpRelayBiding код выполняется должным образом.
С помощью webHttpRelayBinding я получаю исключение InvalidOperationException в mscorlib
System.InvalidOperationException was unhandled
HResult=-2146233079
Message=Manual addressing is enabled on this factory, so all messages sent must be pre-addressed.
Source=mscorlib
Что я упустил? Может быть, какая-то конфигурация на портале Azure? Я просто следовал инструкциям из учебника...
1 ответ
Я смог заставить ваш пример работать в режиме "http", изменив WCFRelayClient.Program.CreateChannel метод для использования WebChannelFactory<T> при работе с WebHttpBinding/WebHttpRelayBinding:
static IProblemSolverChannel CreateChannel(Binding binding, Uri uri, TransportClientEndpointBehavior transportClientEndpointBehavior)
{
ChannelFactory<IProblemSolverChannel> cf;
if (binding is WebHttpBinding || binding is WebHttpRelayBinding)
{
cf = new WebChannelFactory<IProblemSolverChannel>(binding, uri);
}
else
{
cf = new ChannelFactory<IProblemSolverChannel>(binding, new EndpointAddress(uri));
}
cf.Endpoint.Behaviors.Add(transportClientEndpointBehavior);
return cf.CreateChannel();
}
Если вы отправляете с каким-либо HTTP-клиентом, отличным от *HttpRelayBinding, и ваша конечная точка ретрансляции требует аутентификации клиента, вам нужно создать токен SAS и поместить авторизацию в заголовок HTTP-авторизации.
Примеры NodeJ, JAVA, PHP, C# и общее описание того, как создать токен SAS: https://azure.microsoft.com/en-us/documentation/articles/service-bus-sas-overview/
На этой странице показан пример Javascript (я не проверял, что он работает): http://developers.de/blogs/damir_dobric/archive/2013/10/17/how-to-create-shared-access-signature-for-service-bus.aspx